java实现UDP\TCP接收端通信

心已赠人 2023-09-28 15:42 30阅读 0赞

### **一、java实现UDP接收端通信** ###

@SneakyThrows
        public static void init() {
        
            UDPDatagramSocket udpDatagramSocket= (UDPDatagramSocket) ApplicationContextHelper.getBean("UDPDatagramSocket");
            udpDatagramSocket.run();
        }

package org.jeecg.modules.flight.socket;
    
        import org.springframework.stereotype.Component;
        import java.io.IOException;
        import java.net.DatagramPacket;
        import java.net.DatagramSocket;
        // 接收端
        @Component("UDPDatagramSocket")
        public class UDPDatagramSocket {
        
                public void run() throws IOException {
        
                    // 1.创建接受对象
                    DatagramSocket socket = new DatagramSocket(3000);
                    // 2.创建一个数据包接收数据
                    byte [] buffer = new byte[1024];
                    DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
                    while (true) {
        
                        // 3.等待接受数据
                        socket.receive(packet);
                        // 4.取出数据
                        int len = packet.getLength();
                        byte[] data = packet.getData();
                        String rs = new String(data,0,len);
                        System.out.println("收到来自: "+ packet.getAddress()+ ", 端口号为: "+ packet.getPort()+"的消息: " + rs);
                    }
                }
            }

### **二、java实现TCP接收端通信** ###

ExecutorService fixedThreadPool = Executors.newFixedThreadPool(20);//创建20个线程
        ServerSocket ss = null;
        ThreadLocal<String> longLocal = new ThreadLocal<String>();
    
        public void run() {
        
            try {
        
                ss = new ServerSocket(20055);
            } catch (IOException e) {
        
                e.printStackTrace();
            }
            for (int i = 0; i < 20; i++) {
        
                fixedThreadPool.execute(new Runnable() {
        
                    @Override
                    public void run() {
        
                        try {
        
                            //创建一个serversocket其端口与发送端的端口是一样的
                            while (true) {
        
                                Socket s = ss.accept();
                                //侦听并接受到此套接字的连接，返回一个socket对象
                                if (s != null) {
        
                                    InputStream is = null;
                                    //获取到输入流
                                    String ip = s.getInetAddress().toString().replace("/", "");
                                    s.setKeepAlive(true);
                                    is = s.getInputStream();
                                    System.out.println("服务器端接受请求:==========socket.getInetAddress()==========" + ip);
                                    byte[] buf = new byte[4096];
                                    //接收收到的数据
                                    int line = 0;
                                    while ((line = is.read(buf)) != -1) {
        
                                        String valie = new String(buf, 0, line).trim();
    //                                    System.out.println(valie);
                                        saveHlDroneMessage(valie, ip);
                                    }
                                }
                            }
                        } catch (Exception e) {
        
                            e.printStackTrace();
                        }
                    }
                });
            }
        }