使用Apache Camel和Netty对TCP流量进行负载平衡会导致事务失败

Question

null

1.这是Apache Camel-Netty的有效用例吗？我应该看米娜还是其他人？

2.是否可以尝试将tcp通信路由到JMS或其他组件，然后最终到达tcpendpoint？

3.我是否需要编码器/解码器，或者这个配置应该工作？

编辑2：

我增加了客户端的接收超时，并立即注意到预期缓冲区长度的不匹配问题下降到小于1%。但是，我看到使用和不使用Camel时每个事务的响应时间都很大；几乎高出10倍。你能帮我减少每个事务的响应时间吗？我的客户端收到的消息从5000到20000字节不等。以下是我的最新路线：

from（“netty:tcp://this-ip:9445？sync=true&allowdefaultcodec=false&workercount=20&requesttimeout=30000”）.threads(20).loadbalance（）.roundrobin（）.to（“netty:tcp://backend-1:9445？sync=true&allowdefaultcodec=false”,“netty:tcp://backend-1:9445”,“netty:tcp://backend-2:9445”,“sync=true

我还使用了某些性能增强，比如:context.SetAllowUseOriginalMessage(false)；disableJMX（）；Context.SetMessageHistory（false）；Context.SetlazyLoadTypeConverters（true）；

你能告诉我如何减少个人交易次数的正确方向吗？




Answer 1

对于netty4组件，没有名为DefaultCodec的参数。它被称为AllowDefaultCodec。http://camel.apache.org/netty4.html同样，请先尝试类似的操作。

from("netty4:tcp:\\this-ip:9445?textline=true&sync=true").to("netty4:tcp:\\backend1:9445?textline=true&sync=true")

上面的意思是发送的数据是普通文本。如果您发送字节或其他东西，您将需要为netty提供解码/编码来处理数据。

和一个旁注。在运行Camel路由之前，通过sockettest之类的标准tcp工具手动测试发送测试消息，以验证一切正常。然后通过camel实现相同的操作。您可以在http://sockettest.sourceforge.net/找到sockettest。