在Java中，可以使用Socket來實現即時聊天功能。具體步驟如下：

1. 創建一個ServerSocket對象來監聽客戶端連接請求。

2. 當有客戶端發起連接請求時，通過accept()方法接受客戶端的連接，并創建一個Socket對象與客戶端進行通信。

3. 在服務器端，創建一個線程來處理每個客戶端的聊天請求。

4. 在客戶端，創建一個Socket對象來與服務器進行通信。

5. 客戶端和服務器端可以通過InputStream和OutputStream來進行讀寫操作，實現即時聊天功能。

以下是一個簡單的示例代碼：

服務器端代碼：

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
public class ChatServer {
public static void main(String[] args) {
try {
ServerSocket serverSocket = new ServerSocket(1234);
System.out.println("Server started...");
while (true) {
Socket socket = serverSocket.accept();
System.out.println("Client connected: " + socket.getInetAddress().getHostAddress());
// 創建新線程處理客戶端請求
Thread thread = new ChatThread(socket);
thread.start();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
class ChatThread extends Thread {
private Socket socket;
public ChatThread(Socket socket) {
this.socket = socket;
}
public void run() {
try {
BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter writer = new PrintWriter(socket.getOutputStream(), true);
String line;
while ((line = reader.readLine()) != null) {
System.out.println("Received from client: " + line);
// 將接收到的消息發送給所有連接的客戶端
ChatServer.broadcast(line);
if (line.equals("bye")) {
break;
}
}
reader.close();
writer.close();
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
// 將消息發送給所有連接的客戶端
private static synchronized void broadcast(String message) {
// TODO: 實現廣播功能
}
}

客戶端代碼：

import java.io.*;
import java.net.Socket;
import java.util.Scanner;
public class ChatClient {
public static void main(String[] args) {
try {
Socket socket = new Socket("localhost", 1234);
BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter writer = new PrintWriter(socket.getOutputStream(), true);
// 創建一個新線程用于接收服務器端發送的消息
Thread thread = new ReceiveThread(reader);
thread.start();
// 從控制臺讀取用戶輸入并發送給服務器端
Scanner scanner = new Scanner(System.in);
String line;
while ((line = scanner.nextLine()) != null) {
writer.println(line);
if (line.equals("bye")) {
break;
}
}
scanner.close();
reader.close();
writer.close();
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
class ReceiveThread extends Thread {
private BufferedReader reader;
public ReceiveThread(BufferedReader reader) {
this.reader = reader;
}
public void run() {
try {
String line;
while ((line = reader.readLine()) != null) {
System.out.println("Received from server: " + line);
}
} catch (IOException e) {
e.printStackTrace();
}
}
}

注意：以上代碼只是簡單示例，實際應用中還需要添加一些錯誤處理和安全性措施。