没有发布者可发布 TcpConnectionOpenEvent TcpConnectionCloseEvent

Question

我用Spring Integration的Java DSL配置了一个TCP Client。它看起来像这样

    @Bean
    public TcpSendingMessageHandler tcpClient()
    {
        return Tcp
            .outboundAdapter(
                Tcp.nioClient("localhost", 9060)
                   .deserializer(new ByteArrayLfSerializer())
                   .soKeepAlive(false)
                   .leaveOpen(false)
                   .taskExecutor(Executors.newSingleThreadExecutor())
                   .get()
            )
            .clientMode(false)
            .get();
    }

我在一个服务中使用它向客户端连接的TCP套接字发送消息。

    @Slf4j
    @Service
    public class TcpClientConnectionService
    {
        private final TcpSendingMessageHandler messageHandler;

        @Autowired
        public TcpClientConnectionService(final TcpSendingMessageHandler messageHandler)
        {
            this.messageHandler = messageHandler;
            this.messageHandler.start();
        }

        public void sendMessage(final String message)
        {
            messageHandler.handleMessage(new GenericMessage<>(message));

            log.debug("Message: " + message + " send");
        }
    }

但在生产中，我经常收到下面的警告，我不知道问题出在哪里，也不知道如何解决。

o.s.i.i.tcp.connection.TcpNioConnection : No publisher available to publish TcpConnectionOpenEvent o.s.i.i.tcp.connection.TcpNioConnection : No publisher available to publish TcpConnectionCloseEvent。

如果有人能帮助我，那就太好了，因为我通过google找不到任何东西。

Answer 1

嵌套的工厂没有正确初始化，因为你不正确地调用了 .get() 规范上，颠覆了Spring的初始化。

我用Spring Integration的Java DSL配置了一个TCP Client。它看起来像这样

@Bean
public TcpSendingMessageHandler tcpClient()
{
    return Tcp
        .outboundAdapter(
            Tcp.nioClient("localhost", 9060)
               .deserializer(new ByteArrayLfSerializer())
               .soKeepAlive(false)
               .leaveOpen(false)
               .taskExecutor(Executors.newSingleThreadExecutor()))
        .clientMode(false)
        .get();
}

或将工厂定义移至顶层 @Bean.