设计并实现一个基于Java的网络通信服务实例

原创逃离我推掉我的手 2024-11-22 08:27 13阅读 0赞

设计一个基本的网络通信服务实例，我们可以使用Java的Socket编程来实现。以下是一个简单的客户端和服务端的例子：

1. 客户端（ServerThread.java）：
```java
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class ServerThread extends Thread {
    private ServerSocket serverSocket;
    private Socket socket;

public ServerThread(int port) {
        this.serverSocket = new ServerSocket(port);
    }

@Override
    public void run() {
        try {
            while (true) {
                socket = serverSocket.accept();
                System.out.println("New connection from: " + socket.getRemoteSocketAddress()));

// 这里可以添加实际的通信逻辑，例如读写数据
                BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream())));

String inputLine;
                while ((inputLine = in.readLine()) != null)) {
                    System.out.println("Received message from client: " + inputLine));
                }

in.close();
                socket.close();
            }
        } catch (IOException e) {
            System.err.println("Error occurred: " + e.getMessage());
            try {
                if (socket != null) {
                    socket.close();
                }
                if (serverSocket != null) {
                    serverSocket.close();
                }
            } catch (IOException f) {
                System.out.println("Error closing resources: " + f.getMessage());
            }
        }
    }

public static void main(String[] args) {
        int port = 1234; // 自定义端口
        ServerThread serverThread = new ServerThread(port);
        serverThread.start();
    }
}
```

2. 服务端（ClientThread.java）：
```java
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class ClientThread extends Thread {
    private Socket socket;
    private BufferedReader in;
    private PrintWriter out;

public ClientThread(String host, int port) {
        try {
            this.socket = new Socket(host, port));
            System.out.println("Connected to server at: " + socket.getRemoteSocketAddress()));
            in = new BufferedReader(new InputStreamReader(socket.getInputStream()))));
            out = new PrintWriter(socket.getOutputStream(), true));
        } catch (IOException e) {
            System.err.println("Error occurred while connecting to server: " + e.getMessage());
            try {
                if (socket != null) {
                    socket.close();
                }
            } catch (IOException f) {
                System.out.println("Error closing resources while connecting to server: " + f.getMessage());
            }
        }
    }

@Override
    public void run() {
        try {
            String inputLine;
            while ((inputLine = in.readLine()) != null)) {
                out.println(inputLine);
                System.out.println("Sent message to server: " + inputLine));
            }

// 这里可以添加实际的数据交互逻辑
            // 例如，发送一个命令或者数据，然后接收回应
            byte[] sendData = "Hello from client!".getBytes();
            out.write(sendData);
            out.flush();

// 接收服务器的响应
            byte[] receiveData = new byte[1024]; // 假设最大接收长度为 1024 字节
            int numReadBytes = in.read(receiveData));
            if (numReadBytes > 0) {
                System.out.println("Received message from server: " + new String(receiveData, 0, numReadBytes))));
            }
        } catch (IOException e) {
            System.err.println("Error occurred while communicating with server: " + e.getMessage());
            try {
                if (socket != null) {
                    socket.close();
                }
            } catch (IOException f) {
                System.out.println("Error closing resources while communicating with server: " + f.getMessage());
            }
        }
    }

public static void main(String[] args) throws IOException {
        String host = "localhost"; // 本地主机，如 "localhost" 或 "127.0.0.1"
        int port = 1234; // 自定义端口

ClientThread clientThread = new ClientThread(host, port));
        clientThread.start();
    }
}
```

这个例子中，服务端（ServerSocket）监听特定的端口，并接受客户端（ClientSocket）的连接请求。客户端向服务器发送消息，然后接收服务器的回应。

你可以根据自己的需求调整端口号和通信内容。