注册
登录
策略引擎
Spring Integration - 可靠的TCP，适用于大批量应用
返回
Spring Integration - 可靠的TCP，适用于大批量应用
作者:
老人与海
发布时间:
2024-11-10 10:41:51 (3天前)
转自：
<p> <br/> 组态：</p><p>＆lt; task：executor id =“myTaskExecutor”<br/> 池大小=“4-8”<br/> 队列容量=“0”<br/> 拒绝-<br/> <br/> 政策<br/> </跨度><br/> =“CALLER_RUNS”/＆gt;</p><p>＆lt; int-ip：tcp-connection-factory id =“serverTcpConFact”<br/> type =“server ”<br/> 端口= “60000”<br/> 使用-NIO = “真”<br/> 单次使用的=“假”<br/> 所以超时=“300000”<br/> 任务-<br/> <br/> 执行者<br/> </跨度><br/> =“myTaskExecutor”/＆gt;</p><p>＆lt; int-ip：tcp-inbound-channel-adapter id =“tcpInboundAdapter”<br/> 频道<br/> <br/></p>
收藏
举报
3 条回复
0#
回复此人
淋了一整夜的雨
|
2019-08-31 10-32
<div class =“post-text”itemprop =“text”> <P> 昨天我写了一个样本只是为了使用spring集成创建tcp高性能服务器代码。我使用JMeter TCP采样器成功测试了1000个并发客户端请求。 </p> <P> 这是代码 - <a href="https://github.com/rajeshgheware/spring-integration-samples" rel="nofollow"> https://github.com/rajeshgheware/spring-integration-samples </A> 包括JMeter测试配置文件。 </p> <P> 我成功测试了具有Intel核心i5 M520 2.4GHz的64位笔记本电脑上的1000个并发tcp客户端请求（服务器代码和在此机器上运行的JMeter测试） </p> <P> 我还尝试了1500个并发客户端请求，但发现服务器无法承认许多请求。我将继续尝试增强此代码以服务10000个并发客户端请求（我知道我可能需要从亚马逊获得这个测试的好EC2机器:)） </p> </DIV>
编辑
1#
回复此人
Let us fly
|
2019-08-31 10-32
<div class =“post-text”itemprop =“text”> <P> 我知道问题是什么，请打开一个 <a href="https://jira.spring.io/browse/INT" rel="nofollow"> JIRA问题 </A> 。 </p> <P> 问题是 <code> CALLER_RUNS </code> 拒绝政策 <code> 0 </code> 执行程序中的长度队列。 </p> <P> 有一个线程可以处理所有IO事件（通常是 <code> myTaskExecutor-1 </code> ）;当读取事件触发时，他将执行排队以读取数据;读者线程将执行命令排队以组装数据（这将阻塞直到完整的消息 - 在您的情况下由CRLF终止 - 到达）。 </p> <P> 在这种情况下，当没有线程可用时， <code> CALLER_RUNS </code> 策略意味着IO选择器线程执行读取，并成为汇编程序线程，它阻止等待因为被阻止而无法到达的数据，并且稍后在调度要阻止的其他线程之后读取数据。由于他被封锁，他无法处理新的接受事件。 </p> <P> 这是我的测试中的日志，显示了这个问题...... </p> <pre> <code> TRACE: [May-18 10:43:38,923][myTaskExecutor-1] tcp.connection.TcpNioServerConnectionFactory - Port 60000 SelectionCount: 2 DEBUG: [May-18 10:43:38,923][myTaskExecutor-1] tcp.connection.TcpNioConnection - localhost:58509:60000:bdc36c59-c31b-470e-96c3-6270e7c46a2f Reading... DEBUG: [May-18 10:43:38,924][myTaskExecutor-1] tcp.connection.TcpNioConnection - localhost:58509:60000:bdc36c59-c31b-470e-96c3-6270e7c46a2f Running an assembler TRACE: [May-18 10:43:38,924][myTaskExecutor-1] tcp.connection.TcpNioConnection - localhost:58509:60000:bdc36c59-c31b-470e-96c3-6270e7c46a2f Nio message assembler running... DEBUG: [May-18 10:43:38,926][myTaskExecutor-1] tcp.serializer.ByteArrayCrLfSerializer - Available to read:0 </code> </pre> <P> 第二行显示用于执行读取的选择器线程;他检测到此套接字需要汇编程序，并成为汇编程序，阻塞，等待数据。 </p> <P> 你真的相信使用无界任务执行者会有问题吗？这些事件通常都很短暂，所以线程很快就会被回收。 </p> <P> 将执行程序的队列容量增加到0以上也应该有所帮助，但它不能完全确保不会发生问题（尽管不大可能会遇到大的队列大小）。 </p> <P> 我还不确定如何解决这个问题，除了为IO选择器和读取器线程使用专用的任务执行程序，因此它们永远不会用作汇编程序。 </p> </DIV>
编辑
登录
后才能参与评论
