欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

mina 粘包无法解决的解决办法

程序员文章站 2022-03-07 09:05:23
...

如果你遇到”粘包“问题,实际上可能不是粘包问题。

 

使用mina的时候铺天盖地的都说要加上:ExecutorFilter

 

 

 

fc.addLast("executor",new ExecutorFilter(Executors.newCachedThreadPool()));

 

我在测试的时候发现很容易出现粘包问题,ok tcp出现粘包问题很普遍,但是,问题在于我使用的是TextLineCodecFactory

本身是按照\n 分隔符解析消息的,客户端发送消息也是由\n分割的。 完全没有道理出现什么鬼粘包问题。

 

mina封装得很好,大致上需要大家配置的就那么几个。主要是DefaultIoFilterChainBuilder的配置

 

ok,加上了上面写的ExecutorFilter,通过异步队列处理消息,提高性能。

 

问题就来了,在测试过程中,消息居然是乱的,也就是说出现了粘包问题。测试来测试去,想来想去都无法理解这是为什么。

最终注释掉测试:通过。

使用newFixedThreadPool 不通过

使用newSingleThreadExecutor 通过。

 

由此我得出一个结论:虽然粘包问题解决了,但是使用的ExecutorFilter是异步的,导致消息是被一段段的接收并且解析的。

那么,这些消息之间是异步的,对于单个消息的解析是完全没问题的。但是问题在于,收到字节的时候就已经把字节给分错了。

去掉异步的队列就解决了这个问题。

 

以上是没看过源码随口瞎说的,对这方面了解的朋友请交流下。

 

看来我还要多研究,我实在是搞不懂,解析字节也需要异步解析?如果不是因为异步解析字节导致字节分开。又怎么会出现我所描述的问题?

 

如果你遇到粘包问题又无法解决,请尝试下。

 

具体的需要多看下,倒是是什么鬼原因导致字节错乱

 

fuc.

 

----------------------

 

以上都说法都tmd有问题,

实际上我遇到的消息混乱的问题原因出自于一个:DefaultIoFilterChainBuilder 过滤器添加顺序问题。

 

 

我先添加的 ExecutorFilter 再添加的ProtocolCodecFilter 结果导致了异步接收消息后 解析消息。

就如上面所说,我一直奇怪的是为什么mina tmd 不先解析消息然后多线程异步处理消息。

原来这个地方的顺序还有一个 这么bug的要求。

 

虽然我知道 mina的logger放在前面和后面也是由不同的,但是无法理解这个狗日的顺序对mina有什么好处。

 

如果说,在ProtocolCodecFilter 使用order ExecutorFilter 在其后面再放一个 其他线程池?这样又有什么好处?

 

总之,如果你遇到一些奇怪的问题,注意过滤器添加顺序的问题!!!

先解码,后放入队列处理!!!

 

fuc. mina