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 地址和端口号。
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 的连接。
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 通信
在多个客户端同时连接时，我们需要采用多线程的方式来处理。当服务端接收到客户端的请求之后，就开启一个新的线程来处理这个请求。这样就可以保证每个客户端的请求都能够得到相应的处理，并且不会阻塞其他客户端的连接和处理。主要代码如下：
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 网络编程应用非常广泛，例如可以实现网络聊天室、文件传输、远程调用等。示例代码：
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 网络编程的应用场景广泛。
网友评论