TCP VS UDP

程序员写网络程序,主要编写的应用层代码!

真正要发这个数据,需要上层协议调用下层协议,应用层要调用传输层,则传输层给应用层提供一组api,统称为:soket api

基于UDP的api

基于TCP的api

这两个协议差别很大!!提供的api的差异也很大!!

UDP:

  • 无连接:使用UDP通信的双方,不需要可以得存对端的相关信息
  • 不可靠传输:消息发了就发了,不关注结果(投递简历)
  • 面向数据报:以一个UDP数据报为基本单位
  • 全双工:一条路径,双向通信

TCP:

  • 有链接:使用TCP通信的双方,需要刻意保存对方的相关信息
  • 可靠传输:不是说发了就100%能够到达对方,尽可能的传输过去(自己知道没成功)(打电话)
  • 面向字节流:以字节为传输的基本单位,读写方式非常灵活
  • 全双工:一条路径,双向通信

在上述所说的连接:并不是拿一根绳子,把两个设备绑一块,而是一个”抽象的连接“,可以理解成通信双方,各自记录了对方的信息;比如:民政局领结婚证!!(男女双方建立连接)!!

全双工 VS 半双工

那么,有了上述的基础知识,我们先来了解一下UDP的api吧(比TCP的要简单!)

两个重要的方法:DatagramSocket()   DatagramPacket()

DatagramPacket() :这个对象是一个UDP数据报

DatagramSocket()  :Datagram:就是数据报;Socket说明这个对象是一个socket对象

socket对象相当于对应到系统中一个特殊的文件(socket文件)

socket文件并非对应到硬盘上的某个数据存储区域,而是对应到网卡,这个硬件设备!!

要想进行网络通信,就需要有socket文件这样的对象,借助这个socket文件对象,才能够间接的操作网卡!(遥控器)

往这个socket对象中写数据,相当于通过网卡发送数据

从这个socket对象中读数据,相当于通过网卡接收数据

那么,我们来看一下DatagramSocket()  的构造方法:

  1. DatagramSocket() :创建一个UDP数据报套接字的Socket,绑定到本机任意一个随机端口(一般用于客户端)
  2. DatagramSocket(int port):创建一个UDP数据报套接字的Socket,绑定到本机指定的端口下(一般用于服务端)

    这两个构造方法中,一个带参数,一个不带参数

    服务器这边的socket往往要关联一个具体的端口号!(必须要不变)

    客户端这边则不需要手动指定,系统自动分配即可!(不要求)

  3. void  receive(DatagramPacket  p)从此套接字接收数据报(如果没有接受到数据报,该方法就会阻塞等待)
  4. void  send(DatagramPacket  p)从此套接字发送数据报(不会阻塞等待,直接发送)
  5. void  close()关闭此数据报套接字(一定是socket/文件,确定不用了,才能使用该close())

socket也是文件,文件用完了就得记得关闭,否则会出现文件资源泄露的问题!!

那么,我们来看一下DatagramPacket() 的构造方法:

  1. DatagramPacket(byte[]  buf , int length) 构造一个DatagramPacket以用来接收数据报,接收的数据保存在字节数组(第一个参数buf)中,接收指定长度(第二个参数length)
  2. DatagramPacket(byte[]  buf , int offset , int length , SocketAddress address) 构造一个DatagramPacket以用来发送数据报,发送的数据为字节数组(第一个参数buf)中,从0到指定长度(第二个参数length),address指定目的主机的IP和端口号!!
    这个版本,需要显式的设置地址进去,通常要用来发送信息!!

那么,我们来基于UDP  Socket来写一个最简单的客户端服务器程序吧!!

回显服务器(echo server):客户端发了个请求,服务器返回一个一模一样的响应!

一个服务器:主要要做三个核心工作:

  1. 读取请求并解析
  2. 根据请求计算响应(省略)
  3. 把响应返回到客户端

主要代码:

服务器(读取请求,发送响应)

package network;import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;// UDP 版本的回显服务器
public class UdpEchoServer {// 网络编程, 本质上是要操作网卡.// 但是网卡不方便直接操作. 在操作系统内核中, 使用了一种特殊的叫做 "socket" 这样的文件来抽象表示网卡.// 因此进行网络通信, 势必需要先有一个 socket 对象.private DatagramSocket socket = null;// 对于服务器来说, 创建 socket 对象的同时, 要让他绑定上一个具体的端口号.// 服务器一定要关联上一个具体的端口的!!!// 服务器是网络传输中, 被动的一方. 如果是操作系统随机分配的端口, 此时客户端就不知道这个端口是啥了, 也就无法进行通信了!!!public UdpEchoServer(int port) throws SocketException {socket = new DatagramSocket(port);}public void start() throws IOException {System.out.println("服务器启动!");// 服务器不是只给一个客户端提供服务就完了. 需要服务很多客户端.while (true) {// 只要有客户端过来, 就可以提供服务.// 1. 读取客户端发来的请求是啥.//    receive 方法的参数是一个输出型参数, 需要先构造好个空白的 DatagramPacket 对象. 交给 receive 来进行填充.DatagramPacket requestPacket = new DatagramPacket(new byte[4096], 4096);socket.receive(requestPacket);// 此时这个 DatagramPacket 是一个特殊的对象, 并不方便直接进行处理. 可以把这里包含的数据拿出来, 构造成一个字符串.String request = new String(requestPacket.getData(), 0, requestPacket.getLength());// 2. 根据请求计算响应, 由于此处是回显服务器, 响应和请求相同.String response = process(request);// 3. 把响应写回到客户端. send 的参数也是 DatagramPacket. 需要把这个 Packet 对象构造好.//    此处构造的响应对象, 不能是用空的字节数组构造了, 而是要使用响应数据来构造.DatagramPacket responsePacket = new DatagramPacket(response.getBytes(), response.getBytes().length,requestPacket.getSocketAddress());socket.send(responsePacket);// 4. 打印一下, 当前这次请求响应的处理中间结果.System.out.printf("[%s:%d] req: %s; resp: %s\n", requestPacket.getAddress().toString(),requestPacket.getPort(), request, response);}}// 这个方法就表示 "根据请求计算响应"public String process(String request) {return request;}public static void main(String[] args) throws IOException {// 端口号的指定, 大家可以随便指定.// 1024 -> 65535 这个范围里随便挑个数字就行了.UdpEchoServer server = new UdpEchoServer(9090);server.start();}
}

客户端:发请求,接收响应

package network;import java.io.IOException;
import java.net.*;
import java.util.Scanner;// UDP 版本的 回显客户端
public class UdpEchoClient {private DatagramSocket socket = null;private String serverIp = null;private int serverPort = 0;// 一次通信, 需要有两个 ip, 两个端口.// 客户端的 ip 是 127.0.0.1 已知.// 客户端的 port 是系统自动分配的.// 服务器 ip 和 端口 也需要告诉客户端. 才能顺利把消息发个服务器.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 scanner = new Scanner(System.in);while (true) {// 1. 从控制台读取要发送的数据System.out.print("> ");String request = scanner.next();if (request.equals("exit")) {System.out.println("goodbye");break;}// 2. 构造成 UDP 请求, 并发送//    构造这个 Packet 的时候, 需要把 serverIp 和 port 都传入过来. 但是此处 IP 地址需要填写的是一个 32位的整数形式.//    上述的 IP 地址是一个字符串. 需要使用 InetAddress.getByName 来进行一个转换.DatagramPacket requestPacket = new DatagramPacket(request.getBytes(), request.getBytes().length,InetAddress.getByName(serverIp), serverPort);socket.send(requestPacket);// 3. 读取服务器的 UDP 响应, 并解析DatagramPacket responsePacket = new DatagramPacket(new byte[4096], 4096);socket.receive(responsePacket);String response = new String(responsePacket.getData(), 0, responsePacket.getLength());// 4. 把解析好的结果显示出来.System.out.println(response);}}public static void main(String[] args) throws IOException {UdpEchoClient client = new UdpEchoClient("127.0.0.1", 9090);// UdpEchoClient client = new UdpEchoClient("42.192.83.143", 9090);client.start();}
}

对上述代码进行分析:

对于客户端:

  1. 服务器先启动,执行到receive进行阻塞
  2. 客户端运行之后,从控制台读取到数据,并进行send
  3. 客户端这边send之后,继续往下走,走到receive读取响应,会阻塞等待
  4. 客户端这边真正收到服务器send回来的数据之后,就会接解除阻塞,执行下面的打印操作
  5. 客户端继续进入下一轮循环,阻塞在Scanner.next这里,等待用户输入新的数据

对于服务器:

  1. 服务器先启动,执行到receive进行阻塞
  2. 客户端运行之后,从控制台读取到数据,并进行send
  3. 服务器这边,就从reserve返回,读取到请求数据(客户端发来的),往下走到process,生成响应,再往下走,到send,并且打印日志
  4. 进入下一轮循环,在此阻塞在receive,等待客户端下一个请求

小结一下瞬间开心:

客户端:

读取用户输入

构造请求并发送

客户端读取服务器响应

客户端把响应转成字符串并显示出来

服务器:

读取用户的请求

根据请求计算响应

把响应写回到客户端

因此:总的大致过程为:

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

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

相关文章

京东数据接口|电商运营中数据分析的重要性

在电商运营中,数据分析是非常重要的一环,它可以帮助电商企业更好地了解市场、了解消费者、了解产品、了解销售渠道等各种信息,从而制定更为科学有效的运营策略,提高销售效益。 数据方面用户可以直接选择使用数据接口来获取&#…

Synchronized的实现和锁升级

1.JVM是如何处理和识别Synchronized的? 我们从字节码角度分析synchronized的实现: Synchronized(锁对象){}同步代码块底层实现方式是monitorenter和monitorexit指令。 修饰普通同步方法时底层实现方式是执行指令会检查方法是否设置ACC_SYNCHRONIZED&am…

Legion Y9000X IRH8 2023款(82Y3)原装出厂OEM预装Windows11系统

lenovo联想电脑笔记本拯救者原厂win11系统镜像 下载链接:https://pan.baidu.com/s/15G01j7ROVqOFOETccQSKHg?pwdt1ju 系统自带所有驱动、出厂主题壁纸、Office办公软件、联想电脑管家等预装程序 所需要工具:32G或以上的U盘 文件格式:ISO…

Vue 3 学习 源码解读

该文章内容为以下视频的学习笔记: 前言_哔哩哔哩_bilibili前言是秋招解决方案:深入 Vue3 源码,带你彻底打通 Vue3 源码面试的第1集视频,该合集共计13集,视频收藏或关注UP主,及时了解更多相关视频内容。htt…

JVM上篇之虚拟机与java虚拟机介绍

目录 虚拟机 java虚拟机 简介 特点 作用 位置 整体结构 类装载子系统 运行时数据区 java执行引擎 Java代码执行流程 jvm架构模型 基于栈式架构 基于寄存器架构 总结 jvm的生命周期 1.启动 2.执行 3.退出 JVM的发展历程 虚拟机 所谓虚拟机,指的…

【微服务】RedisSearch 使用详解

目录 一、RedisJson介绍 1.1 RedisJson是什么 1.2 RedisJson特点 1.3 RedisJson使用场景 1.3.1 数据结构化存储 1.3.2 实时数据分析 1.3.3 事件存储和分析 1.3.4 文档存储和检索 二、当前使用中的问题 2.1 刚性数据库模式限制了敏捷性 2.2 基于磁盘的文档存储导致瓶…

数字三角形加强版题解(组合计数+快速幂+逆元)

Description 一个无限行的数字三角形,第 i 行有 i 个数。第一行的第一个数是 1 ,其他的数满足如下关系:如果用 F[i][j] 表示第 i 行的第 j 个数,那么 F[i][j]A∗F[i−1][j]B∗F[i−1][j−1] (不合法的下标的数为 0 &a…

Springboot项目log4j与logback的Jar包冲突问题

异常信息关键词: SLF4J: Class path contains multiple SLF4J bindings. ERROR in ch.qos.logback.core.joran.spi.Interpreter24:14 - no applicable action for [properties], current ElementPath is [[configuration][properties]] 详细异常信息&#xff1a…

水波纹文字效果动画

效果展示 CSS 知识点 text-shadow 属性绘制立体文字clip-path 属性来绘制水波纹 工具网站 CSS clip-path maker 效果编辑器 页面整体结构实现 使用多个 H2 标签来实现水波纹的效果实现&#xff0c;然后使用clip-path结合动画属性一起来进行波浪的起伏动画实现。 <div …

盒子模型的基础

盒子模型 边框&#xff08;border&#xff09; border可以设置元素的边框&#xff0c;边框分成三部分&#xff0c;边框的&#xff08;粗细&#xff09;边框的样式&#xff0c;边框的颜色 <style>div {width: 100px;height: 100px;border-width: 200;border-style: 边框…

应用层协议——DNS、DHCP、HTTP、FTP

目录 1、DNS 协议 1-1&#xff09;Hosts 文件 1-2&#xff09;DNS 系统 1-3&#xff09;域名的组成、分类和树状结构 1-4&#xff09;DNS 域名服务器类型 1-5&#xff09;DNS 查询方式 1-6&#xff09;DNS 域名解析的一般步骤 1-7&#xff09;对象类型与资源记录 2、D…

ELK整合springboot(第二课)

一、创建一个springboot的项目 pom文件如下&#xff1a; <?xml version"1.0" encoding"UTF-8"?> <project xmlns"http://maven.apache.org/POM/4.0.0" xmlns:xsi"http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLo…