JAVA UDP 发送和接收数据
UDP的三种通讯方式
单播: 单机与单机之间的通讯广播: 当前主机与所在网络中的所有主机通讯组播: 当前主机与选定的一组主机通讯
一.单播
1.发送单次单条数据
1.发送端代码
package com.wei.udp;import .DatagramPacket;import .DatagramSocket;import .InetAddress;public class ClientDemo1 {/*** 发送端*/public static void main(String[] args) throws Exception {System.out.println("=============发送端启动===========");// 1.创建发送端对象DatagramSocket socket = new DatagramSocket(6666);// 2.创建一个数据包对象封装数据/*** 参数1:封装要发送的数据* 参数2:发送数据的大小* 参数3:服务端的IP地址* 参数4:服务端的端口** InetAddress.getLocalHost() 获取本机IP地址*/byte[] buffer = "我是一坨数据!".getBytes();DatagramPacket packet = new DatagramPacket(buffer,buffer.length, InetAddress.getLocalHost(),8888);// 3.发送数据socket.send(packet);// 4.关闭管道socket.close();}}
2.服务端(接收端)代码
package com.wei.udp;import .DatagramPacket;import .DatagramSocket;/*** 接收端*/public class ServerDemo2 {public static void main(String[] args) throws Exception {System.out.println("=============客户端启动===========");// 1.创建接受对象DatagramSocket socket = new DatagramSocket(8888);// 2.创建一个数据包接收数据byte [] buffer = new byte[1024];DatagramPacket packet = new DatagramPacket(buffer, buffer.length);// 3.等待接受数据socket.receive(packet);// 4.取出数据int len = packet.getLength();String rs = new String(buffer,0,len);System.out.println("收到的数据:" + rs);// 获取发送端的ip和端口String ip = packet.getSocketAddress().toString();System.out.println("发送端的IP地址: " + ip);int port = packet.getPort();System.out.println("发送端端口为: "+port);// 关闭管道socket.close();}}
3.接收到的数据
=============客户端启动===========收到的数据: 我是一坨数据!发送端的IP地址: /192.168.43.83:6666发送端端口为: 6666
2.多发多收消息
1.服务端代码
package com.wei.udp2;import .DatagramPacket;import .DatagramSocket;/*** 接收端*/public class ServerDemo2 {public static void main(String[] args) throws Exception {System.out.println("=============客户端启动===========");// 1.创建接受对象DatagramSocket socket = new DatagramSocket(8888);// 2.创建一个数据包接收数据byte [] buffer = new byte[1024];DatagramPacket packet = new DatagramPacket(buffer, buffer.length);while (true) {// 3.等待接受数据socket.receive(packet);// 4.取出数据int len = packet.getLength();String rs = new String(buffer,0,len);System.out.println("收到来自: "+ packet.getAddress()+ ",对方端口号为: "+ packet.getPort()+"的消息: " + rs);}}}
2.客户端代码
package com.wei.udp2;import .DatagramPacket;import .DatagramSocket;import .InetAddress;import java.util.Scanner;public class ClientDemo1 {/*** 发送端*/public static void main(String[] args) throws Exception {System.out.println("=============发送端启动===========");// 1.创建发送端对象DatagramSocket socket = new DatagramSocket(6666);Scanner sc = new Scanner(System.in);while (true) {System.out.println("请输入您要发送的消息: ");String msg = sc.nextLine();if("exit".equals(msg)){System.out.println("退出成功!");socket.close();break;}// 2.创建一个数据包对象封装数据byte[] buffer = msg.getBytes();DatagramPacket packet = new DatagramPacket(buffer,buffer.length, InetAddress.getLocalHost(),8888);// 3.发送数据socket.send(packet);}}}
3.发送及接收到的数据
===发送端启动=
请输入您要发送的消息:
嗨,在吗?
请输入您要发送的消息:
在吗?
请输入您要发送的消息:
怎么不说话?
请输入您要发送的消息:
exit
退出成功!
===客户端启动=
收到来自: /192.168.43.83,对方端口号为: 6666的消息: 嗨,在吗?
收到来自: /192.168.43.83,对方端口号为: 6666的消息: 在吗?
收到来自: /192.168.43.83,对方端口号为: 6666的消息: 怎么不说话?
二.广播消息
发送广播消息需要使用广播地址: 255.255.255.255发送端的数据包的目的地址是广播地址+指定端口号(255.255.255.255,9999)本机所在网段的其他主机只要匹配到端口即可接受消息(9999)
1.服务端代码
package com.wei.udp3;import .DatagramPacket;import .DatagramSocket;/*** 服务端*/public class ServerDemo2 {public static void main(String[] args) throws Exception {System.out.println("=============客户端启动===========");// 1.创建接受对象DatagramSocket socket = new DatagramSocket(9999);// 2.创建一个数据包接收数据byte [] buffer = new byte[1024];DatagramPacket packet = new DatagramPacket(buffer, buffer.length);while (true) {// 3.等待接受数据socket.receive(packet);// 4.取出数据int len = packet.getLength();String rs = new String(buffer,0,len);System.out.println("收到来自: "+ packet.getAddress()+ ",对方端口号为: "+ packet.getPort()+"的消息: " + rs);}}}
2.发送端代码
package com.wei.udp3;import .DatagramPacket;import .DatagramSocket;import .InetAddress;import java.util.Scanner;public class ClientDemo1 {/*** 发送端*/public static void main(String[] args) throws Exception {System.out.println("=============发送端启动===========");// 1.创建发送端对象DatagramSocket socket = new DatagramSocket(6666);Scanner sc = new Scanner(System.in);while (true) {System.out.println("请输入您要发送的消息: ");String msg = sc.nextLine();if("exit".equals(msg)){System.out.println("退出成功!");socket.close();break;}// 2.创建一个数据包对象封装数据byte[] buffer = msg.getBytes();DatagramPacket packet = new DatagramPacket(buffer,buffer.length, InetAddress.getByName("255.255.255.255"),9999);// 3.发送数据socket.send(packet);}}}
3.发送及接收到的数据
===发送端启动=
请输入您要发送的消息:
hello
请输入您要发送的消息:
我是一条广播消息
请输入您要发送的消息:
exit
退出成功!
===客户端启动=
收到来自: /192.168.43.83,对方端口号为: 6666的消息: hello
收到来自: /192.168.43.83,对方端口号为: 6666的消息: 我是一条广播消息
三.组播
使用组播地址: 224.0.0.0~239.255.255.255发送端的数据包的目的目的地址是组播ip(224.0.1.1,9999)接收端必须绑定该组播ip(224.0.1.1),端口还要对应发送端的目的端口(9999)
1.服务端代码
package com.wei.udp4;import .*;/*** 服务端*/public class ServerDemo2 {public static void main(String[] args) throws Exception {System.out.println("=============客户端启动===========");// 1.创建接受对象MulticastSocket socket = new MulticastSocket(9999);// 把当前接受端加入到一个组播组中,绑定对应组播消息的组ip// socket.joinGroup(InetAddress.getByName("224.0.1.1")); 过时的方法socket.joinGroup(new InetSocketAddress(InetAddress.getByName("224.0.1.1"),9999), NetworkInterface.getByInetAddress(InetAddress.getLocalHost()));// 2.创建一个数据包接收数据byte [] buffer = new byte[1024];DatagramPacket packet = new DatagramPacket(buffer, buffer.length);while (true) {// 3.等待接受数据socket.receive(packet);// 4.取出数据int len = packet.getLength();String rs = new String(buffer,0,len);System.out.println("收到来自: "+ packet.getAddress()+ ",对方端口号为: "+ packet.getPort()+"的消息: " + rs);}}}
2.客户端代码
package com.wei.udp4;import .DatagramPacket;import .DatagramSocket;import .InetAddress;import java.util.Scanner;public class ClientDemo1 {/*** 发送端*/public static void main(String[] args) throws Exception {System.out.println("=============发送端启动===========");// 1.创建发送端对象DatagramSocket socket = new DatagramSocket(6666);Scanner sc = new Scanner(System.in);while (true) {System.out.println("请输入您要发送的消息: ");String msg = sc.nextLine();if("exit".equals(msg)){System.out.println("退出成功!");socket.close();break;}// 2.创建一个数据包对象封装数据byte[] buffer = msg.getBytes();DatagramPacket packet = new DatagramPacket(buffer,buffer.length, InetAddress.getByName("224.0.1.1"),9999);// 3.发送数据socket.send(packet);}}}
3.发送及接收到的数据
===发送端启动=
请输入您要发送的消息:
hello
请输入您要发送的消息:
我是一条组播消息
请输入您要发送的消息:
exit
===客户端启动=
收到来自: /192.168.43.83,对方端口号为: 6666的消息: hello
收到来自: /192.168.43.83,对方端口号为: 6666的消息: 我是一条组播消息
