socket和串口在一个线程读

Question

JAVA，从串口收数据后写到socket（udp），从socket收到数据后写到串口，这两个操作如何在一个线程完成？谢谢！

Answer 1

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class SerialPortToUDPSocket {

    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(2);

        // 串口到Socket的数据传输
        executorService.execute(() -> {
            try {
                // 初始化串口读取
                InputStream serialInputStream = // 初始化串口输入流

                // 初始化UDP Socket
                DatagramSocket socket = new DatagramSocket();

                byte[] buffer = new byte[1024];
                int bytesRead;

                while ((bytesRead = serialInputStream.read(buffer)) != -1) {
                    DatagramPacket packet = new DatagramPacket(buffer, bytesRead);
                    // 设置目标UDP Socket地址
                    packet.setSocketAddress(/* 设置目标Socket地址 */);
                    socket.send(packet);
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        });

        // Socket到串口的数据传输
        executorService.execute(() -> {
            try {
                // 初始化串口写入
                OutputStream serialOutputStream = // 初始化串口输出流

                // 初始化UDP Socket
                DatagramSocket socket = new DatagramSocket(/* 设置监听的端口号 */);

                byte[] buffer = new byte[1024];

                while (true) {
                    DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
                    socket.receive(packet);

                    // 从Socket接收到的数据写入串口
                    serialOutputStream.write(packet.getData(), 0, packet.getLength());
                    serialOutputStream.flush();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        });
    }
}