Socket、UDP、TCP协议和简单实现基于UDP的客户端服务端

目录

Socket

TCP和UDP区别

UDP:无连接,不可靠传输,面向数据报,全双工

TCP:有连接,可靠传输,面向字节流,全双工

无连接和有连接

可靠传输和不可靠传输 

面向数据报和面向字节流 

全双工和半双工

Java中对于传输层的一些API 

DatagramSocket 

DatagramSocket构造方法 

send()和receive()方法

close()方法 

DatagramPacket 

 DatagramPacket构造方法

实现一个UDP客户端-服务端的代码 

明确服务端做的事

UDP服务端代码编写 

明确客户端做的事 

UDP客户端代码编写 

通信结果: 

为什么客户端不需要指定一个特定的端口号呢? 


Socket

我们都知道用户在进行网络通信的时候,应用层会将报文发送给传输层,发送的这个过程,应用层需要调用操作系统的一些api,准确来说就是调用传输层的api,应用层和传输层之间沟通调用的api就是Socket。严格意义上讲,socket的api属于传输层。

TCP和UDP就是Socke的apit提供的两种不同的风格。

TCP和UDP区别

UDP:无连接,不可靠传输,面向数据报,全双工

TCP:有连接,可靠传输,面向字节流,全双工

无连接和有连接

无连接:不确保接收方是否接收到信息。比如发短信,发微信都是无连接通信,不需要对方在线什么的就能直接把要传递的信息发送出去

有连接:确保接收方会收到信息 。比如打电话,打视频,需要对方接起才能让双方进行信息的传递

原因:UDP协议当中发送方和接收方的运输层进程之间没有建立握手,只负责把应用层的报文打包成UDP报文段进行发送,不关注接收方是否能收到,所以UDP协议是无连接的。而TCP协议在传输数据之前会进行“三次握手”来确保接收方是能够收到信息的,所以TCP协议是有连接的

可靠传输和不可靠传输 

可靠传输就是发送方发送完信息后,接收方如果收到了信息,发送方可以知晓接收方已经收到了信息,比如有些聊天的已读功能

不可靠传输就是发送方发送完信息后,不知道接收方是否收到了信息,比如微信聊天,发送方并不知道接收方是否接受到信息。

面向数据报和面向字节流 

UDP协议就是面向数据报的协议。

传输层协议是以数据报为基本单位进行传输的,操作系统不会对消息进行拆分,也就是直接把应用层传过来的报文打包为UDP数据段,然后传输到网络层 

而TCP协议是面向字节流的协议。

TCP把数据看成一个没有结构的,但是有序的字节流。

当使用TCP协议进行传输的时候,一条应用层消息可能会被操作系统分成多个TCP报文。也就是说应用层发送过来的报文会被拆分成多个数据段,比如:|

应用层打算发送Hello This is Java,使用TCP协议就有可能拆分成两个TCP段:

也有可能只有一个TCP段。

而对于UDP协议是不会拆分的:

全双工和半双工

全双工:一个通信通道可以双向传输(既可以发送,又可以接收) 比如很多道路都是可以双向通行的

半双工:通信通道只能单向传输(只能发送或接收) 比如青藏铁路这样的,只能单向通行。

Java中对于传输层的一些API 

DatagramSocket 

在操作系统中一切皆为文件。

使用DatagramSocket这个类,可以创建socket对象,操作系统中把这个socket当做一个文件来处理,相当于文件描述符表上的某一项。 

使用一个socket对象就可以和另外一个主机进行通信了,如果要和多个主机进行通信,可以创建多个socket对象。 

DatagramSocket构造方法 

DatagramSocket()   系统自动分配一个空闲的端口号

DatagramSocket(int port)   指定端口号,将socket和对应的端口相关联。

send()和receive()方法

void send(DatagramPacket packet)  代表socket发送应用层报文的方式
void receive(DatagramPacket packet) 代表socket接收应用层报文的方式

需要发送/接收的DatagramPackett就是一个应用层报文。 

close()方法 

用于关闭文件描述符表项,释放进程当中的文件描述符表项所占用的空间。

DatagramPacket 

表示的是UDP当中传输的一个应用层报文 

 DatagramPacket构造方法

DatagramPacket(byte[] buf,int length)把buf数组作为地址
DatagramPacket(byte[] buf,int offset,int length,SocketAddress)把buf数组作为地址,并且指定了需要传输的目标主机IP和端口号

实现一个UDP客户端-服务端的代码 

假设约定:客户端是运行在用户手中的,服务器是运行在我们程序员自己的电脑 。

明确服务端做的事

1、读取客户端的请求

2、根据请求计算响应

3、将响应返回给客户端 

需要指定的属性:DatagramSocket socket(socket对象) 用来为客户端提供socket来接收应用层报文

构造方法当中初始化socket对象,并且指定本机当中需要建立通信的端口号。 

 注意:应用层和传输层建立连接的时候一定要指明socket端口号,不然就会导致选用无参构造方法,无法明确UDP和应用层的哪个端口建立联系,从而无法通信。 

UDP服务端代码编写 

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketAddress;
import java.net.SocketException;public class UdpEchoServer2 {//与服务端建立联系的socketprivate DatagramSocket datagramSocket;//使用构造方法并传入端口(关联端口)public UdpEchoServer2(int port) throws SocketException {//创建对象datagramSocket=new DatagramSocket(port);//port是服务端进程端口号}//创建start方法作为服务器启动public void start() throws IOException {System.out.println("服务器启动!");while(true){//1、packet存放接收应用层内容DatagramPacket receivePacket=new DatagramPacket(new byte[4096],4096);//2、使用socket来接收应用层信息并将其存放在packet的byte数组中datagramSocket.receive(receivePacket);//3、截取byte数组中应用层信息的实际长度的内容,比如hello就截取hello长度的内容//也就是获取数据报的实际长度部分String request = new String(receivePacket.getData(),0,receivePacket.getLength());//4、模拟回显服务器,将提取出来的数据报传给process进行处理并把响应赋值给responseString response= process(request);//5、将响应字符串转化为字节数组byte[] responseByte=response.getBytes();//6、获取响应数组长度int responseByteLength= responseByte.length;//7、获取对应的客户端的IP和端口号(SocketAddress)根据packet的信息获取对应的地址SocketAddress address = receivePacket.getSocketAddress();//8、构造返回给客户端的socket对象DatagramPacket responsePacket=new DatagramPacket(responseByte,responseByteLength,address);//9、使用构造的socket对象将响应发送给客户端datagramSocket.send(responsePacket);//输出处理结果作为验证System.out.println("客户端IP:"+receivePacket.getAddress()+"客户端端口号:"+receivePacket.getPort());}}//服务器响应public String process(String request){return "udp服务器已响应"+request;}//服务端启动public static void main(String[] args) throws IOException {UdpEchoServer2 udpEchoServer2=new UdpEchoServer2(9090);udpEchoServer2.start();}}

启动服务端:(指定服务器端口号为9090)此时启动后服务器正常启动,但是由于客户端没有向服务端发送任何请求,所以服务端会在receive方法出进行阻塞等待。

    public static void main(String[] args) throws IOException {UdpEchoServer2 udpEchoServer2=new UdpEchoServer2(9090);udpEchoServer2.start();}

  

明确客户端做的事 

客户端主要做的事就是和服务端建立通信,并且为服务端的receive方法内部的数据(DatagramPacket)等待服务端的send方法发送数据(DatagramPacket)回来并做出响应

UDP客户端代码编写 

import java.io.IOException;
import java.net.*;
import java.util.Scanner;public class UdpEchoClient {/*** 客户端需要有的属性:* 1、和服务端建立联系的socket* 2、服务端的ip地址* 3、服务端的端口号*/private DatagramSocket socket;//和服务端建立联系的socketprivate String serverIp;//服务端的ip地址(目的IP)private int serverPort;//服务端的端口号(目的端口)//构造方法public UdpEchoClient(String serverIp,int serverPort) throws SocketException {socket=new DatagramSocket();this.serverIp=serverIp;this.serverPort=serverPort;}//启动客户端public void start() throws IOException {System.out.println("客户端已启动!");Scanner input=new Scanner(System.in);while(true){//1.用户从控制台输入想要发送给服务端的数据System.out.println("请输入您想要发送给服务端的数据:");String request= input.next();//2、构造Udp请求//将请求转为请求数组byte[] requestBytes=request.getBytes();//获取请求数组的长度int length= requestBytes.length;//3、指定服务端的ip和端口号DatagramPacket requestPacket=new DatagramPacket(requestBytes,length,InetAddress.getByName(serverIp),serverPort);//4、将请求发送到服务端的receive方法中socket.send(requestPacket);//5、读取并接收服务端的响应结果DatagramPacket responsePacket=new DatagramPacket(new byte[4096],4096);//存放读取的结果//接收服务端的响应socket.receive(responsePacket);//6、构造响应的字符串String response=new String(responsePacket.getData(),0,responsePacket.getLength());//7、输出响应的字符串System.out.println(response);}}public static void main(String[] args) throws IOException {UdpEchoClient udpEchoClient=new UdpEchoClient("127.0.0.1",9090);udpEchoClient.start();//客户端启动}}

先启动服务端,再启动客户端,否则无法顺利完成通信。

通信结果: 

 

客户端和服务端通信的流程图解:

 

为什么客户端不需要指定一个特定的端口号呢? 

首先,客户端指定特定的端口号,如果该端口号被占用,那么就无法取得和服务端的通信了,会抛出BindException异常。其次,客户端是不可控的,因为客户端往往是有很多台的,不同客户端的程序运行情况我们是不知道的,无法有效的进行控制,这些不受到我们程序员的控制,所以不如让客户端自由分配一个可以使用的端口号即可,而服务端是可控的,程序员可以手动的控制服务端的端口占用情况是非常方便的,如果是随机分配的反而会提高程序员的工作难度。 

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

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

相关文章

学习或从事鸿蒙开发工作,有学历要求吗?

目前安卓有2,000万的开发者。本科及以上学历占比为35%;iOS有2,400万开发者,本科及以上学历占比为40% 绝大多数的前端开发者都是大专及以下学历,在2023年华为开发者大会上余承东透露华为的开发者目前有200万,但鸿蒙开发者统计的数据…

C#,数组数据波形排序(Sort in Wave Form)的朴素算法与源代码

1 波形排序 所谓“波形排序”就是一大一小。 将n个身高互不相同的人排成一行 ,对于每个人 ,要求他要么比相邻的人均高 ,要么比相邻的人均矮 ,问共有多少种排法 ,这一问题称为波形排列问题。 2 源程序 using System; using System.Collections; using System.Collections.Gen…

[嵌入式系统-33]:RT-Thread -18- 新手指南:三种不同的版本、三阶段学习路径

目录 前言:学习路径:入门学习-》进阶段学习》应用开发 一、RT-Thread版本 1.1 标准版 1.2 Nano 1.3 Smart版本 1.4 初学者制定学习路线 1.5 RT-Thread在线文档中心目录结构 1.6 学习和使用RT-Thread的三种场景 二、入门学习阶段:内…

信息系统项目管理师论文分享(质量管理)

水一篇文章。我发现身边考高项的朋友很多都是论文没过,我想着那就把我的论文分享出来,希望能有帮助。 质量管理 摘要 2020年5月,我作为项目经理参加了“某市某医联体的互联网诊疗(互联网医院和远程医疗)平台”的建设…

编程的基础:理解时间和空间复杂度

编程的基础:理解时间和空间复杂度 时间复杂度空间复杂度示例常数时间复杂度 O(1)线性时间复杂度 O(n)线性对数时间复杂度 O(n log n)二次时间复杂度 O(n^2)指数时间复杂度 O(2^n) 空间复杂度示例常数空间复杂度 O(1)线性空间复杂度 O(n)线性对数空间复杂度 O(log n)…

apache 模式、优化、功能 与 nginx优化、应用

一、I/O模型——Input/Output模型 1.同步/异步 A程序需要调用B程序的某一个功能,A发送一个请求需要B完成一个任务 同步:B不会主动去通知A是否完成需要A自己去问 异步:B会主动通知A是否完成 2.阻塞/非阻塞 A发送一个请求需要B完成一个任务 …

Vision Mamba:使用双向状态空间模型进行高效视觉表示学习

模型效果 将DeiT和Vim模型之间的性能和效率比较,为了进行准确性比较,我们首先在IN1K分类数据集上预训练DeiT和Vim,然后在不同的下游密集预测任务上微调通用主干,即,语义分割、目标检测、实例分割。结果表明&#xff0c…

Maven 私服 Nexus3

一、Maven和Nexus3 简介 Maven是一个采用纯Java编写的开源项目管理工具,采用一种被称之为Project Object Model(POM)概念来管理项目,所有的项目配置信息都被定义在一个叫做POM.xml的文件中, 通过该文件Maven可以管理项目的整个生命周期,包括…

2024年危险化学品经营单位主要负责人证考试题库及危险化学品经营单位主要负责人试题解析

题库来源:安全生产模拟考试一点通公众号小程序 2024年危险化学品经营单位主要负责人证考试题库及危险化学品经营单位主要负责人试题解析是安全生产模拟考试一点通结合(安监局)特种作业人员操作证考试大纲和(质检局)特…

Ubuntu22.04和Windows10双系统安装

概要 本篇演示Ubuntu22.04和Windows10双系统的安装。先安装Ubuntu22.04,再安装Windows10。 一、说明 1、电脑 笔者的电脑品牌是acer(宏碁/宏基) 电脑开机按F2进入BIOS 电脑开机按F12进入Boot Manager 2、U盘启动盘 需要用到两个U盘启动盘 (1&a…

市场复盘总结 20240223

仅用于记录当天的市场情况,用于统计交易策略的适用情况,以便程序回测 短线核心:不参与任何级别的调整,采用龙空龙模式 一支股票 10%的时候可以操作, 90%的时间适合空仓等待 二进三: 进级率中 57% 最常用的…

牛客周赛 Round 33 解题报告 | 珂学家 | 思维场

前言 整体评价 感觉这场更偏思维,F题毫无思路,但是可以模拟骗点分, E题是dij最短路. A. 小红的单词整理 类型: 签到 w1,w2 input().split() print (w2) print (w1)B. 小红煮汤圆 思路: 模拟 可以从拆包的角度去构建模拟 注意拆一包,可以…

vmware安装centos 7.9 操作系统

vmware安装centos 7.6 操作系统 1、下载centos 7.9 操作系统镜像文件2、安装centos 7.9 操作系统3、配置centos 7.6 操作系统3.1、配置静态IP地址 和 dns3.2、查看磁盘分区3.3、查看系统版本 1、下载centos 7.9 操作系统镜像文件 本文选择centos 7.9 最小化安装镜像包 这里选…

Nest创建神经元,并显示电压变化曲线

nest 安装与介绍 NEST(神经模拟工具)最初是在 1990 年代后期开发的。它的主要目标是作为计算神经科学模拟器。它支持具有不同生物学细节水平的各种神经元和突触模型。例如,NEST 的神经元模型范围从泄漏积分和激发模型到详细的 Hodgkin-Huxle…

python jupyter notebook打开页面方便使用

如果没安装jupyter, 请安装: pip install jupyter notebook 运行jupyter notebook jupyter-notebook

03|Order by与Group by优化

索引顺序依次是 : name,age,position 案例1 EXPLAIN SELECT * FROM employees WHERE name LiLei AND position dev ORDER BY age;分析: 联合索引中只是用到了name字段做等值查询[通过key_len 74可以看出因为name字段的len74],在这个基础上使用了age进…

学会字符转换

字符转换 题目描述:解法思路:解法代码:运行结果: 题目描述: 输入⼀一个字符串,将字符串中大写字母全部转为小写字母,小写字母转成大写字母,其他字符保持不变。注:字符串…

pthread_cond_timedwait()函数

绝对时间:相对于1970年1月1日0时0分0秒 相对时间:相对于当前时间,如sleep(3);相对于当前,过3s.

1110. 删点成林

1110. 删点成林 关键要点 通过O(1)时间复杂度确认节点是否需要删除 Set to_deleteSet new HashSet<>(); Arrays.stream(to_delete).forEach(to_deleteSet::add); 使用深度优先搜索&#xff08;DFS&#xff09;遍历树 node.left dfs(node.left, s, ans); node.right …

组态软件在物联网中的应用

随着物联网的快速发展&#xff0c;组态软件在物联网中的应用也越来越广泛。组态软件是一种用于创建和管理物联网系统的可视化工具&#xff0c;它能够将传感器、设备和网络连接起来&#xff0c;实现数据的采集、分析和可视化。本文将探讨组态软件在物联网中的应用&#xff0c;并…