springboot 写一个tcp服务接口接收数据

好的，以下是一个简单的 Spring Boot TCP 服务接口接收数据的示例代码：

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.integration.annotation.MessagingGateway;
import org.springframework.integration.annotation.ServiceActivator;
import org.springframework.integration.ip.tcp.connection.TcpConnectionEvent;
import org.springframework.integration.ip.tcp.connection.TcpConnectionEvent.TcpConnectionEventType;
import org.springframework.integration.ip.tcp.connection.TcpListener;
import org.springframework.integration.ip.tcp.connection.TcpMessageMapper;
import org.springframework.integration.ip.tcp.connection.TcpNetServerConnectionFactory;
import org.springframework.integration.ip.tcp.serializer.ByteArrayCrLfSerializer;
import org.springframework.messaging.Message;
import org.springframework.messaging.handler.annotation.Payload;

@SpringBootApplication
public class TcpServerApplication {

    public static void main(String[] args) {
        SpringApplication.run(TcpServerApplication.class, args);
    }

    @MessagingGateway(defaultRequestChannel = "tcpServerChannel")
    public interface TcpGateway {

        void send(@Payload byte[] data);

    }

    @ServiceActivator(inputChannel = "tcpServerChannel")
    public void handleTcpMessage(Message<byte[]> message) {
        byte[] payload = message.getPayload();
        String data = new String(payload);
        System.out.println("Received TCP message: " + data);
    }

    @ServiceActivator(inputChannel = "tcpServerEventChannel")
    public void handleTcpConnectionEvent(TcpConnectionEvent event) {
        if (event.getType() == TcpConnectionEventType.OPEN) {
            System.out.println("TCP connection opened: " + event.getConnectionId());
        } else if (event.getType() == TcpConnectionEventType.CLOSE) {
            System.out.println("TCP connection closed: " + event.getConnectionId());
        }
    }

    @ServiceActivator(inputChannel = "tcpServerExceptionChannel")
    public void handleTcpException(Throwable t) {
        System.err.println("TCP exception occurred: " + t.getMessage());
    }

    @ServiceActivator(inputChannel = "tcpServerConnectionExceptionChannel")
    public void handleTcpConnectionException(Throwable t) {
        System.err.println("TCP connection exception occurred: " + t.getMessage());
    }

    @ServiceActivator(inputChannel = "tcpServerConnectionFactoryChannel")
    public TcpNetServerConnectionFactory createTcpConnectionFactory() {
        TcpNetServerConnectionFactory factory = new TcpNetServerConnectionFactory(1234);
        factory.setSerializer(new ByteArrayCrLfSerializer());
        factory.setDeserializer(new ByteArrayCrLfSerializer());
        factory.setMapper(new TcpMessageMapper());
        factory.setTcpListener(new TcpListener() {
            @Override
            public void onMessage(Message<?> message) {
                System.out.println("Received TCP message: " + message.getPayload());
            }
        });
        return factory;
    }

}

这个示例代码使用 Spring Integration 来实现 TCP 服务接口接收数据。它创建了一个 TCP 服务器连接工厂，监听端口号为 1234。当有 TCP 客户端连接时，它会打印出连接的 ID。当有 TCP 消息到达时，它会打印出消息的内容。你可以使用 `TcpGateway` 接口来发送 TCP 消息。