package com.ruoyi.fuzhou.utils;
|
|
import java.io.BufferedReader;
|
import java.io.IOException;
|
import java.io.InputStreamReader;
|
import java.io.PrintWriter;
|
import java.net.ServerSocket;
|
import java.net.Socket;
|
|
public class RS485TCPServer {
|
private static final int PORT = 20108;
|
|
public static void main(String[] args) throws Exception {
|
try (ServerSocket serverSocket = new ServerSocket(PORT)) {
|
System.out.println("RS485 TCP Server is listening on port " + PORT);
|
while (true) {
|
// 等待客户端连接
|
try (Socket socket = serverSocket.accept()) {
|
|
System.out.println("New client connected: " + socket.getInetAddress());
|
// 获取输入流和输出流
|
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
|
PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
|
// 读取客户端发送的数据
|
int r = in.read();
|
while(r > -1){
|
System.out.print(r);
|
}
|
/*String inputLine = in.readLine();
|
while (inputLine != null) {
|
System.out.println("Received from client: " + inputLine);
|
// 处理数据(这里简单地将数据原样返回)
|
out.println("Server received: " + inputLine);
|
Thread.sleep(1000);
|
}*/
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|