<JavaEE> 基于 TCP 的 Socket 通信模型

目录

一、认识相关API

1)ServerSocket

2)Socket

二、TCP字节流套接字通信模型概述

三、回显客户端-服务器

1)服务器代码

2)客户端代码


一、认识相关API

1)ServerSocket

ServerSocket 常用构造方法
ServerSocket(int port)创建使用TCP协议的Scoket套接字,绑定本机指定端口(通常用于服务器)。
ServerSocket 常用方法
Socket accept()开始监听指定端口(端口在创建时绑定)。没有客户端连接时就阻塞,有客户端连接就返回一个服务端的Socket对象,并基于该Socket建立与客户端的连接。
void close()关闭ServerSocket套接字。

2)Socket

Socket 常用构造方法
Socket(String host, int port)创建一个客户端流套接字Socket,并与对应的主机上的对应端口进程建立连接。
Socket 常用方法
InetAddress getInetAddress()返回套接字连接的对端地址。
int getPort()返回套接字连接的对端端口。
InetAddress getLocalAddress()返回套接字连接的本地地址。
int getLocalPort()返回套接字连接的本地端口。
InputStream getInputStream()返回该套接字的输入流。
OutputStream getOutputStream()返回该套接字的输出流。
void close()关闭Socket套接字。

二、TCP字节流套接字通信模型概述

TCP协议具有有连接,面向字节流的特征。在通信之初,通信双方会先建立连接,并保存对端信息。通信连接的建立由系统内核完成,不需要代码干预。
TCP通信,使用ServerSocket类在服务端创建TCPSocket,并获取与客户端的连接。使用Socket类分别在客户端和服务端保存对端信息,并用于与对端的数据交互。
TCP通信流程:服务端客户端建立连接 -> 客户端构造请求->发出请求 -> 服务器接收请求->解析请求->处理请求->构造响应->返回响应->客户端接收响应->解析响应->处理响应

三、回显客户端-服务器

1)服务器代码

public class TCP_Echo_Server {private ServerSocket serverSocket = null;public TCP_Echo_Server(int port) throws IOException {serverSocket = new ServerSocket(port);}public void start() throws IOException {System.out.println("服务器启动!");//创建线程池;ExecutorService executorService = Executors.newCachedThreadPool();while (true){//获得连接;Socket socket = serverSocket.accept();//添加任务,每获得一个连接就使用一个线程去执行accpetConnection方法;executorService.submit(new Runnable() {@Overridepublic void run() {accpetConnection(socket);}});}}private void accpetConnection(Socket socket){System.out.printf("客户端上线:[%s,%d]\n",socket.getInetAddress(),socket.getPort());//TCP传输的是字节流,创建两个流对象用于获得Socket的输入流和输出流;try(InputStream is = socket.getInputStream();OutputStream os = socket.getOutputStream()){//使用Scanner在流中读取并翻译字节;Scanner sc = new Scanner(is);//用于将获取到的输出流封装成PrintWriter;PrintWriter printWriter = new PrintWriter(os);while (true){//判断如果没有后续数据了,就退出;if (!sc.hasNext()){System.out.printf("客户端下线:[%s,%d]\n",socket.getInetAddress(),socket.getPort());break;}//获得请求;String request = sc.next();//构造响应;String response = process(request);//将响应写入Socket的输出流中;printWriter.println(response);//刷新缓冲区,确保响应及时发送;printWriter.flush();//打印日志;System.out.printf("[%s,%d] req=%s res=%s\n",socket.getInetAddress(),socket.getPort(),request,response);}}catch (IOException e) {e.printStackTrace();}finally {try {//关闭Socket文件资源;socket.close();} catch (IOException e) {e.printStackTrace();}}}private String process(String request) {return request;}public static void main(String[] args) throws IOException {TCP_Echo_Server server = new TCP_Echo_Server(9090);server.start();}
}

2)客户端代码

public class TCP_Echo_Client {private Socket clientSocket = null;public TCP_Echo_Client(String serverIP,int serverport) throws IOException {//根据指定的服务器地址和端口号构建客户端套接字;clientSocket = new Socket(serverIP,serverport);}public void start(){System.out.println("成功连接!");//TCP传输的是字节流,创建两个流对象用于获得Socket的输入流和输出流;try(InputStream is = clientSocket.getInputStream();OutputStream os = clientSocket.getOutputStream();){//创建两个Scanner对象,分别用于从控制台输入请求和从输入流获得响应;Scanner ossc = new Scanner(System.in);Scanner issc = new Scanner(is);//用于将输出流封装成PrintWriter;PrintWriter printWriter = new PrintWriter(os);while (true){//输入请求;System.out.print("->");String request = ossc.next();//构造请求的字节流,并写入Socket的输出流中printWriter.println(request);//刷新缓冲区,确保请求及时发送;printWriter.flush();//获取响应;String response = issc.next();//打印响应;System.out.println(response);}} catch (IOException e) {e.printStackTrace();}finally {try {clientSocket.close();} catch (IOException e) {e.printStackTrace();}}}public static void main(String[] args) throws IOException {TCP_Echo_Client client = new TCP_Echo_Client("127.0.0.1",9090);client.start();}
}

阅读指针 -> 《 协议格式 -- 传输层协议 UDP 》

<JavaEE> 协议格式 -- 传输层协议 UDP-CSDN博客介绍了传输层协议UDP的协议格式https://blog.csdn.net/zzy734437202/article/details/135185783

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

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

相关文章

数据库管理-第127期 LSM Tree(202301225)

数据库管理-第127期 LSM Tree(202301225) 说起分布式数据库,绕不开的一个话题就是LSM Tree,全称为log-structured merge-tree,回到吕海波老师授权过的那句话“没搞过Oracle的,但又是数据库圈里的人&#x…

【算法学习】斐波那契数列模型-动态规划

前言 我在算法学习过程中,针对斐波那契数列模型的动态规划的例题进行了一个整理,并且根据标准且可靠一点的动态规划解题思路进行求解类似的动归问题,来达到学习和今后复习的必要。 所谓的斐波那契数列模型,即当前状态的值等于前两…

每日一练2023.12.25——验证身份【PTA】

题目链接 :验证身份 题目要求: 一个合法的身份证号码由17位地区、日期编号和顺序编号加1位校验码组成。校验码的计算规则如下: 首先对前17位数字加权求和,权重分配为:{7,9,10,5&a…

图片转excel:“保留数字格式”在什么场景下该勾

保留数字格式是什么意思呢?顾名思义,就是将转出来的数字保留为数字格式,而不是文本格式。我们知道,OCR程序将图片上的文字识别为电脑可编辑的文字后,如果导入到excel不加处理,则单个数字过长的文字就会被ex…

.net6使用Sejil可视化日志

(关注博主后,在“粉丝专栏”,可免费阅读此文) 之前介绍了这篇.net 5使用LogDashboard_.net 5logdashboard rootpath-CSDN博客 这篇文章将会更加的简单,最终的效果都是可视化日志。 在程序非常庞大的时候&…

Linux bridge开启hairpin模拟测试macvlan vepa模式

看到网上介绍可以通过Linux bridge 开启hairpin方式测试macvlan vepa模式,但是没有找到详细资料。我尝试测试总提示错误信息,无法实现,经过几天的研究,我总算实现模拟测试,记录如下: 参考 1.Linux Macvla…

Flink电商实时数仓(六)

交易域支付成功事务事实表 从topic_db业务数据中筛选支付成功的数据从dwd_trade_order_detail主题中读取订单事实数据、LookUp字典表关联三张表形成支付成功宽表写入 Kafka 支付成功主题 执行步骤 设置ttl,通过Interval join实现左右流的状态管理获取下单明细数据…

LED驱动电源

LED驱动电源 常用电子元器件 TB62726AFG LED SOP-24 文章目录 LED驱动电源前言一、LED驱动电源是什么二、TB62726AFG LED SOP-24总结 前言 LED驱动电源可以根据应用需求采用不同的输入和输出电源类型、电源转换拓扑、调光方式等。常见的LED驱动电源类型包括恒流驱动电源、恒…

c# OpenCvSharp 检测(斑点检测、边缘检测、轮廓检测)(五)

在C#中使用OpenCV进行图像处理时,可以使用不同的算法和函数来实现斑点检测、边缘检测和轮廓检测。 斑点检测边缘检测轮廓检测 一、斑点检测(Blob) 斑点检测是指在图像中找到明亮或暗的小区域(通常表示为斑点)&#…

数据智慧:C#中编程实现自定义计算的Excel数据透视表

前言 数据透视表(Pivot Table)是一种数据分析工具,通常用于对大量数据进行汇总、分析和展示。它可以帮助用户从原始数据中提取关键信息、发现模式和趋势,并以可视化的方式呈现。 在数据透视表中,数据分析师通常希望进…

doris数据模型,06-Aggregate(聚合模型)

聚合模型的特点 将表中的列分为Key和Value。 Key是数据的维度列,比如时间,地区等等。key相同时会发生聚合。 Value是数据的指标列,比如点击量,花费等等。 每个指标列还会有自己的聚合函数,如:sum&#xff…

【开源】基于JAVA语言的企业项目合同信息系统

目录 一、摘要1.1 项目介绍1.2 项目录屏 二、功能模块2.1 数据中心模块2.2 合同审批模块2.3 合同签订模块2.4 合同预警模块2.5 数据可视化模块 三、系统设计3.1 用例设计3.2 数据库设计3.2.1 合同审批表3.2.2 合同签订表3.2.3 合同预警表 四、系统展示五、核心代码5.1 查询合同…

geyser互通服基岩版进不去

Java版需要在服务器安全组开通TCP端口(如果有宝塔,也需要开通) geyser下载好的安装运行也需要开通端口,但是它是UDP的(但是我同时也开启了TCP,可能不需要? Java 版玩家隧道 Java 版玩家使用 T…

使用教程之【SkyWant.[2304]】路由器操作系统,破解移动【Netkeeper】校园网【小白篇】

许多高校目前饱受Netkeeper认证的痛苦,普通路由器无法使用, 教你利用SkyWant的Netkeeper认证软件来使你的SkyWant路由器顺利认证上网,全宿舍又可以合作共赢了! 步骤一:正确连接网线,插电开机 正确连接网…

<meta name=“Keywords“ content=““ >、<meta name=“Description“ content=““ > 等用法解释

今天在看网站代码&#xff0c;发现类似<meta name"Keywords" content"" >、<meta name"Description" content"" >这样的写法&#xff0c;不知道具体代表什么意思&#xff0c;于是上网搜了一下&#xff0c;下面是在网上找到…

计算机组成原理综合6

补码表示&#xff1a; X&#xff1a;1111 1111 1111 1101 Y&#xff1a;1111 1111 1101 1111 Z&#xff1a;0111 1111 1111 1100 转原码表示&#xff1a;从右往左找第一个“1”&#xff0c;左边的所有数值位按位取反 X&#xff1a;1111 1111 1111 1101 1000 0000 00…

学Java的第二天

一、常量 1.值不可以变化的量。 2. 分类&#xff1a; 字符串常量 用双引号括起来的多个字符&#xff0c;可以包含 0、1 或多个&#xff0c;例如 "a" 、 "abc" 、 " 中国 " 整数常量&#xff0c;例如&#xff1a; -10 、 0 、 88 小数常量&…

LeetCode-回文链表(234)

题目描述&#xff1a; 给你一个单链表的头节点 head &#xff0c;请你判断该链表是否为回文链表。如果是&#xff0c;返回 true &#xff1b;否则&#xff0c;返回 false 。 因为这一题是受到876题求链表中间节点的启发&#xff0c;所以在这里也加一下。 876.链表的中间结点…

泛微OA xmlrpcServlet接口任意文件读取漏洞(CNVD-2022-43245)

CNVD-2022-43245 泛微e-cology XmlRpcServlet接口处存在任意文件读取漏洞&#xff0c;攻击者可利用漏洞获取敏感信息。 1.漏洞级别 中危 2.影响范围 e-office < 9.5 202201133.漏洞搜索 fofa 搜索 app"泛微-OA&#xff08;e-cology&#xff09;"4.漏洞复现 …

快速安装方式安装开源OpenSIPS和CP控制界面

OpenSIPS是目前世界上主流的两个SIP软交换引擎(其中另外一个是kamailio)或者SIP信令服务器&#xff08;个人认为是比较正确的称谓&#xff09;。关于Opensips的基础和一些参数配置和安装方式笔者在很久以前的历史文档中有非常多的介绍。最近&#xff0c;很多用户使用OpenSIPS软…