UDP通信程序的详细解析

2.UDP通信程序

2.1 UDP发送数据

  • Java中的UDP通信

    • UDP协议是一种不可靠的网络协议，它在通信的两端各建立一个Socket对象，但是这两个Socket只是发送，接收数据的对象，因此对于基于UDP协议的通信双方而言，没有所谓的客户端和服务器的概念

    • Java提供了DatagramSocket类作为基于UDP协议的Socket

  • 构造方法

    方法名说明
    DatagramSocket()创建数据报套接字并将其绑定到本机地址上的任何可用端口
    DatagramPacket(byte[] buf,int len,InetAddress add,int port)创建数据包,发送长度为len的数据包到指定主机的指定端口

  • 相关方法

    方法名说明
    void send(DatagramPacket p)发送数据报包
    void close()关闭数据报套接字
    void receive(DatagramPacket p)从此套接字接受数据报包

  • 发送数据的步骤

    • 创建发送端的Socket对象(DatagramSocket)

    • 创建数据，并把数据打包

    • 调用DatagramSocket对象的方法发送数据

    • 关闭发送端

  • 代码演示

    public class SendDemo {public static void main(String[] args) throws IOException {//创建发送端的Socket对象(DatagramSocket)// DatagramSocket() 构造数据报套接字并将其绑定到本地主机上的任何可用端口DatagramSocket ds = new DatagramSocket();
​//创建数据，并把数据打包//DatagramPacket(byte[] buf, int length, InetAddress address, int port)//构造一个数据包，发送长度为 length的数据包到指定主机上的指定端口号。byte[] bys = "hello,udp,我来了".getBytes();
​DatagramPacket dp = new DatagramPacket(bys,bys.length,InetAddress.getByName("127.0.0.1"),10086);
​//调用DatagramSocket对象的方法发送数据//void send(DatagramPacket p) 从此套接字发送数据报包ds.send(dp);
​//关闭发送端//void close() 关闭此数据报套接字ds.close();}
}

2.2UDP接收数据

  • 接收数据的步骤

    • 创建接收端的Socket对象(DatagramSocket)

    • 创建一个数据包，用于接收数据

    • 调用DatagramSocket对象的方法接收数据

    • 解析数据包，并把数据在控制台显示

    • 关闭接收端

  • 构造方法

    方法名说明
    DatagramPacket(byte[] buf, int len)创建一个DatagramPacket用于接收长度为len的数据包

  • 相关方法

    方法名说明
    byte[] getData()返回数据缓冲区
    int getLength()返回要发送的数据的长度或接收的数据的长度

  • 示例代码

    public class ReceiveDemo {public static void main(String[] args) throws IOException {//创建接收端的Socket对象(DatagramSocket)DatagramSocket ds = new DatagramSocket(12345);
​//创建一个数据包，用于接收数据byte[] bys = new byte[1024];DatagramPacket dp = new DatagramPacket(bys, bys.length);
​//调用DatagramSocket对象的方法接收数据ds.receive(dp);
​//解析数据包，并把数据在控制台显示System.out.println("数据是：" + new String(dp.getData(), 0,                                             dp.getLength()));}}
}

2.3UDP通信程序练习

  • 案例需求

    UDP发送数据：数据来自于键盘录入，直到输入的数据是886，发送数据结束

    UDP接收数据：因为接收端不知道发送端什么时候停止发送，故采用死循环接收

  • 代码实现

    /*UDP发送数据：数据来自于键盘录入，直到输入的数据是886，发送数据结束*/
public class SendDemo {public static void main(String[] args) throws IOException {//创建发送端的Socket对象(DatagramSocket)DatagramSocket ds = new DatagramSocket();//键盘录入数据Scanner sc = new Scanner(System.in);while (true) {String s = sc.nextLine();//输入的数据是886，发送数据结束if ("886".equals(s)) {break;}//创建数据，并把数据打包byte[] bys = s.getBytes();DatagramPacket dp = new DatagramPacket(bys, bys.length, InetAddress.getByName("192.168.1.66"), 12345);
​//调用DatagramSocket对象的方法发送数据ds.send(dp);}//关闭发送端ds.close();}
}
​
/*UDP接收数据：因为接收端不知道发送端什么时候停止发送，故采用死循环接收*/
public class ReceiveDemo {public static void main(String[] args) throws IOException {//创建接收端的Socket对象(DatagramSocket)DatagramSocket ds = new DatagramSocket(12345);while (true) {//创建一个数据包，用于接收数据byte[] bys = new byte[1024];DatagramPacket dp = new DatagramPacket(bys, bys.length);//调用DatagramSocket对象的方法接收数据ds.receive(dp);//解析数据包，并把数据在控制台显示System.out.println("数据是：" + new String(dp.getData(), 0, dp.getLength()));}//关闭接收端
//        ds.close();}
}

2.4UDP三种通讯方式

  • 单播

    单播用于两个主机之间的端对端通信

  • 组播

    组播用于对一组特定的主机进行通信

  • 广播

    广播用于一个主机对整个局域网上所有主机上的数据通信

2.5UDP组播实现

  • 实现步骤

    • 发送端

      1. 创建发送端的Socket对象(DatagramSocket)

      2. 创建数据，并把数据打包(DatagramPacket)

      3. 调用DatagramSocket对象的方法发送数据(在单播中,这里是发给指定IP的电脑但是在组播当中,这里是发给组播地址)

      4. 释放资源

    • 接收端

      1. 创建接收端Socket对象(MulticastSocket)

      2. 创建一个箱子,用于接收数据

      3. 把当前计算机绑定一个组播地址

      4. 将数据接收到箱子中

      5. 解析数据包,并打印数据

      6. 释放资源

  • 代码实现

    // 发送端
public class ClinetDemo {public static void main(String[] args) throws IOException {// 1. 创建发送端的Socket对象(DatagramSocket)DatagramSocket ds = new DatagramSocket();String s = "hello 组播";byte[] bytes = s.getBytes();InetAddress address = InetAddress.getByName("224.0.1.0");int port = 10000;// 2. 创建数据，并把数据打包(DatagramPacket)DatagramPacket dp = new DatagramPacket(bytes,bytes.length,address,port);// 3. 调用DatagramSocket对象的方法发送数据(在单播中,这里是发给指定IP的电脑但是在组播当中,这里是发给组播地址)ds.send(dp);// 4. 释放资源ds.close();}
}
// 接收端
public class ServerDemo {public static void main(String[] args) throws IOException {// 1. 创建接收端Socket对象(MulticastSocket)MulticastSocket ms = new MulticastSocket(10000);// 2. 创建一个箱子,用于接收数据DatagramPacket dp = new DatagramPacket(new byte[1024],1024);// 3. 把当前计算机绑定一个组播地址,表示添加到这一组中.ms.joinGroup(InetAddress.getByName("224.0.1.0"));// 4. 将数据接收到箱子中ms.receive(dp);// 5. 解析数据包,并打印数据byte[] data = dp.getData();int length = dp.getLength();System.out.println(new String(data,0,length));// 6. 释放资源ms.close();}
}

2.6UDP广播实现

  • 实现步骤

    • 发送端

      1. 创建发送端Socket对象(DatagramSocket)

      2. 创建存储数据的箱子,将广播地址封装进去

      3. 发送数据

      4. 释放资源

    • 接收端

      1. 创建接收端的Socket对象(DatagramSocket)

      2. 创建一个数据包，用于接收数据

      3. 调用DatagramSocket对象的方法接收数据

      4. 解析数据包，并把数据在控制台显示

      5. 关闭接收端

  • 代码实现

    // 发送端
public class ClientDemo {public static void main(String[] args) throws IOException {// 1. 创建发送端Socket对象(DatagramSocket)DatagramSocket ds = new DatagramSocket();// 2. 创建存储数据的箱子,将广播地址封装进去String s = "广播 hello";byte[] bytes = s.getBytes();InetAddress address = InetAddress.getByName("255.255.255.255");int port = 10000;DatagramPacket dp = new DatagramPacket(bytes,bytes.length,address,port);// 3. 发送数据ds.send(dp);// 4. 释放资源ds.close();}
}
​
// 接收端
public class ServerDemo {public static void main(String[] args) throws IOException {// 1. 创建接收端的Socket对象(DatagramSocket)DatagramSocket ds = new DatagramSocket(10000);// 2. 创建一个数据包，用于接收数据DatagramPacket dp = new DatagramPacket(new byte[1024],1024);// 3. 调用DatagramSocket对象的方法接收数据ds.receive(dp);// 4. 解析数据包，并把数据在控制台显示byte[] data = dp.getData();int length = dp.getLength();System.out.println(new String(data,0,length));// 5. 关闭接收端ds.close();}
}

##3. TCP通信程序

3.1TCP发送数据

  • Java中的TCP通信

    • Java对基于TCP协议的的网络提供了良好的封装，使用Socket对象来代表两端的通信端口，并通过Socket产生IO流来进行网络通信。

    • Java为客户端提供了Socket类，为服务器端提供了ServerSocket类

  • 构造方法

    方法名说明
    Socket(InetAddress address,int port)创建流套接字并将其连接到指定IP指定端口号
    Socket(String host, int port)创建流套接字并将其连接到指定主机上的指定端口号

  • 相关方法

    方法名说明
    InputStream getInputStream()返回此套接字的输入流
    OutputStream getOutputStream()返回此套接字的输出流

  • 示例代码

    public class Client {public static void main(String[] args) throws IOException {//TCP协议，发送数据
​//1.创建Socket对象//细节：在创建对象的同时会连接服务端//      如果连接不上，代码会报错Socket socket = new Socket("127.0.0.1",10000);
​//2.可以从连接通道中获取输出流OutputStream os = socket.getOutputStream();//写出数据os.write("aaa".getBytes());
​//3.释放资源os.close();socket.close();}
}

3.2TCP接收数据

  • 构造方法

    方法名说明
    ServletSocket(int port)创建绑定到指定端口的服务器套接字

  • 相关方法

    方法名说明
    Socket accept()监听要连接到此的套接字并接受它

  • 注意事项

    1. accept方法是阻塞的,作用就是等待客户端连接

    2. 客户端创建对象并连接服务器,此时是通过三次握手协议,保证跟服务器之间的连接

    3. 针对客户端来讲,是往外写的,所以是输出流 针对服务器来讲,是往里读的,所以是输入流

    4. read方法也是阻塞的

    5. 客户端在关流的时候,还多了一个往服务器写结束标记的动作

    6. 最后一步断开连接,通过四次挥手协议保证连接终止

  • 三次握手和四次挥手

    • 三次握手

    • 四次挥手

  • 示例代码

    public class Server {public static void main(String[] args) throws IOException {//TCP协议，接收数据
​//1.创建对象ServerSockerServerSocket ss = new ServerSocket(10000);
​//2.监听客户端的链接Socket socket = ss.accept();
​//3.从连接通道中获取输入流读取数据InputStream is = socket.getInputStream();int b;while ((b = is.read()) != -1){System.out.println((char) b);}
​//4.释放资源socket.close();ss.close();}
}

3.3TCP程序练习（传输中文）

发送端：

public class Client {public static void main(String[] args) throws IOException {//TCP协议，发送数据
​//1.创建Socket对象//细节：在创建对象的同时会连接服务端//      如果连接不上，代码会报错Socket socket = new Socket("127.0.0.1",10000);
​
​//2.可以从连接通道中获取输出流OutputStream os = socket.getOutputStream();//写出数据os.write("你好你好".getBytes());//12字节
​//3.释放资源os.close();socket.close();
​}
}
​

接收端：

public class Server {public static void main(String[] args) throws IOException {//TCP协议，接收数据
​//1.创建对象ServerSockerServerSocket ss = new ServerSocket(10000);
​//2.监听客户端的链接Socket socket = ss.accept();
​//3.从连接通道中获取输入流读取数据InputStream is = socket.getInputStream();InputStreamReader isr = new InputStreamReader(is);BufferedReader br = new BufferedReader(isr);
​// BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
​int b;while ((b = br.read()) != -1){System.out.print((char) b);}
​//4.释放资源socket.close();ss.close();
​}
}

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

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

相关文章

JMeter学习第一、二、三天

JMeter学习第一、二、三天

首先，我们来了解一下到底什么是接口测试与性能测试： 接口测试 定义 接口测试主要关注系统组件之间的交互，确保各个接口按预期工作。这包括验证传递的数据、数据格式、调用的频率和其他与接口调用相关的任何限制。 目的 确保系统的各个组件可…
阅读更多...
Qt中 QMap 类、QHash 类、QVector 类详解

Qt中 QMap 类、QHash 类、QVector 类详解

目录 一、QMap 类 1.插入数据信息 2.删除数据信息 3.迭代器 4.STL类型迭代 5.key键/T键查找 6.修改键值 7. 一个键对应多个值 直接使用QMultiMap类来实例化一个QMap对象 二、QHash 类 三、QVector类 一、QMap 类 QMap<Key,T>提供一个从类型为 Key 的键到类型为…
阅读更多...
解决WPF+Avalonia在openKylin系统下默认字体问题

解决WPF+Avalonia在openKylin系统下默认字体问题

一、openKylin简介 openKylin&#xff08;开放麒麟&#xff09; 社区是在开源、自愿、平等和协作的基础上&#xff0c;由基础软硬件企业、非营利性组织、社团组织、高等院校、科研机构和个人开发者共同创立的一个开源社区&#xff0c;致力于通过开源、开放的社区合作&#xff…
阅读更多...
【MySQL】索引特性

【MySQL】索引特性

目录 MySQL索引特性 索引的概念 认识磁盘 磁盘的结构 磁盘的随机访问&#xff08;Random Access&#xff09;与连续访问&#xff08;Sequential Access&#xff09; MySQL与磁盘交互的基本单位 索引的理解 观察主键索引现象 推导主键索引结构的构建 索引结构可以采用…
阅读更多...
IPSG技术和IP组播

IPSG技术和IP组播

1&#xff0c;IPSG技术概述 实验&#xff1a; DHCP snooping IPSG 拓扑&#xff1a; 需求&#xff1a; 1&#xff0c;实现PC1 和PC2 动态获取IP地址 2, 在SW2 配置DHCP snooping 实现DHCP 服务器的安全 3, 在 连接PC 1 和 PC2 的 接口上 做IPSG &#xff0c;防止终端…
阅读更多...
贪心算法+练习

贪心算法+练习

正值国庆之际&#xff0c;祝愿祖国繁荣昌盛&#xff0c;祝愿朋友一生平安&#xff01;终身学习&#xff0c;奋斗不息&#xff01; 目录 1.贪心算法简介 2.贪心算法的特点 3.如何学习贪心算法 题目练习&#xff08;持续更新&#xff09; 1.柠檬水找零&#xff08;easy&…
阅读更多...
​苹果应用高版本出现：“无法安装此app，因为无法验证其完整性”是怎么回事?竟然是错误的?

​苹果应用高版本出现：“无法安装此app，因为无法验证其完整性”是怎么回事?竟然是错误的?

最近经常有同学私聊我问苹果应用签名后用落地页下载出现高版本是什么意思&#xff1f;我一脸懵&#xff01;还有这个操作&#xff1f;高版本是个啥玩意&#xff01;所以我就上了一下科技去搜索引擎搜索了下&#xff0c;哈哈哈&#xff0c;然后了解下来发现是这样的首先我们确定…
阅读更多...
Kubernetes安装部署 1

Kubernetes安装部署 1

本文主要描述kubernetes的安装部署&#xff0c;kubernetes的安装部署主要包括三个关键组件&#xff0c;其中&#xff0c;包括kubeadm、kubelet、kubectl&#xff0c;这三个组件的功能描述如下所示&#xff1a; Kubeadm 用于启动与管理kubernetes集群 Kubelet 运行在所有集群的…
阅读更多...
Mac版快速切换工具：One Switch中文 for mac

Mac版快速切换工具：One Switch中文 for mac

One Switch是一款功能强大、体验极简的Mac菜单栏工具&#xff0c;适合需要频繁切换系统设置和启动应用程序的用户使用。通过它&#xff0c;用户可以更方便地完成日常操作&#xff0c;提高工作效率。 快速访问工具&#xff1a;One Switch提供了一个便捷的菜单栏图标&#xff0c;…
阅读更多...
nodejs+vue晨拾酒馆管理系统elementui

nodejs+vue晨拾酒馆管理系统elementui

晨拾酒馆管理系统&#xff0c;主要的模块包括管理员&#xff1b;系统首页、个人中心、用户管理、图书分类管理、图书信息管理、图书借阅管理、图书归还管理、图书入库管理、热门图书管理、论坛管理、系统管理&#xff0c;用户&#xff1b;系统首页、个人中心、图书借阅管理、图…
阅读更多...
数据科学最佳实践：Kedro 的工程化解决方案 | 开源日报 No.47

数据科学最佳实践：Kedro 的工程化解决方案 | 开源日报 No.47

leonardomso/33-js-concepts Stars: 58.4k License: MIT 这个项目是一个帮助开发者掌握 JavaScript 概念的资源库。该项目基于 Stephen Curtis 撰写的一篇文章&#xff0c;包含了对 33 个重要 JavaScript 概念全面深入地讲解&#xff0c;并被 GitHub 评为 2018 年最佳开源项目…
阅读更多...
【二】spring boot-设计思想

【二】spring boot-设计思想

spring boot-设计思想 简介&#xff1a;现在越来越多的人开始分析spring boot源码&#xff0c;拿到项目之后就有点无从下手了&#xff0c;这里介绍一下springboot源码的项目结构 一、项目结构 从上图可以看到&#xff0c;源码分为两个模块&#xff1a; spring-boot-project&a…
阅读更多...
linux虚拟机查看防火墙状态

linux虚拟机查看防火墙状态

linux虚拟机查看防火墙状态 在Linux虚拟机中&#xff0c;你可以通过以下几种方法查看防火墙状态&#xff1a; 查看iptables防火墙状态 对于使用iptables防火墙的Linux系统&#xff0c;可以使用以下命令查看防火墙状态&#xff1a; sudo iptables -L -v -n查看firewalld防火墙…
阅读更多...
c++---模板篇

c++---模板篇

1、模板 概念&#xff1a;模板就是建立通用的模具&#xff0c;大大提高复用性 特点&#xff1a; 模板不可以直接使用&#xff0c;它只是一个框架模板的通用并不是万能的 1.1、函数模板 C另一种编程思想称为泛型编程&#xff0c;主要利用的技术就是模板C提供两种模板机制&a…
阅读更多...
3D孪生场景SDK：Viwer 孪生世界

3D孪生场景SDK：Viwer 孪生世界

NSDT 编辑器 提供三维场景构建、场景效果设计、场景服务发布全流程工具等&#xff0c;其场景编辑器支持资产管理、灯光设置、骨骼动画等功能&#xff1b;致力于协助资源不足的中小企业及个人快速开发数字孪生场景&#xff0c;帮助企业提高生产力、实现降本增效。 NSDT编辑器简…
阅读更多...
MySQL之主从复制

MySQL之主从复制

概述&#xff1a; 将主库的数据 变更同步到从库&#xff0c;从而保证主库和从库数据一致。 它的作用是 数据备份&#xff0c;失败迁移&#xff0c;读写分离&#xff0c;降低单库读写压力 原理&#xff1a; 主服务器上面的任何修改都会保存在二进制日志&#xff08; Bin-log日志…
阅读更多...
【Overload游戏引擎分析】画场景网格的Shader

【Overload游戏引擎分析】画场景网格的Shader

Overload引擎地址&#xff1a; GitHub - adriengivry/Overload: 3D Game engine with editor 一、栅格绘制基本原理 Overload Editor启动之后&#xff0c;场景视图中有栅格线&#xff0c;这个在很多软件中都有。刚开始我猜测它应该是通过绘制线实现的。阅读代码发现&#xff0…
阅读更多...
【Pytorch笔记】6.Transforms

【Pytorch笔记】6.Transforms

pytorch官方文档 - transforms transforms需要使用计算机视觉工具包&#xff1a;torchvision。 torchvision.transforms&#xff1a;常用的图像预处理方法&#xff1b; torchvision.datasets&#xff1a;常用数据集的dataset实现&#xff0c;如MNIST、CIFAR-10、ImageNet等&am…
阅读更多...
[每日算法 - 阿里机试] leetcode19. 删除链表的倒数第 N 个结点

[每日算法 - 阿里机试] leetcode19. 删除链表的倒数第 N 个结点

入口 力扣&#xff08;LeetCode&#xff09;官网 - 全球极客挚爱的技术成长平台备战技术面试&#xff1f;力扣提供海量技术面试资源&#xff0c;帮助你高效提升编程技能&#xff0c;轻松拿下世界 IT 名企 Dream Offer。https://leetcode.cn/problems/remove-nth-node-from-end…
阅读更多...
java项目log4j2单独为某个类配置日志文件

java项目log4j2单独为某个类配置日志文件

在项目中&#xff0c;一般都是把日志记录到一个日志文件中。 对应的log4j2.xml内容如下图所示&#xff1a;只有一个RollingFile节点&#xff0c;整个系统只会生成一个log日志文件。 生成的日志文件如下图&#xff1a; 当系统不断扩大&#xff0c;业务越来越复杂&#xff0c;所…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023