网络编程（TCP、UDP）

news2024/10/8 23:01:03

文章目录

  • 一、概念
    • 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() {
                @Override
                public 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();
    }
}

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

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

相关文章

大模型量化技术-GPTQ

大模型量化技术-GPTQ

大模型量化技术-GPTQ 2022年，Frantar等人发表了论文 GPTQ：Accurate Post-Training Quantization for Generative Pre-trained Transformers。 这篇论文详细介绍了一种训练后量化算法，适用于所有通用的预训练 Transformer模型，同时只有微小的性能下降。 GPTQ算法需要通过…
阅读更多...
Autodesk Maya 2025 Multilanguage (macOS, Linux, Windows) - 三维动画和视觉特效软件

Autodesk Maya 2025 Multilanguage (macOS, Linux, Windows) - 三维动画和视觉特效软件

Autodesk Maya 2025 Multilanguage (macOS, Linux, Windows) - 三维动画和视觉特效软件 三维计算机动画、建模、仿真和渲染软件 请访问原文链接：https://sysin.org/blog/autodesk-maya/，查看最新版。原创作品，转载请保留出处。 作者主页&a…
阅读更多...
‘cv2’、PIL、torch、torchivision

‘cv2’、PIL、torch、torchivision

运行环境安装失败集 1、 ModuleNotFoundError: No module named ‘cv2’No module named ‘cv2’ opencv-python PEP517 ERROR2、ModuleNotFoundError: No module named PIL3、torch、torchvision安装 1、 ModuleNotFoundError: No module named ‘cv2’ No module named ‘cv…
阅读更多...
基于SSM的社区疫情防控管理信息系统

基于SSM的社区疫情防控管理信息系统

目录 背景 技术简介 系统简介 界面预览 背景 随着时代的进步，计算机技术已经全方位地影响了社会的发展。随着居民生活质量的持续上升，人们对社区疫情防控管理信息系统的期望和要求也在同步增长。在社区疫情防控日益受到广泛关注的背景下&#xff0c…
阅读更多...
JAVAEE——文件IO

JAVAEE——文件IO

文章目录 文件的概念什么是文件？树型结构组织 和 目录文件路径相对路径绝对路径 文件的分类文件的权限 文件读写IO API字符流操作API 警告字节流操作APIInputStreamOutputStream 文件的概念 什么是文件？ 我们先来理解一下什么是文件，那么想…
阅读更多...
四川尚熠电子商务有限公司靠谱吗？怎么样？

四川尚熠电子商务有限公司靠谱吗？怎么样？

在当下数字化浪潮中，电子商务行业正以前所未有的速度蓬勃发展。四川尚熠电子商务有限公司，作为专注于抖音电商服务的企业，凭借其敏锐的市场洞察力和创新精神，正成为行业内的佼佼者，为众多品牌打开抖音电商市场的大门。…
阅读更多...
[技术闲聊]我对电路设计的理解(三)

[技术闲聊]我对电路设计的理解(三)

终于可以独立做项目了，是不是很激动，是不是为自己骄傲和自豪，应该的，奋斗那么久不就是为了站在山巅看看四周的风景嘛！ 虽说山外还有山，但是此刻就在脚下的山巅上，怡然自得都是不过分的&#xff…
阅读更多...
YOLOv8改进 | 低照度检测 | 2024最新改进CPA-Enhancer链式思考网络（适用低照度、图像去雾、雨天、雪天）

YOLOv8改进 | 低照度检测 | 2024最新改进CPA-Enhancer链式思考网络（适用低照度、图像去雾、雨天、雪天）

一、本文介绍 本文给大家带来的2024.3月份最新改进机制，由CPA-Enhancer: Chain-of-Thought Prompted Adaptive Enhancer for Object Detection under Unknown Degradations论文提出的CPA-Enhancer链式思考网络，CPA-Enhancer通过引入链式思考提示机制，实现了对未知退化条件下…
阅读更多...
《内心强大比什么都重要》 - 三余书屋 3ysw.net

《内心强大比什么都重要》 - 三余书屋 3ysw.net

内心强大比什么都重要 今天我和大家一起分享一本好书，艾米莫林的《内心强大比什么都重要》。这本书中描述了人们如何控制情绪、想法和行动，让自己的内心更强大。书中也列举了一些有用的建议、积极向上的例子和实际解决方法，来帮助读者们克服…
阅读更多...
Python搭建编程环境-安装Python3解释器

Python搭建编程环境-安装Python3解释器

✅作者简介：CSDN内容合伙人、新星计划第三季Python赛道Top1🏅 🔥本文已收录于Python系列专栏：零基础学Python 💬订阅专栏后可私信博主进入Python学习交流群，进群可领取Python视频教程以及Python相关电子书…
阅读更多...
Linux是什么，该如何学习

Linux是什么，该如何学习

🐇明明跟你说过：个人主页 🏅个人专栏：《Linux ：从菜鸟到飞鸟的逆袭》 🏅 🔖行路有良友，便是天堂🔖 目录 一、引言 1、Linux的起源与发展 2、Linux在现代计算机领域…
阅读更多...
Java源值1.5已过时，将在未来所有发行版中删除

Java源值1.5已过时，将在未来所有发行版中删除

1、背景 确认java项目没问题，但是启动的时候，却报错：java: -source 1.5 中不支持 diamond 运算符 2、解决 2.1 2.2 2.3 2.4 2.5
阅读更多...
阿里云PAI-EAS试用-ComfyUI

阿里云PAI-EAS试用-ComfyUI

试用信息 试用地址 PAI-EAS试用 提供资源 其中A10服务器在10元每小时左右，意味着我们可以使用的试用时间在40个小时以上。每天玩4小时，也可以玩10天了，练习完全够用。 具体过程 官方给了一个简单的指导文档，包括领用资源、部…
阅读更多...
1688API接口|获取商品详情信息商品列表商品采集API图搜商品API

1688API接口|获取商品详情信息商品列表商品采集API图搜商品API

API调用公共参数 名称类型必须描述keyString是调用key（注册账号获取API&secret）secretString是调用密钥api_nameString是API接口名称（包括在请求地址中）[item_search,item_get,item_search_shop等]cacheString否[yes,no]默认…
阅读更多...
vulhub中Apache Solr RemoteStreaming 文件读取与SSRF漏洞复现

vulhub中Apache Solr RemoteStreaming 文件读取与SSRF漏洞复现

Apache Solr 是一个开源的搜索服务器。在Apache Solr未开启认证的情况下，攻击者可直接构造特定请求开启特定配置，并最终造成SSRF或任意文件读取。 访问http://your-ip:8983即可查看Apache Solr后台 1.访问http://your-ip:8983/solr/admin/cores?indexI…
阅读更多...
Windows通过git配置github代码仓库全流程

Windows通过git配置github代码仓库全流程

git git是代码的版本控制工具 git安装和github注册 这个默认弄过了 通过git和github之间的SSH配置 在github上面新建仓库，做好配置 git绑定GitHub账号 先cd到上传的文件所在的目录 git config --global user.name "你的github用户名"git config -…
阅读更多...
Linux 文件相关命令

Linux 文件相关命令

一、查看文件命令 1）浏览文件less 默认查看文件的前 10 行。 less /etc/services ##功能说明： #1.默认打开首屏内容 #2.按【回车】按行访问 #3.按【空格】按屏访问 #4.【从上向下】搜索用/111,搜索包含111的内容，此时按n继续向下搜&#x…
阅读更多...
Hadoop: word count,并将结果写入到MySQL

Hadoop: word count,并将结果写入到MySQL

一、依赖 <?xml version"1.0" encoding"UTF-8"?> <project xmlns"http://maven.apache.org/POM/4.0.0"xmlns:xsi"http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation"http://maven.apache.org/POM/4.0.0…
阅读更多...
Python | Leetcode Python题解之第10题正则表达式匹配

Python | Leetcode Python题解之第10题正则表达式匹配

题目&#xff1a; 题解&#xff1a; class Solution:def isMatch(self, s: str, p: str) -> bool:m, n len(s), len(p)dp [False] * (n1)# 初始化dp[0] Truefor j in range(1, n1):if p[j-1] *:dp[j] dp[j-2]# 状态更新for i in range(1, m1):dp2 [False] * (n1) …
阅读更多...
python怎么存储数据

python怎么存储数据

在Python开发中&#xff0c;数据存储、读取是必不可少的环节&#xff0c;而且可以采用的存储方式也很多&#xff0c;常用的方法有json文件、csv文件、MySQL数据库、Redis数据库以及Mongdb数据库等。 1. json文件存储数据 json是一种轻量级的数据交换格式&#xff0c;采用完全…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023