湛江网站制作公司/河南制作网站公司

湛江网站制作公司,河南制作网站公司,简洁大方网站建设,做网站必须租服务器吗TCP 和 UDP 的区别 在传输层，TCP 协议是有连接的，可靠传输，面向字节流，全双工 而UDP 协议是无连接的，不可靠传输，面向数据报，全双工 有连接和无连接的区别是在进行网络通信的时候，…

TCP 和 UDP 的区别

在传输层，TCP 协议是有连接的，可靠传输，面向字节流，全双工
而UDP 协议是无连接的，不可靠传输，面向数据报，全双工

有连接和无连接的区别是在进行网络通信的时候，通信双方有没有保存对端的地址信息，即假设 A 和 B 进行通信，A 保存了 B 的地址信息，B 也保存了 A 的地址信息，此时双方都知道和谁建立了连接，这就是有连接的通信，在之前的 UDP 数据报套接字编程中就提到过 UDP 是无连接的，所以在发送数据报的时候要加上对端的信息，防止丢包。

可靠传输是通过各种手段来防止丢包的出现，而不可靠传输则没有做任何处理直接把数据报传输过去，但是可靠传输不意味着能 100% 把数据报完整无误地传输给对方，只是尽可能降低丢包发生的概率，并且可靠传输是要使用很多手段来保持的，所以付出的代价相比于不可靠传输要大。

面向字节流就是以字节为单位来进行数据的传输，面向数据报就是以数据报为单位进行数据的传输。

全双工就是通信的双发可以同时给对方发送数据，但是半双工是指双方只有一方可以发送数据。

TCP流套接字 API 介绍

ServerSocket

ServerSocket 是TCP服务端Socket 的API

构造方法：

方法名说明
ServerSocket(int port)创建一个TCP服务端流套接字Socket，并绑定端口号

ServerSocket 方法：

方法名返回值说明
accept()Socket开始监听指定端口（创建时绑定的端口），有客户端连接后，返回一个服务端Socket 对象，并基于该Socket 建立于客户端的连接，否则阻塞等待
close()void关闭此套接字

Socket

Socket 是客户端Socket 或者是 服务端那边收到客户端建立连接的请求（通过 accept() 方法）返回的Socket 对象。

不管是客户端还是服务端的Socket 对象，他们都保留了对端的地址信息，这也是TCP协议有连接的体现。

Socket 构造方法：

方法名说明
Socket(String host, int port)创建一个客户端流套接字Socket,并于对应IP 的主机对应的端口的进程建立连接

Socket 方法：

方法名返回值说明
getInetAddress()InetAddress返回套接字所连接的地址
getInputStream()InputStream返回此套接字的输入流
getOutputStream()OutputStream返回此套接字的输出流

回显服务器

首先在回显服务器的构造方法里初始化我们的ServerSocket

    public TcpEchoServer(int port) throws IOException {serverSocket = new ServerSocket(port);}

然后就是服务器启动运行的代码了：在面对多个客户端的时候，我们可以使用线程池来进行处理。
这里使用Executors.newCachedThreadPool()是不固定线程的个数的线程池，这样可以灵活地处理多个客户端的请求。

    public void start() throws IOException {System.out.println("服务器启动...");ExecutorService executorService = Executors.newCachedThreadPool();while(true) {//与客户端建立连接Socket clientSocket = serverSocket.accept();//处理客户端发出的多个请求executorService.submit(() -> {try {processClient(clientSocket);} catch (IOException e) {throw new RuntimeException(e);}});}}

处理请求

我们通过了一个方法processClient来封装了处理请求的逻辑

如何进行数据的获取和写入操作？
可以通过输入流和输出流来处理getInputStream和getOutputStream

try(InputStream inputStream = clientSocket.getInputStream();OutputStream outputStream = clientSocket.getOutputStream())

为了更加方便地使用这两个流对象，我们进行了进一步的封装：

//对输入流和输出流进行进一步的封装，方便我们的使用
Scanner scanner = new Scanner(inputStream);
PrintWriter writer = new PrintWriter(outputStream);

由于客户端可能发来的不止一个请求，我们可以使用循环来处理一下，在循环体中，我们处理请求有三个步骤，首先获取请求解析请求，然后计算响应，最后发送响应

            while(true) {if(!scanner.hasNext()) {System.out.printf("[%s:%d] 客户端下线\n",clientSocket.getInetAddress(),clientSocket.getPort());break;}//解析请求String request = scanner.next();//计算响应String response = process(request);//发送响应writer.println(response);//因为此时的响应数据还在缓存区里，所以需要使用 flush 来将内存的数据发送出去writer.flush();System.out.printf("[%s:%d] request:%s response:%s\n",clientSocket.getInetAddress(),clientSocket.getPort(),request,response);}

由于这里是回显服务器，所以计算响应的代码是直接返回字符串就可以了

    private String process(String request) {return request;}

最后当客户端没有请求的时候，我们需要断开此次连接，释放资源，避免资源的泄漏

 finally {//当请求处理完的时候记得关闭服务器与客户端的连接，防止资源泄漏clientSocket.close();}

最终代码

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;public TcpEchoServer(int port) throws IOException {serverSocket = new ServerSocket(port);}public void start() throws IOException {System.out.println("服务器启动...");ExecutorService executorService = Executors.newCachedThreadPool();while(true) {//与客户端建立连接Socket clientSocket = serverSocket.accept();//处理客户端发出的多个请求executorService.submit(() -> {try {processClient(clientSocket);} catch (IOException e) {throw new RuntimeException(e);}});}}private void processClient(Socket clientSocket) throws IOException {//获取输入流和输出流try(InputStream inputStream = clientSocket.getInputStream();OutputStream outputStream = clientSocket.getOutputStream()) {System.out.printf("[%s:%d] 客户端上线\n",clientSocket.getInetAddress(),clientSocket.getPort());//对输入流和输出流进行进一步的封装，方便我们的使用Scanner scanner = new Scanner(inputStream);PrintWriter writer = new PrintWriter(outputStream);while(true) {if(!scanner.hasNext()) {System.out.printf("[%s:%d] 客户端下线\n",clientSocket.getInetAddress(),clientSocket.getPort());break;}//解析请求String request = scanner.next();//计算响应String response = process(request);//发送响应writer.println(response);//因为此时的响应数据还在缓存区里，所以需要使用 flush 来将内存的数据发送出去writer.flush();System.out.printf("[%s:%d] request:%s response:%s\n",clientSocket.getInetAddress(),clientSocket.getPort(),request,response);}} catch (IOException e) {throw new RuntimeException(e);} finally {//当请求处理完的时候记得关闭服务器与客户端的连接，防止资源泄漏clientSocket.close();}}private String process(String request) {return request;}public static void main(String[] args) throws IOException {TcpEchoServer server = new TcpEchoServer(9090);server.start();}
}

客户端

首先在客户端构造方法建立于服务器的连接：

    public TcpEchoClient(String serverIP, int port) throws IOException {//与服务器建立连接socket = new Socket(serverIP,port);}

运行逻辑

首先用户从控制台输入数据，然后发送请求，接着等待服务器的响应并接收响应然后打印响应的内容即可。

    public void start() {try(InputStream inputStream = socket.getInputStream();OutputStream outputStream = socket.getOutputStream()) {//对输入流和输出流进行进一步的封装Scanner scanner = new Scanner(System.in);Scanner scanner2 = new Scanner(inputStream);PrintWriter writer = new PrintWriter(outputStream);while(true) {//发送多个请求和接收多个响应if(!scanner.hasNext()) {break;}//发送请求String request = scanner.next();writer.println(request);writer.flush();//接收响应String response = scanner2.next();System.out.println(response);}} catch (IOException e) {throw new RuntimeException(e);}}

这里要注意用户通过控制台输入数据，我们要使用的是Scanner(System.in)
当我们要发送数据的时候是使用 Socket 的 getOutputStream 方法来获取对应的输出流对象，为了便于使用所以我们又使用 PrintWriter 来进一步封装输出流，来打印响应
在发送请求的时候我们需要使用 Socket 的 getInputStream 方法来获得输入流对象，为了方便使用，所以使用Scanner(inputStream)进一步封装。

最终代码

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 socket;public TcpEchoClient(String serverIP, int port) throws IOException {//与服务器建立连接socket = new Socket(serverIP,port);}public void start() {try(InputStream inputStream = socket.getInputStream();OutputStream outputStream = socket.getOutputStream()) {//对输入流和输出流进行进一步的封装Scanner scanner = new Scanner(System.in);Scanner scanner2 = new Scanner(inputStream);PrintWriter writer = new PrintWriter(outputStream);while(true) {//发送多个请求和接收多个响应if(!scanner.hasNext()) {break;}//发送请求String request = scanner.next();writer.println(request);writer.flush();//接收响应String response = scanner2.next();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();}
}

细节说明

在我们使用PrintWriter 的 writer.println(xxx)之后，我们的数据其实还保留在缓存区中，也就是还没发出去，我们需要通过flush() 方法来刷新缓存区的数据，才能将数据真正发送到对端去。

我们不可以使用writer.print这种没有自动添加换行符的方法，因为我们在接收数据的时候，使用的是Scanner 的 next()方法，next() 是要接收到空白符（包括换行符，制表符，翻页符…）才停止接收的，如果你使用 print 来发送数据，这时候的数据是没有带任何空白符的，那么就不会停止接收数据而是继续等待空白符的到来，这时候服务器就无法处理客户端的请求：如下图：

服务器就阻塞在 下图标红的代码里：
在这里插入图片描述

客户端被阻塞在接收响应的代码里：
在这里插入图片描述

你在客户端的控制台输入的回车不算进数据的换行符里，控制台输入的回车时，只是将数据交给了客户端程序，并不会自动将这些数据转换为网络流中的换行符。

换一句话说，控制台的回车只是结束你在控制台的输入，并不会自动在数据末尾加上换行符

效果展示

在这里插入图片描述
在这里插入图片描述

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

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

相关文章

MySQL 事务笔记

MySQL 事务笔记

MySQL 事务笔记 目录 事务简介事务操作事务四大特性并发事务问题事务隔离级别总结 事务简介 事务（Transaction）是数据库操作的逻辑单元，由一组不可分割的SQL操作组成。主要用于保证： 多个操作的原子性（要么全部成功…
阅读更多...
Android Audio其他——数字音频接口（附）

Android Audio其他——数字音频接口（附）

数字音频接口 DAI，即 Digital Audio Interfaces，顾名思义，DAI 表示在板级或板间传输数字音频信号的方式。相比于模拟接口，数字音频接口抗干扰能力更强，硬件设计简单，DAI 在音频电路设计中得到越来越广泛的应用。 一、音频链路 1、模拟音频信号 可以看到在传统的…
阅读更多...
kafka-leader -1问题解决

kafka-leader -1问题解决

一. 问题： 在 Kafka 中，leader -1 通常表示分区的领导者副本尚未被选举出来，或者在获取领导者信息时出现了问题。以下是可能导致出现 kafka leader -1 的一些常见原因及相关分析： 1. 副本同步问题： 在 Kafka 集群中&…
阅读更多...
【jira】用到几张表

【jira】用到几张表

jira用到的几张表 测试计划，测试周期，测试用例，问题记录 1. 测试计划 # 记录表，查计划详情 SELECT ID,issuenum,SUMMARY FROM jiraissue where issuenum 22871# 测试计划下，测试周期，查测试周期id&…
阅读更多...
Redis 持久化方式：RDB（Redis Database）和 AOF（Append Only File）

Redis 持久化方式：RDB（Redis Database）和 AOF（Append Only File）

本部分内容是关于博主在学习 Redis 时关于持久化部分的记录，介绍了 RDB 和 AOF 两种持久化方式，详细介绍了持久化的原理、配置、使用方式、优缺点和使用场景。并对两种持久化方式做了对比。文章最后介绍了 Redis 持久化的意义并与其他常见的缓存技术做了…
阅读更多...
Linux中lshw相关的命令

Linux中lshw相关的命令

​ lshw（List Hardware）是一个在 Linux 系统中用于显示硬件详细信息的强大工具。以下是一些常见的 lshw 相关命令及其用法： 1. 安装 lshw 在使用 lshw 之前，你可能需要先安装它。不同的 Linux 发行版安装方式有所不同&#xff1…
阅读更多...
ONNX转RKNN的环境搭建

ONNX转RKNN的环境搭建

将ONNX模型转换为RKNN模型的过程记录 工具准备 rknn-toolkit:https://github.com/rockchip-linux/rknn-toolkit rknn-toolkit2:https://github.com/airockchip/rknn-toolkit2 rknn_model_zoo:https://github.com/airockchip/rknn_model_zoo ultralytics_yolov8:https://github…
阅读更多...
华为认证考试证书下载步骤（纸质+电子版）

华为认证考试证书下载步骤（纸质+电子版）

华为考试证书可以通过官方渠道下载相应的电子证书，部分高级认证如HCIE还支持申请纸质证书。 一、华为电子版证书申请步骤如下： ①访问华为培训与认证网站 打开浏览器，登录华为培训与认证官方网站 ②登录个人账号 在网站首页，点…
阅读更多...
面试八股文--数据库基础知识总结(2) MySQL

面试八股文--数据库基础知识总结(2) MySQL

本文介绍关于MySQL的相关面试知识 一、关系型数据库 1、定义 关系型数据库（Relational Database）是一种基于关系模型的数据库管理系统（DBMS），它将数据存储在表格（表）中，并通过表格…
阅读更多...
介绍下pdf打印工具类 JasperPrint

介绍下pdf打印工具类 JasperPrint

JasperPrint 工具类深度解析 JasperPrint 是 JasperReports 框架中实现 PDF 打印的核心载体类，其本质是 填充数据后的可打印报表对象，承担着从模板编译、数据填充到格式输出的全流程控制。以下从 7 个维度展开深度解析： 一、核心定位与生命周…
阅读更多...
LVS+Keepalived 高可用集群搭建

LVS+Keepalived 高可用集群搭建

一、高可用集群： 1.什么是高可用集群： 高可用集群（High Availability Cluster）是以减少服务中断时间为目地的服务器集群技术它通过保护用户的业务程序对外不间断提供的服务，把因软件、硬件、人为造成的故障对业务的影响…
阅读更多...
从【人工智能】到【计算机视觉】，【深度学习】引领的未来科技创新与变革

从【人工智能】到【计算机视觉】，【深度学习】引领的未来科技创新与变革

前几天偶然发现了一个超棒的人工智能学习网站，内容通俗易懂，讲解风趣幽默，简直让人欲罢不能。忍不住分享给大家，点击这里立刻跳转，开启你的AI学习之旅吧！ 前言 – 人工智能教程https://www.captainbed.cn/l…
阅读更多...
数据结构-直接插入和希尔排序

数据结构-直接插入和希尔排序

这次，我们来讲数据结构的排序的直接插入。 一：排序的思想：把待排序的记录按其关键码值的大小逐个插入到一个已经排好序的有序序列中，直到所有的记录插入完为止，得到一个新的有序序列 相当于，我们打牌如上图…
阅读更多...
基于coze+微信小程序的ai对话

基于coze+微信小程序的ai对话

界面介绍&#xff1a; 代码&#xff1a;&#xff08;替换你的coze的配置&#xff09; <template><view class"container"><!-- 高斯模糊背景 --><view class"animated-bg"><view class"gradient-blob"></view…
阅读更多...
Day11，Hot100（贪心算法）

Day11，Hot100（贪心算法）

贪心 &#xff08;1&#xff09;121. 买卖股票的最佳时机 第 i 天卖出的最大利润&#xff0c;即在前面最低价的时候买入 class Solution:def maxProfit(self, prices: List[int]) -> int:min_price prices[0]ans 0for price in prices:ans max(ans, price - min_price…
阅读更多...
vLLM服务设置开机自启动（Linux）

vLLM服务设置开机自启动（Linux）

要在开机时进入指定的 conda 环境并启动此 vllm 服务&#xff0c;您可以通过以下步骤设置一个 systemd 服务来自动执行脚本。 一、第一步&#xff1a;创建一个启动脚本 1.打开终端并创建启动脚本&#xff0c;例如 /home/username/start_vllm.sh&#xff08;请替换 username 为…
阅读更多...
AI绘画软件Stable Diffusion详解教程（3）：Windows系统本地化部署操作方法（通用版）

AI绘画软件Stable Diffusion详解教程（3）：Windows系统本地化部署操作方法（通用版）

上一篇教程介绍了如何在本地部署Stable Diffusion专业版&#xff0c;虽然便于技术人员研究&#xff0c;但是普通人使用起来不便捷&#xff0c;每次只能通过cmd窗口的指令形式或者python代码方式来画图&#xff0c;要记很多的指令很繁琐。 本篇教程教您搭建webui版的&#xff0…
阅读更多...
贪心算法精品题

贪心算法精品题

1.找钱问题 本题的贪心策略在于我们希望就可能的保留作用大的5元 class Solution { public:bool lemonadeChange(vector<int>& bills) {std::map<int ,int> _map;for(auto ch:bills){if(ch 5) _map[ch];else if(ch 10){if(_map[5] 0) return false;else{_m…
阅读更多...
spring结合mybatis多租户实现单库分表

spring结合mybatis多租户实现单库分表

实现单库分表 思路&#xff1a;student表数据量大&#xff0c;所以将其进行分表处理。一共有三个分表&#xff0c;分别是student0&#xff0c;student1&#xff0c;student2&#xff0c;在新增数据的时候&#xff0c;根据请求头中的meta-tenant参数决定数据存在哪张表表。 数…
阅读更多...
Ecode前后端传值

Ecode前后端传值

说明 在泛微 E9 系统开发过程中&#xff0c;使用 Ecode 调用后端接口并进行传值是极为常见且关键的操作。在上一篇文章中&#xff0c;我们探讨了 Ecode 调用后端代码的相关内容&#xff0c;本文将深入剖析在 Ecode 中如何向后端传值&#xff0c;以及后端又该如何处理接收这些值…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023