Java模拟UDP通信示例代码
程序员文章站
2023-09-07 15:26:02
java基础:模拟udp通信1、一次发送,一次接收1.1、发送方// 发送端,不需要连接服务器public class udpclientdemo { public static void main...
java基础:模拟udp通信
1、一次发送,一次接收
1.1、发送方
// 发送端,不需要连接服务器 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(); } }
1.2、接收方
// 接收端,接收端需要保证存在,否则接收不到,所以需要提前开启 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()); } }
2、多次发送,多次接收
一方多次发送,一方多次接收,加上一个 while(true) {} 死循环,并规定在什么情况下退出即可。
2.1、发送方
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(); } }
2.2、接收方
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(); } }
3、模拟双方通信
模拟双方使用udp通信,需要开启两个线程,并对以上代码进行【共性提取】,进一步进行抽象。
由此,双方可以通过指定的端口来互相发送消息。
3.1、发送方的线程
// 开启多线程需要实现 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(); } }
3.2、接收方的线程
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(); } }
3.3、模拟学生
// 学生端 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(); } }
3.4、模拟老师
// 教师端 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通信的资料请关注其它相关文章!
上一篇: C++的基本语言学习 , 简单易懂
下一篇: Python 判断奇数偶数的方法