触发按需TCP消息到可重新连接、不可共享的Netty管道的正确方法是什么？

Question

我有一个棘手的问题。x TCP客户端应用程序具有重新连接侦听器，我想不出实现将写入套接字通道的触发器（HTTP、MQ等）的方法。

到目前为止，我尝试通过以下另一个示例向我的ChannelInboundHandler添加write（ByteBuf msg），但是使用我的reconnect listener，我在重新连接时遇到以下异常：

... is not a @Sharable handler, so can't be added or removed multiple times.

我对Netty是新手，所以我不确定用户事件触发器是否可以解决这个问题。

重新连接代码：

if (!future.isSuccess()) {
    future.channel().eventLoop().schedule(() -> {
        bootstrap.connect().addListener(this);
    }, reconnectDelayTimeNanos, TimeUnit.NANOSECONDS);
} else {
    future.channel().closeFuture().addListener((ChannelFuture cf) -> {
        bootstrap.connect().addListener(this);
    });
}

引导代码：

final MyHandler myHandler = new MyHandler();
final EventLoopGroup requestGroup = new NioEventLoopGroup();
final Bootstrap requestBootstrap = new Bootstrap()
        .group(requestGroup)
        .channel(NioSocketChannel.class)
        .remoteAddress("localhost", 9999)
        .option(ChannelOption.SO_KEEPALIVE, true);
requestBootstrap.handler(new ChannelInitializer<SocketChannel>() {
    @Override
    protected void initChannel(final SocketChannel ch) {
        ch.pipeline().addLast(myHandler);
    }
});

为了能够从我的处理程序中使用写（ByteBuf msg）方法，处理程序需要在Channel初始器之外有一个引用。

我希望能够从触发器（HTTP、MQ等）向管道、非共享处理程序等发送消息。

目前，我得到以下例外情况：

... is not a @Sharable handler, so can't be added or removed multiple times.

Answer 1

您需要通过使用@sharable或重写isSharable（）方法将您的MyHandler标记为可共享。也就是说，在这种情况下，您需要确保处理程序是线程安全的。