Java Socket 是 Java 标准库中用于网络编程的一种方式,通过 Socket 实现可以在不同的计算机之间进行数据传输。在聊天应用中,Socket 可以用来建立客户端和服务器之间的连接,实现用户之间的聊天交流。
一、建立服务器端
在建立服务器端时,我们需要使用 ServerSocket 类,该类提供了套接字服务器端的基本实现。以下是建立服务器端的示例代码:
```java
public class Server {
public static void main(String[] args) {
try {
//创建ServerSocket对象,绑定端口号
ServerSocket serverSocket = new ServerSocket(8888);
System.out.println("服务器启动成功,等待客户端连接...");
//等待客户端连接,阻塞式方法
Socket socket = serverSocket.accept();
System.out.println("客户端" + socket.getInetAddress().getHostAddress() + "已连接!");
//启动读取客户端消息的子线程
Thread thread = new Thread(new ReceiveMessage(socket));
thread.start();
//启动发送消息的主线程
sendMessage(socket);
} catch (IOException e) {
e.printStackTrace();
}
}
//发送消息的方法
public static void sendMessage(Socket socket) throws IOException {
BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
//获取输出流,向客户端发送数据
PrintWriter printWriter = new PrintWriter(socket.getOutputStream(), true);
while (true) {
String message = reader.readLine();
printWriter.println(message);
}
}
}
```
在上述代码中,我们通过 ServerSocket 类的构造方法实例化了一个服务器端对象,并绑定了端口号 8888,接着调用 ServerSocket 对象的 accept() 方法等待客户端连接。当有客户端连接时,accept() 方法会返回一个 Socket 对象,通过该对象可以与客户端建立网络通信。我们可以通过启动一个子线程来读取客户端发送的数据,并使用主线程来发送数据至客户端。
二、建立客户端
在建立客户端时,我们需要使用 Socket 类,该类提供了客户端套接字的基本实现。以下是建立客户端的示例代码:
```java
public class Client {
public static void main(String[] args) {
try {
//创建Socket对象,指定连接的服务器端地址和端口号
Socket socket = new Socket("localhost", 8888);
System.out.println("已连接服务器!");
//启动读取服务器端消息的子线程
Thread thread = new Thread(new ReceiveMessage(socket));
thread.start();
//启动发送消息的主线程
sendMessage(socket);
} catch (IOException e) {
e.printStackTrace();
}
}
//发送消息的方法
public static void sendMessage(Socket socket) throws IOException {
BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
//获取输出流,向服务器端发送数据
PrintWriter printWriter = new PrintWriter(socket.getOutputStream(), true);
while (true) {
String message = reader.readLine();
printWriter.println(message);
}
}
}
```
在上述代码中,我们通过 Socket 类的构造方法实例化了一个客户端对象,并指定了连接的服务器端地址和端口号。接着与服务器端建立网络通信,使用子线程读取服务器端发送的数据,并使用主线程发送数据至服务器端。
三、处理数据交互
在服务器端和客户端中,我们都启动了一个子线程用于读取对端发送的数据。但是,我们还需要处理收到的数据并展现给用户。在上述代码中,我们使用了 ReceiveMessage 类来读取对端发送的数据,并控制台显示该数据。以下是 ReceiveMessage 类的代码:
```java
public class ReceiveMessage implements Runnable {
private Socket socket;
public ReceiveMessage(Socket socket) {
this.socket = socket;
}
@Override
public void run() {
try {
//获取输入流,接收数据
BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
while (true) {
String message = reader.readLine();
System.out.println("收到消息:" + message);
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
```
在 ReceiveMessage 类中,我们首先通过 Socket 对象获取输入流并读取对端发送的数据,读取完成后在控制台输出该数据。
四、运行程序
运行程序时,我们需要先运行服务器端程序,随后运行客户端程序。可以在控制台中输入需要发送的数据,发送数据后对端会收到该数据并在控制台中展示。
最后,我们将完整的聊天室程序代码放在一起:
Server.java
```java
public class Server {
public static void main(String[] args) {
try {
//创建ServerSocket对象,绑定端口号
ServerSocket serverSocket = new ServerSocket(8888);
System.out.println("服务器启动成功,等待客户端连接...");
//等待客户端连接,阻塞式方法
Socket socket = serverSocket.accept();
System.out.println("客户端" + socket.getInetAddress().getHostAddress() + "已连接!");
//启动读取客户端消息的子线程
Thread thread = new Thread(new ReceiveMessage(socket));
thread.start();
//启动发送消息的主线程
sendMessage(socket);
} catch (IOException e) {
e.printStackTrace();
}
}
//发送消息的方法
public static void sendMessage(Socket socket) throws IOException {
BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
//获取输出流,向客户端发送数据
PrintWriter printWriter = new PrintWriter(socket.getOutputStream(), true);
while (true) {
String message = reader.readLine();
printWriter.println(message);
}
}
}
```
Client.java
```java
public class Client {
public static void main(String[] args) {
try {
//创建Socket对象,指定连接的服务器端地址和端口号
Socket socket = new Socket("localhost", 8888);
System.out.println("已连接服务器!");
//启动读取服务器端消息的子线程
Thread thread = new Thread(new ReceiveMessage(socket));
thread.start();
//启动发送消息的主线程
sendMessage(socket);
} catch (IOException e) {
e.printStackTrace();
}
}
//发送消息的方法
public static void sendMessage(Socket socket) throws IOException {
BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
//获取输出流,向服务器端发送数据
PrintWriter printWriter = new PrintWriter(socket.getOutputStream(), true);
while (true) {
String message = reader.readLine();
printWriter.println(message);
}
}
}
```
ReceiveMessage.java
```java
public class ReceiveMessage implements Runnable {
private Socket socket;
public ReceiveMessage(Socket socket) {
this.socket = socket;
}
@Override
public void run() {
try {
//获取输入流,接收数据
BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
while (true) {
String message = reader.readLine();
System.out.println("收到消息:" + message);
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
```
以上就是使用 Socket 实现聊天功能的全部内容。
来源地址:https://blog.csdn.net/weixin_39706415/article/details/131136575