Java Camel Netty TCP消费者仅接收1024字节

Question

我正在使用最新版本的骆驼和Netty与Spring，并且具有以下定义：

<bean id="transformIncoming" class="com.hugin.camel.transform.IncomingMessageTransformer"/>
<from uri="netty4:tcp://127.0.0.1:8888?allowDefaultCodec=false&amp;encoder=#byteArrayEncoder"/>

<route>
<transform>
  <method ref="transformIncoming" method="process"></method>
</transform>

我定义了一个类来处理传入的tcp请求:

@Component
public class IncomingMessageTransformer implements Processor {

public void process(Exchange in) throws Exception {
    Message inm = in.getIn();
    byte[] buf = inm.getBody(byte[].class); 

我的问题是，不管传入消息的大小，buf变量永远不会超过1024字节，因此我的请求被截断。

根据组件定义，receiveBufferSize应该是65536字节。我如何处理大的请求？

Answer 1

< code>receiveBufferSize属性仅在UDP使用者中用于配置< code>SO_RCVBUF套接字选项。它不用于TCPendpoint。

您不应该依赖 Camel 来实现您的协议：如果没有适当的解码器，则会为每个 tcp 帧发送一条消息，并且您无法保证帧大小。

您应该在Netty中实现您的协议，并生成然后由camel处理的对象。Netty拥有通过tcp流重组协议所需的所有工具。