观察骆驼/网络环境中的连接状态

Question

我希望了解camel/netty环境中的连接状态。

为了做到这一点，我尝试了这样的方法：

• 指定了我的骆驼路线

    from("direct:in").marshal().serialization()
    .to("netty:tcp://localhost:42123?clientPipelineFactory=#cpf&sync=false");

• 实施了我的管道工厂

    public class ConnectionStatusPipelineFactory extends ClientPipelineFactory {
        @Override
        public ChannelPipeline getPipeline() throws Exception {
            ChannelPipeline cp = Channels.pipeline();
            cp.addLast("statusHandler", new ConnectionStatusHandler());
            return cp;
        }

        @Override
        public ClientPipelineFactory createPipelineFactory(NettyProducer producer) {
            return new ConnectionStatusPipelineFactory();
        }
    }

• 实现我的连接状态处理程序

    public class ConnectionStatusHandler extends SimpleChannelUpstreamHandler {
        @Override
        public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e)
                throws Exception {
            System.out.println("Event: " + e);
            super.channelConnected(ctx, e);
        }

        @Override
        public void channelDisconnected(ChannelHandlerContext ctx,
                ChannelStateEvent e) throws Exception {
            System.out.println("Event: " + e);
            super.channelDisconnected(ctx, e);
        }
    }

最后把"ConnectionStatusPipelineFactory“和"cpf”绑定到我的骆驼注册中心。

但出现了以下例外情况：

java.lang.IllegalArgumentException: unsupported message type: class [B

备注：

• "channelConnected“和"channelDisconnected”方法按预期调用。
• 当我禁用它时，一切正常工作(消息编组、连接、远程进程.)。

问题是：

• 这有什么问题吗？
• 这是了解连接状态(连接与否)的好方法吗？

Answer 1

尝试使用解码器选项，而不是使用整个客户端管道工厂。例如使用选项decoder=#myConnectionStatusHandler。然后在注册表中注册名为ConnectionStatusHandler的myConnectionStatusHandler。

如果您使用管道工厂，那么您需要添加所有其他骆驼添加的盒子。