SpringBoot快速搭建TCP服务端和客户端

以下是一个简单的Spring Boot TCP服务器和客户端的示例。

TCP服务器端 (Spring Boot):

1. 添加依赖 spring-boot-starter-integration 和 spring-boot-starter-web 到 pom.xml。
2. 配置服务器端口和TCP连接工厂。
3. 创建TCP连接接收器。
4. 启动Spring Boot应用程序。

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.integration.annotation.ServiceActivator;
import org.springframework.integration.ip.tcp.TcpInboundGateway;
import org.springframework.integration.ip.tcp.TcpNetServerConnectionFactory;
import org.springframework.integration.ip.tcp.serializer.ByteArraySerializer;
 
@Configuration
public class TcpServerConfig {
 
    @Bean
    public TcpNetServerConnectionFactory serverConnectionFactory() {
        TcpNetServerConnectionFactory factory = new TcpNetServerConnectionFactory(12345);
        factory.setSerializer(new ByteArraySerializer());
        factory.setDeserializer(new ByteArraySerializer());
        return factory;
    }
 
    @Bean
    public TcpInboundGateway tcpInboundGateway() {
        TcpInboundGateway gateway = new TcpInboundGateway();
        gateway.setConnectionFactory(serverConnectionFactory());
        return gateway;
    }
 
    @ServiceActivator
    public void clientMessageHandler() {
        // 处理接收到的消息
    }
}

TCP客户端 (Spring Boot):

1. 添加依赖 spring-boot-starter-integration 和 spring-boot-starter-web 到 pom.xml。
2. 配置服务器地址和端口。
3. 发送消息。
4. 启动Spring Boot应用程序。

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.integration.annotation.ServiceActivator;
import org.springframework.integration.ip.tcp.TcpOutboundGateway;
import org.springframework.integration.ip.tcp.TcpNetClientConnectionFactory;
import org.springframework.integration.ip.tcp.serializer.ByteArraySerializer;
 
@Configuration
public class TcpClientConfig {
 
    @Bean
    public TcpNetClientConnectionFactory clientConnectionFactory() {
        TcpNetClientConnectionFactory factory = new TcpNetClientConnectionFactory("localhost", 12345);
        factory.setSerializer(new ByteArraySerializer());
        factory.setDeserializer(new ByteArraySerializer());
        return factory;
    }
 
    @Bean
    @ServiceActivator
    public TcpOutboundGateway tcpOutboundGateway() {
        Tc