JAVAEE值网络编程（2）_TCP流套接字及通信模型、TCP网络编程及代码实例

前言

 在上一节内容中，我们介绍了什么是套接字，以及使用UDP数据报套接字网络编程， 最后我们还介绍了Java数据报套接字通信模型以及相关代码实例。在这一节我们将会介绍TCP流套接字编程。

一、流套接字及通信模型

1.1 TCP套接字

 TCP，即Transmission Control Protocol（传输控制协议），是传输层协议。

TCP主要特点：(会在后续单独章节中详细介绍)

  1. 有连接
  2. 可靠传输
  3. 面向字节流
  4. 有接收、发送缓冲区
  5. 大小不限

 对于字节流来说，可以简单的理解为，传输数据是基于IO流，流式数据的特征就是在IO流没有关闭的情况下，是无边界的数据，可以多次发送，也可以分开多次接收。

1.2 原始套接字

 原始套接字用于自定义传输层协议，用于读写内核没有处理的IP协议数据。

1.3 Java流套接字通信模型

在这里插入图片描述
注意事项：

  1. 客户端和服务端：开发时，经常是基于一个主机开启两个进程作为客户端和服务端，但真实的场景，一般都是不同主机。
  2. 注意目的IP和目的端口号，标识了一次数据传输时要发送数据的终点主机和进程
  3. Socket编程我们是使用流套接字和数据报套接字，基于传输层的TCP或UDP协议，但应用层协议也需要考虑。
  4. 端口占用问题：如果一个进程A已经绑定了一个端口，再启动一个进程B绑定该端口，就会报错，这种情况也叫端口被占用。
  5. 解决端口被占用的问题：
    如果占用端口的进程A不需要运行，就可以关闭A后，再启动需要绑定该端口的进程B；
    如果需要运行A进程，则可以修改进程B的绑定端口，换为其他没有使用的端口。

二、TCP流套接字编程

2.1 ServerSocket API

 ServerSocket 是创建TCP服务端Socket的API，ServerSocket构造方法如下：
在这里插入图片描述
 另外，ServerSocket 相关方法如下：
在这里插入图片描述

2.2 Socket API

 Socket 是客户端Socket，或服务端中接收到客户端建立连接（accept方法）的请求后，返回的服务端Socket。不管是客户端还是服务端Socket，都是双方建立连接以后，保存的对端信息，及用来与对方收发数据的。
 Socket的构造方法如下：
在这里插入图片描述
 Socket相关方法：
在这里插入图片描述

2.3 TCP中的长短连接

TCP发送数据时，需要先建立连接，什么时候关闭连接就决定是短连接还是长连接：

短连接：每次接收到数据并返回响应后，都关闭连接，短连接只能一次收发数据。
长连接：不关闭连接，一直保持连接状态，双方不停的收发数据，长连接可以多次收发数据。

TCP长短连接对比：

  1. 建立连接、关闭连接的耗时：短连接每次请求、响应都需要建立连接，关闭连接；而长连接只需要第一次建立连接，之后的请求、响应都可以直接传输。相对来说建立连接，关闭连接也是要耗时的，长连接效率更高。
  2. 主动发送请求不同：短连接一般是客户端主动向服务端发送请求；而长连接可以是客户端主动发送请求，也可以是服务端主动发。
  3. 两者的使用场景有不同：短连接适用于客户端请求频率不高的场景，如浏览网页等。长连接适用于客户端与服务端通信频繁的场景，如聊天室，实时游戏等。

三、代码实例

3.1 TCP 客户端

package network;import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.lang.ref.SoftReference;
import java.net.Socket;
import java.util.Scanner;/*** @author Zhang* @date 2024/5/2115:13* @Description:*/
public class TcpEchoClient {private Socket socket = null;public TcpEchoClient(String serverIP,int serverPort) throws IOException {// 此时，需要在创建 Socket 的同时，和服务器”建立连接“，此时就得告诉 Socket 服务器在哪里socket = new Socket(serverIP,serverPort);}public void start(){Scanner scanner = new Scanner(System.in);try(InputStream  inputStream = socket.getInputStream();OutputStream outputStream = socket.getOutputStream()){PrintWriter writer = new PrintWriter(outputStream);Scanner scannerNetwork = new Scanner(inputStream);while (true){// 1. 从控制台读取用户输入的内容System.out.print("-->");String request = scanner.next();// 2. 把字符串作为请求，发给服务器//    这里用println，是为了让后后面请求带上换行，也就是和服务器读取请求，scanner.next 呼应writer.println(request);writer.flush();// 3. 读取服务器返回的响应String response = scannerNetwork.next();// 4. 在界面上显示内容System.out.println(response);}} catch (IOException e) {throw new RuntimeException(e);}}public static void main(String[] args) throws IOException {TcpEchoClient client = new TcpEchoClient("127.0.0.1",9090);client.start();}
}

3.2 TCP 服务端

package network;import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;/*** @author Zhang* @date 2024/5/2115:13* @Description:*/
public class TcpEchoServer {private ServerSocket serverSocket  = null;public TcpEchoServer(int port) throws IOException {serverSocket = new ServerSocket(port);// 指定端口号}public void start() throws IOException {System.out.println("服务器启动！");ExecutorService service = Executors.newCachedThreadPool();  //创建线程池while (true){//通过 accept 方法，把内核中已经建立好的连接那回到应用程序中Socket clientSocket = serverSocket.accept();/***  此处不能直接调用processConnection，这会导致服务器不能处理多个客户端，通过创建新的线程来调用是更合理的方法*             Thread t = new Thread(()->{*                 try {*                     processConnection(clientSocket);*                 } catch (IOException e) {*                     throw new RuntimeException(e);*                 }*             });*            t.start();*///使用创建线程的方式开销会比较大，此处我们使用线程池的方式service.submit(new Runnable() {@Overridepublic void run() {try {processConnection(clientSocket);} catch (IOException e) {throw new RuntimeException(e);}}});}}// 通过这个方法，来处理当前的连接private void processConnection(Socket clientSocket) throws IOException {//进入方法，先打印一个日志System.out.printf("[%s:%d] 客户端上线\n",clientSocket.getInetAddress(),clientSocket.getPort());//InputStream 和OutputStream就是在字节流，可以借助这两个对象，完成数据的“发送”和“接收”//通过InputStream 进行read 操作，就是“接收”操作（站在CPU角度）//通过OutputStream 进行 writ额操作，就是“发送”操作。try(InputStream inputStream = clientSocket.getInputStream();OutputStream outputStream = clientSocket.getOutputStream()){//使用try（）方式，避免后续使用完了流对象，忘记关闭//由于客户端发来的可能是“多条数据”，针对对条数据，进行循环处理while (true){Scanner scanner = new Scanner(inputStream);if (!scanner.hasNext()){//连接断开了，此时循环就应该结束System.out.printf("[%s:%d] 客户端下线!\n",clientSocket.getInetAddress(),clientSocket.getPort());break;}// 1. 读取请求并解析， 此处就以next来作为读取请求的方式，next 的规则：读取到“空白符”就返回。String request = scanner.next();// 2. 根据请求，计算响应String response = process(request);//3. 把响应写回客户端//     方式一：可以把String转成字符数组，写入到OutputStream//      方式二：使用PrintWriter 把OutputStream 包裹一下，来写入字符串PrintWriter printWriter = new PrintWriter(outputStream);printWriter.println(response);  //此处的打印是写入到outputStream 对应的流对象中，也就是写入到 clientSocketprintWriter.flush();  //刷新缓冲区，如果没有此操作，数据仍然可能在内存中，没有被写入网卡// 4.打印一下这次请求交互的内容System.out.printf("[%s:%d] req=%s resp=%s\n",clientSocket.getInetAddress(),clientSocket.getPort(),request,response);}}catch (IOException e){e.printStackTrace();}finally {//在这个地方进行clientSocket的关闭，processConnection就是处理一个连接，如果这个方法执行完毕，这个连接也就处理完了clientSocket.close();}}public String process(String request){// 此处也是写的服务器，响应和请求一样return request;}public static void main(String[] args) throws IOException {TcpEchoServer server = new TcpEchoServer(9090);server.start();}
}

启动客户端和服务器

运行结果：

//客户端发送请求
TcpEchoClient：-->张三
张三
-->
----------------------------------
//服务器响应
TcpEchoServer：服务器启动！
[/127.0.0.1:60107] 客户端上线
[/127.0.0.1:60107] req=张三 resp=张三

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

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

相关文章

云计算-高级云资源配置（Advanced Cloud Provisioning）

云计算-高级云资源配置（Advanced Cloud Provisioning）

向Bucket添加公共访问（Adding Public Access to Bucket） 在模块5中，我们已经看到如何使用CloudFormation创建和更新一个Bucket。现在我们将进一步更新该Bucket，添加公共访问权限。我们在模块5中使用的模板（third_templ…
阅读更多...
内网安全--隧道技术代理技术

内网安全--隧道技术代理技术

注:本文仅做技术交流,请勿非法破坏... 目录 项目: 1-Ngrok 用法 2-Frp 用法 3-Nps 用法 4-Spp 用法 工具: windows下: Proxifier(推荐~) Sockscap ccproxy Linux下: Proxychains 用法 http://t.csdnimg.cn/88Ew7 隧道技术：解决不出网协议上线的问…
阅读更多...
TikTok运营必看|7大广告类型及特点

TikTok运营必看|7大广告类型及特点

TikTok广告是品牌或创作者付费向特定目标受众展示的推广内容（通常是全屏视频）。TikTok 上的广告是一种社交媒体营销形式，通常旨在提高广告商的知名度或销售特定产品或服务。 就 TikTok广告投放而言，其组织层级分为三个层级&#x…
阅读更多...
【Java】static 修饰成员方法

【Java】static 修饰成员方法

static 修饰成员方法 简介 应用 static 修饰成员方法 1.static 修饰成员方法2.内存原理3.main函数4.类方法的应用 1.static 修饰成员方法 测试类： package suziguang_d2_staticdemo;public class Test {public static void main(String[] args) {// 1.类方法使用/…
阅读更多...
【成品设计】基于USB接口的指纹图像采集与处理系统设计

【成品设计】基于USB接口的指纹图像采集与处理系统设计

《基于USB接口的指纹图像采集与处理系统设计》 所需器件： STM32F429阿波罗开发板。ATK-AS608 模块指纹识别模块。USB转TTL模块。 整体功能： 实现指纹的采集录入。实现指纹的对比，并展示对比结果，用LED灯和蜂鸣器提示。指纹信息…
阅读更多...
app自动识别ios或安卓手机,微信浏览器,并下载相应的apk安装包

app自动识别ios或安卓手机,微信浏览器,并下载相应的apk安装包

来源是安卓下载界面显示: 来源是IOS下载界面显示: 源码 <!DOCTYPE html> <html lang="en"><head
阅读更多...
微软新AI工具 Recall 被白帽公开锤了？

微软新AI工具 Recall 被白帽公开锤了？

近日&#xff0c;一些网络安全研究人员演示了恶意软件是如何成功窃取 Windows Recall 工具收集到的数据。 2024年5月21日&#xff0c;微软发布全新的“CopilotPC”&#xff0c;这类 AI PC 通过与高通的最新芯片合作&#xff0c;实现了一个叫做“Recall”的功能。借助这个人工智…
阅读更多...
5.31.8 学习深度特征以实现判别定位

5.31.8 学习深度特征以实现判别定位

1. 介绍 尽管没有对物体的位置提供监督，但卷积神经网络 (CNN) 各层的卷积单元实际上可以充当物体检测器。尽管卷积层具有这种出色的物体定位能力，但当使用全连接层进行分类时，这种能力就会丧失。最近，一些流行的全卷积神经网络，如 Network in Network (NIN) [13] 和 Goog…
阅读更多...
Docker大学生看了都会系列（六、Dokcer容器数据卷）

Docker大学生看了都会系列（六、Dokcer容器数据卷）

系列文章目录 第一章 Docker介绍 第二章 2.1 Mac通过Homebrew安装Docker 第二章 2.2 CentOS安装Docker 第三章 Docker常用命令 第四章 常用命令实战 第五章 Docker镜像详解 第六章 Docker容器数据卷 文章目录 一、前言二、环境三、容器数据卷基本介绍3.1 什么是容器数据卷3.2 容…
阅读更多...
nginx--centos安装

nginx--centos安装

参考&#xff1a;https://blog.csdn.net/chang_chunhua/article/details/129298660 下载官网&#xff1a;https://nginx.org/ 选择稳定版本&#xff1a;stable 下载linux版本的&#xff1a; 可以选择直接下载到本地再上传到服务器相对应位置&#xff01; 同时也可以用下载地…
阅读更多...
利用MaxKB+Ollama：搭建智能问答系统_Ubuntu部署maxkb

利用MaxKB+Ollama：搭建智能问答系统_Ubuntu部署maxkb

Docker方式&#xff0c;不建议使用 即使maxKB和ollama在同一目录下&#xff0c;API域名也显示无效。 Ollama下载网址&#xff1a;Download Ollama on Linux Linux下载&#xff1a;curl -fsSL https://ollama.com/install.sh | sh The Ollama API is now available at 127.0.…
阅读更多...
openh264 自适应量化功能源码分析

openh264 自适应量化功能源码分析

openh264 OpenH264是一个开源的H.264/AVC视频编解码器&#xff0c;由Cisco公司发起并贡献了最初的代码基础。它提供了一个用于视频编码和解码的库&#xff0c;支持H.264视频压缩标准&#xff0c;广泛应用于视频会议、流媒体和视频存储等领域。OpenH264是实现H.264编解码功能的…
阅读更多...
【鸿蒙】开发之页面跳转组件—实现页面跳转方法汇总！

【鸿蒙】开发之页面跳转组件—实现页面跳转方法汇总！

①不同 Slice 间跳转&#xff0c;同一个 Ability 中&#xff0c;优点是方便&#xff0c;高效&#xff0c;缺点是业务逻辑复杂度受限。 button.setClickedListener(listener -> present(new SecondAbilitySlice(), new Intent()) );②使用 Intent 借助于 ElementName&#x…
阅读更多...
javascript导入excel文件

javascript导入excel文件

导入文件用到一个 xlsx.core.js 的包。 <!DOCTYPE html> <html lang"en"><head><meta charset"UTF-8"><meta name"viewport" content"widthdevice-width, initial-scale1.0"><script type"tex…
阅读更多...
DSP28335模块配置模板系列——ADC配置模板

DSP28335模块配置模板系列——ADC配置模板

一、配置步骤 1.使能并配置高速时钟HSPCLK、ADC校验 EALLOW;SysCtrlRegs.PCLKCR0.bit.ADCENCLK 1; EDIS;EALLOW;SysCtrlRegs.HISPCP.all ADC_MODCLK; // HSPCLK SYSCLKOUT/(2*ADC_MODCLK)ADC_cal();EDIS; 这里ADC_MODCLK3&#xff0c;所以HSPCLK时钟为150/625Mhz 2.配…
阅读更多...
《TCP/IP网络编程》（第十三章）多种I/O函数（2）

《TCP/IP网络编程》（第十三章）多种I/O函数（2）

使用readv和writev函数可以提高数据通信的效率&#xff0c;它们的功能可以概括为**“对数据进行整合传输及发送”**。 即使用writev函数可以将分散在多个缓冲中的数据一并发送&#xff0c;使用readv函数可以由多个缓冲分别接受&#xff0c;所以适当使用他们可以减少I/O函数的调…
阅读更多...
压力测试-性能指标-Jmeter使用-压力测试报告

压力测试-性能指标-Jmeter使用-压力测试报告

文章目录 1.压测目的2.性能指标3.Jmeter3.1Jmeter使用3.1.1 运行Jmeter3.1.2 添加线程组3.1.3设置HTTP请求3.1.4 设置监视器 3.2 查看Jmeter压测结果3.2.1 查看结果树3.2.2 查看汇总报告3.2.3 查看聚合报告3.2.4 查看汇总图 1.压测目的 内存泄漏&#xff1a;OOM&#xff0c;重…
阅读更多...
Hadoop3：MapReduce源码解读之Map阶段的CombineFileInputFormat切片机制（4）

Hadoop3：MapReduce源码解读之Map阶段的CombineFileInputFormat切片机制（4）

Job那块的断点代码截图省略&#xff0c;直接进入切片逻辑 参考&#xff1a;Hadoop3&#xff1a;MapReduce源码解读之Map阶段的Job任务提交流程&#xff08;1&#xff09; 6、CombineFileInputFormat原理解析 类的继承关系 与TextInputFormat切片机制的区别 框架默认的TextI…
阅读更多...
TPC-H建表语句（MySQL语法）

TPC-H建表语句（MySQL语法）

TPC-H测试集介绍 TPC-H&#xff08;Transaction Processing Performance Council, Standard Specification, Decision Support Benchmark, 简称TPC-H&#xff09;是一个非常权威数据库基准测试程序&#xff0c;由TPC组织制定。 TPC-H定义了一个包含8个表的模式&#xff08;Sc…
阅读更多...
敏捷开发：拥抱变化，持续交付价值的艺术

敏捷开发：拥抱变化，持续交付价值的艺术

目录 敏捷开发&#xff1a;拥抱变化&#xff0c;持续交付价值的艺术 引言 第一部分&#xff1a;敏捷开发是什么&#xff1f; a.定义&#xff1a;敏捷开发的基本概念和核心原则 b.历史&#xff1a;敏捷宣言的诞生和敏捷开发的历史背景 c.价值观&#xff1a;敏捷宣言的12条…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023