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 实现聊天功能的全部内容。