要在Java中实现即时通讯，您可以使用Socket编程来建立网络连接并进行实时消息传输。下面是一个简单的示例，展示了基于TCP协议的即时通讯的实现：

　　1. 服务器端代码：　

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("服务器已启动，监听端口：" + 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("连接服务器成功");

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

            // 创建一个线程用于接收服务器消息
            Thread receiveThread = new Thread(() -> {
                try {
                    while (true) {
                        String message = reader.readLine();
                        System.out.println("收到消息：" + message);
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
            });
            receiveThread.start();

            // 读取用户输入并发送消息给服务器
            BufferedReader userInputReader = new BufferedReader(new InputStreamReader(System.in));
            String input;
            while ((input = userInputReader.readLine()) != null) {
                writer.println(input);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

　　在这个示例中，服务器端使用`ServerSocket`监听指定端口，接受客户端的连接。每当有新的客户端连接时，创建一个`ClientHandler`线程来处理客户端的消息收发。

　　客户端通过`Socket`连接到服务器，并创建一个读取服务器消息的线程。客户端通过标准输入读取用户的输入，并将其发送给服务器。

　　`ClientHandler`是一个用于处理单个客户端消息收发的线程类。它在接收到客户端的消息后，将消息广播给所有连接的客户端。

　　在运行示例之前，请确保您已经启动了服务器端代码，并在客户端代码中指定正确的服务器主机名和端口。

　　请注意，这只是一个简单的示例，实际的即时通讯系统需要考虑更多的因素，如消息协议、身份验证、安全性等。此外，以上示例基于TCP协议，对于大规模或需要更高性能的应用，您可能需要考虑使用更高级的通信协议或框架，如WebSocket或Netty。