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

2024-04-21 03:36
文章标签 实现 服务器 编程 网络 tcp 接字 回显 流套

本文主要是介绍【网络编程】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数据并非是同一时刻都需要处理).

这篇关于【网络编程】TCP流套接字编程(TCP实现回显服务器)的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/922062。

相关文章

SpringBoot集成redisson实现延时队列教程

SpringBoot集成redisson实现延时队列教程

《SpringBoot集成redisson实现延时队列教程》文章介绍了使用Redisson实现延迟队列的完整步骤,包括依赖导入、Redis配置、工具类封装、业务枚举定义、执行器实现、Bean创建、消费... 目录1、先给项目导入Redisson依赖2、配置redis3、创建 RedissonConfig 配
阅读更多...
Python的Darts库实现时间序列预测

Python的Darts库实现时间序列预测

《Python的Darts库实现时间序列预测》Darts一个集统计、机器学习与深度学习模型于一体的Python时间序列预测库,本文主要介绍了Python的Darts库实现时间序列预测,感兴趣的可以了解... 目录目录一、什么是 Darts？二、安装与基本配置安装 Darts导入基础模块三、时间序列数据结构与
阅读更多...
Python使用FastAPI实现大文件分片上传与断点续传功能

Python使用FastAPI实现大文件分片上传与断点续传功能

《Python使用FastAPI实现大文件分片上传与断点续传功能》大文件直传常遇到超时、网络抖动失败、失败后只能重传的问题,分片上传+断点续传可以把大文件拆成若干小块逐个上传,并在中断后从已完成分片继... 目录一、接口设计二、服务端实现（FastAPI）2.1 运行环境2.2 目录结构建议2.3 serv
阅读更多...
C#实现千万数据秒级导入的代码

C#实现千万数据秒级导入的代码

《C#实现千万数据秒级导入的代码》在实际开发中excel导入很常见,现代社会中很容易遇到大数据处理业务,所以本文我就给大家分享一下千万数据秒级导入怎么实现,文中有详细的代码示例供大家参考,需要的朋友可... 目录前言一、数据存储二、处理逻辑优化前代码处理逻辑优化后的代码总结前言在实际开发中excel导入很
阅读更多...
SpringBoot+RustFS 实现文件切片极速上传的实例代码

SpringBoot+RustFS 实现文件切片极速上传的实例代码

《SpringBoot+RustFS实现文件切片极速上传的实例代码》本文介绍利用SpringBoot和RustFS构建高性能文件切片上传系统,实现大文件秒传、断点续传和分片上传等功能,具有一定的参考... 目录一、为什么选择 RustFS + SpringBoot？二、环境准备与部署2.1 安装 RustF
阅读更多...
Nginx部署HTTP/3的实现步骤

Nginx部署HTTP/3的实现步骤

《Nginx部署HTTP/3的实现步骤》本文介绍了在Nginx中部署HTTP/3的详细步骤,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学... 目录前提条件第一步：安装必要的依赖库第二步：获取并构建 BoringSSL第三步：获取 Nginx
阅读更多...
MySQL的JDBC编程详解

MySQL的JDBC编程详解

《MySQL的JDBC编程详解》：本文主要介绍MySQL的JDBC编程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录前言一、前置知识1. 引入依赖2. 认识 url二、JDBC 操作流程1. JDBC 的写操作2. JDBC 的读操作总结前言本文介绍了mysq
阅读更多...
MyBatis Plus实现时间字段自动填充的完整方案

MyBatis Plus实现时间字段自动填充的完整方案

《MyBatisPlus实现时间字段自动填充的完整方案》在日常开发中,我们经常需要记录数据的创建时间和更新时间,传统的做法是在每次插入或更新操作时手动设置这些时间字段,这种方式不仅繁琐,还容易遗漏,... 目录前言解决目标技术栈实现步骤1. 实体类注解配置2. 创建元数据处理器3. 服务层代码优化填充机制详
阅读更多...
Python实现Excel批量样式修改器(附完整代码)

Python实现Excel批量样式修改器(附完整代码)

《Python实现Excel批量样式修改器(附完整代码)》这篇文章主要为大家详细介绍了如何使用Python实现一个Excel批量样式修改器,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一... 目录前言功能特性核心功能界面特性系统要求安装说明使用指南基本操作流程高级功能技术实现核心技术栈关键函
阅读更多...
Java实现字节字符转bcd编码

Java实现字节字符转bcd编码

《Java实现字节字符转bcd编码》BCD是一种将十进制数字编码为二进制的表示方式,常用于数字显示和存储,本文将介绍如何在Java中实现字节字符转BCD码的过程,需要的小伙伴可以了解下... 目录前言BCD码是什么Java实现字节转bcd编码方法补充总结前言BCD码（Binary-Coded Decima
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2