闹腾网,香港居民身份证,tokyo hot n0458
java基础：模拟udp通信
我要评论
// 发送端，不需要连接服务器
public class udpclientdemo {
public static void main(string[] args) throws exception {
// 1. 发送数据包需要一个socket
datagramsocket socket = new datagramsocket();
// 1.2 建立一个包
string msg = "你好";
inetaddress localhost = inetaddress.getbyname("localhost");
system.out.println(localhost);
int port = 8080;
/*
通过udp发送消息，需要通过 包 来发送，--> datagrampacket()，该方法有多种重载形式，以下使用参数列表最多的那个
参数：
- 要发送的 消息 的字节数组
- 从字节数组的哪个位置开始发送
- 发送的长度
- 对方的 ip地址
- 对方的端口号
*/
datagrampacket packet = new datagrampacket(msg.getbytes(), 0, msg.getbytes().length, localhost, port);
// 2. 发送数据包
socket.send(packet);
socket.close();
}
}
// 接收端，接收端需要保证存在，否则接收不到，所以需要提前开启
public class udpserverdemo {
public static void main(string[] args) throws exception {
// 1. 接收也需要一个socket，并且要开启接收的端口
datagramsocket socket = new datagramsocket(8080);
// 需要一个字节数组来接收数据
byte[] buffer = new byte[1024];
// 1.2 封装数据包
datagrampacket packet = new datagrampacket(buffer, 0, buffer.length);
// 2. 接收数据，阻塞式接收：一直处于监听状态
socket.receive(packet);
// 关闭套接字
socket.close();
// 输出一下
system.out.println(packet.getaddress().gethostaddress());
// trim()：为了去除多余的空格
system.out.println(new string(packet.getdata()).trim());
}
}
一方多次发送，一方多次接收，加上一个 while(true) {} 死循环，并规定在什么情况下退出即可。
public class chatsenderdemo {
public static void main(string[] args) throws exception {
// 使用socket来接收
datagramsocket socket = new datagramsocket();
while (true) {
// 准备发送包裹，从键盘接收数据
bufferedreader reader = new bufferedreader(new inputstreamreader(system.in));
// 读取一行
string data = reader.readline();
byte[] databytes = data.getbytes();
datagrampacket packet = new datagrampacket(databytes, databytes.length, new inetsocketaddress("127.0.0.1", 6666));
// 发送
socket.send(packet);
// 什么时候退出
if ("bye".equals(data)) {
break;
}
}
// 关闭
socket.close();
}
}
public class chatreceivedemo {
public static void main(string[] args) throws exception {
datagramsocket socket = new datagramsocket(6666);
while (true) {
// 准备接收数据包裹
byte[] buffer = new byte[1024];
// 用来接收数据
datagrampacket packet = new datagrampacket(buffer, 0, buffer.length);
// 接收包裹，阻塞时接收
socket.receive(packet);
// 接收到的数据
string receivedata = new string(packet.getdata()).trim();
// 打印到控制台
system.out.println(receivedata);
// 什么时候退出
if ("bye".equals(receivedata)) {
break;
}
}
// 关闭
socket.close();
}
}
模拟双方使用udp通信，需要开启两个线程，并对以上代码进行【共性提取】，进一步进行抽象。
由此，双方可以通过指定的端口来互相发送消息。
// 开启多线程需要实现 runnable 接口，实现 run()方法
public class talksender implements runnable {
// 网络套接字，发送需要
datagramsocket socket = null;
// 缓冲读取流
bufferedreader reader = null;
// 开启哪个端口接收
private int fromport;
// 对方的 ip
private string toip;
// 对方的端口
private int toport;
// 通过构造方法进行初始化
public talksender(int fromport, string toip, int toport) {
this.fromport = fromport;
this.toip = toip;
this.toport = toport;
try {
socket = new datagramsocket(fromport);
} catch (socketexception e) {
e.printstacktrace();
}
}
// 重写 run()方法，设置线程任务
@override
public void run() {
while (true) {
string data = null;
try {
// 准备发送包裹，从键盘接收数据
reader = new bufferedreader(new inputstreamreader(system.in));
// 读取一行
data = reader.readline();
byte[] databytes = data.getbytes();
datagrampacket packet = new datagrampacket(databytes, databytes.length, new inetsocketaddress(toip, toport));
socket.send(packet);
} catch (ioexception e) {
e.printstacktrace();
}
// 什么时候退出
if ("bye".equals(data)) {
break;
}
}
// 关闭
socket.close();
}
}
public class talkreveicer implements runnable {
datagramsocket socket = null;
// 从哪个端口接收
private int formport;
// 发送方是谁
private string who;
public talkreveicer(int formport, string who) {
this.formport = formport;
this.who = who;
try {
socket = new datagramsocket(formport);
} catch (socketexception e) {
e.printstacktrace();
}
}
@override
public void run() {
while (true) {
string receivedata = null;
try {
// 准备接收数据包裹
byte[] buffer = new byte[1024];
// 接收数据
datagrampacket packet = new datagrampacket(buffer, 0, buffer.length);
// 接收数据，阻塞式
socket.receive(packet);
// 接收到的数据
receivedata = new string(packet.getdata());
system.out.println(who + "：" + receivedata.trim());
} catch (ioexception e) {
e.printstacktrace();
}
// 什么时候退出
if ("bye".equals(receivedata)) {
break;
}
}
// 关闭
socket.close();
}
}
// 学生端
public class talkstudent {
public static void main(string[] args) {
// 开启 5555端口，发送到本机的 6666端口
new thread(new talksender(5555, "localhost", 6666)).start();
// 规定使用 7777 端口接收老师发送的消息
new thread(new talkreveicer(7777, "老师")).start();
}
}
// 教师端
public class talkteacher {
public static void main(string[] args) {
// 开启 8888端口，发送到本机的 7777端口
new thread(new talksender(8888, "localhost", 7777)).start();
// 规定使用 6666 端口接收学生发送的消息
new thread(new talkreveicer(6666, "学生")).start();
}
}
总结：
使用udp通信，其实主要的步骤分为三步：
1 用 datagramsocket() 来开启端口，通过开启端口聊天。
2 用datagrampacket() 来发送或者接收数据。
3 关闭 datagramsocket，释放资源。
以上就是java模拟udp通信示例代码的详细内容，更多关于java模拟udp通信的资料请关注移动技术网其它相关文章！
如对本文有疑问，请在下面进行留言讨论，广大热心网友会与你互动！！ 点击进行留言回复
apollo与springboot集成实现动态刷新配置的教程详解
网友评论