标签：Netty EventLoop ctx 线程 writeAndFlush sendRequest 服务端
目的
为了保证客户端的请求是顺序发送到服务端的，ctx.writeAndFlush被包装在用synchronized修饰的send方法中，客户端统一调用sendRequest方法。
有多个线程使用sendRequest方法
1.eventLoop处理channelRead的结果，并调用sendRequest发送到服务端。
2.业务线程（如心跳线程，http请求对应的线程）去调用ctx.writeAndFlush
造成的后果
从客户端看日志是顺序的，但是服务端总是收到非连续的请求。
代码
服务端
检测客户端的请求cmdCnt，如果小于当前服务端的值，那么就认为是过期的命令
客户端
同步的sendRequest方法，保证不同线程都是顺序执行，cmdCnt顺序增长。
除了EventLoop线程，业务线程也会调用到sendRequest
EventLoop线程执行sendRequest
原因
这是EventLoop的一个特性：【非EventLoop线程】调用ctx.writeAndFlush时，不会直接执行，而是放入taskQueue队列中（等待之后eventLoop线程去执行）。
解决方法
全部改为非业务线程去执行同步的sendRequest方法，去执行ctx.writeAndFlush，最终都提交给队列。那么顺序提交到队列，就顺序取出发送到服务端。避免了EventLoop线程直接执行writeAndFlush。
解决问题的代码
注意，内部的sendRequest才是同步方法。
EventLoop处理任务流程
thewindkee
发布了118 篇原创文章 · 获赞 47 · 访问量 32万+
私信
关注
标签：Netty,EventLoop,ctx,线程,writeAndFlush,sendRequest,服务端 来源： https://blog.csdn.net/thewindkee/article/details/104416732
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。