【转】UDP协议格式以及在java中的使用

UDP协议格式以及在java中的使用

UDP是面向无连接的通讯协议,由于通讯不需要连接,所以可以实现广播发送。UDP通讯时不需要接收方确认,属于不可靠的传输,可能会出现丢包现象,实际应用中要求程序员编程验证。

UDP适用于DNS、视频音频等多媒体通信、广播通信(广播、多播)。例如我们常用的QQ,就是一个以UDP为主,TCP为辅的通讯协议。

UDP报文格式如下:

在这里插入图片描述
UDP首部有8个字节,由4个字段构成,每个字段都是两个字节,

  1. 源端口:数据发送方的端口号.
  2. 目的端口:数据接收方的端口号。
  3. 长度:UDP数据报的整个长度(包括首部和数据),其最小值为8(只有首部)。
  4. 校验和:检测UDP数据报在传输中是否有错,有错则丢弃。

可以使用nc发送UDP数据包:echo hello | nc -uv 127.0.0.1 9999

用tcpdump抓取到的数据包如下(注意先运行tcpdump,然后再执行nc命令):

# tcpdump -i lo -X udp port 9999
tcpdump: verbose output suppressed, use -v or -vv for full protocol decode
listening on lo, link-type EN10MB (Ethernet), capture size 262144 bytes
11:19:39.267912 IP localhost.45666 > localhost.distinct: UDP, length 60x0000:  4500 0022 5914 4000 4011 e3b4 7f00 0001  E.."Y.@.@.......0x0010:  7f00 0001 b262 270f 000e fe21 6865 6c6c  .....b'....!hell0x0020:  6f0a                                     o.
... ...

说明:

  • 源端口:0xb262,十进制的45666。
  • 目的端口:0x270f,十进制的9999。
  • 长度:0x000e,14个字节的报文长度。
  • 校验和:0xfe21。

bio之单播

单播就是一对一通信。

服务器端代码如下:

package com.morris.udp.bio.single;import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;public class Server {public static void main(String[] args) throws IOException {DatagramSocket datagramSocket = new DatagramSocket(9999);byte[] bytes = new byte[1024];DatagramPacket datagramPacket = new DatagramPacket(bytes, bytes.length);datagramSocket.receive(datagramPacket);System.out.println("receive from client: " + new String(bytes));byte[] req = "hello client".getBytes();DatagramPacket resp = new DatagramPacket(req, req.length, datagramPacket.getSocketAddress());datagramSocket.send(resp);}
}

客户端代码如下:

package com.morris.udp.bio.single;import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;public class Client {public static void main(String[] args) throws IOException {DatagramSocket datagramSocket = new DatagramSocket();byte[] req = "hello server".getBytes();DatagramPacket datagramPacket = new DatagramPacket(req, req.length, new InetSocketAddress("127.0.0.1", 9999));datagramSocket.send(datagramPacket);datagramSocket.receive(datagramPacket);System.out.println("receive from server: " + new String(datagramPacket.getData()));}
}

客户端和服务端的代码几乎一致,只不过接收和发送数据的顺序不一致,receive和send都欧式阻塞方法。

bio之广播

广播:同一网段所有主机都能接收,前提是端口要开启监听。

只需要将单播的例子中客户端发送数据的IP修改为255.255.255.255即可,具体修改如下:

DatagramPacket datagramPacket = new DatagramPacket(req, req.length, new InetSocketAddress("255.255.255.255", 9999));
  • 1

bio之多播(组播)

多播数据报套接字类用于发送和接收IP多播包。MulticastSocket是一种DatagramSocket,它具有加入Internet上其他多播主机的“组”的附加功能。

多播组通过D类IP地址和标准UDP端口号指定。D类IP地址在224.0.0.0和239.255.255.255的范围内。地址224.0.0.0被保留,不应使用。

可以通过首先使用所需端口创建MulticastSocket,然后调用joinGroup(InetAddress groupAddr)方法来加入多播组。

服务器端代码如下:

package com.morris.udp.bio.multicast;import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.MulticastSocket;public class Server {public static void main(String[] args) throws IOException {InetAddress group = InetAddress.getByName("228.5.6.7");MulticastSocket s = new MulticastSocket(6789);s.joinGroup(group);byte[] buf = new byte[1000];DatagramPacket recv = new DatagramPacket(buf, buf.length);s.receive(recv);System.out.println("receive : " + new String(buf));s.leaveGroup(group);}
}

客户端代码如下:

package com.morris.udp.bio.multicast;import java.io.IOException;
import java.net.*;public class Client {public static void main(String[] args) throws IOException {String msg = "Hello";InetAddress group = InetAddress.getByName("228.5.6.7");MulticastSocket s = new MulticastSocket();s.joinGroup(group);DatagramPacket hi = new DatagramPacket(msg.getBytes(), msg.length(), group, 6789);s.send(hi);s.leaveGroup(group);}
}

NIO实现单播

服务器端代码如下:

package com.morris.udp.nio;import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.SocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.DatagramChannel;public class Server {public static void main(String[] args) throws IOException {DatagramChannel datagramChannel = DatagramChannel.open();datagramChannel.bind(new InetSocketAddress(9999));// datagramChannel.configureBlocking(false);ByteBuffer byteBuffer = ByteBuffer.allocate(128);SocketAddress receive = datagramChannel.receive(byteBuffer);byteBuffer.flip();byte[] bytes = new byte[byteBuffer.remaining()];byteBuffer.get(bytes);System.out.println("receive from client: " + new String(bytes));byteBuffer.clear();byteBuffer.put("hello client".getBytes());datagramChannel.send(byteBuffer, receive);}
}

客户端代码如下:

package com.morris.udp.nio;import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.SocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.DatagramChannel;public class Client {public static void main(String[] args) throws IOException {DatagramChannel datagramChannel = DatagramChannel.open();// datagramChannel.configureBlocking(false);String req = "hello server";ByteBuffer byteBuffer = ByteBuffer.allocate(req.length());byteBuffer.put(req.getBytes());byteBuffer.flip();datagramChannel.send(byteBuffer, new InetSocketAddress("127.0.0.1", 9999));datagramChannel.receive(byteBuffer);byteBuffer.flip();byte[] bytes = new byte[byteBuffer.remaining()];byteBuffer.get(bytes);System.out.println("receive from server: " + new String(bytes));}
}

Netty实现单播

服务器端代码如下:

package com.morris.udp.netty.single;import io.netty.bootstrap.Bootstrap;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelOption;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.DatagramPacket;
import io.netty.channel.socket.nio.NioDatagramChannel;
import io.netty.util.CharsetUtil;public class Server {private static final int port = 8899;public static void main(String[] args) throws InterruptedException {NioEventLoopGroup group = new NioEventLoopGroup();try {Bootstrap bootstrap = new Bootstrap();bootstrap.group(group).channel(NioDatagramChannel.class).handler(new SimpleChannelInboundHandler<DatagramPacket>() {@Overrideprotected void channelRead0(ChannelHandlerContext ctx, DatagramPacket msg) throws Exception {// 接收数据System.out.println(msg.content().toString(CharsetUtil.UTF_8));// 发送数据ctx.writeAndFlush(new DatagramPacket(Unpooled.copiedBuffer("hello client", CharsetUtil.UTF_8), msg.sender()));ctx.close();}});bootstrap.bind(port).sync().channel().closeFuture().await();} finally {group.shutdownGracefully();}}
}

客户端代码如下:

package com.morris.udp.netty.single;import io.netty.bootstrap.Bootstrap;
import io.netty.buffer.Unpooled;
import io.netty.channel.Channel;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelOption;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.DatagramPacket;
import io.netty.channel.socket.nio.NioDatagramChannel;
import io.netty.util.CharsetUtil;import java.net.InetSocketAddress;public class Client {public static void main(String[] args) throws InterruptedException {NioEventLoopGroup group = new NioEventLoopGroup();try {Bootstrap bootstrap = new Bootstrap();bootstrap.group(group).channel(NioDatagramChannel.class).handler(new SimpleChannelInboundHandler<DatagramPacket>() {@Overrideprotected void channelRead0(ChannelHandlerContext ctx, DatagramPacket msg) throws Exception {// 接收数据System.out.println(msg.content().toString(CharsetUtil.UTF_8));ctx.close();}});Channel channel = bootstrap.bind(0).sync().channel();// 发送数据channel.writeAndFlush(new DatagramPacket(Unpooled.copiedBuffer("hello server", CharsetUtil.UTF_8), new InetSocketAddress("127.0.0.1", 8899)));if (!channel.closeFuture().await(30 * 1000)) {System.err.println("查询超时");}} finally {group.shutdownGracefully();}}
}

Netty实现广播

只需要将netty实现的单播的客户端代码做如下修改:

  1. 增加option:
.option(ChannelOption.SO_BROADCAST, true)
  • 1
  1. 将IP地址修改为广播地址255.255.255.255
channel.writeAndFlush(new DatagramPacket(Unpooled.copiedBuffer("hello server", CharsetUtil.UTF_8), new InetSocketAddress("255.255.255.255", 8899)));
  • 1

底层实现

recvfrom负责接收UDP数据,其函数声明如下:

ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags, struct sockaddr *src_addr, socklen_t *addrlen);

sendto负责发送UDP数据,其函数声明如下:

ssize_t sendto(int sockfd, const void *buf, size_t len, int flags, const struct sockaddr *dest_addr, socklen_t addrlen);
  • 下面通过对bio之单播的例子所产生的系统调用进行跟踪:

启动服务器端服务Server:

# strace -ff -o out java Server

然后使用nc命令充当客户端进行连接:echo hello | nc -uv 127.0.0.1 9999

产生的系统调用中关键信息如下:

socket(AF_INET6, SOCK_DGRAM, IPPROTO_IP) = 4
bind(4, {sa_family=AF_INET6, sin6_port=htons(9999), inet_pton(AF_INET6, "::", &sin6_addr), sin6_flowinfo=htonl(0), sin6_scope_id=0}, 28) = 0
recvfrom(4, "hello\n", 1024, 0, {sa_family=AF_INET6, sin6_port=htons(7361), inet_pton(AF_INET6, "::ffff:127.0.0.1", &sin6_addr), sin6_flowinfo=htonl(0), sin6_scope_id=0}, [28]) = 6
write(1, "receive from client: hello\n\0\0\0\0\0"..., 1045) = 1045
write(1, "\n", 1) 
sendto(4, "hello client", 12, 0, {sa_family=AF_INET6, sin6_port=htons(7361), inet_pton(AF_INET6, "::ffff:127.0.0.1", &sin6_addr), sin6_flowinfo=htonl(0), sin6_scope_id=0}, 28) = 12

可见发送和接收数据确实使用了上面的系统调用,另外上面的系统调用中并没有listen函数,不需要监听端口,再次验证UDP是面向无连接的。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/436991.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

python网页填表教程_PythonSpot 中文系列教程 · 翻译完成

原文&#xff1a;PythonSpot Python Tutorials 协议&#xff1a;CC BY-NC-SA 4.0 欢迎任何人参与和完善&#xff1a;一个人可以走的很快&#xff0c;但是一群人却可以走的更远。在线阅读ApacheCN 学习资源目录PythonSpot 中文系列教程初学者 介绍Python 字符串字符串&#xff0…

Qt生成的exe中为什么会带有不该有的盾牌?

参考 为什么EXE文件出现了不该出现的“盾牌”什么情况下 exe 会自动加上 UAC 的盾标&#xff1f;

【转】TCP/IP协议到底在讲什么?【乐搏TestPro】

用比喻和漫画给有需要的小伙伴解释下IP、TCP捎带题一下各种协议与HTTP协议的关系&#xff1b; 目录&#xff1a; 负责传输的IP协议 确保可靠性的TCP协议 各种协议与HTTP协议的关系 一、负责传输的IP协议 按照层次分&#xff0c;IP&#xff08;全称&#xff1a;Internet Prot…

python文本去重函数_python3.4.3下逐行读入txt文本并去重的方法

读写文件时应注意的问题包括&#xff1a;1.字符编码2.操作完成即时关闭文件描述符3.代码兼容性几种方法&#xff1a;#!/bin/python3original_list1[" "]original_list2[" "]original_list3[" "]original_list4[" "]newlist1[" &q…

Qt中标绘功能的实现方法对比

使用Qt开发桌面程序&#xff0c;经常会有标绘的需求&#xff0c;一般有以下几点&#xff1a; 新建&#xff1a;圆、矩形、椭圆、文字标注&#xff0c;插入图像等&#xff1b;编辑&#xff1a;指对已标绘内容的属性编辑修改功能&#xff1b;删除&#xff1a;指对已标绘内容的删…

【转】PE文件结构详解--(完整版)

&#xff08;一&#xff09;基本概念 PE&#xff08;Portable Execute&#xff09;文件是Windows下可执行文件的总称&#xff0c;常见的有DLL&#xff0c;EXE&#xff0c;OCX&#xff0c;SYS等&#xff0c;事实上&#xff0c;一个文件是否是PE文件与其扩展名无关&#xff0c;P…

sap 订单状态修改时间_SAP中对于获取订单的状态

在SAP中对于如何获取订单的状态&#xff0c;提供了至少两个函数&#xff0c;分别是 STATUS_READ 和 STATUS_TEXT_EDIT。下面简单介绍这两个函数1.STATUS_READ 改函数的实现原理大概是通过订单的对象好(OR订单号) 到JEST中取出字段STAT INACT.JEST表中STAT是一串从字面看不出…

【转】%~dp0是什么意思

转载自 www.cnblogs.com/yxsylyh 转载内容如下&#xff1a; cd /D %~dp0的意思如下&#xff1a; 更改当前目录为批处理本身的目录 比如你有个批处理a.bat在D:\qq文件夹下 a.bat内容为 cd /d %~dp0 在这里 cd /d %~dp0的意思就是cd /d d:\qq %0代表批处理本身 d:\qq\a.b…

AutoCode For XML(XML解析代码生成器)发布

项目地址 AutoCode For XML on Gitee bug反馈、意见建议 bug反馈、意见建议请直接在此项目主页上进行&#xff01; 版本更新 AutoCode For XML v1.0.0发布啦&#xff01; 第一个发行版本&#xff0c;主要用于测试。 下载地址&#xff1a;点我 本工具由Qt未来工程师原创发布。…

wince投屏苹果手机_怎么把手机上的导航映射到中控屏

展开全部第一种&#xff1a;通过MHL线进行手机屏幕和车载屏幕连62616964757a686964616fe78988e69d8331333431353366接实现这种连接方式&#xff0c;必须满足三个条件&#xff1a;一是手机需要支持MHL功能&#xff0c;目前大多数安卓智能手机均具备这一功能&#xff1b;二是车上…

【转】逆变与协变详解

逆变&#xff08;contravariant&#xff09;与协变&#xff08;covariant&#xff09;是C#4新增的概念&#xff0c;许多书籍和博客都有讲解&#xff0c;我觉得都没有把它们讲清楚&#xff0c;搞明白了它们&#xff0c;可以更准确地去定义泛型委托和接口&#xff0c;这里我尝试画…

设计模式(二)设计模式的本质

简介 设计模式是计算机前辈们&#xff0c;总结项目开发成败经验&#xff0c;得出的一套最佳实践理论。它并不是高高在上、不切实际的理论&#xff0c;而是具体到代码编写层面的指导理论。 从学习编写代码开始&#xff0c;我们就被教导&#xff0c;要写高内聚、低耦合、可复用…

angular设置referer_Angular-cli 构建应用的一些配置

Angular-cli 构建应用的一些配置标签(空格分隔)&#xff1a; Angular直接使用 ng build --prod --build-optimizer --base-href/ 来发布base-href可以设置服务器上的某个子路径&#xff0c;使用 ng build --base-href/my/path/如果打包静态文件(js和css)不放在和index.html同一…

设计模式(三)创建型模式

前言 根据菜鸟教程的目录&#xff0c;我们首先来看看创建型模式。 创建型模式研究&#xff1a; 实际应用中通常有哪些不同的创建对象的场景&#xff1b;在不同的场景下&#xff0c;如何更好地编写创建对象的代码。主要研究构造函数。 下面分别对创建型模式下的各种具体模式进…

CSDN改版,找不到各种入口,链接放下面

https://mp.csdn.net/console/article?spm1010.2135.3001.5128 https://mp.csdn.net/console/column/allColumnList 分类管理 https://mp.csdn.net/console/article 文章管理 https://mp.csdn.net/console/upDetailed 资源管理 https://mp.csdn.net/editor/html?spm1011.…

python中pca算法_python实现PCA算法01

python实现PCA算法Software version&#xff1a; Python 2.7.12 |Anaconda 4.2.0 (64-bit)|法1. 编程一步一步实现法2. sklearn我们以定义函数的形式来一步一步进行1.1 导入模块&#xff1a;Numpy&#xff0c;Pandas# -*- coding: utf-8 -*-# Time : 2017/8/17 14:20# Author :…

设计模式(一)预备知识

前言 学习设计模式需要有面向对象编程的基础&#xff0c;要基本掌握一种面向对象的编程语言。关于面向对象编程思想&#xff0c;我们有另外一篇文章专门讲解&#xff1a;面向过程和面向对象的联系和区别。 知识点 虚函数 在类的成员函数定义中&#xff0c;形式上为定义为vir…

【转】GitHub 从单机到联机:玩转 Pull Request

最近在参与一个叫 Exercism 的项目&#xff0c;这是一个由 GitHub 生态工程师 Katrina Owen 发起的编程练习社区&#xff0c;提供了超过50门语言的练习。作为用户&#xff0c;你仅需使用命令行工具即可下载和提交练习&#xff0c;提交后还可以和社区中其他学习者交流讨论。 Exe…

android cmake 打印_Android使用CMAKE编译libjpeg

本文主要介绍使用 CMAKE 编译 libjpeg-turbo 类库&#xff0c;本文相关代码请在GitHub-TurboJpegSample 查看。libjpeg-turbo 附GitHub 地址&#xff0c;libjpeg-turbo 是个运用极其广泛的库&#xff0c;可以说&#xff0c;基本上电脑上手机上能见到的 JPEG 压缩的地方用的一般…

设计模式(四)结构型模式

前言 结构型设计模式&#xff0c;主要研究&#xff1a; 主要有哪些场景使用结构型设计模式&#xff1b;每种场景应该使用何种设计模式&#xff1b;以程序中的功能为核心&#xff0c;研究程序功能的组织结构。所以这一章&#xff0c;我们要把“功能结构”作为研究的核心。 下…