溫馨提示×

java如何實現udp聊天室

小億
96
2024-12-07 08:51:38
欄目: 編程語言

在Java中實現UDP聊天室,你需要使用java.net包中的DatagramSocket類。以下是一個簡單的UDP聊天室示例,包括一個服務器端和一個客戶端。

服務器端代碼:

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.util.Scanner;

public class UDPServer {
    public static void main(String[] args) throws IOException {
        int port = 12345;
        DatagramSocket socket = new DatagramSocket(port);
        System.out.println("Server is listening on port " + port);

        while (true) {
            byte[] buffer = new byte[1024];
            DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
            socket.receive(packet);

            String receivedMessage = new String(packet.getData(), 0, packet.getLength());
            System.out.println("Received message: " + receivedMessage);

            String response = "Message received: " + receivedMessage;
            byte[] sendData = response.getBytes();
            DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, packet.getAddress(), packet.getPort());
            socket.send(sendPacket);
        }
    }
}

客戶端代碼:

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.util.Scanner;

public class UDPClient {
    public static void main(String[] args) throws IOException {
        String serverAddress = "localhost";
        int serverPort = 12345;
        DatagramSocket socket = new DatagramSocket();
        System.out.println("Connected to server " + serverAddress + ":" + serverPort);

        Scanner scanner = new Scanner(System.in);
        while (true) {
            System.out.print("Enter your message: ");
            String message = scanner.nextLine();
            byte[] sendData = message.getBytes();
            DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, InetAddress.getByName(serverAddress), serverPort);
            socket.send(sendPacket);

            byte[] buffer = new byte[1024];
            DatagramPacket receivePacket = new DatagramPacket(buffer, buffer.length);
            socket.receive(receivePacket);

            String receivedMessage = new String(receivePacket.getData(), 0, receivePacket.getLength());
            System.out.println("Server response: " + receivedMessage);
        }
    }
}

這個示例中,服務器端監聽指定的端口,接收客戶端發送的消息,并將接收到的消息原樣發送回客戶端??蛻舳诉B接到服務器,發送消息并接收服務器的響應。

請注意,這個示例僅用于演示目的,實際應用中可能需要考慮更多因素,例如多個客戶端之間的通信、消息格式、錯誤處理等。

0
亚洲午夜精品一区二区_中文无码日韩欧免_久久香蕉精品视频_欧美主播一区二区三区美女