Java如何实现基于UDP协议的聊天室功能？

本文共计862个文字，预计阅读时间需要4分钟。

UDP概述：UDP（User Datagram Protocol，用户数据报协议）是Internet协议集支持的一个无连接的传输协议，中文称为用户数据报协议。它为应用程序提供了无需建立连接即可发送封装的IP数据报的方法。

UDP简述

UDP（User Datagram Protocol）协议是Internet 协议集支持的一个无连接的传输协议，中文名为用户数据报协议。它为应用程序提供了一种无需建立连接就可以发送封装的 IP 数据报的方法。

Internet 的传输层有两个主要协议，互为补充。无连接的是 UDP，它除了给应用程序发送数据包功能并允许它们在所需的层次上架构自己的协议之外，几乎没有做什么特别的事情。面向连接的是TCP，该协议几乎做了所有的事情。“when in trouble ， use TCP”。

那么今天讲讲如何使用UDP协议构建一个简单的小型聊天室。ChatA先发起聊天，然后ChatB才能在控制台输入聊天内容。如果想结束聊天可以输入over，当一方结束聊天，另一方也将结束聊天。

ChatA类(客户端A)：

代码展示如下：

package my.demo; import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetSocketAddress; import java.net.SocketException; import java.util.Scanner; //客户端A public class ChatA {     public static void main(String[] args) {         //控制台输入         Scanner input = new Scanner(System.in);                  // 创建基于UDP协议的DatagramSocket对象         // 客户端A监听8888端口         try (DatagramSocket socket = new DatagramSocket(8888)) {             //封装成DatagramPacket对象(数据包)             DatagramPacket sendPacket = new DatagramPacket(                     new byte[1024],                     1024,                     new InetSocketAddress("192.168.254.105", 7777));//对方的IP地址和端口号             DatagramPacket receivePacket = new DatagramPacket(new byte[1024], 1024);             while (true) {                 // 发送数据包                 System.out.print("（你）说: ");                 String sendContent = input.nextLine();                 sendPacket.setData(sendContent.getBytes());                 socket.send(sendPacket);                 if (sendContent.equals("over")) {                     System.out.println("你退出了聊天......");                     break;                 }                 // 接收数据包                 socket.receive(receivePacket);                 String receiveContent = new String(                         receivePacket.getData(),   //数据                         receivePacket.getOffset(), //读取位置                         receivePacket.getLength());//长度                 if (receiveContent.equals("over")) {                     System.out.println("对方退出了聊天......");                     break;                 }                 System.out.println("（他）说: " + receiveContent);             }         } catch (SocketException e) {             e.printStackTrace();         } catch (IOException e) {             e.printStackTrace();         }     } }

ChatB类(客户端B)：

代码展示如下：

package my.demo; import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetSocketAddress; import java.net.SocketException; import java.util.Scanner; //客户端B public class ChatB {     public static void main(String[] args) {         // 控制台输入         Scanner input = new Scanner(System.in);         try (// 客户端B监听7777端口                 DatagramSocket socket = new DatagramSocket(7777)) {             // 封装成DatagramPacket对象(数据包)             DatagramPacket sendPacket = new DatagramPacket(new byte[1024], 1024,                     new InetSocketAddress("192.168.254.105", 8888));// 对方的IP地址和端口号             DatagramPacket receivePacket = new DatagramPacket(new byte[1024], 1024);             while (true) {                 // 接收数据包                 socket.receive(receivePacket);                 String receiveContent = new String(receivePacket.getData(), receivePacket.getOffset(),                         receivePacket.getLength());                 if (receiveContent.equals("over")) {                     System.out.println("对方退出了聊天......");                     break;                 }                 System.out.println("（他）说: " + receiveContent);                 // 发送数据包                 System.out.print("（你）说: ");                 String sendContent = input.nextLine();                 sendPacket.setData(sendContent.getBytes());                 socket.send(sendPacket);                 if (sendContent.equals("over")) {                     System.out.println("你退出了聊天......");                     break;                 }             }         } catch (SocketException e) {             e.printStackTrace();         } catch (IOException e) {             e.printStackTrace();         }     } }

运行结果展示：

1.运行ChatA和ChatB（不分先后顺序）

2. ChatA先发起聊天：

在控制台输入：你好

ChatB显示内容：

3. ChatB向ChatA发起聊天：

ChatA显示内容：

4. 输入over结束聊天：

ChatA：

ChatB：

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持自由互联。