spring-integration - 没有发布者可以发布 TcpConnectionOpenEvent / TcpConnectionCloseEvent
问题描述
我用 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");
}
}
但是在生产中,我经常收到以下警告,我不知道问题是什么以及如何解决它。
osiitcp.connection.TcpNioConnection : 没有发布者可以发布 TcpConnectionOpenEvent osiitcp.connection.TcpNioConnection : 没有发布者可以发布 TcpConnectionCloseEvent
如果有人可以帮助我,那就太好了,因为我无法通过谷歌搜索找到任何东西。
解决方案
嵌套工厂未正确初始化,因为您错误地调用.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
。
推荐阅读
- typescript - NestJs + TypeScript + Jest - TypeError: Class extends value undefined is not a constructor or null
- reactjs - 过滤一系列数据 - Ant Design Table
- postgresql - 获取表的 ID 及其模尊重 Postgres 中同一表中的总行数
- reactjs - 带有 React 组件的 Chrome/Edge 上的页面无响应和“内存不足”错误
- php - 条件不起作用请指导我如何获取正确的数据
- javascript - 我在“尝试从我的 ReactJs 应用程序上的 Firestore 返回通知时连接”的上下文中遇到此错误找不到“商店”
- mongodb - 在 shell 中运行 mongo 查询
- reactjs - 如何使用嵌套三元运算符渲染字符串?
- csv - 如何防止 LibreOfficeCalc 将 CSV 保存为 text/html?
- node.js - sequelize 播种时批量插入失败