漯河 做网站,湖南响应式网站推荐,网易企业邮箱收不到邮件怎么回事,做系统去哪个网站文章目录 UDP 和 TCP 之间的差别有连接/无连接可靠传输/不可靠传输面向字节流/面向数据报全双工/半双工 UDP/TCP API 的使用UDP APIDatagramSocket构造方法方法 DatagramPacket构造方法方法 回显服务器#xff08;Echo Server#xff09;1. 接收请求2. 根据请求计算响应3. 将… 文章目录 UDP 和 TCP 之间的差别有连接/无连接可靠传输/不可靠传输面向字节流/面向数据报全双工/半双工 UDP/TCP API 的使用UDP APIDatagramSocket构造方法方法 DatagramPacket构造方法方法 回显服务器Echo Server1. 接收请求2. 根据请求计算响应3. 将响应写回客户端完整代码 学习多线程打破了以往对于程序的认知 学习网络编程将会再次打破对于程序的认知 套接字Socket 单词 操作系统给应用程序传输层给应用层提供的 API起了个名字就叫 Socket API
Socket 本身是“插槽”的意思
电脑的主板插着各种其他的硬件 接下来学习的就是操作系统提供的 Socket APIJava 版本的
UDP 和 TCP 之间的差别
socket API 提供了两组不同的 APIUDP 有一套TCP 也有一套 TCP 有连接可靠传输面向字节流全双工 UDP 无连接不可靠传输面向数据报全双工
有连接/无连接
此处谈到的连接是“抽象”的连接
通信双方如果保存了通信对端的信息就相当与是“有连接”如果不保存对端的信息就是“无连接”连接通信双方 A 保存了 B 的信息IP 和端口号B 也保存了 A 的信息如果通信双方各自把对方的信息删除掉此时就相当与“断开了连接” 举个栗子 将来你和你的另一半去领证结婚证上就会写上两个人的名字贴上照片。一式两份你保存一份你的另一半保存一份你的本上保留了 ta 的信息你翻开本就能看到另一个人是 tata 的本上保留了你的信息ta 翻开本就能看到另一个人是你此时你们俩就相当于建立了“抽象的/逻辑上的连接” 可靠传输/不可靠传输
此处谈到的“可靠”不是指 100% 能到达对方而是 “尽可能”到达对方
因为网络环境非常复杂存在很多的不确定因素你再厉害的技术也抵不过挖掘机一铲子 相对来说不可靠就是完全不考虑数据是否能到达对方
TCP 内置了一些机制能够保证可靠传输
感知到对方是不是收到了重传机制在对方没收到的时候进行重试
UDP 则没有这种可靠性机制完全不管发出去的数据是否顺利到达对方 直观感觉可靠比不可靠传输更好 但可靠传输要付出代价TCP 协议设计就要比 UDP 复杂很多也会损失一些传输数据的效率 面向字节流/面向数据报
TCP 是面向字节流的TCP 的传输过程就和文件流/水流是一样的特点
从文件读写 100 个字节 一次读写 100 字节两次一次读写 50 字节十次一次读写 10 字节… TCP 读写和文件读写是一摸一样的
UDP 是面向数据报的传输数据的基本单位不是字节而是“UDP 数据报”
一次发送/接收必须是完整的 UDP 数据报 这些差别会直接影响到代码的写法
全双工/半双工
全双工一个通信链路可以发送数据也可以接收数据双向通信 半双工一个通信链路只能发送/只能接收单向通信 有一根网线怎么进行双向通信呢 全双工这个事情物理层面上并非是只有一根线在连接一根网线里有 8 根铜线分成 4 4 一组四根就可以正常工作另外四根是防止意外情况发生的铜线备份主要的四根线中两根线用来负责发送两根用来接收 UDP/TCP API 的使用
UDP API
API 就是一组函数/一组类
DatagramSocket
网卡的遥控器 代表一个 Socket 对象
属于操作系统的概念Socket 就可以认为是操作系统中广义的文件里面的一种文件类型 这样的文件就是网卡/控制台/键盘/显卡…这种硬件设备抽象的表示形式 所以 Socket 也具有一些文件的特性操作文件需要先打开、再读写、再关闭。Socket 也是这样包括创建一个 Socket 对象也会占用一个文件描述符表里面的资源 在这里 Socket 对象就是网卡的代言人 因为我们通过代码直接操作网卡是不好操作的网卡有很多种型号之间提供的 API 都会有差别于是操作系统就把网卡概念封装成 Socket应用程序员就不需要关注硬件的差异和细节直接统一操作 Socket 对象就能间接的操作网卡了Socket 就像万能遥控器一样 构造方法
方法签名方法说明DatagramSocket ()创建⼀个 UDP 数据报套接字的 Socket绑定到本机任意⼀个随机端⼝⼀般⽤于客⼾端DatagramSocket (int port)创建⼀个 UDP 数据报套接字的 Socket绑定到本机指定的端⼝需要指定端口号⼀般⽤于服务端
方法
方法签名方法说明void receive (DatagramPacket p)从此套接字接收数据报如果没有接收到数据报该⽅法会阻塞等待void send (DatagramPacket p)从此套接字发送数据报包不会阻塞等待直接发送void close ()关闭此数据报套接字
DatagramPacket
UDP 传输数据的基本单位 代表一个 UDP 数据报
构造方法
方法签名方法说明DatagramPacket(byte[] buf, int length)构造⼀个 DatagramPacket 以⽤来接收数据报接收的数据保存在字节数组第⼀个参数 buf中接收指定 ⻓度第⼆个参数 lengthDatagramPacket(byte[] buf, int offset, int length, SocketAddress address)构造⼀个 DatagramPacket 以⽤来发送数据报发送的数据为字节数组第⼀个参数 buf中从 0 到指定⻓ 度第⼆个参数 length。address 指定⽬的主机的 IP 和端⼝号
方法
方法签名方法说明InetAddress getAddress()从接收的数据报中获取发送端主机 IP 地址或从发送的数据报中获取接收端主机 IP 地址int getPort()从接收的数据报中获取发送端主机的端⼝号或从发送的数据报中获取接收端主机端口号byte[] getData()获取数据报中的数据
回显服务器Echo Server
最简单的客户端服务器程序不涉及到业务流程只是对与 API 的用法做演示
客户端发送什么样的请求服务器就返回什么样的响应没有任何业务逻辑没有进行任何计算或者处理
网络编程必须要使用网卡就需要用到 Socket 对象 创建一个 DatagramSocket 对象之后在基于这个对象进行操作
import java.net.DatagramSocket;
import java.net.SocketException; public class UdpEchoServer { private DatagramSocket socket null; public UdpEchoServer(int port) throws SocketException { //SocketException 异常是 IOException 的子类socket new DatagramSocket(port); }
}对于服务器这一端来说需要在 socket 对象创建的时候就指定一个端口号 port作为构造方法的参数后续服务器开始运行之后操作系统就会把端口号和该进程关联起来端口号的作用就是来区分进程的一台主机上可能有很多个进程很多个程序都要去操作网络。当我们收到数据的时候哪个进程来处理就需要通过端口号去区分 所以就需要在程序一启动的时候就把这个程序关联哪个端口指明清楚 在调用这个构造方法的过程中JVM 就会调用系统的 Socket API完成“端口号-进程”之间的关联动作 这样的操作也叫“绑定端口号”系统原生 API 名字就叫 bind绑定好了端口号之后就明确了端口号和进程之间的关联关系 对于一个系统来说同一时刻一个端口号只能被一个进程绑定但是一个进程可以绑定多个端口号通过创建多个 Socket 对象来完成 因为端口号是用来区分进程收到数据之后明确说这个数据要给谁如果一个端口号对应到多个进程那么就难以起到区分的效果如果有多个进程尝试绑定一个端口号只有一个能绑定成功后来的都会绑定失败
1. 接收请求
通过 start 来启动服务器的核心流程对于服务器来说主要的工作就是不停地处理客户端发来的请求因为客户端什么时候会发来请求是未知的所以要时刻待命
public void start() { System.out.println(服务器启动); //通过一个死循环来不停地处理请求 while(true) { //1. 读取客户端的请求并解析socket.receive(); }
}对 7*24 小时工作的服务器来说服务器里面有死循环是很正常的不是说死循环就是代码 bug
读取客户端的请求并解析 receive 是从网卡上读取数据但是调用 receive 的时候网卡上不一定就有数据当调用 start 方法之后程序启动就立刻调用了 receive一调用 receive就会立刻从网卡中读取数据但这个时候客户端可能还没来网卡中还没有数据如果网卡上收到数据了receive 立刻返回获取收到的数据如果没有收到数据receive 就会阻塞等待直到真正收到数据为止此处 receive 也是通过“输出型参数”获取到网卡上收到的数据的
receive 的参数是 DatagramPacket 我们就需要构造一个空的 DatagramPacket 对象将其作为参数传递给 receive
public void start() throws IOException { System.out.println(服务器启动); //通过一个死循环来不停地处理请求 while(true) { //1. 读取客户端的请求并解析 DatagramPacket requestPacket new DatagramPacket(new byte[4096],4096); socket.receive(requestPacket); }
}DatagramPacket 自身需要存储数据但是数据的空间具体多大需要外部来定义自身不负责 需要指定 requestPacket 所需要存储数据/持有数据的基数 指定一个字节数组和其长度大小没什么讲究只要能确保能够存储下你通讯的一个数据包即可 收到的请求数据是通过二进制 byte[] 的形式来体现的而我们后续要将其进行处理最好将它转成字符串才好处理
public void start() throws IOException { System.out.println(服务器启动); //通过一个死循环来不停地处理请求 while(true) { //1. 读取客户端的请求并解析 DatagramPacket requestPacket new DatagramPacket(new byte[4096],4096); socket.receive(requestPacket); //将收到的二进制 byte[] 数据转换成字符串 String request new String(requestPacket.getData(),0,requestPacket.getLength()); }
}构造 String 可以基于字节数组构造也可以基于字符数组进行构造 此处 DatagramPacket 里面持有的就是字节数组我们就取出里面包含的字节数此处就指定了是哪个字节数组、从哪开始构造、构造多长
2. 根据请求计算响应
请求request客户端主动给服务器发起的数据响应response服务器给客户端返回的数据
此处是一个回显服务器响应就是请求
public void start() throws IOException { System.out.println(服务器启动); //通过一个死循环来不停地处理请求 while(true) { //1. 读取客户端的请求并解析 DatagramPacket requestPacket new DatagramPacket(new byte[4096],4096); socket.receive(requestPacket); //将收到的二进制 byte[] 数据转换成字符串 String request new String(requestPacket.getData(),0,requestPacket.getLength()); //2. 根据请求计算响应 String response process(request); }
} //请求是什么响应就是什么
private String process(String request) { return request;
}3. 将响应写回客户端
此时需要主动的将数据通过网卡发送回客户端
与 receive 相似 send 的参数是 DatagramPacket 我们就需要构造一个 DatagramPacket 对象将其作为参数传递给 send但此时不能使用空的数组来构造 DatagramPacket 对象需要使用刚刚的 response 数据进行构造
public void start() throws IOException { System.out.println(服务器启动); //通过一个死循环来不停地处理请求 while(true) { //1. 读取客户端的请求并解析 DatagramPacket requestPacket new DatagramPacket(new byte[4096],4096); socket.receive(requestPacket); //将收到的二进制 byte[] 数据转换成字符串 String request new String(requestPacket.getData(),0,requestPacket.getLength()); //2. 根据请求计算响应 String response process(request); //3. 把响应写回到客户端 DatagramPacket responsePacket new DatagramPacket(response.getBytes(),response.getBytes().length, requestPacket.getSocketAddress()); socket.send(responsePacket); }
} //请求是什么响应就是什么
private String process(String request) { return request;
}String 可以基于字节数组来构造也可以随时取出里面的字节数组response.getBytes().length 不能写成 response.length 前者是在获取字节数组得到字节数组的长度单位是“字节”后者是在获取字符串中字符的个数单位是“字符” UDP 有一个特点——无连接 所谓的连接就是通信双方保存对方的信息IP端口号就是说 DatagramSocket 这个对象中不持有对方客户端和 IP 端口的进行 send 的时候就需要在 send 的数据包里把要“发给谁”这样的信息写进去才能够正确的把数据进行返回所以要将信息也作为参数传入 responsePacket 中 客户端刚才给服务器发了一个请求 requestPacket这个包记录了这个数据是从哪来从哪来就让它回哪去所以直接获取这个 requestPacket 的信息就可以了客户端的 IP 和端口就都包含在 requestPacket.getSocketAddress() 中后续往外发送数据包的时候就知道该发去哪了 - 相比之下TCP 代码中因为 TCP 是有连接的则无需关心对端的 IP 和端口只管发送数据即可 如果字符串里都是英文字母/阿拉伯数字/英文标点符号的话都是 ASCII 编码的一个字符也就是一个字节这么长如果字符串里有中文是 UTF8 编码的一个中文就是 3 个字节UTF8 也是能兼容 ASCII当使用 UTF8 表示英文的时候和 ASCII 表示英文是完全相同的 完整代码
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException; public class UdpEchoServer { private DatagramSocket socket null; public UdpEchoServer(int port) throws SocketException { socket new DatagramSocket(port); } public void start() throws IOException { System.out.println(服务器启动); //通过一个死循环来不停地处理请求 while(true) { //1. 读取客户端的请求并解析 DatagramPacket requestPacket new DatagramPacket(new byte[4096],4096); socket.receive(requestPacket); //将收到的二进制 byte[] 数据转换成字符串 String request new String(requestPacket.getData(),0,requestPacket.getLength()); //2. 根据请求计算响应 String response process(request); //3. 把响应写回到客户端 DatagramPacket responsePacket new DatagramPacket(response.getBytes(),response.getBytes().length, requestPacket.getSocketAddress()); socket.send(responsePacket); //4. 打印日志 System.out.printf([%s:%d req%s, res%s\n,requestPacket.getAddress(),requestPacket.getPort(),request,response); } } //请求是什么响应就是什么 private String process(String request) { return request; } public static void main(String[] args) throws IOException { UdpEchoServer server new UdpEchoServer(9090); server.start(); }
}
