【网络编程】TCP流套接字编程(TCP实现回显服务器)

一.TCP流套字节相关API.

Socket(既能给客户端使用,也能给服务器使用)

构造方法

在这里插入图片描述

基本方法:

在这里插入图片描述

ServerSocket(只能给服务器使用)

构造方法:

在这里插入图片描述

基本方法:

在这里插入图片描述

二.TCP实现回显服务器.

客户端代码示例:

package Demo2;import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;public class TcpEchoClient {private Socket clientSocket =null;public TcpEchoClient(String serverIp,int serverPort) throws IOException {//此处可以把这里的IP和port直接传给socket对象.//由于TCP是有连接的,所以socket中就会保存好这两个信息.clientSocket = new Socket(serverIp,serverPort);}public void start(){System.out.println("客户端启动~~");try(InputStream inputStream = clientSocket.getInputStream();OutputStream outputStream = clientSocket.getOutputStream()) {Scanner scannerConsole = new Scanner(System.in);//从控制台读取数据Scanner scannerNetWork = new Scanner(inputStream);//while(true){//1.从控制台读取数据.System.out.println("->");if(!scannerConsole.hasNext()){break;}String request = scannerConsole.next();PrintWriter printWriter = new PrintWriter(outputStream);//2.把请求发送给服务器. 这里要使用println来发送.为了让发送的请求末尾带有一个换行.printWriter.println(request);//通过flush来主动刷新缓冲区,来确保数据发送到服务器了.printWriter.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();}
}

服务器代码示例:

package Demo2;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;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 pool = Executors.newCachedThreadPool();while(true) {//通过accept方法来接听电话,然后才能进行通信.Socket clientSocket = serverSocket.accept();
//            Thread thread = new Thread(()->{
//                processConnection(clientSocket);
//            });
//            thread.start();pool.submit(new Runnable() {@Overridepublic void run() {processConnection(clientSocket);}});}}//通过这个方法来处理一次连接,连接过程中就会涉及请求响应交互public void processConnection(Socket clientSocket){System.out.printf("[%s:%d] 客户端上线!\n",clientSocket.getInetAddress(),clientSocket.getPort());//循环读取客户端的请求并返回响应try(InputStream inputStream = clientSocket.getInputStream();OutputStream outputStream = clientSocket.getOutputStream()) {Scanner scanner = new Scanner(inputStream);while(true){//可以通过inputStream来读取数据了.//byte[] buffer = new byte[4096];//int n = inputStream.read(buffer);//此处读操作完全可以用read来完成,但是read是把读取到的数据放到一个byte数组之中//后续根据请求处理响应,还需要把数组转化成字符串.//此时就可以使用Scanner来简化这个过程.if(!scanner.hasNext()){//读取完毕,例如客户端断开链接.System.out.printf("[%s %d] 客户端下线!\n",clientSocket.getInetAddress(),clientSocket.getPort());break;}//1.读取请求并解析,此时有一个隐藏的约定,next读的时候要读到空白符才会结束//  因此就要求客户端发来的请求必须带有空白符结尾.比如带有/n或" ".String request = scanner.next();//2.根据请求计算响应.String response = process(request);//3.把相应给客户端.//outputStream.write(response.getBytes(),0,response.getBytes().length);//  通过这种方式可以返回,但是这种方式不方便给返回的响应中添加换行//  此时就可以给outputStream套一层来完成更方便的写入.PrintWriter printWriter = new PrintWriter(outputStream);printWriter.println(response);printWriter.flush();System.out.printf("[%s %d] request : %s ;response : %s ",clientSocket.getInetAddress(),clientSocket.getPort(),request,response);System.out.println();}} catch (IOException e) {throw new RuntimeException(e);}finally {try {clientSocket.close();} catch (IOException e) {throw new RuntimeException(e);}}}public String process(String request){return request;}public static void main(String[] args) throws IOException {TcpEchoServer server = new TcpEchoServer(9090);server.start();}
}

运行结果:
在这里插入图片描述
在这里插入图片描述

代码执行流程:

  1. 服务器启动,阻塞在accept,等待客户端建立连接.
    在这里插入图片描述
  2. 客户端启动.这里的new操作会触发和服务器之间建立连接的操作.此时服务器就会从accept中返回.
    在这里插入图片描述
  3. 服务器解除阻塞,继续向下执行,执行processConnection方法
    在这里插入图片描述执行这个方法,执行到hasNext就会阻塞,此时虽然建立了连接,但是客户端还没有发来任何请求.hasNext阻塞等待到请求到达.
  4. 客户端继续执行到hasNext,等待用户向客户端写入内容.
    在这里插入图片描述
  5. 如果用户真的输入了,就会继续向下执行发送请求等待返回的逻辑.
    在这里插入图片描述这里就会把请求真的发出去,同时客户端等待服务器返回响应,此时next就会阻塞等待.
  6. 服务器从hasNext 返回读取到的请求,构造响应,并把响应返回给客户端.
    在这里插入图片描述此时服务器结束此次循环,开启下一次循环,继续阻塞在hasNext等待下一个请求
  7. 客户端读取到响应,并显示出来.
    在这里插入图片描述此时客户端就会结束此次循环,开启下一次循环,继续阻塞在hasNext等待用户输入下一个请求.

代码注意事项:

    1. flush()方法存在一个内存缓冲区.由于文件IO的操作比较低效,因此就希望IO的次数少一些,等攒到一定程度再进行IO操作.(相当于多次IO合并成一次了). 因此就引入了缓冲区,此时就会出现问题,你输入的数据比较少,数据被存在内存缓冲区了,所以需要我们手动刷新缓冲区.
    1. 如果客户端非常的多,就需要创建多个Socket对象,此时就可能导致系统的资源使用完了,因此需要在Socket执行完毕之后关闭资源.
    1. 引入线程池来解决频繁的创建销毁线程.
    1. 如果有多个客户端建立请求,并且长时间不销毁
    • 解决方案一:引入协程===>轻量级线程,用户态可以通过手动调度的方式让一个线程并发的做多个任务.
    • 解决方案二:IO多路复用===>这是一个系统内核级别的机制,本质上是让一个线程去处理多个Socket对象 (这些Socket数据并非是同一时刻都需要处理).

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

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

相关文章

【AI 测试】自然语言处理(NLP)类项目如何测试

目录 NLP类项目需要的技能针对NLP领域大模型的评测任务及评价指标设计如何开展测试一、准确性评测实例二、稳定性评测实例三、效率评测实例四、执行测试注意事项以下是摘自某招聘网站的AI 测试工作职责: 负责NLP等领域大模型评测任务及评价指标的设计与制定;跟进业内大模型技…

一个char类型数字转字符串后引起的惨案

问题现象 嵌入式开发平台&#xff0c;交叉编译链比较老&#xff0c;还不支持 C11 的 to_string 写法&#xff0c;此时想通过模板方式&#xff0c;构造一个通用的 toString 接口&#xff0c;采用了 ostringstream &#xff0c;就出现了问题。 模板接口如下 template <type…

2 逻辑斯蒂回归(分类)

目录 1 理论 逻辑回归假设数据服从伯努利分布&#xff08;二分类&#xff09;,通过极大化似然函数的方法&#xff0c;运用梯度下降来求解参数&#xff0c;来达到将数据二分类的目的。 逻辑斯蒂回归&#xff08;Logistic Regression&#xff09;是一种用于解决分类问题的…

esp32-通过wifi使用timelib库同步时间(三)

库的安装 本文基于platformIO&#xff0c;安装较为简单如下图 实例代码 完整代码如下&#xff0c;如果时间获取超时请使用time1.aliyun.com获取时间。 /** Time_NTP.pde* Example showing time sync to NTP time source** This sketch uses the Ethernet library*/#include …

Kafka入门介绍+集群部署+简单使用

Kafka入门介绍集群部署简单使用 简介核心概念Broker&#xff08;服务节点/实例&#xff09;Producer&#xff08;生产者&#xff09;Topic&#xff08;主题&#xff09;Partition&#xff08;分区&#xff09;Consumer&#xff08;消费者&#xff09;和Consumer Group&#xff…

shell 脚本常用 逻辑判断符 与 || 或 ! 非

shell 脚本常用 逻辑判断符 文章目录 1、&& 逻辑与2、|| 逻辑或3、! 逻辑非 – 1、&& 逻辑与 只有两个都是真&#xff0c;结果才是真 如果第一个式子为false&#xff0c;则不会执行后面 2、|| 逻辑或 一真则真 如果左端为真&#xff0c;则右端不需要再进行…

超级好用的C++实用库之字节流解析器

概述 字节流解析器是一种软件组件&#xff0c;它负责将接收到的原始二进制数据&#xff08;字节流&#xff09;转换为有意义的信息结构或格式。在计算机网络、文件处理和数据通信中&#xff0c;字节流是最基本的数据传输形式&#xff0c;但这些原始字节对于应用程序通常是没有直…

对组合模式的理解

目录 一、场景1、题目描述 【[案例来源](https://kamacoder.com/problempage.php?pid1090)】2、输入描述3、输出描述4、输入示例5、输出示例 二、实现&#xff08;假的组合模式&#xff09;1、代码2、为什么上面的写法是假的组合模式&#xff1f; 三、实现&#xff08;真的组合…

文本生成任务的评价方法BLEU 和 ROUGE

BLEU 是 2002 年提出的&#xff0c;而 ROUGE 是 2003 年提出的。这两种指标虽然存在着一些问题&#xff0c;但是仍然是比较主流的评价指标。 BLUE BLEU 的全称是 Bilingual evaluation understudy&#xff0c;BLEU 的分数取值范围是 0&#xff5e;1&#xff0c;分数越接近1&a…

使用new 关键字调用函数,创建对象的过程中做了什么

使用new 关键字调用函数&#xff0c;创建对象的过程中做了什么 使用 new关键字创建对象的过程大致可以分为以下几个步骤&#xff1a; 创建空对象&#xff1a;首先&#xff0c;new操作符会创建一个空对象&#xff0c;这个对象的隐式原型__proto__属性会被设置为构造函数的显示原…

YOLOv9改进策略 | 细节创新篇 | 迭代注意力特征融合AFF机制创新RepNCSPELAN4

一、本文介绍 本文给大家带来的改进机制是AFF&#xff08;迭代注意力特征融合&#xff09;&#xff0c;其主要思想是通过改善特征融合过程来提高检测精度。传统的特征融合方法如加法或串联简单&#xff0c;未考虑到特定对象的融合适用性。iAFF通过引入多尺度通道注意力模块(我…

搭建vue3组件库(一):Monorepo项目搭建

Monorepo Monorepo 是一种项目代码管理方式&#xff0c;指单个仓库中管理多个项目&#xff0c;有助于简化代码共享、版本控制、构建和部署等方面的复杂性&#xff0c;并提供更好的可重用性和协作性。 pnpm pnpm 全称 performant npm&#xff0c;意思为 高性能的 npm。pnpm 由…

mysql面试题六(视图,存储过程,触发器)

目录 1.什么是视图 视图的特点 视图的创建与使用 视图的用途与优势 注意事项 2.什么是存储过程 存储过程的特点 存储过程的创建与调用 存储过程的使用场景 注意事项 3.什么是触发器 触发器的特点 触发器的创建与管理 触发器的使用场景 注意事项 1.什么是视图 在…

算法打卡day52|单调栈篇03| 84.柱状图中最大的矩形

算法题 Leetcode 84.柱状图中最大的矩形 题目链接:84.柱状图中最大的矩形 大佬视频讲解&#xff1a;84.柱状图中最大的矩形视频讲解 个人思路 这题和接雨水是相似的题目&#xff0c;原理上基本相同&#xff0c;也是可以用双指针和单调栈解决&#xff0c;只是有些细节不同。…

深度学习之目标检测从入门到精通——json转yolo格式

记录点&#xff1a; import json import osname2id {person:0,helmet:1,Fire extinguisher:2,Hook:3,Gas cylinder:4}def convert(img_size, box):dw 1./(img_size[0])dh 1./(img_size[1])x (box[0] box[2])/2.0 - 1y (box[1] box[3])/2.0 - 1w box[2] - box[0]h box…

23种设计模式之行为模式篇

三、行为模式 这类模式主要关注对象之间的通信&#xff0c;尤其是它们之间进行通信的方式和时机。 包括&#xff1a; 策略模式&#xff08;Strategy&#xff09;模板方法模式&#xff08;Template Method&#xff09;观察者模式&#xff08;Observer&#xff09;迭代器模式&…

jtop安装

一、安装依赖环境 sudo apt-get install git cmake sudo apt-get install python3-dev sudo apt-get install libhdf5-serial-dev hdf5-tools sudo apt-get install libatlas-base-dev gfortran二、pip3安装 sudo apt-get update sudo apt-get upgrade sudo apt-get install …

「High Cry」Solution

简述题意 给定长度为 n n n 的数组 n n n&#xff0c;求出有多少个区间满足区间或大于区间最大值。 n ≤ 2 1 0 5 n \le 2 \times 10^5 n≤2105 思路 从区间入手肯定不好做&#xff0c;考虑从最大值入手。 注意到一个区间&#xff0c;其肯定有一个最大值 a i a_i ai​&…

【rust简单工具理解】

1.map方法 map这个闭包的本质就是映射 let numbers vec![1, 2, 3, 4, 5]; let numbers_f64: Vec<f64> numbers.into_iter().map(|&x| x as f64).collect(); println!("{:?}", numbers_f64); // 输出: [1.0, 2.0, 3.0, 4.0, 5.0]2.and_then and_then …

锦瑟香也MYLOVE:音质与颜值俱佳,入坑HiFi的热门好物!

当下尽管无线耳机大行其道&#xff0c;但有线耳机依旧保有其独特的魅力&#xff0c;特别是在音质表现上&#xff0c;它们拥有无线耳机难以企及的优势。如果对音质要求很高的话&#xff0c;口袋里还是少不了一副有线耳机。国产品牌中就有许多性价比高的有线耳机&#xff0c;它们…