Java的Socket网络编程

客官°小女子只卖身不卖艺 2023-10-15 10:48 16阅读 0赞

Java 网络编程是实现网络通信的重要技术，它可以帮助我们实现像聊天室、远程调用、下载、上传等网络应用。Java 网络编程是基于 TCP/IP 协议实现的，在 Java 中，可以使用 Socket 类来进行创建客户端和服务端之间的通信。Socket 类是在 java.net 包中实现的。

# TCP/IP 网络协议 #

TCP/IP 是 Transmission Control Protocol / Internet Protocol，是一组网络通信协议，是因特网的基础。TCP/IP 协议族主要包括入门级协议（如 IP、ICMP）、传输层协议（如 TCP 与 UDP）和应用层协议（如 FTP、HTTP、SMTP 等）

*  IP（Internet Protocol）协议：用于对数据进行分组和转发，IP 把数据分成数据包进行传输，每个数据包包含发送地址、接收地址和其他相关信息。
 *  ICMP（Internet Control Message Protocol）协议：用于对网络通信状态进行监控和调整，常用于 ping 命令。
 *  TCP（Transmission Control Protocol）协议：是一种可靠的、面向连接的通信协议，负责提供高可靠性的数据传输。TCP 协议以字节流方式传输数据，会先建立连接再进行数据传输，所以可靠性更高，用于文件传输、电子邮件等传输较大数量的数据。
 *  UDP（User Datagram Protocol）协议：是一种无连接、不可靠的通信协议，不需要先建立连接，不保证数据是否到达，用于实现视频、音频等实时传输的服务，速度更快。

# ServerSocket #

ServerSocket 是服务端的套接字对象，提供了用于监听客户端请求并接受连接请求的方法，在 TCP/IP 连接中服务端一般通过 ServerSocket 去监听客户端的 Socket 连接。主要方法如下：

*  void bind(SocketAddress endpoint, int backlog)：将 ServerSocket 绑定到指定的端口和 IP 地址，并设置等待队列的长度（一般为 50）。
 *  Socket accept()：监听并等待客户端连接，返回一个 Socket 对象，该对象用于与客户端进行通信。
 *  void close()：关闭 ServerSocket 的连接。

其中，SocketAddress 类用于表示 IP 地址和端口号。

java复制代码import java.io.IOException;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    public class Server {
        public static void main(String[] args) {
            System.out.println("Server start.");
    
            try {
                // 创建 ServerSocket 对象，并监听指定的端口
                ServerSocket serverSocket = new ServerSocket(8888);
                System.out.println("Server started, listening on port " + serverSocket.getLocalPort());
                // 循环等待客户端的连接请求
                while (true) {
                    // 阻塞等待客户端的连接请求
                    Socket socket = serverSocket.accept();
                    // 启动一个新的线程来处理请求
                    new ServerThread(socket).start();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

# Socket #

Socket 是客户端的套接字对象，用于与服务端进行连接。主要方法如下：

*  void connect(SocketAddress endpoint)：连接到指定 IP 地址和端口号的远程主机。
 *  InputStream getInputStream()：获取该 Socket 连接的输入流，可以从输入流读取远程主机发送的数据。
 *  OutputStream getOutputStream()：获取该 Socket 连接的输出流，可以向输出流写入数据。
 *  void close()：关闭 Socket 的连接。

java复制代码import java.io.*;
    import java.net.Socket;
    
    public class Client {
        public static void main(String[] args) {
            System.out.println("Client start.");
    
            try {
                // 建立 Socket 连接，连接到服务端
                Socket socket = new Socket("localhost", 8888);
                // 获取 Socket 对应的输入流和输出流
                BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                PrintWriter out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())));
    
                // 向服务端发送消息
                out.println("Hello, World!");
                out.flush();
                // 接收服务端的消息并进行处理
                String response = in.readLine();
                System.out.println("Received from server: " + response);
    
                // 关闭流和 Socket 连接
                in.close();
                out.close();
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

# 基于多线程的 Socket 通信 #

在多个客户端同时连接时，我们需要采用多线程的方式来处理。当服务端接收到客户端的请求之后，就开启一个新的线程来处理这个请求。这样就可以保证每个客户端的请求都能够得到相应的处理，并且不会阻塞其他客户端的连接和处理。主要代码如下：

java复制代码import java.io.*;
    import java.net.Socket;
    
    public class ServerThread extends Thread {
        private Socket socket;
    
        public ServerThread(Socket socket) {
            this.socket = socket;
        }
    
        @Override
        public void run() {
            System.out.println("Client connected: " + socket.getRemoteSocketAddress());
            try {
                // 获取 Socket 对应的输入流和输出流
                BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                PrintWriter out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())));
    
                // 处理客户端请求
                String request = in.readLine();
                System.out.println("Received from client: " + request);
                out.println("Your message has been received. response success.");
                out.flush();
    
                // 关闭流和 Socket 连接
                in.close();
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

# Java 网络编程应用 #

Java 网络编程应用非常广泛，例如可以实现网络聊天室、文件传输、远程调用等。示例代码：

java复制代码import java.io.*;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    public class NetworkApplication {
        public static void main(String[] args) throws IOException {
            // 创建服务端，监听客户端连接请求
            ServerSocket serverSocket = new ServerSocket(9999);
            System.out.println("Server started, listening on: " + serverSocket.getLocalSocketAddress());
            while (true) {
                // 阻塞等待客户端连接
                Socket socket = serverSocket.accept();
                // 客户端连接成功，启动线程处理请求
                new HandlerThread(socket).start();
            }
        }
    
        private static class HandlerThread extends Thread {
            private Socket socket;
    
            public HandlerThread(Socket socket) {
                this.socket = socket;
            }
    
            @Override
            public void run() {
                try {
                    // 读取客户端传来的消息
                    BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                    StringBuilder message = new StringBuilder();
                    String line;
                    while ((line = reader.readLine()) != null) {
                        message.append(line);
                    }
                    System.out.println("Received message from client: " + message);
    
                    // 发送响应
                    PrintWriter writer = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())));
                    writer.println("Hello, Client.");
                    writer.flush();
    
                    // 关闭流和 Socket 连接
                    reader.close();
                    writer.close();
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }

一个简单的 Java 网络应用就实现了，程序可以不停地监听客户端连接请求，收到请求之后就启动一个新的线程来处理客户端的请求。客户端连接时，就会向服务端发送消息，服务端接收消息之后向客户端回复一个消息。

# 总结 #

Java 网络编程是建立在 TCP/IP 协议上的网络通信技术，主要用于实现两个端点（客户端和服务端）之间的数据传输。在 Java 中，可以使用 Socket 类来实现网络编程，服务端通过 ServerSocket 监听客户端连接，客户端通过 Socket 连接服务端。在多个客户端连接时，需要使用多线程来处理。Java 网络编程的应用场景广泛。