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

目录

一、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.rhkb.cn/news/276061.html

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

相关文章

机械女生,双非本985硕,目前学了C 基础知识,转嵌入式还是java更好?

作为单片机项目开发的卖课佬,个人建议,先转嵌入式单片机开发方向,哈哈。 java我也学过,还学过oracle、mysql数据库,只是当时没做笔记,找不好充分的装逼证据了。 从实习通过业余时间,学到快正式毕…

AI 大模型赋能手机影像,小米14 Ultra 让真实有层次

2月22日,小米龙年第一场重磅发布会,正式发布专业影像旗舰小米14 Ultra。 此前小米发布的两代 Ultra,在不同维度,引领了移动影像行业的走向。最新的小米14 Ultra 在定义的时候,我们反复在思考:怎么才能把移动…

HBase安装,配置,启动,检查

目录: 一、HBase安装,配置 1、下载HBase安装包 2、解压,配置环境变量并激活 3、hbase 配置 4、将hadoop和zookeeper的配置文件创建软连接放在hbase配置目录 5、配置 regionserver 和 backup-master 二、HBase启动与关闭,安装检验 1、启动关闭…

吴恩达深度学习笔记:神经网络的编程基础2.9-2.14

目录 第一门课:神经网络和深度学习 (Neural Networks and Deep Learning)第二周:神经网络的编程基础 (Basics of Neural Network programming)2.9 逻辑回归中的梯度下降(Logistic Regression Gradient Descent) 第一门课&#xff…

蓝牙耳机链接电脑莫名奇妙关机问题(QQ浏览器)

蓝牙耳机连接电脑听歌的时候,如果听歌软件是暴风影音,或者其它播放器,蓝牙不会自动关机,但如果是QQ浏览器,蓝牙耳机经常莫名其妙的关机,时间间隔忽长忽短,没有规律,解决办法就是重启…

【C++ 设计模式】简单工厂模式

文章目录 前言一、简单工厂模式是什么?二、实现原理三、UML类图四、简单工厂模式具体代码总结 前言 在软件开发中,设计模式是解决特定问题的可复用解决方案。其中,简单工厂模式是一种创建型设计模式,旨在封装对象的创建过程&…

使用耳机壳UV树脂制作私模定制耳塞的价格如何呢?

耳机壳UV树脂制作私模定制耳塞的价格因多个因素而异,如材料、工艺、设计、定制复杂度等。 根据我目前所了解到的信息,使用UV树脂制作私模定制耳塞的价格可能在数百元至数千元不等。具体价格还需根据用户的需求和预算进行综合考虑。 如需获取更准确的报…

MySQL order by 语句执行流程

全字段排序 假设这个表的部分定义是这样的: CREATE TABLE t (id int(11) NOT NULL,city varchar(16) NOT NULL,name varchar(16) NOT NULL,age int(11) NOT NULL,addr varchar(128) DEFAULT NULL,PRIMARY KEY (id),KEY city (city) ) ENGINEInnoDB; 有如下 SQL 语…

抖音在线点赞任务发布接单运营平台PHP网站源码

源码简介 抖音在线点赞任务发布接单运营平台PHP网站源码 多个支付通道分级会员制度 介绍: 1、三级代理裂变,静态返佣/动态返佣均可设置。(烧伤制度)。 2、邀请二维码接入防红跳转。 3、自动机器人做任务,任务时间…

STM32CubeIDE基础学习-STM32CubeIDE软件新增工程文件夹

STM32CubeIDE基础学习-STM32CubeIDE软件新增工程文件夹 文章目录 STM32CubeIDE基础学习-STM32CubeIDE软件新增工程文件夹前言第1章 添加文件夹第2章 添加文件路径2.1 相对路径方法2.2 绝对路径方法 总结 前言 在编程的过程中,如果需要在原有的工程基础上新增其它的…

微信小程序-day01

文章目录 前言微信小程序介绍 一、为什么要学习微信小程序?二、微信小程序的历史创建开发环境1.注册账号2.获取APPID 三、下载微信开发者工具1.创建微信小程序项目2.填写相关信息3.项目创建成功 四、小程序目录结构项目的主体组成结构 总结 前言 微信小程序介绍 微信小程序&…

【OceanBase诊断调优 】 —— 合并问题如何排查?

最近总结一些诊断OCeanBase的一些经验,出一个【OceanBase诊断调优】专题,也欢迎大家贡献自己的诊断OceanBase的方法。 1. 前言 OceanBase 数据库的存储引擎基于 LSM-Tree 架构,将数据分为静态基线数据(放在 SSTable 中&#xff…

留学生课设|R语言|研究方法课设

目录 INSTRUCTIONS Question 1. Understanding Quantitative Research Question 2. Inputting data into Jamovi and creating variables (using the dataset) Question 3. Outliers Question 4. Tests for mean difference Question 5. Correlation Analysis INSTRUCTIO…

有趣的前端知识(三)

推荐阅读 有趣的前端知识(一) 有趣的前端知识(二) 文章目录 推荐阅读JS内置对象JS外部对象BOM模型history对象screen对象navigator对象 DOM(文档对象模型)DOM的方法(对于节点的操作&#xff09…

金蝶BI方案能解决云星空数据分析痛点吗?

金蝶云星空作为一个主攻企业管理流程的软件确实立下了汗马功劳,但一到数据分析方面那就阻碍重重了。直接的感受是分析步骤多且复杂,数据展现不够直观易懂,有些分析指标的计算真的很难实现,跨部门跨组织计算指标、合并账套什么的能…

vscode 向下复制当前行(即visual studio 中的Ctrl + D)功能快捷键

参考:https://blog.csdn.net/haihui1996/article/details/87937912 打开vscode左下角键盘快捷键设置,找到copy line down,即可查看当前默认快捷键为“shift Alt ↓” 双击快捷键,输入自己想要的快捷组合,如CtrlD,然…

尚硅谷SpringBoot3笔记 (二) Web开发

Servlet,SpringMVC视频推荐:53_尚硅谷_servlet3.0-简介&测试_哔哩哔哩_bilibili HttpServlet 是Java Servlet API 的一个抽象类,用于处理来自客户端的HTTP请求并生成HTTP响应。开发人员可以通过继承HttpServlet类并重写其中的doGet()、do…

给电脑加硬件的办法 先找电脑支持的接口,再买相同接口的

需求:我硬盘太小,换或加一个大硬盘 结论:接口是NVMe PCIe 3.0 x4 1.找到硬盘型号 主硬盘 三星 MZALQ512HALU-000L2 (512 GB / 固态硬盘) 2.上官网查 或用bing查 非官方渠道信息,不确定。

[论文笔记]LLaMA: Open and Efficient Foundation Language Models

引言 今天带来经典论文 LLaMA: Open and Efficient Foundation Language Models 的笔记,论文标题翻译过来就是 LLaMA:开放和高效的基础语言模型。 LLaMA提供了不可多得的大模型开发思路,为很多国产化大模型打开了一片新的天地,论文和代码值…

uniapp运行钉钉小程序

因项目原因,公司需要在钉钉里面开发小程序。之前用uniapp开发过app,H5,小程序。还真没尝试过钉钉小程序,今天就简单的记录下uniapp运行钉钉小程序中的过程。 在项目目录新建package.json文件,在文件中添加如下代码&am…