要在Java中實(shí)現(xiàn)即時(shí)通訊，您可以使用Socket編程來(lái)建立網(wǎng)絡(luò)連接并進(jìn)行實(shí)時(shí)消息傳輸。下面是一個(gè)簡(jiǎn)單的示例，展示了基于TCP協(xié)議的即時(shí)通訊的實(shí)現(xiàn)：

　　1. 服務(wù)器端代碼：　

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;

public class ChatServer {
    private static final int PORT = 8000;
    private static List<ClientHandler> clients = new ArrayList<>();

    public static void main(String[] args) {
        try {
            ServerSocket serverSocket = new ServerSocket(PORT);
            System.out.println("服務(wù)器已啟動(dòng)，監(jiān)聽(tīng)端口：" + PORT);

            while (true) {
                Socket clientSocket = serverSocket.accept();
                System.out.println("客戶端連接：" + clientSocket);

                ClientHandler clientHandler = new ClientHandler(clientSocket);
                clients.add(clientHandler);
                clientHandler.start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public static void broadcastMessage(String message) {
        System.out.println("廣播消息：" + message);

        for (ClientHandler client : clients) {
            client.sendMessage(message);
        }
    }
}

　　2. 客戶端代碼：　　

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

public class ChatClient {
    private static final String SERVER_HOST = "localhost";
    private static final int SERVER_PORT = 8000;

    public static void main(String[] args) {
        try {
            Socket socket = new Socket(SERVER_HOST, SERVER_PORT);
            System.out.println("連接服務(wù)器成功");

            BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            PrintWriter writer = new PrintWriter(socket.getOutputStream(), true);

            // 創(chuàng)建一個(gè)線程用于接收服務(wù)器消息
            Thread receiveThread = new Thread(() -> {
                try {
                    while (true) {
                        String message = reader.readLine();
                        System.out.println("收到消息：" + message);
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
            });
            receiveThread.start();

            // 讀取用戶輸入并發(fā)送消息給服務(wù)器
            BufferedReader userInputReader = new BufferedReader(new InputStreamReader(System.in));
            String input;
            while ((input = userInputReader.readLine()) != null) {
                writer.println(input);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

　　在這個(gè)示例中，服務(wù)器端使用`ServerSocket`監(jiān)聽(tīng)指定端口，接受客戶端的連接。每當(dāng)有新的客戶端連接時(shí)，創(chuàng)建一個(gè)`ClientHandler`線程來(lái)處理客戶端的消息收發(fā)。

　　客戶端通過(guò)`Socket`連接到服務(wù)器，并創(chuàng)建一個(gè)讀取服務(wù)器消息的線程。客戶端通過(guò)標(biāo)準(zhǔn)輸入讀取用戶的輸入，并將其發(fā)送給服務(wù)器。

　　`ClientHandler`是一個(gè)用于處理單個(gè)客戶端消息收發(fā)的線程類。它在接收到客戶端的消息后，將消息廣播給所有連接的客戶端。

　　在運(yùn)行示例之前，請(qǐng)確保您已經(jīng)啟動(dòng)了服務(wù)器端代碼，并在客戶端代碼中指定正確的服務(wù)器主機(jī)名和端口。

　　請(qǐng)注意，這只是一個(gè)簡(jiǎn)單的示例，實(shí)際的即時(shí)通訊系統(tǒng)需要考慮更多的因素，如消息協(xié)議、身份驗(yàn)證、安全性等。此外，以上示例基于TCP協(xié)議，對(duì)于大規(guī)模或需要更高性能的應(yīng)用，您可能需要考慮使用更高級(jí)的通信協(xié)議或框架，如WebSocket或Netty。