Java基于UDP协议的聊天室功能
短信预约 -IT技能 免费直播动态提醒
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("【客户端A】（你）说: ");
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("【客户端B】（他）说: " + 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("【客户端A】（他）说: " + receiveContent);
// 发送数据包
System.out.print("【客户端B】（你）说: ");
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：
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持编程网。
免责声明：
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的，并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据，供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
