编写一个Java服务，监听网络通信并处理数据

原创柔光的暖阳◎ 2025-03-10 21:00 28阅读 0赞

以下是一个简单的Java服务示例，它使用ServerSocket来监听网络通信，并对接收到的数据进行处理。

```java
import java.io.*;
import java.net.ServerSocket;
import java.util.ArrayList;
import java.util.List;

public class NetworkDataProcessor {

private static final int SERVER_PORT = 1234;

public static void main(String[] args) {
        try (ServerSocket serverSocket = new ServerSocket(SERVER_PORT)) {
            System.out.println("Server listening on port " + SERVER_PORT);

while (true) {
                Socket clientSocket = serverSocket.accept();
                handleClientConnection(clientSocket);
            }
        } catch (IOException e) {
            System.err.println("Error occurred while server is running.");
            e.printStackTrace();
        }
    }

private static void handleClientConnection(Socket clientSocket) {
        try (InputStream input = new BufferedInputStream(clientSocket.getInputStream()));
        {
            byte[] buffer = new byte[1024];
            int bytesRead;

System.out.println("Received data from client...");

while ((bytesRead = input.read(buffer))) != -1) {
                String receivedData = new String(buffer, 0, bytesRead));
                processReceivedData(receivedData);
            }
        } catch (IOException e) {
            System.err.println("Error occurred while handling client connection.");
            e.printStackTrace();
        } finally {
            try {
                clientSocket.close();
            } catch (IOException e) {
                System.out.println("Failed to close the client socket properly.");
                e.printStackTrace();
            }
        }
    }

private static void processReceivedData(String receivedData) {
        // Here, you can write your own logic for data processing.
        System.out.println("Processed data: " + receivedData);
    }
}
```

这个示例创建了一个ServerSocket监听1234端口。当有客户端连接时，它会读取接收到的数据，并通过`processReceivedData`方法进行处理。

你可以根据实际需求，替换`processReceivedData`方法中的内容以适应不同的数据处理逻辑。