Netty中遇到的问题:ctx.writeAndFlush造成非连续的请求。
作者：互联网
目的
为了保证客户端的请求是顺序发送到服务端的，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