0

尝试在骆驼中使用 netty 编写大型传输时出现 TooLongFrameException 异常。如果不进行一些认真的重构，我就无法真正缩小交换的规模。

作为一种解决方法，我明确指定了一个具有更大估计长度的 ObjectEncoder。但是，它不会自动将对象转换回其本机形式。我必须在骆驼路线上调用 convertBodyTo()，这需要事先知道类的类型。

这是一个例子：

public static void main(String[] args) throws Exception{
    JndiContext registry=new JndiContext();

    //Workaround #1:  explicitly specify the encoder so we can increase the estinatedLength.
    registry.bind("encoder", new ObjectEncoder(99999999));
    CamelContext context=new DefaultCamelContext(registry);
    context.addRoutes(new RouteBuilder() {        
        @Override
        public void configure() throws Exception {
            //This is the receiving end of the large data.
            from("netty:tcp://0.0.0.0:9002?transferExchange=true&encoder=#encoder")
                //At this point the body is a BigEndianHeapChannelBuffer not a String
                .to("log:nettyin?level=INFO")
                .bean(System.out, "println")         

                //Workaround #2:  explicitly convert the body to the expected class.  What do you do if you want several possible classes?
                .convertBodyTo(String.class)

                //Now we have a String as the body.
                .to("log:nettyin.string?level=INFO")
                .bean(System.out, "println");            

            //Use this endpoint to send large data.
            from("direct:start")
                .to("log:start?level=INFO")
                .to("netty:tcp://localhost:9002?transferExchange=true&encoder=#encoder");
        }
    });
    context.start();
    final ProducerTemplate template = context.createProducerTemplate();
    String s=org.apache.commons.lang.StringUtils.repeat("x", 1133461);
    template.sendBody("direct:start", s);                
    context.stop();
}

有没有办法不显式调用 convertBodyTo()？另外我如何处理泛型？例如 convertBodyTo(List.class) 不适用于 List<String>。我得到一个这样的例外：

原因：org.apache.camel.NoTypeConversionAvailableException：没有类型转换器可用于从类型：org.jboss.netty.buffer.BigEndianHeapChannelBuffer 转换为所需类型：java.util.ArrayList，值为 BigEndianHeapChannelBuffer（ridx=0，widx=422 , 上限 = 422)
    在 org.apache.camel.impl.converter.BaseTypeConverterRegistry.mandatoryConvertTo(BaseTypeConverterRegistry.java:169) ~[camel-core-2.10.3.jar:2.10.3]
    在 org.apache.camel.impl.MessageSupport.getMandatoryBody(MessageSupport.java:99) ~[camel-core-2.10.3.jar:2.10.3]
    ...省略了40个常用框架
4

0 回答 0