使用SocketServer实现简单的Java网络通信

在现代网络通讯中，基于TCP/IP协议的Socket通信已成为标配。Socket通信是指应用程序通过网络进行数据交换的方式。在Java中，Socket通信可以通过Socket和ServerSocket类来实现。其中，使用ServerSocket类可以实现Java程序的服务器端，同时支持多客户端的数据传输通信。在本文中，我们将介绍如何使用ServerSocket类来实现简单的Java网络通信。

一、创建ServerSocket

使用Java中的ServerSocket类可以创建服务器端的Socket对象，从而支持多客户端的数据传输通信。ServerSocket类中的构造函数可以带有一个整型参数，该参数指定了服务器使用的端口号。创建ServerSocket对象时，我们可以通过该端口号让客户端连接到服务器的指定端口，从而实现数据传输通信。以下是创建ServerSocket对象的示例代码：

ServerSocket serverSocket = new ServerSocket(8888);

在本示例中，我们创建了一个端口号为8888的ServerSocket对象 serverSocket。

二、建立Socket连接

通过上面的代码，我们已经创建了一个ServerSocket对象。接下来，我们需要监听特定的端口，并等待客户端的Socket请求。ServerSocket类中的accept()方法可以实现阻塞式监听，即如果没有客户端连接，代码将会一直停在该处等待。如果有客户端请求连接，则accept()方法会将该请求封装成一个Socket对象返回。以下是接收客户端请求的实例代码：

Socket socket = null;
while(true){
    socket = serverSocket.accept();
    //执行数据传输操作
}

在本示例中，我们使用while循环不断接收客户端的Socket请求。如果有请求连接，则将请求封装成Socket对象并返回，用于后续的数据传输操作。

三、数据传输

建立Socket连接之后，就可以使用Java的IO流来进行数据传输。在Java中，为了实现服务器端的多客户端数据传输，我们需要为每个客户端Socket创建一个新的线程来处理数据。以下是服务器端进行数据传输操作的实例代码：

BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter writer = new PrintWriter(socket.getOutputStream(),true);
String line="";
while((line=reader.readLine())!=null){
    writer.println("收到客户端消息："+line);
}

在本示例中，我们创建了一个输入流reader和一个输出流writer，分别用于从Socket中读取数据和向Socket中写入数据。通过while循环，我们可以持续获取客户端发送的数据并进行传输。

四、完整示例代码

下面是本文涉及到的完整示例代码：

//Server端代码
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
    public static void main(String[] args){
        try{
            ServerSocket serverSocket = new ServerSocket(8888);
            System.out.println("服务器已启动，等待客户端连接..");
            Socket socket = null;
            while(true){
                socket = serverSocket.accept();
                new ServerThread(socket).start();
            }
        }catch(Exception e){
            e.printStackTrace();
        }
    }

    public static class ServerThread extends Thread{

        private Socket socket;
        BufferedReader reader = null;
        PrintWriter writer = null;

        public ServerThread(Socket socket){
            this.socket = socket;
        }

        public void run(){
            try {
                reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                writer = new PrintWriter(socket.getOutputStream(),true);
                String line="";
                while((line=reader.readLine())!=null){
                    System.out.println("收到客户端消息："+line);
                    writer.println("收到消息："+line);
                }
                reader.close();
                writer.close();
                socket.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

//Client端代码
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

public class Client {

    public static void main(String[] args) {
        try {
            Socket socket = new Socket("localhost", 8888);
            BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            PrintWriter writer = new PrintWriter(socket.getOutputStream(), true);
            System.out.println("客户端已启动..");
            writer.println("你好，我是客户端..");
            String line = reader.readLine();
            System.out.println("收到服务端消息：" + line);
            writer.close();
            reader.close();
            socket.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

五、总结

本文介绍了如何使用Java中的ServerSocket类实现简单的多客户端数据传输通信。具体来说，我们从创建ServerSocket对象、建立Socket连接、数据传输三个方面介绍了相关的实现方法，并给出了完整的示例代码。在实际应用中，Socket通信可以用于构建各种互联网应用，如网络聊天室、远程操作和数据传输等。