网络编程TCP

White graces:个人主页

🙉专栏推荐:Java入门知识🙉

🙉 内容推荐:Java网络编程(下)🙉

🐹今日诗词: 壮士当唱大风哥, 宵小之徒能几何?🐹


⛳️点赞 ☀️收藏⭐️关注💬卑微小博主🙏

⛳️点赞 ☀️收藏⭐️关注💬卑微小博主🙏


目录

TCP字节流套接字编程

回显服务器

服务端(有点问题的)

空白符问题

客户端

代码问题

原因

解决办法一

服务器(没问题的代码)

解决方法二

线程池的服务端代码(没问题的代码)

美图分享


TCP字节流套接字编程

TCP也有两个类用于网络编程

SeverSocket: 用于TCP字节数据进行网络通信, 创建了TCP服务端API, 专门用于服务器的

Socket: 客户端和服务器都能够使用, 客户端使用可以建立和服务器的通信

服务器可使用可以监听客户端的连接请求

值得注意的是: TCP是字节流传输, 传输单位是字节(byte), 不需要向UDP那样专门搞出一个类来用于传输数据报

SeverSocket类

构造方法: SeverSocket(int Port)

SeverSocket函数方法

函数方法

Socket类

构造方法: Socket(String host, int port)

Socket函数方法

回显服务器

服务端(有点问题的)

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;public class TcpSever {private ServerSocket serverSocket = null;public TcpSever(int port) throws IOException {serverSocket = new ServerSocket(port);}public void start() throws IOException {System.out.println("服务器!启动");while (true) {Socket clientsocket = serverSocket.accept();//这里和UDP不一样,UDP是直接接收请求, 而TCP需要先和客户端建立连接, 才能进一步处理请求processmethod(clientsocket);//客户端请求结束时应该调用close方法,释放资源, 所以在processmethod方法里调用close方法关闭}}private void processmethod(Socket clientsocket) throws IOException {System.out.printf("[%s:%d]客户端成功连接服务器\n", clientsocket.getInetAddress(), clientsocket.getPort());//打印日志, 接下来就是响应请求了try (OutputStream outputStream = clientsocket.getOutputStream();InputStream inputStream = clientsocket.getInputStream()){//从clientsocket中获取流对象, 对数据进一步处理, 把他们放到try()里,结束会自动调用close方法Scanner scanner = new Scanner(inputStream);while (true) {//客户端建立连接后, 可能会发送很多请求, 需要循环处理//inputStream.read();//读取请求,这样就得到了字符数组,接下来转成字符串, 这样写很麻烦我们可以使用Scanner一步到位if (!scanner.hasNext()) {//读取前判断有没有数据, 没有数据说明连接断开了System.out.printf("[%s:%d]客户端断开连接\n", clientsocket.getInetAddress(), clientsocket.getPort());break;}String request = scanner.next();//读取请求, next()方法读取数据是读到空白符String response = process(request);//根据请求计算响应System.out.printf("[%s:%d] request = %s response = %s",clientsocket.getInetAddress(), clientsocket.getPort(), request, response);//打印日志outputStream.write(response.getBytes());//将响应数据写回客户端}} finally {clientsocket.close();//客户端断开连接调用close方法释放资源}}private String process(String request) {//回显服务器,前面next()方法读取数据读到空白符停止,当我们把数据写回客户端是要把空白符加上return request + "\n";}public static void main(String[] args) throws IOException {TcpSever tcpSever = new TcpSever(9090);tcpSever.start();}
}

空白符问题

空白符是一类分隔符的统称, 不是一个空格, 常见空白符有很多

TCP字节流传输常见的问题就是空白符问题

发送请求和读取请求时都需要考虑分隔符

因为发送的数据带有空白符,当使用next方法读取数据时, 会忽略空白符, 因此当我们向客户端写回请求时需要把空白符加回去, 保持格式的统一性

客户端

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Scanner;public class TcpClient {private Socket socket = null;public TcpClient(String SeverIP, int SeverPort) throws IOException {socket = new Socket(SeverIP, SeverPort);}private void start() throws IOException {System.out.println("客户端, 启动!");Scanner scanner = new Scanner(System.in);try (InputStream inputStream = socket.getInputStream();OutputStream outputStream = socket.getOutputStream()) {//获取流对象, 把数据传入流对象之后, 等待服务器响应即可, 这里和UDP不同, UDP是把数据打包发送到服务器//而TCP客户端已经和服务器建立连接了, 中间通道已经打通, 将数据传入流对象等待响应即可//流对象扮演的角色就像是中间商, 服务器和客户端的操作都要经过流对象Scanner scannerinpuStream = new Scanner(inputStream);while (true) {System.out.print("请输入你要发送的请求: ");String request = scanner.next();request += "\n";//next方法会忽略\n, 为了保持服务端next方法一致, 手动加上\noutputStream.write(request.getBytes());//将请求写到流对象中if(!scannerinpuStream.hasNext()) {//没有数据说明读取完毕了break;}String response = scannerinpuStream.next();//从服务器获取响应System.out.println(response);//将数据打印出来}}}public static void main(String[] args) throws IOException {TcpClient tcpClient = new TcpClient("127.0.0.1", 9090);tcpClient.start();}
}

运行效果

代码问题

这种写法只能对一个客户端提供服务,  当我们启动多个客户端时

原因

解决办法一

把processmethod方法放到多线程的环境下运行


服务器(没问题的代码)

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;public class TcpSever {private ServerSocket serverSocket = null;public TcpSever(int port) throws IOException {serverSocket = new ServerSocket(port);}public void start() throws IOException {System.out.println("服务器!启动");while (true) {Socket clientsocket = serverSocket.accept();//这里和UDP不一样,UDP是直接接收请求, 而TCP需要先和客户端建立连接, 才能进一步处理请求Thread thread = new Thread(() -> {try {processmethod(clientsocket);//客户端请求结束时应该调用close方法,释放资源, 所以在processmethod方法里调用close方法关闭} catch (IOException e) {throw new RuntimeException(e);}});thread.start();}}private void processmethod(Socket clientsocket) throws IOException {System.out.printf("[%s:%d]客户端成功连接服务器\n", clientsocket.getInetAddress(), clientsocket.getPort());//打印日志, 接下来就是响应请求了try (OutputStream outputStream = clientsocket.getOutputStream();InputStream inputStream = clientsocket.getInputStream()){//从clientsocket中获取流对象, 对数据进一步处理, 把他们放到try()里,结束会自动调用close方法Scanner scanner = new Scanner(inputStream);while (true) {//客户端建立连接后, 可能会发送很多请求, 需要循环处理//inputStream.read();//读取请求,这样就得到了字符数组,接下来转成字符串, 这样写很麻烦我们可以使用Scanner一步到位if (!scanner.hasNext()) {//读取前判断有没有数据, 没有数据说明连接断开了System.out.printf("[%s:%d]客户端断开连接\n", clientsocket.getInetAddress(), clientsocket.getPort());break;}String request = scanner.next();//读取请求, next()方法读取数据是读到空白符String response = process(request);//根据请求计算响应System.out.printf("[%s:%d] request = %s response = %s",clientsocket.getInetAddress(), clientsocket.getPort(), request, response);//打印日志outputStream.write(response.getBytes());//将响应数据写回客户端}} finally {clientsocket.close();//客户端断开连接调用close方法释放资源}}private String process(String request) {//回显服务器,前面next()方法读取数据读到空白符停止,当我们把数据写回客户端是要把空白符加上return request + "\n";}public static void main(String[] args) throws IOException {TcpSever tcpSever = new TcpSever(9090);tcpSever.start();}
}

解决方法二

把代码放到线程池中, 这种方法更合适, 不仅解决了只能连接一个客户端, 又能减少线程创建销毁的开销

线程池的服务端代码(没问题的代码)

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;public class TcpSever {private ServerSocket serverSocket = null;public TcpSever(int port) throws IOException {serverSocket = new ServerSocket(port);}public void start() throws IOException {System.out.println("服务器!启动");ExecutorService pool = Executors.newCachedThreadPool();//这个线程池可以自动扩容while (true) {Socket clientsocket = serverSocket.accept();//这里和UDP不一样,UDP是直接接收请求, 而TCP需要先和客户端建立连接, 才能进一步处理请求pool.submit(new Runnable() {@Overridepublic void run() {try {processmethod(clientsocket);//客户端请求结束时应该调用close方法,释放资源, 所以在processmethod方法里调用close方法关闭} catch (IOException e) {throw new RuntimeException(e);}}});}}private void processmethod(Socket clientsocket) throws IOException {System.out.printf("[%s:%d]客户端成功连接服务器\n", clientsocket.getInetAddress(), clientsocket.getPort());//打印日志, 接下来就是响应请求了try (OutputStream outputStream = clientsocket.getOutputStream();InputStream inputStream = clientsocket.getInputStream()){//从clientsocket中获取流对象, 对数据进一步处理, 把他们放到try()里,结束会自动调用close方法Scanner scanner = new Scanner(inputStream);while (true) {//客户端建立连接后, 可能会发送很多请求, 需要循环处理//inputStream.read();//读取请求,这样就得到了字符数组,接下来转成字符串, 这样写很麻烦我们可以使用Scanner一步到位if (!scanner.hasNext()) {//读取前判断有没有数据, 没有数据说明连接断开了System.out.printf("[%s:%d]客户端断开连接\n", clientsocket.getInetAddress(), clientsocket.getPort());break;}String request = scanner.next();//读取请求, next()方法读取数据是读到空白符String response = process(request);//根据请求计算响应System.out.printf("[%s:%d] request = %s response = %s",clientsocket.getInetAddress(), clientsocket.getPort(), request, response);//打印日志outputStream.write(response.getBytes());//将响应数据写回客户端}} finally {clientsocket.close();//客户端断开连接调用close方法释放资源}}private String process(String request) {//回显服务器,前面next()方法读取数据读到空白符停止,当我们把数据写回客户端是要把空白符加上return request + "\n";}public static void main(String[] args) throws IOException {TcpSever tcpSever = new TcpSever(9090);tcpSever.start();}
}


美图分享

✨🎆谢谢你的阅读和耐心!祝愿你在编程的道路上取得更多的成功与喜悦!"🎆✨🎄

⭐️点赞收藏加关注,学习知识不迷路⭐️

🎉✔️💪🎉✔️💪🎉✔️💪🎉✔️💪🎉

👍😏⛳️点赞☀️收藏⭐️关注😏👍

👍😏⛳️点赞☀️收藏⭐️关注😏👍

👍😏⛳️点赞☀️收藏⭐️关注😏👍

🙆‍♂️🙆‍♂️🙆‍♂️🙆‍♂️🙆‍♂️🙆‍♂️🙆‍♂️🙆‍♂️🙆‍♂️🙆‍♂️🙆‍♂️🙆‍♂️🙆‍♂️

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

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

相关文章

CentOS7单用户模式,救援模式操作记录

CentOS7单用户模式,救援模式操作记录 1. 单用户模式 单用户模式进入不需要密码,无网络连接,拥有root权限,禁止远程登陆。一般用于用于系统维护,例如忘记root密码后可以通过进入单用户模式进行重置。 开机启动&#…

数据结构 实验 1

题目一:用线性表实现文具店的货品管理问题 问题描述:在文具店的日常经营过程中,存在对各种文具的管理问题。当库存文具不足或缺货时,需要进货。日常销售时需要出库。当盘点货物时,需要查询货物信息。请根据这些要求编…

使用低代码系统的意义与价值主要体现在哪里?

使用低代码系统的意义与价值主要体现在以下几个方面,这些观点基于驰骋低代码设计者的专业洞察和行业经验: 快速原型创建: 低代码平台通过提供图形化界面和预构建的模块,极大地加速了系统原型的创建过程。这意味着企业能够更快地验…

60 关于 SegmentFault 的一些场景 (1)

前言 呵呵 此问题主要是来自于 帖子 月经结贴 -- 《Segmentation Fault in Linux》 这里主要也是 结合了作者的相关 case, 来做的一些 调试分享 当然 很多的情况还是 蛮有意思 本文主要问题如下 1. 访问可执行文件中的 只读数据 2. 访问不存在的虚拟地址 3. 访问内核地址…

嵌入式笔试面试刷题(day16)

文章目录 前言一、PWM波形的占空比计算公式是什么?二、ADC和DAC在嵌入式系统中的应用场景有哪些?三、watchdog定时器的作用及其在系统中的使用是什么?四、JTAG接口在嵌入式开发中的作用是什么?五、实时操作系统(RTOS)的任务调度策…

嵌入式工程师人生提质的十大成长型思维分享

大家好,作为一名嵌入式开发者,很多时候,需要考虑个人未来的发展,人生旅途复杂多变,时常面临各种各样的挑战。如何在这个复杂多变的社会中稳步向前,不断成长,成为每个人都应该思考的问题。实际上,思维方式的差异决定我们应对挑战的能力与成长的速度。 第一:寻找自我坐…

HNCTF2022 REVERSE

[HNCTF 2022 WEEK2]esy_flower 简单花指令 Nop掉 然后整段u c p然后就反汇编 可能反编译的不太对&#xff0c;&#xff0c;看了别人的wp就是ida反编译的有问题 #include<stdio.h> #include<string.h> int main() {int i,j;char ch[]"c~scvdzKCEoDEZ[^roDICU…

NumPy应用(二)

numpy高效的处理数据&#xff0c;提供数组的支持&#xff0c; python 默认没有数组。 pandas 、 scipy 、 matplotlib 都依赖 numpy 。 pandas主要用于数据挖掘&#xff0c;探索&#xff0c;分析 maiplotlib用于作图&#xff0c;可视化 scipy进行数值计算&#xff0c;如&…

微软远程连接工具:Microsoft Remote Desktop for Mac 中文版

Microsoft Remote Desktop 是一款由微软开发的远程桌面连接软件&#xff0c;它允许用户从远程地点连接到远程计算机或虚拟机&#xff0c;并在远程计算机上使用桌面应用程序和文件。 下载地址&#xff1a;https://www.macz.com/mac/5458.html?idOTI2NjQ5Jl8mMjcuMTg2LjEyNi4yMz…

C++进阶之AVL树+模拟实现

目录 目录 一、AVL树的基本概念 1.1 基本概念 二、AVL树的模拟实现 2.1 AVL树节点的定义 2.2 插入操作 2.3 旋转操作 2.4 具体实现 一、AVL树的基本概念 1.1 基本概念 二叉搜索树虽可以缩短查找的效率&#xff0c;但如果数据有序或接近有序二叉搜索树将退化为单支树&…

山东大学软件学院项目实训-创新实训-基于大模型的旅游平台(二十四)- 微服务(4)

目录 8. http客户端Feign 8.1 feign远程调用 8.2 feign自定义配置 8.3 feign性能优化 8.4 feign最佳实践 8. http客户端Feign 8.1 feign远程调用 RestTemplate存在的问题 &#xff1a; 代码可读性差 参数复杂URL难以维护 Feign是声明式的http客户端 使用步骤 &#xf…

飞书API(11):阿里云MaxCompute分区表入库

一、引入 前面入库阿里云 MaxCompute 的数据都是读取之后直接写入&#xff0c;保留数据最新的状态&#xff0c;如果我要保留历史的状态&#xff0c;怎么办呢&#xff1f;MaxCompute 表有一个分区功能&#xff0c;可以自行定义分区。我们可以使用 MaxCompute 表的分区功能&…

Python | A + B问题||

既然是持续性的输入&#xff0c;说明在循环做输入n这个操作&#xff0c;那我们就需要使用到上一节中使用的while while True:try:# 将输入的 N 转换成整数N int(input())except:break 列表 for循环&#xff1a;可遍历列表、字符串、内置的range()函数 for item in list:# …

生产问题临时解决方案

临时解决方案的目标是迅速恢复系统的可用性&#xff0c;确保服务不中断&#xff0c;同时为深入分析和解决根本问题争取时间。以下是一些常见的临时解决方案&#xff1a; 1. 重启服务 重启应用服务器&#xff1a;很多时候&#xff0c;重启可以释放资源&#xff0c;缓解瞬时压力…

Express 框架

1. Express 框架的功能 Express 框架提供了丰富的功能和工具&#xff0c;使开发者能够更轻松地构建 Web 应用程序。以下是 Express 框架的一些主要功能&#xff1a; 路由功能&#xff1a;Express 框架提供了简单易用的路由功能&#xff0c;可以根据不同的 URL 请求来执行不同…

远程自动锁定平面

目录 Ubuntu 系统上 方法一&#xff1a;使用 SSH 重新连接 方法二&#xff1a;解锁当前会话 方法三&#xff1a;通过 SSH 解锁会话 方法四&#xff1a;禁用自动锁屏&#xff08;如果合适&#xff09; windows系统 方法三&#xff1a;修改组策略设置 Ubuntu 系统上 远程…

重生之我要精通JAVA--第七周笔记

文章目录 IO流字符流字符流原理解析flush和close方法 文件拷贝代码文件加密解密修改文件中的数据 缓冲流字节缓冲流字符缓冲流例题 转换流序列化流序列化流/对象操作输出流 反序列化流序列化流/反序列化流的细节汇总打印流字节打印流字符打印流 解压缩流压缩流Commons-io常见方…

网络空间安全数学基础·环

4.1 环与子环 &#xff08;理解&#xff09; 4.2 整环、除环、域 &#xff08;熟练&#xff09; 4.3 环的同态、理想 &#xff08;掌握&#xff09; 4.1 环与子环 定义&#xff1a;设R是一非空集合&#xff0c;在R上定义了加法和乘法两种代数运算&#xff0c; 分别记为ab和a…

122.买卖股票的最佳时机Ⅱ

思考 把题目抽象 1 2 3 4 5 1 2 3 4 5 低买高卖&#xff0c;如果递增可以先不卖&#xff0c;但是一旦递减&#xff0c;比如第五天和第六天&#xff0c;降低了&#xff0c;应该在第五天卖&#xff0c;第六天买 注意特殊情况&#xff0c;如果 1 2 3 4 5 这个没有1中的改变&…

java收徒、java面试辅导、java辅导、java就业辅导

&#x1f497;博主介绍&#xff1a;✌全网粉丝1W,CSDN作者、博客专家、全栈领域优质创作者&#xff0c;博客之星、平台优质作者、专注于Java、小程序技术领域和毕业项目实战✌&#x1f497; &#x1f31f;文末获取源码数据库&#x1f31f; 感兴趣的可以先收藏起来&#xff0c;还…