接地气讲解UDP协议和网络程序设计（深度好文）

Posted 2021-04-15 计算机技术和网络资源

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了接地气讲解UDP协议和网络程序设计（深度好文）相关的知识，希望对你有一定的参考价值。

点击上方“蓝字”关注，酷爽一夏

1、

UDP接地气解释

啥是UDP？

UDP协议是用户数据报协议，基于UDP的通信与基于TCP的通信不同，TCP讲究可靠传送，是一对一，而UDP是不提供可靠的保证，但是传输信息更快。可以把UDP形象地比喻成学校广播，在广播台吼一声，学校范围内的人就能听得到，而在学校范围外的人就听不到，这里说的范围呢，在计算机中就是IP和端口，你进了这个范围就能收到广播的信息。

接地气讲解UDP协议和网络程序设计（深度好文）

包裹包好了，需要一个快递小哥来取件啊，这里的DatagramSocket充当一个快递员的角色，这里端口就决定了快递小哥的单位了，你在哪家快递公司下的单肯定是由这家公司的人来收件，这就对应了上面的包裹的端口。send和receive方法就是发送和接收数据包的方法了。

这里使用得更多的是DatagramSocket的一个子类MulticastSocket（多点广播），它继承了DatagramSocket，所以它能使用DatagramSocket类的所有方法，并且它自己本身多了两个方法，加入广播组和离开广播组，这里出现了一个广播组的概念，广播组其实就是发广播的地方，你可以比喻为发快递的地方，他是数据包获取与发送的来源，你的包裹都是从这里拿和发送的。

1、

实战

有了上面的基础，那就来一个小例子实战一下：

public class Weather extends Thread { // 创建类。该类为多线程执行程序 String weather = "节目预报：八点有大型晚会，请收听"; int port = 9898; // 定义端口 InetAddress iaddress = null; // 创建InetAddress对象 MulticastSocket socket = null; // 声明多点广播套接字  Weather() { // 构造方法 try { // 实例化InetAddress，指定发广播的地址 iaddress = InetAddress.getByName("224.255.101.0"); socket = new MulticastSocket(port); // 实例化多点广播套接字 socket.setTimeToLive(1); // 指定发送范围是本地网络 socket.joinGroup(iaddress); // 加入广播组 } catch (Exception e) { e.printStackTrace(); // 输出异常信息 } }  public void run() { // run()方法 while (true) { DatagramPacket packet = null; // 声明DatagramPacket对象 byte data[] = weather.getBytes(); // 声明字节数组 // 将数据打包 packet = new DatagramPacket(data, data.length, iaddress, port); System.out.println(new String(data)); // 将广播信息输出 try { socket.send(packet); // 发送数据 sleep(3000); // 线程休眠 } catch (Exception e) { e.printStackTrace(); // 输出异常信息 } }  }   public static void main(String[] args) { // 主方法 Weather w = new Weather(); // 创建本类对象 w.start(); // 启动线程 } }

public class Receive_1 extends Thread { int port = 9898; InetAddress group = null; // 创建InetAddress对象 MulticastSocket socket = null; // 声明多点广播套接字
 public Receive_1() { try { group=InetAddress.getByName("224.255.101.0"); socket=new MulticastSocket(port); socket.joinGroup(group); } catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } }
 public void run() {    while(true) {     byte data[]=new byte[1024]; DatagramPacket packet=null; packet=new DatagramPacket(data, data.length,group,port);//接收数据包 try { socket.receive(packet); String message=new String(packet.getData(),0,packet.getLength()); System.out.println("广播发来的消息："+message); } catch (IOException e) { e.printStackTrace(); } } } public static void main(String[] args) { Receive_1 receive=new Receive_1(); receive.start(); } }