当前位置: 首页 > news >正文

网络编程(TCP、UDP)

文章目录

  • 一、概念
    • 1.1 什么是网络编程
    • 1.2 网络编程中的基本知识
  • 二、Socket套接字
    • 2.1 概念及分类
    • 2.2 TCP VS UDP
    • 2.3 通信模型
    • 2.4 接口方法
      • UDP数据报套接字编程
      • TCP流套接字编程
  • 三、代码示例
    • 3.1 注意点
    • 3.2 回显服务器
      • 基于UDP
      • 基于TCP

一、概念

首先介绍了什么是网络编程,随后介绍了接收端发送端、请求响应等基本知识

1.1 什么是网络编程

网络编程
(1)网络上的主机,通过不同的进程,以编程的方式实现网络通信(或称为网络数据传输)。(2)在程序员层面上,即要写一个应用程序通过调用传输层提供的API实现网络通信

1.2 网络编程中的基本知识

  1. 发送端和接收端:字面意思,发送端是发送数据的,接收端是接收数据的,注意这个概念只是相对的,主要看数据是从哪发到哪。

  2. 请求和响应
    一般来说,获取一个网络资源,涉及到两次网络数据传输:

    • 第一次:请求数据的发送
    • 第二次:响应数据的发送
  3. 客户端和服务器
    服务端:在常见的网络数据传输场景下,给用户提供服务的一方进程
    客户端:获取服务的一方进程,是指给用户使用的程序

  4. 常见的客户端服务端模型

    • 客户端先发送请求到服务端
    • 服务端根据请求数据,执行相应的业务处理
    • 服务端返回响应:发送业务处理结果
    • 客户端根据响应数据,展示处理结果(展示获取的资源,或提示保存资源的处理结果)

二、Socket套接字

网络编程是基于Socket开发的,传输层上主要涉及TCP、UDP这两种协议,而他俩给出的API都不同,本段主要介绍概念,包括分类和区别。

2.1 概念及分类

(1)Socket套接字,是由系统提供用于网络通信的技术,是基于TCP/IP协议的网络通信的基本操作单元。基于Socket套接字的网络程序开发就是网络编程。

(2)Socket套接字主要针对传输层协议划分为如下三类:

  1. 流套接字:传输层TCP协议(传输控制协议)
  2. 数据报套接字:传输层UDP协议(用户数据报协议)
  3. 原始套接字:原始套接字用于自定义传输层协议,用于读写内核没有处理的IP协议数据

2.2 TCP VS UDP

TCP:有连接;可靠传输;面向字节流;有接收缓冲区和发送缓冲区;大小不限;全双工
UDP:无连接;不可靠传输;面向数据报;有接收缓冲区,无发送缓冲区;大小受限,一次最多传输64k

  1. 连接:客户端和服务器之间是否使用内存保存对端信息,互相承认,连接就建立了。
  2. 传输
    • 可靠传输:A尽可能把消息传过去,传输失败与否都能感知到,会降低传输效率。不可靠传输传输效率更高
    • 注意:这并不意味着,TCP比UDP更安全,因为“网络安全”指的是传输的数据是否容易被黑客截获,以及如果被截获后是否会泄漏一些重要信息
  3. 字节流VS数据报
    • 面向字节流:TCP流式操作
    • 面向数据报:读写的基本单位是一个UDP数据报,且一次只能传输一个
  4. 全双工VS半双工
    • 全双工:一个通道,可以双向通信。网线就是全双工的
    • 半双工:一个通道,只能单向通信

2.3 通信模型

数据报套接字模型

在这里插入图片描述
流套接字模型
在这里插入图片描述

2.4 接口方法

UDP数据报套接字编程

UDP提供的API主要通过两个类来实现,一个是DatagramSocket,一个是DatagramPacket。

DatagramSocket 方法:代表一个Socket对象,即一个网卡的文件
DatagramPacket 方法:代表一个UDP数据报

TCP流套接字编程

因为TCP是字节流式传输,所以不需要一个专门的类来表示TCP数据报

ServerSocket 方法:
(1)给服务器使用的
(2)负责拉客,在外场广撒网。

Socket 方法:
(1)服务端和客户端都能用
(2)像是一个耳麦,可以直接与对方进行通信,负责在内场细致服务。

三、代码示例

3.1 注意点

  1. 服务器使用的端口需要手动指定,客户端的则需要系统自动分配
    • 因为服务器需要能被客户端百分百找到,万一服务器随便改变端口,那客户端按照以往的连接是无法连接到服务器的。
    • 客户端则没有这个需求,且客户端一旦指定端口号很可能回合其他程序冲突,系统自动分配的端口号一定是空闲的。
  2. flush() ------ 手动刷新
    • IO操作是比较有开销的,相比于访问内存,进行IO次数越多,程序的速度就越慢。为了解决这个问题,我们会使用一块内存作为缓冲区,写数据的时候,先写到缓冲区里。攒了一波数据之后,统一进行IO。
    • printWriter 内置了缓冲区
    • flush()可以实现手动刷新,可以确保这里的数据是真的通过网卡发出去了,而不是残留在内存缓冲区中的
    • 加上flush()可以让代码更稳妥,但是不加不一定会出错,因为缓冲区内置了一定的刷新策略
  3. 关于 close()
    close() 主要是删除文件描述符表中的记录。当然也并不是每个流对象都有文件描述符表,只有那种调用了操作系统提供的open()方法,涉及到了用户态和用户态。

3.2 回显服务器

基于UDP

(1)InetAddress 表示的是IP地址
(2)客户端要设置要传给的服务器的IP地址和端口号是多少,即示例中的 serverIp 和 serverPort 。服务器则是要手动指定一个端口号。
(3)难点在于 DatagramPacket 的构造,涉及了String 和 DatagramPacket 之间的转换。
(4)数据包的接收和发送,依靠 DatagramSocket 的 send 和 receive 方法。

//客户端
public class UdpEchoClient {private DatagramSocket socket = null;private String serverIp;private int serverPort;public UdpEchoClient(String ip, int port) throws SocketException {serverIp = ip;serverPort = port;socket = new DatagramSocket();}public void start() throws IOException {//获取用户输入的内容Scanner scanner = new Scanner(System.in);System.out.println("客户端启动!");//给服务器发送响应while (true){System.out.print("-> ");String request = scanner.next();//不能用request.length(),因为这是指字符长度,我们需要的是字节长度//除非是纯英文且由utf-8编码,那么两者会相同。Socket是按照字节来处理的。DatagramPacket requestPacket = new DatagramPacket(request.getBytes(), request.getBytes().length,InetAddress.getByName(serverIp), serverPort);socket.send(requestPacket);//接收响应DatagramPacket responsePacket = new DatagramPacket(new byte[4096], 4096);socket.receive(responsePacket);String response = new String(responsePacket.getData(), 0, responsePacket.getLength());System.out.println(response);}}public static void main(String[] args) throws IOException {UdpEchoClient client = new UdpEchoClient("127.0.0.1", 9090);client.start();}
}
//服务器
public class UdpEchoServer {private DatagramSocket socket = null;public UdpEchoServer(int port) throws SocketException {socket = new DatagramSocket(port);}public void start() throws IOException {System.out.println("服务器启动");while(true){DatagramPacket requestPacket = new DatagramPacket(new byte[4096], 4096);socket.receive(requestPacket);String request = new String(requestPacket.getData(), 0, requestPacket.getLength());String response = process(request);DatagramPacket responsePacket = new DatagramPacket(response.getBytes(), response.getBytes().length,requestPacket.getSocketAddress());socket.send(responsePacket);System.out.printf("[%s:%d req:%s, resp:%s\n]", requestPacket.getAddress().toString(),requestPacket.getPort(), request, response);}}public String process(String request){return request;}public static void main(String[] args) throws IOException {UdpEchoServer server= new UdpEchoServer(9090);server.start();}
}

基于TCP

  1. 服务器对客户是多对多的关系,一个服务器内核会存许多客户端的连接(建立连接的过程,系统内核会自己完成)。连接就像是一个个代办事项,等待应用程序一个个完成。
  2. serverSocket.accept():将在内核中已经建立好的连接取出来给应用程序
  3. 原理是一个【生产者消费者模型】
    在这里插入图片描述
  4. TCP中的长短连接
    • 短连接:每次接收到数据并返回响应后,都关闭连接,即只能一次收发数据
    • 长连接:不关闭连接,一直保持连接状态,双方不停的收发数据
public class TcpServer {private ServerSocket socket = null;private ExecutorService service = Executors.newCachedThreadPool();public TcpServer(int port) throws IOException {socket = new ServerSocket(9090);}public void start() throws IOException {System.out.println("服务端启动!");while (true){Socket clientSocket = socket.accept();//为了能够接收多个客户端,这里使用了线程池//当客户端进一步增加,线程数目也会增加,系统的负担也就越来越重,响应速度也就越来越慢//为了解决这个问题,就需要开源(引入更多的硬件资源)节流(减少每种硬件资源占用的资源)service.submit(new Runnable() {@Overridepublic void run() {try {processConnection(clientSocket);} catch (IOException e) {throw new RuntimeException(e);}}});}}public void processConnection(Socket clientSocket) throws IOException {try(InputStream inputStream = clientSocket.getInputStream();OutputStream outputStream = clientSocket.getOutputStream()){while(true){Scanner scannerClient = new Scanner(inputStream);String request = scannerClient.next();String response = process(request);PrintWriter writer = new PrintWriter(outputStream);writer.println(response);writer.flush();System.out.printf("[%s:%d] req:%s, resp:%s\n", clientSocket.getInetAddress().toString(),clientSocket.getPort(), request, response);}} catch (IOException e) {throw new RuntimeException(e);}finally {clientSocket.close();}}public String process(String request){return request;}public static void main(String[] args) throws IOException {TcpServer server = new TcpServer(9090);server.start();}
}
public class TcpClient {private Socket socket = null;public TcpClient(String serverIp, int serverPort) throws IOException {socket = new Socket(serverIp, serverPort);}public void start(){System.out.println("客户端启动");Scanner scanner = new Scanner(System.in);try(InputStream inputStream = socket.getInputStream();OutputStream outputStream = socket.getOutputStream()){while (true){System.out.print("---->");String request = scanner.next();PrintWriter writer = new PrintWriter(outputStream);writer.println(request);writer.flush();Scanner scammerConsole = new Scanner(inputStream);String response = scammerConsole.next();System.out.println(response);}} catch (IOException e) {throw new RuntimeException(e);}}public static void main(String[] args) throws IOException {TcpClient client = new TcpClient("127.0.0.1", 9090);client.start();}
}

相关文章:

网络编程(TCP、UDP)

文章目录 一、概念1.1 什么是网络编程1.2 网络编程中的基本知识 二、Socket套接字2.1 概念及分类2.2 TCP VS UDP2.3 通信模型2.4 接口方法UDP数据报套接字编程TCP流套接字编程 三、代码示例3.1 注意点3.2 回显服务器基于UDP基于TCP 一、概念 首先介绍了什么是网络编程&#xff…...

Python快速入门系列-7(Python Web开发与框架介绍)

第七章:Python Web开发与框架介绍 7.1 Flask与Django简介7.1.1 Flask框架Flask的特点Flask的安装一个简单的Flask应用示例7.1.2 Django框架Django的特点Django的安装一个简单的Django应用示例7.2 前后端交互与数据传输7.2.1 前后端交互7.2.2 数据传输格式7.2.3 示例:使用Flas…...

最长对称子串

对给定的字符串,本题要求你输出最长对称子串的长度。例如,给定Is PAT&TAP symmetric?,最长对称子串为s PAT&TAP s,于是你应该输出11。 输入格式: 输入在一行中给出长度不超过1000的非空字符串。 输出格式&…...

【大模型】大模型 CPU 推理之 llama.cpp

【大模型】大模型 CPU 推理之 llama.cpp llama.cpp安装llama.cppMemory/Disk RequirementsQuantization测试推理下载模型测试 参考 llama.cpp 描述 The main goal of llama.cpp is to enable LLM inference with minimal setup and state-of-the-art performance on a wide var…...

异地组网怎么管理?

在当今信息化时代,随着企业的业务扩张和员工的分布,异地组网已经成为越来越多企业的需求。异地组网管理相对来说是一项复杂而繁琐的任务。本文将介绍一种名为【天联】的管理解决方案,帮助企业更好地管理异地组网。 【天联】组网的优势 【天联…...

Kafka参数介绍

官网参数介绍:Apache KafkaApache Kafka: A Distributed Streaming Platform.https://kafka.apache.org/documentation/#configuration...

如何利用待办事项清单提高工作效率?

你是否经常因为繁重的工作量而感到不堪重负?你是否在努力赶工期或经常忘记重要的电子邮件?你并不是特例。如何利用待办事项清单提高工作效率?这里有一个简单的方法可以帮你理清混乱并更高效地完成任务—待办事项清单。 这种类型的清单可以帮…...

力扣经典150题第二题:移除元素

移除元素问题详解与解决方法 1. 介绍 移除元素问题是 LeetCode 经典题目之一,要求原地修改输入数组,移除所有数值等于给定值的元素,并返回新数组的长度。 问题描述 给你一个数组 nums 和一个值 val,你需要 原地 移除所有数值等…...

55555555555555

欢迎关注博主 Mindtechnist 或加入【Linux C/C/Python社区】一起学习和分享Linux、C、C、Python、Matlab,机器人运动控制、多机器人协作,智能优化算法,滤波估计、多传感器信息融合,机器学习,人工智能等相关领域的知识和…...

用Skimage学习数字图像处理(018):图像形态学处理(上)

本节开始讨论图像形态学处理,这是上篇,将介绍与二值形态学相关的内容,重点介绍两种基本的二值形态学操作:腐蚀和膨胀,以及三种复合二值形态学操作:开、闭和击中击不中变换。 目录 9.1 基础 9.2 基本操作…...

MySQL中 in 和 exists 区别

在MySQL中,IN和EXISTS都是用于在子查询中测试条件的操作符,但它们在处理和效率上有一些重要的区别。MySQL中的in语句是把外表和内表作hash连接,⽽exists语句是对外表作loop循环,每次loop循环再对内表进⾏查询。⼤家⼀直认为exists…...

Java基础 - 代码练习

第一题&#xff1a;集合的运用&#xff08;幸存者&#xff09; public class demo1 {public static void main(String[] args) {ArrayList<Integer> array new ArrayList<>(); //一百个囚犯存放在array集合中Random r new Random();for (int i 0; i < 100; …...

【Redis】redis集群模式

概述 Redis集群&#xff0c;即Redis Cluster&#xff0c;是Redis 3.0开始引入的分布式存储方案。实际使用中集群一般由多个节点(Node)组成&#xff0c;Redis的数据分布在这些节点中。集群中的节点分为主节点和从节点&#xff1a;只有主节点负责读写请求和集群信息的维护&#…...

基于opencv的猫脸识别模型

opencv介绍 OpenCV的全称是Open Source Computer Vision Library&#xff0c;是一个跨平台的计算机视觉库。OpenCV是由英特尔公司发起并参与开发&#xff0c;以BSD许可证授权发行&#xff0c;可以在商业和研究领域中免费使用。OpenCV可用于开发实时的图像处理、计算机视觉以及…...

基于注意力整合的超声图像分割信息在乳腺肿瘤分类中的应用

基于注意力整合的超声图像分割信息在乳腺肿瘤分类中的应用 摘要引言方法 Segmentation information with attention integration for classification of breast tumor in ultrasound image 摘要 乳腺癌是世界范围内女性最常见的癌症之一。基于超声成像的计算机辅助诊断&#x…...

数据库重点知识(个人整理笔记)

目录 1. 索引是什么&#xff1f; 1.1. 索引的基本原理 2. 索引有哪些优缺点&#xff1f; 3. MySQL有哪几种索引类型&#xff1f; 4. mysql聚簇和非聚簇索引的区别 5. 非聚簇索引一定会回表查询吗&#xff1f; 6. 讲一讲前缀索引&#xff1f; 7. 为什么索引结构默认使用B…...

[技术闲聊]checklist

电路设计完成后&#xff0c;需要确认功能完整性&#xff0c;明确是否符合设计规格需求&#xff1b;需要确认电路设计是否功能符合但是系列项不符合设计规则&#xff0c;如果都没有问题&#xff0c;那么就可以发给layout工程师。 今天主要讲讲电路设计规则&#xff0c;涉及到一…...

力扣刷题 二叉树的迭代遍历

题干 给你二叉树的根节点 root &#xff0c;返回它节点值的 前序 遍历。 示例 1&#xff1a; 输入&#xff1a;root [1,null,2,3] 输出&#xff1a;[1,2,3]示例 2&#xff1a; 输入&#xff1a;root [] 输出&#xff1a;[]示例 3&#xff1a; 输入&#xff1a;root [1] 输…...

【二】Django小白三板斧

今日内容 静态文件配置 request对象方法初识 pycharm链接数据库&#xff08;MySQL&#xff09; django链接数据库&#xff08;MySQL&#xff09; Django ORM简介 利用ORM实现数据的增删查改 【一】Django小白三板斧 HttpResponse 返回字符串类型的数据 render 返回HTML文…...

MyBatis的基本应用

源码地址 01.MyBatis环境搭建 添加MyBatis的坐标 <!--mybatis坐标--><dependency><groupId>org.mybatis</groupId><artifactId>mybatis</artifactId><version>3.5.9</version></dependency><!--mysql驱动坐…...

Day80:服务攻防-中间件安全HW2023-WPS分析WeblogicJettyJenkinsCVE

目录 中间件-Jetty-CVE&信息泄漏 CVE-2021-34429(信息泄露) CVE-2021-28169(信息泄露) 中间件-Jenkins-CVE&RCE执行 cve_2017_1000353 CVE-2018-1000861 cve_2019_1003000 中间件-Weblogic-CVE&反序列化&RCE 应用金山WPS-HW2023-RCE&复现&上线…...

使用generator实现async函数

我们先来看一下async函数是怎么使用的 const getData (sec) > new Promise((resolve) > {setTimeout(() > resolve(sec * 2), sec * 1000);})// aim to get this asycnFun by generator async function asyncFun() {const data1 await getData(1);const data2 awa…...

go并发请求url

sync.WaitGroup写法 package mainimport ("database/sql""fmt""net/http""sync""time"_ "github.com/go-sql-driver/mysql" )func main() {//开始计时start : time.Now()//链接数据库&#xff0c;用户名&#xf…...

刷题之Leetcode704题(超级详细)

704. 二分查找 力扣题目链接(opens new window)https://leetcode.cn/problems/binary-search/ 给定一个 n 个元素有序的&#xff08;升序&#xff09;整型数组 nums 和一个目标值 target &#xff0c;写一个函数搜索 nums 中的 target&#xff0c;如果目标值存在返回下标&am…...

leetcode热题100.前k个高频元素

作者&#xff1a;晓宜 &#x1f308;&#x1f308;&#x1f308; 个人简介&#xff1a;互联网大厂Java准入职&#xff0c;阿里云专家博主&#xff0c;csdn后端优质创作者&#xff0c;算法爱好者 ❤️❤️❤️ 你的关注是我前进的动力&#x1f60a; Problem: 347. 前 K 个高频元…...

LangChain Demo | Agent X ReAct X wikipedia 询问《三体》的主要内容

背景 LangChain学习中&#xff0c;尝试改了一下哈里森和吴恩达课程当中的问题&#xff0c;看看gpt-3.5-turbo在集成了ReAct和wikipedia后&#xff0c;如何回答《三体》的主要内容是什么这个问题&#xff0c;当然&#xff0c;主要是为了回答这问题时LangChain内部发生了什么。所…...

Revit 2025新功能一览~

Hello大家好&#xff01;我是九哥~ Revit2025已经更新&#xff0c;安装后&#xff0c;简单试了下&#xff0c;还是挺不错的&#xff0c;流畅度啊&#xff0c;新功能啊&#xff0c;看来还是有听取用户意见的&#xff0c;接下来就简单看看都有哪些新功能。 好了&#xff0c;今天的…...

Head First Design Patterns -代理模式

什么是代理模式 代理模式为另一个对象提供替身或者占位符&#xff0c;以便控制客户对对象的访问&#xff0c;管理访问的方式有很多种。例如远程代理、虚拟代理、保护代理等。 远程代理&#xff1a;管理客户和远程对象之间的交互。 虚拟代理&#xff1a;控制访问实例化开销大的对…...

第十三题:天干地支

题目描述 古代中国使用天干地支来记录当前的年份。 天干一共有十个&#xff0c;分别为&#xff1a;甲&#xff08;jiǎ&#xff09;、乙&#xff08;yǐ&#xff09;、丙&#xff08;bǐng&#xff09;、丁&#xff08;dīng&#xff09;、戊&#xff08;w&#xff09;、己&a…...

8000预算可以购买阿里云服务器配置整理

一个月8000元预算如何选择阿里云服务器配置&#xff1f;八千预算可选的阿里云服务器配置相当高了&#xff0c;这个预算可以购买阿里云企业级独享型云服务器&#xff0c;至少8核以上的配置&#xff0c;这个预算可以支持复杂、高负载或大规模的业务需求。阿里云服务器网整理8000元…...

专业营销团队公司/郑州seo外包v1

最近&#xff0c;阿里巴巴发布了《阿里巴巴Java开发手册》&#xff0c;总结了阿里人多年一线实战中积累的研发流程规范&#xff0c;这些流程规范在一定程度上能够保证最终的项目交付质量&#xff0c;通过限制开发人员的编程风格、实现方式来避免研发人员在实践中容易犯的错误&a…...

专注郑州网站建设/下载优化大师安装桌面

无法在证书存储区中找到清单签名证书 第一种办法&#xff1a;用记事本打开对应csproj文件。将 change " <SignManifests>true</SignManifests> " to "<SignManifests>false</SignManifests>".thats ok!第二种办法&#xff1a;在v…...

做海报哪个网站好/2345网址导航官网官方电脑版

长期存储信息的三个基本要求&#xff1a;&#xff08;1&#xff09;能够存储大量信息&#xff08;2&#xff09;使用信息的进程终止时&#xff0c;信息依旧存在&#xff08;3&#xff09;必须能使多个进程并发访问有关信息文件是进程创建的信息逻辑单元&#xff0c;可以把文件看…...

网页设计与网站建设 在线测试/seo网站推广教程

先点hex 后点 decimal 再开始start attack&#xff0c;这是一个软件bug&#xff0c;需要手动让它刷新。...

找老外做网站可靠吗/cms建站系统

f{} Python3.6及以上版本才有&#xff0c;Python3.5及以下版本会出错。 %s%() 常用格式 {}.format() {}里面可以带数字也可以不带数字&#xff0c;带数字编号可以调换输出顺序&#xff0c;还可以带关键字。 device torch.device(fcuda:{opt.local_rank}) #python3.6 device …...

行业网站建设多少钱/韩国搜索引擎排名

# -*- coding: utf-8 -*- """ 姓名区域销售区域 张三湖南100华中 李四湖北50华中 小明河北80华北 小张上海58华东 小宋吉林70东北 小国四川90西北 """ from pyecharts.charts import Bar import xlrd dataxlrd.open_workbook(11.xlsx) tabledata…...