udp编程:一对一咨询
2021/7/13 14:07:34
本文主要是介绍udp编程:一对一咨询,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
package com.sundear.demo.util; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetSocketAddress; import java.net.SocketException; /** * 发送端:使用面向对象封装 */ public class TalkSend implements Runnable{ private DatagramSocket client; private BufferedReader reader; private String toIP; private int toPort; public TalkSend(int port,String toIP,int toPort){ this.toIP=toIP; this.toPort =toPort; try{ client = new DatagramSocket(port); reader = new BufferedReader(new InputStreamReader(System.in)); }catch (SocketException e){ e.printStackTrace(); } } @Override public void run() { while(true) { String data; try { data = reader.readLine(); byte[] datas = data.getBytes(); DatagramPacket packet = new DatagramPacket(datas, 0, datas.length, new InetSocketAddress(this.toIP, this.toPort)); client.send(packet); if(data.equals("bye")){ break; } } catch (IOException e) { e.printStackTrace(); } } } }
package com.sundear.demo.util; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.SocketException; public class TalkReceive implements Runnable{ private DatagramSocket server; private String from; public TalkReceive(int port,String from){ this.from= from; try { server = new DatagramSocket(port); } catch (SocketException e) { e.printStackTrace(); } } @Override public void run() { byte[] container=new byte[1024*60]; while(true) { DatagramPacket packet = new DatagramPacket(container, 0, container.length); try { server.receive(packet); byte[] datas = packet.getData(); String string = new String(datas, 0, packet.getLength()); System.out.println(this.from+":"+string); if(string.equals("bye")){ break; } } catch (IOException e) { e.printStackTrace(); } } server.close(); } }
package com.sundear.demo.util; public class TalkStudent { public static void main(String[] args) { new Thread(new TalkSend(7777,"localhost",9999)).start();//发送 new Thread(new TalkReceive(8888,"老师")).start();//接收 } }
package com.sundear.demo.util; public class TalkTeacher { public static void main(String[] args) { new Thread(new TalkReceive(9999,"学生")).start();//接收 new Thread(new TalkSend(5555,"localhost",8888)).start(); } }
老师和学生通过控制台一对一聊天
这篇关于udp编程:一对一咨询的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-05-15鸿蒙生态设备数量超8亿台
- 2024-05-13TiDB + ES:转转业财系统亿级数据存储优化实践
- 2024-05-09“2024鸿蒙零基础快速实战-仿抖音App开发(ArkTS版)”实战课程已上线
- 2024-05-09聊聊如何通过arthas-tunnel-server来远程管理所有需要arthas监控的应用
- 2024-05-09log4j2这么配就对了
- 2024-05-09nginx修改Content-Type
- 2024-05-09Redis多数据源,看这篇就够了
- 2024-05-09Google Chrome驱动程序 124.0.6367.62(正式版本)去哪下载?
- 2024-05-09有没有大佬知道这种数据应该怎么抓取呀?
- 2024-05-09这种运行结果里的10.100000001,怎么能最快改成10.1?