Spring Boot Integration TCP如何处理Socket事件及解决监听失败问题

日志中出现的No publisher available to publish TcpConnectionOpenEvent错误，本质是TCP连接工厂未关联Spring的ApplicationEventPublisher，导致事件无法发布到Spring上下文，进而使@EventListener方法无法触发。以下是具体解决步骤及Kotlin代码示例：

1. 确保TCP连接工厂由Spring容器管理 #

不要手动new连接工厂实例，需通过@Bean注解将其交给Spring管理，这样Spring会自动注入ApplicationEventPublisher。

import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration
import org.springframework.integration.channel.DirectChannel
import org.springframework.integration.ip.tcp.TcpInboundGateway
import org.springframework.integration.ip.tcp.connection.TcpNetServerConnectionFactory

@Configuration
class TcpServerConfig {

    // 配置TCP服务器连接工厂
    @Bean
    fun tcpServerConnectionFactory(): TcpNetServerConnectionFactory {
        val factory = TcpNetServerConnectionFactory(9000) // 替换为你的监听端口
        // Spring会自动注入ApplicationEventPublisher，无需手动设置
        return factory
    }

    // 配置请求通道
    @Bean
    fun tcpRequestChannel(): DirectChannel {
        return DirectChannel()
    }

    // 配置TCP入站网关
    @Bean
    fun tcpInboundGateway(): TcpInboundGateway {
        val gateway = TcpInboundGateway()
        gateway.connectionFactory = tcpServerConnectionFactory()
        gateway.requestChannel = tcpRequestChannel()
        return gateway
    }
}

2. 确保事件监听类是Spring管理的Bean #

@EventListener所在的类必须被Spring扫描识别，需添加@Component或其他Spring组件注解：

import org.springframework.context.event.EventListener
import org.springframework.stereotype.Component
import org.springframework.integration.ip.tcp.connection.TcpConnectionCloseEvent
import org.springframework.integration.ip.tcp.connection.TcpConnectionExceptionEvent
import org.springframework.integration.ip.tcp.connection.TcpConnectionOpenEvent

@Component
class TcpConnectionEventHandler {

    @EventListener
    fun onConnectionOpen(event: TcpConnectionOpenEvent) {
        println("新Socket连接建立: 连接ID=${event.connectionId}")
        // 自定义连接打开后的业务逻辑
    }

    @EventListener
    fun onConnectionClose(event: TcpConnectionCloseEvent) {
        println("Socket连接关闭: 连接ID=${event.connectionId}")
        // 自定义连接关闭后的业务逻辑
    }

    @EventListener
    fun onConnectionError(event: TcpConnectionExceptionEvent) {
        println("Socket连接异常: 连接ID=${event.connectionId}, 异常信息=${event.cause?.message}")
        // 自定义异常处理逻辑
    }
}

3. 额外排查点 #

• 检查Spring Boot组件扫描范围，确保配置类和事件监听类处于主启动类的包或子包下；
• 避免版本冲突：确保Spring Integration版本与Spring Boot版本兼容（建议使用Spring Boot Starter集成，自动管理版本）；
• 若使用XML配置，需确保<int-ip:tcp-connection-factory>的publish-events属性设置为true（Kotlin/Java配置默认启用）。

内容的提问来源于stack exchange，提问作者Romain-p