网络编程套接字(4)——Java套接字(TCP协议)

news/2024/5/30 2:14:32/文章来源:https://blog.csdn.net/cool_tao6/article/details/136670168

目录

一、Java流套接字通信模型

二、TCP流套接字编程 

1、ServerSocket

ServerSocket构造方法:

ServerSocket方法:

2、Socket

Socket构造方法:

Socket方法:

三、代码示例:回显服务器

1、服务器代码

代码解析

2、客户端代码

代码解析

3、注意事项

        (1)缓冲区

        (2)socket的close,释放文件描述符表

        (3)多线程的应用

        (4)引入线程池的改进

                1、协程

                2、IO多路复用

4、执行代码

        前述:

5、客户端和服务器交互的过程


一、Java流套接字通信模型

        

        1.客户端和服务端:开发时,经常是基于一个主机开启两个进程作为客户端和服务端,但是真实的场景,一般是不同主机。

        2.注意目的IP和目的端口号,标识了一次数据传输时要发送数据的终点主机和进程。

        3.Socket编程我们是使用流套接字和数据报套接字,基于TCP或UDP协议,但应用层协议,也需要考虑。


二、TCP流套接字编程 

        TCP面向字节流,和UDP面向数据报不同,但是写的回显服务器中心思想是一样的,代码会有不同。以下API介绍。

1、ServerSocket

        这个Socket类对应到网卡,只能给服务器使用。

        ServerSocket是创建TCP服务端Socket的API。

ServerSocket构造方法:

方法签名方法说明
ServerSocket(int port)创建一个服务端流套接字Socket,并绑定到指定端口

ServerSocket方法:

方法签名方法说明
Socket accept()

开始监听指定端口(创建时绑定的端口),有客户端

连接后,返回一个服务端socket对象,并基于该

Socket建立与客户端的连接,否则阻塞等待

void close()关闭此套接字

2、Socket

        对应到网卡,既可以给客户端使用,也可以给服务器使用。

        Socket是客户端Socket,或服务端接收到客户端建立的连接(accept方法)的请求后,返回的服务端Socket。

        不管是客户端还是服务端Socket,都是双方建立连接之后,保存对端信息,及用来与对方收发数据的。

Socket构造方法:

方法签名方法说明
Socket(String host, int port)

创建一个客户端流套接字Socket,并与对应IP的主机

上,对应端口的进程进行连接

Socket方法:

方法签名方法说明
InetAddress getInetAddress()返回套接字所连接的地址
InputStream getInputStream()返回此套接字的输入流
OutputStream getOutputStream()返回此套接字的输出流

三、代码示例:回显服务器

1、服务器代码

public class TcpEchoServer {ServerSocket socket = null;public TcpEchoServer(int serverPort) throws IOException {socket = new ServerSocket(serverPort);}public void start() throws IOException {System.out.println("服务器启动");ExecutorService pool = Executors.newCachedThreadPool();while (true) {//通过 accept 这个方法来 “接听电话”,然后才能通信Socket clientSocket = socket.accept();
//            Thread t = new Thread(() -> {
//                //通过这个方法来处理一次连接,连接的过程会涉及到多次请求响应交互
//                processConnection(clientSocket);
//            });
//            t.start();pool.submit(new Runnable() {@Overridepublic void run() {processConnection(clientSocket);}});}}//通过这个方法来处理一次连接,连接的过程会涉及到多次请求响应交互private void processConnection(Socket clientSocket) {System.out.printf("[%s : %d] 客户端上线\n", clientSocket.getInetAddress(), clientSocket.getPort());//循环读取客户端请求并返回响应try(InputStream inputStream = clientSocket.getInputStream();OutputStream outputStream = clientSocket.getOutputStream()) {while (true) {Scanner scanner = new Scanner(inputStream);if(!scanner.hasNext()) {//读取完毕,客户端断开连接,就会产生读取完毕System.out.printf("[%s : %d] 客户端下线\n", clientSocket.getInetAddress(), clientSocket.getPort());break;}//1、接受从客户端发来的请求,解析请求(将请求转换为字符串)为了方便,直接使用Scanner读取//  读取请求并解析. 这里注意隐藏的约定. next 读的时候要读到空白符才会结束.//    因此就要求客户端发来的请求必须带有空白符结尾. 比如 \n 或者空格.//客户端发来的请求要包含 “\n”String request = scanner.next();//2、计算请求String response = process(request);//3、把计算的响应返回给客户端//也可以通过下面的这种方式写回,但下面这种方式不好添加 "\n"//outputStream.write(response.getBytes(), 0, response.getBytes().length);// 也可以给outputStream套上一层,可以更方便的加上 "\n"PrintWriter writer = new PrintWriter(outputStream);writer.println(response);//刷新缓冲器writer.flush();//打印日志System.out.printf("[%s : %d] res: %s resp: %s\n", clientSocket.getInetAddress(),clientSocket.getPort(), request, response);}} catch (IOException e) {throw new RuntimeException(e);} finally {try {clientSocket.close();} catch (IOException e) {throw new RuntimeException(e);}}}private String process(String request) {return request;}public static void main(String[] args) throws IOException {TcpEchoServer tcpEchoServer = new TcpEchoServer(9090);tcpEchoServer.start();}
}

代码解析

        服务器通过accept方法,和客户端建立联系

        如上图,应用程序代码中调用对应的 api 和服务器尝试建立连接,内核就会发起连接的流程。

        服务器的内核就会配合客户端这边的工作来完成连接的建立。

        这个连接建立的过程,就相当于:电话这边在拨号,另一边在响铃;但是要等到用户点击了接听,然后才能进行后续的通信。

        内核建立的连接不上决定性的,还需要用户程序把这个连接进行 "接听" / accept 操作,然后才能进行后续的通信。

        注意:accept也是一个可能会产生阻塞的操作,如果当前没有客户端连过来,此时 accept 就会阻塞。

        有一个客户端连过来,accept 一次就能返回一次。

        有若干个客户端连过来,accept 就需要执行多次。

        第一个socket是负责客户端的连接第二个clientSocket是负责操作服务器内部的业务。

        接下来的方法是处理连接的交互,新创建多出来线程后面讲

        TCP是有连接的和面向字节流的,从下面代码就可以看出来

        TCP的 socket 是可以保存对端的信息InputStream是从网卡读数据,outputStream是从网卡写数据。

        TCP面向字节流,这里的字节流和 文件 中的字节流完全一样,使用文件操作一样的方法和类的对 TCP 的 socket 进行读写。

        如图:

此处的读操作完全可以通过 read 来完成,read 是把收到的数据放到 byte 数组中,后续根据请求处理响应还需要把这个 byte 数组转成 String,比较麻烦,还有一个更简单的方法:Scanner,如上图。

        如图:

        客户端退出之后,服务器就能感知到 “客户端下线” 的操作客户端退出的时候,就会触发TCP的“断开连接”流程,服务器这边的代码就能感知到,对应的Scanner就能够在hasNext这里返回false。

        这里要用 scanner.next() ,因为接受来的请求的字节流,要知道什么时候结束发送过来的请求会带有 "\n",发来的请求中有空白符,比如 \n 或 空格。

        接下来是计算请求,如图:

        因为这里是简单的回显服务器,所以计算就直接返回请求的内容,process方法如图:

        返回响应

        记得要刷新缓冲器。

        

2、客户端代码

public class TchEchoClient {Socket socket = null;public TchEchoClient(String serverIp, int serverPort) throws IOException {//这里的ip和port是直接发给socket的对象// 因为TCP是有连接的,所以socket会保存ip和port这些信息//因此TcpEchoClient不必保存ip和portsocket = new Socket(serverIp, serverPort);}public void start() {System.out.println("客户端启动");try(InputStream inputStream = socket.getInputStream();OutputStream outputStream = socket.getOutputStream();Scanner scannerConsole = new Scanner(System.in);Scanner scannerNetwork = new Scanner(inputStream);PrintWriter writer = new PrintWriter(outputStream)) {while (true) {System.out.print("->");//1、从控制台输入请求,构造请求if(!scannerConsole.hasNext()) {break;}//发送给服务器的字符串要带有 "\n"String request = scannerConsole.next();//2、把请求发给发送给服务器,这里需要用println来发生,确保信息里面有 "\n"//这里是和服务器的scanner.next()对应的writer.println(request);//通过flush刷新缓冲器,确保数据真的发出去了writer.flush();//3、接收服务器返回的响应//这里也是和服务器返回的响应逻辑对应,返回的响应带有 "\n"String response = scannerNetwork.next();//4、把返回的响应显示到控制台System.out.println(response);}} catch (IOException e) {throw new RuntimeException(e);}}public static void main(String[] args) throws IOException {TchEchoClient tchEchoClient = new TchEchoClient("127.0.0.1", 9090);tchEchoClient.start();}
}

代码解析

        构造方法里面,如图:

        执行客户端里的构造方法,就会和对应的服务器进行TCP的连接建立流程。(系统内核完成的)。

        这边把内核中连接的流程走完了,服务器这边就能够从 accept 返回

        服务器的建立连接,如图

        processConnection方法内部

        然后进入while循环,执行服务器的内部逻辑,如图:

3、注意事项

        (1)缓冲区

        文件的IO操作都是比较低效的,所以就希望能够让低效的操作,进行的尽量少一些。

        解决方案:引入缓冲区(内存),先把写入网卡的数据放到内存缓冲区中,等攒一波再统一进行发送(把多次IO合并成一次)

        但也有个问题,如果发送的数据很少。此时由于缓冲区还没满,数据就待在缓冲区里,没有被真正发送出去。所以上面的代码中要加入刷新缓冲区的代码。(不然就连数据都发送不出去),如图:不管数据有没有真的发送出去,都要进行刷新缓冲器

        (2)socket的close,释放文件描述符表

        如图:

        clientSocket对象要释放掉因为客户端不止一个,会有很多个,一个客户端发来请求就会占用一个文件描述符表,我们不确定客户端什么时候下线,就可能会一直占用着这些资源(文件描述符表),随着客户端越来越多,又无法释放,文件描述符表就可能占满

        而服务器的sock就不用释放,调用close方法,如图:

        因为这个socket会伴随着服务器的生命周期很长,整个生命周期都会使用到它,而且也只有一个就不用担心占不占满文件描述符表了,像这种情况就不用释放;只要程序退出,socket也会随着进程的销毁一起被释放;UDP的回显服务器的socket不用释放也是因为这个原因。

        因为有finally最后会执行socket的释放,所以,释放了 socket 对象,上述流对象不释放,也问题不大。这两流对象内部不持有文件描述符,只是只有一些内存结构。内存结构可以被 gc 释放。

        但是只释放了流对象,不释放socket,就不行了socket持有了文件描述符表,本质还是要释放文件描述符资源。

        不过这里使用try with resources 的版本,也给它close了,更保险一点

        (3)多线程的应用

        服务器支持多个客户端同时访问是天经地义的,但如果不加多线程方案执 processConnection方法,如图:

        当有多个客户端想同时访问时,第一个客户端先访问服务器,服务器就会从accept这返回(解除阻塞),进入到processConnection中了,接下来就会在scanner.hasNext返回,继续执行服务器逻辑,因为有while循环,完成服务器的逻辑后,把响应返回给客户端执行完上述一轮操作后,循环回来继续再hasNext阻塞,等待下一次循环,知道客户端退出,连接结束,服务器中的循环才会结束、退出,如图:

        当有第二个客户端想访问服务器时,因为第一个客户端还没执行完服务器还在里面的while循环转圈圈呢就无法第二次执行到accept

        这里虽然第二个客户端和服务器在内核层面上建立了TCP连接,但是应用程序这里,无法把连接拿到的应用程序,在服务器程序里面进行处理(像是别人给你打电话,你手机一直在响,但是你没接)。

        如果第一个客户端退出了,第二个客户端之前的请求为啥就会被立即出来,而没有丢弃呢?这是因为当前TCP在内核中,每个 socket 都是有缓冲区的客户端发送的数据确实是发了,服务器也收到了,只不过数据是在服务器的接受缓冲区中。

        一旦第一个客户端退出了,回到第一层循环,继续执行第二次 accept ,继续执行 next 就能把之前缓冲区的内容给读出来像是菜鸟驿站,可以存放快递包裹)。

        单个线程,无法既能给客户端提供循环提供服务,又能快速的调用到第二次accept

        所以这里的核心思路就是使用多线程,也是简单的办法,引入多线程,主线程负责执行 accept每次有一个客户端连上来,就分配一个新的线程,由新的线程负责给客户端提供服务。如图:

        而上述没有引用多线程而造成的问题,并不是 TCP 的问题,而是代码本身的问题,因为两层循环嵌套而导致的问题。UDP只有一层循环,所以就不涉及到这种问题,之前的UDP天然的就能处理多个客户端的请求。

        (4)引入线程池的改进

        如图:

        这里每次来一个客户端,就会创建一个新的线程;每次这个客户端结束,就要销毁这个线程。如果客户端比较多,就会使服务器 频繁创建、销毁 线程

        因此,这里我们可以引入线程池,代码如图:

        线程池,解决的事频繁创建销毁的问题。

        如果当前场景是线程频繁创建,但是不销毁呢?(扩展话题)

        每个客户端如果处理过程都很短(网站),线程池可以解决这种频繁创建消耗的问题

        但是每个客户端处理过程都很长呢(例如吃鸡、王者、LOL等待),如果继续使用线程池 / 多线程,此时就会导致当前的服务器上一下积累了大量线程,此时对于服务器的负担就会非常重!!

        为了解决上述积累大量线程的问题,可以引入以下的方案:

                1、协程

                轻量级线程。本质还是一个线程,用户态可以通过手动调度的方式,让这一个线程 “并发” 的做多个任务。(Go / Python)

                2、IO多路复用

                系统内核级别的机制本质上是让一个线程同时去负责处理多个 socket本质在于这些 socket 数据并非是同一时刻都需要处理。

                基本盘在于,虽然有多个 socket ,但是同一时刻活跃的 socket 只是少数(需要读写数据的 socket),大部分 socket 都是在等,使用一个线程来等多个 socket。        就像去路边摊吃小吃,有很多小吃,我可以在我想吃的小吃店,依次都付款,然后站在这些店的中间,哪个路边摊先做好就去哪个路边摊拿小吃,这样等的过程,就可以节约出很多时间。

4、执行代码

        前述:

        要想执行多个客户端程序,我们要设置一些东西,设置方法如图:

        执行代码后,服务器和客户端交互,如图:

        客户端:

        服务器:

        多个客户端发送数据给服务器:

        可以看到,不同的客户端的进程号不同。而且服务器可以同时被多个客户端请求。

5、客户端和服务器交互的过程

1、服务器启动,阻塞在 accept,等待客户端发来的请求

2、客户端启动

        这里的 new 操作,触发了和服务器之间的建立连接的操作,此时 服务器 就会从 accept 中返回。

 3、服务器从 accept 返回,进入到 processConnection方法中

        执行到 hasNext 这里,产生阻塞,此时虽然连接建立了,但客户端还没发来任何请求,hasNext 阻塞等待请求到达。类似电话通了,但没人说。

4、客户端继续执行到 hasNext,等待用户从控制台写入信息。

5、用户真的输入了,此时 hasNext 就返回了,继续执行这里的发送请求的逻辑。

6、服务器从 hasNext 返回读取到请求内容,并进行处理

        读取到请求,构造成响应,并把响应返回给客户端

        服务器就结束本次循环,开启下一轮循环,继续阻塞在 hasNext 等待下一个请求。

7、客户端读到响应,并且显示出来

        结束本次循环,进入下一次循环,继续阻塞等待在 hasNext 等待用户下一次的输入。


都看到这了,点个赞再走吧,谢谢谢谢谢

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

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

相关文章

和泓海棠府——与阳光大海约会 悦享惬意生活

海南三亚海棠湾 四季如春的梦想在这里即可实现和泓海棠府 与阳光大海约会 悦享惬意生活 如果在三亚有一套房 你就可以把父母接过来一起住 尽己所能让老人圆一个海居梦 带着孩子一起在园林里探索自然 陪孩子度过每一个有趣的海边假期 你也可以随时沿着会唱歌的沙滩迎风漫…

Php和h5等静态文件的服务容器化部署(下)

一、接着上文 上文介绍了php/h5程序的部署过程,最后是通过slb把不同的服务暴露给外部。 本文试着把外部的配置交待清楚,包括: kong配置ingress配置 部署逻辑图见下: 总结: 去掉slb,引入ingress组件。…

新火种AI|GPT-4诞生1年,OpenAI把它放到了机器人上

作者:一号 编辑:美美 ChatGPT拥有了身体,机器人也有了灵魂。 从OpenAI在去年3月14日拿出GPT-4后,已经过了整整一年。显然,在GPT-4诞生之后的这一年,一切都迭代得太快了,从GPT-4展现多模态能力&…

Nginx、LVS、HAProxy工作原理和负载均衡架构

当前大多数的互联网系统都使用了服务器集群技术,集群是将相同服务部署在多台服务器上构成一个集群整体对外提供服务,这些集群可以是 Web 应用服务器集群,也可以是数据库服务器集群,还可以是分布式缓存服务器集群等等。 在实际应用…

EMQX 4.0和EMQX 5.0集群架构实现1亿MQTT连接哪些改进

EMQX 5.0水平扩展能力得到了指数级提升,能够更可靠地承载更大规模的物联网设备连接量。 在EMQX5.0正式发布前的性能测试中,我们通过一个23节点的EMQX集群,全球首个达成了1亿MQTT连接每秒100万消息吞吐,这也使得EMQX 5.0成为目前为…

自然语言处理实验2 字符级RNN分类实验

实验2 字符级RNN分类实验 必做题: (1)数据准备:academy_titles.txt为“考硕考博”板块的帖子标题,job_titles.txt为“招聘信息”板块的帖子标题,将上述两个txt进行划分,其中训练集为70%&#xf…

【matlab】如何将.mat文件与.nii文件互转

【matlab】如何将.mat文件与.nii文件互转 .mat转为.nii文件 有时候代码需要读取的是.nii文件,但是如何现有的数据是.mat格式,需要将.mata转化为.nii文件 1、先加载.mat文件 % 加载.mat文件 load(your_mat_file.mat); % 请将your_mat_file.mat替换为实…

《家庭的觉醒》(二)提升觉悟的日常提示

尊重内心的本质 专注于你的孩子今天是谁,而不是今天他做了什么。 不要执着于他们的学业表现,测验成绩,成就或功课。 敞开心扉 发自内心与孩子分享你自己。还记得当孩子生病,在急诊室或医院的时候吗?还记得认识的另…

配置阿里云加速器

国内镜像中心常用阿里云或者网易云。在本地docker中指定要使用国内加速器的地址后&#xff0c;就可以直接从阿里云镜像中心下载镜像。 2024阿里云-上云采购季-阿里云 [rootlocalhost /]# mkdir -p /etc/docker [rootlocalhost /]# tee /etc/docker/daemon.json <<-EOF &…

信号与系统学习笔记——信号的分类

目录 一、确定与随机 二、连续与离散 三、周期与非周期 判断是否为周期函数 离散信号的周期 结论 四、能量与功率 定义 结论 五、因果与反因果 六、阶跃函数 定义 性质 七、冲激函数 定义 重要关系 作用 一、确定与随机 确定信号&#xff1a;可以确定时间函数…

阿里云免费证书改为3个月,应对方法很简单

情商高点的说法是 Google 积极推进90天免费证书&#xff0c;各服务商积极响应。 情商低点的话&#xff0c;就是钱的问题。 现在基本各大服务商都在2024年停止签发1年期的免费SSL证书产品&#xff0c;有效期都缩短至3个月。 目前腾讯云倒还是一年期。 如果是一年期的话&#x…

冒泡排序,详详解解

目录 基本概念&#xff1a; 上图&#xff1a; 核心思路&#xff1a; 基本步骤&#xff1a; 关键&#xff1a; 代码核心&#xff1a; 补充&#xff1a; 代码&#xff08;规范&#xff09; &#xff1a; 代码&#xff08;优化&#xff09;&#xff1a; 今天我们不刷力扣了&…

CSDN 编辑器设置图片缩放和居中

CSDN 编辑器设置图片缩放和居中 文章目录 CSDN 编辑器设置图片缩放和居中对齐方式比例缩放 对齐方式 Markdown 编辑器插入图片的代码格式为 ![图片描述](图片路径)CSDN 的 Markdown 编辑器中插入图片&#xff0c;默认都是左对齐&#xff0c;需要设置居中对齐的话&#xff0c;…

ChatGPT-Next-Web SSRF漏洞+XSS漏洞复现(CVE-2023-49785)

0x01 产品简介 ChatGPT-Next-Web 是一种基于 OpenAI 的 GPT-3.5 、GPT-4.0语言模型的产品。它是设计用于 Web 环境中的聊天机器人,旨在为用户提供自然语言交互和智能对话的能力。 0x02 漏洞概述 2024年3月,互联网上披露CVE-2023-49785 ChatGPT-Next-Web SSRF/XSS 漏洞,未经…

CompletableFuture原理与实践-外卖商家端API的异步化

背景 随着订单量的持续上升&#xff0c;美团外卖各系统服务面临的压力也越来越大。作为外卖链路的核心环节&#xff0c;商家端提供了商家接单、配送等一系列核心功能&#xff0c;业务对系统吞吐量的要求也越来越高。而商家端API服务是流量入口&#xff0c;所有商家端流量都会由…

IDEA如何删除git最新一次远程提交

IDEA如何删除git最新一次远程提交 选择应用 -> Git -> Show History 选择最新提交上一次提交 -> Reset Current Branch to Here… Reset 提示框选择 Hard push到远程分支 -> 选择Force Push 结果验证 &#xff08;最新分支已被删除&#xff09;

Docker-基本命令

目录 一、Docker与虚拟机技术 二、Docker功能 三、安装 安装&#xff1a; 1、环境准备&#xff1a; 2、安装docker 3、配置阿里云镜像加速 镜像加速源 4、Docker是怎么工作的 5、Docker为什么比虚拟机快 四、docker命令 1、镜像命令 Docker官方镜像库&#xff1a…

小程序学习3 goods-card

pages/home/home home.wxml <goods-listwr-class"goods-list-container"goodsList"{{goodsList}}"bind:click"goodListClickHandle"bind:addcart"goodListAddCartHandle"/> <goods-list>是一个自定义组件&#xff0c;它具…

什么是制作视频内容?如何搞好视频内容制作?

写在前面 视频内容已成为希望吸引数字观众的企业、品牌和创作者的必备资产。事实上&#xff0c;根据NogenTech的一份报告&#xff0c;在2023年&#xff0c;91%的营销部门使用了这种动态内容。 视频内容创作和优化性能的技巧和窍门的增加绝非巧合。TikTok以及Instagram Reels和…

BMJ杂志方法学推荐:断点回归方法

直播课程 郑老师本周六&#xff1a;真实世界临床研究直播课&#xff08;点击了解详情&#xff09; 2024年2月27日&#xff0c;顶级医学期刊BMJ发表了一篇有关断点回归设计研究的指南&#xff0c;文中所介绍的断点回归既具有类似随机对照组的优势&#xff0c;又能依托于观察性研…