在spring boot应用程序中创建要发送和接收的TCP客户端

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-integration</artifactId>
</dependency>

spring.integration.tcp.connection-factory.type=client
spring.integration.tcp.connection-factory.host=localhost
spring.integration.tcp.connection-factory.port=1234

@Component
public class TcpMessageHandler {

    @ServiceActivator(inputChannel = "tcpClientChannel")
    public void handleMessage(String message) {
        // 处理接收到的TCP消息
        System.out.println("Received message: " + message);
    }
}

@Component
public class TcpClient {

    @Autowired
    private MessageChannel tcpClientChannel;

    public void sendMessage(String message) {
        // 发送消息到TCP服务器
        tcpClientChannel.send(MessageBuilder.withPayload(message).build());
    }
}

@RestController
public class MyController {

    @Autowired
    private TcpClient tcpClient;

    @GetMapping("/send")
    public String sendMessage() {
        tcpClient.sendMessage("Hello TCP Server!");
        return "Message sent";
    }
}