UDP 实现多收多发，广播发送，组播发送 TCP 实现多收多发

文章目录

TCP 实现多收多发（上线下线提醒）
UDP多收多发
UDP广播发送接收
UDP 组播发送接收

TCP 实现多收多发（上线下线提醒）

创建发送端

public static void main(String[] args) throws IOException {System.out.println("客户端");// 创建客户端对象Socket socket = new Socket("192.168.43.1", 7771);// 创建低级输出流并转高级PrintStream ps = new PrintStream(socket.getOutputStream());// 创建输入Scanner sc = new Scanner(System.in);while (true){System.out.println("请说：");ps.println(sc.nextLine());// 刷新ps.flush();}}

创建接收端

public static void main(String[] args) throws IOException {// 创建服务端// 调用连接方法ServerSocket server = new ServerSocket(7771);while (true) {Socket accept = server.accept();// 当用户到了这里，说明已经上线准备发送数据了// 上线提醒应该在这里System.out.println(accept.getRemoteSocketAddress() + "上线啦！！！");new MyTherad(accept).start();}
}

创建多线程

public class MyTherad extends Thread {private Socket accept;public MyTherad(Socket socket) {this.accept = socket;}@Overridepublic void run() {// 把低级流转换高级流try {BufferedReader buff = new BufferedReader(new InputStreamReader(accept.getInputStream()));String msg;while ((msg = buff.readLine()) != null) {// 打印了System.out.println(accept.getRemoteSocketAddress() + "说了：" + msg);}} catch (IOException e) {System.out.println(accept.getRemoteSocketAddress() + "离线啦！！！");}}
}

使用线程池优化多收多发的代码

创建接收端

public static void main(String[] args) throws IOException {// 创建服务端ServerSocket server = new ServerSocket(7771);// 创建线程池 3 个核心 5个最大，预留五个准备空位ThreadPoolExecutor pool = new ThreadPoolExecutor(3, 5, 6, TimeUnit.SECONDS,new ArrayBlockingQueue<>(3), new ThreadPoolExecutor.AbortPolicy());while (true) {// 调用连接方法Socket accept = server.accept();// 当用户到了这里，说明已经上线准备发送数据了// 上线提醒应该在这里System.out.println(accept.getRemoteSocketAddress() + "上线啦！！！");pool.execute(new MyTherad(accept));;}
}

创建发送端

public static void main(String[] args) throws IOException {// 创建客户端Socket socket = new Socket("192.168.43.1", 7771);// 创建打印流PrintStream ps = new PrintStream(socket.getOutputStream());Scanner sc = new Scanner(System.in);while (true){String s = sc.nextLine();if(s.equals("exit")){System.exit(0);}ps.println(s);}
}

创建线程

public class MyTherad extends Thread {private final Socket accept;public MyTherad(Socket socket) {this.accept = socket;}@Overridepublic void run() {// 把低级流转换高级流try {BufferedReader buff = new BufferedReader(new InputStreamReader(accept.getInputStream()));String msg;while ((msg = buff.readLine()) != null) {// 打印了System.out.println(accept.getRemoteSocketAddress() + "说了：" + msg);}} catch (IOException e) {System.out.println(accept.getRemoteSocketAddress() + "离线啦！！！");}}
}

UDP多收多发

创建发送端

public static void main(String[] args) throws IOException {// 创建发送端DatagramSocket data = new DatagramSocket();Scanner sc = new Scanner(System.in);while (true){System.out.println("请说：");String s = sc.nextLine();if(s.equals("exit")){data.close();break;}// 写入数据byte[] bytes = s.getBytes();// 创建数据包DatagramPacket pack = new DatagramPacket(bytes, 0, bytes.length, InetAddress.getLocalHost(), 6666);data.send(pack);}}

创建接收端

public static void main(String[] args) throws IOException {// 创建接收端DatagramSocket data = new DatagramSocket(6666);byte[] bytes = new byte[1024 * 24];// 创建数据包DatagramPacket pack = new DatagramPacket(bytes,bytes.length);while (true){// 接收数据data.receive(pack);// 获取数据发送的长度int len = pack.getLength();// 数据转换成字符串打印String s = new String(bytes, 0, len);System.out.println(s);// 打印发送者ipSystem.out.println(pack.getSocketAddress());// 打印发送者端口号System.out.println(pack.getPort());}}

UDP广播发送接收

只需要把发送的 ip 换成如下 OK

InetAddress.getByName("255.255.255.255")

创建发送端

public static void main(String[] args) throws IOException {// 创建发送端DatagramSocket data = new DatagramSocket();Scanner sc = new Scanner(System.in);while (true) {System.out.println("请说：");String s = sc.nextLine();if (s.equals("exit")) {data.close();break;}// 写入数据byte[] bytes = s.getBytes();// 创建数据包DatagramPacket pack = new DatagramPacket(bytes, 0, bytes.length, InetAddress.getByName("255.255.255.255"), 6666);data.send(pack);}

创建接收端

public static void main(String[] args) throws IOException {// 创建接收端DatagramSocket data = new DatagramSocket(6666);byte[] bytes = new byte[1024 * 24];// 创建数据包DatagramPacket pack = new DatagramPacket(bytes,bytes.length);while (true){// 接收数据data.receive(pack);// 获取数据发送的长度int len = pack.getLength();// 数据转换成字符串打印String s = new String(bytes, 0, len);System.out.println(s);// 打印发送者ipSystem.out.println(pack.getSocketAddress());// 打印发送者端口号System.out.println(pack.getPort());}
}

UDP 组播发送接收

接收端的改变

要使用MulticastSocket，但是技术在 java14 就过时了。

// 创建接收端
MulticastSocket data = new MulticastSocket(6666);
data.joinGroup(InetAddress.getByName("224.0.3.6"));

使用新版。不适用 java 1.8

// 创建接收端
MulticastSocket data = new MulticastSocket(6666);
data.joinGroup(new InetSocketAddress(InetAddress.getByName("224.0.3.6"),6666),NetworkInterface.getByInetAddress(InetAddress.getLocalHost()));

发送端

public static void main(String[] args) throws IOException {// 创建发送端DatagramSocket data = new DatagramSocket();Scanner sc = new Scanner(System.in);while (true) {System.out.println("请说：");String s = sc.nextLine();if (s.equals("exit")) {data.close();break;}// 写入数据byte[] bytes = s.getBytes();// 创建数据包  组播地址，在224之间DatagramPacket pack = new DatagramPacket(bytes, bytes.length,InetAddress.getByName("224.0.0.1"), 9999);data.send(pack);}
}

接收端

public static void main(String[] args) throws IOException {// 创建接收端MulticastSocket data = new MulticastSocket(9999);data.joinGroup(new InetSocketAddress(InetAddress.getByName("224.0.0.1"), 9999),NetworkInterface.getByInetAddress(InetAddress.getLocalHost()));byte[] bytes = new byte[1024 * 64];// 创建数据包DatagramPacket pack = new DatagramPacket(bytes, bytes.length);while (true) {// 接收数据data.receive(pack);// 获取数据发送的长度int len = pack.getLength();// 数据转换成字符串打印String s = new String(bytes, 0, len);System.out.println(s);// 打印发送者ipSystem.out.println(pack.getSocketAddress());// 打印发送者端口号System.out.println(pack.getPort());}
}

UDP 实现多收多发，广播发送，组播发送 TCP 实现多收多发相关推荐

Java-UDP通信（实现多发多收、广播、组播）
个人简介大家好,我是韩慧腾.一名正在努力学JAVA的大一小白,本文章为初学的笔记,希望各位多多指教.
java (多网卡环境下)发送组播广播(multicast/broadcast)失败问题
java发送组播或广播包并不复杂网上有很多文章,比如下面的两篇: <Java实现组播(multicast)简单例子> <Java 网络编程案例:使用 MulticastSocket ...
[转]UDP（udp通信、广播、组播），本地套接字
转发参考链接: [陈宸-研究僧] https://blog.csdn.net/qq_35883464/article/details/103741461 [Alliswell_WP] https:// ...
c/c++：UDP（udp通信、广播、组播），本地套接字
目录 1. udp 1.1 udp通信流程 1.2 操作函数 send.sendto recv.recvfrom 2. 广播 2.1 广播通信流程 2.2 设置广播属性函数:setsockopt 2. ...
网络编程-Socket套接字（TCP、UDP、广播和组播通信）
socket套接字 socket是一个编程接口(网络编程接口) 作用是用来实现网络上不同的主机的应用进程之间进行双向通信套接字是一种特殊的文件描述符也就意味着我们使用套接字实现网络通信的时候可以用 ...
java udp 广播组播_UDP广播和组播的基础知识介绍
UDP广播和组播的基础知识介绍 ━━━━━━━━━━━━━━━━━━━━━━━━━ UDP可以实现一对多的传输方式,即通过广播和组播把数据发送给一组进程.下面就介绍下UDP广播和组播的相关知识. 一. ...
网络通信：单播、广播、组播
网络通信:单播.广播.组播本文文件夹: 一.网络通信的分类.他们的定义和特点. 二.单播.广播.组播的传输信息的网络拓扑模型. 三.单播.广播.组播的编程实例. 一.网络通信的分类.他们的定义和特点 ...
Linux系统的广播和组播
广播广播:在一个局域网内部,所有的终端都能够收到数据包.使用广播的发送数据,会使处于同一个局域网内部的所有用户都必须接收到数据,用户不能拒绝. 注意:在使用广播和组播时,发送方和接收方都要处于同一个 ...
广播单播组播的知识总结与分享
第一部分基本概念在网络中设备与设备通信也就是我们说的报文的传递.他们传递的方式分为以下几种:广播.单播和组播.我们以下提到的二层和三层指的是OSI模型,它总共工作分为七层:物理层.数据链路层.网络 ...
LWIP应用开发|广播与组播
广播与组播 1. 广播与组播简介 1.1 组网方式网络中有三种通讯模式:单播.广播.组播(多播) 单播:主机之间"一对一"的通讯模式,网络中的交换机和路由器对数据只进行转发不进行 ...

UDP 实现多收多发，广播发送，组播发送 TCP 实现多收多发

文章目录

TCP 实现多收多发（上线下线提醒）

UDP多收多发

UDP广播发送接收

UDP 组播发送接收

UDP 实现多收多发，广播发送，组播发送 TCP 实现多收多发相关推荐

最新文章

热门文章