【网络编程】从零开始彻底了解网络编程(三)

news2025/4/27 0:12:11

在这里插入图片描述

本篇博客给大家带来的是网络编程的知识点.
🐎文章专栏: JavaEE初阶
🚀若有问题 评论区见
❤ 欢迎大家点赞 评论 收藏 分享
如果你不知道分享给谁,那就分享给薯条.
你们的支持是我不断创作的动力 .

王子,公主请阅🚀

  • 要开心
    • 要快乐
      • 顺便进步
  • TCP流套接字编程

要开心

要快乐

顺便进步

TCP流套接字编程

TCP 的 socket API 和 UDP 的 socket API 差异很大.
但是和的文件操作有密切联系.
TCP中关键的类:
① ServerSocket: 给服务器使用的类,使用这个类来绑定端口号.
② Socket: 既会给服务器用,又会给客户端用.
这两个类抽象了网卡这样的硬件设备.

1. ServerSocket
ServerSocket 是创建TCP服务端的API。
ServerSocket 构造方法：

在这里插入图片描述

2. ServerSocket 方法：

ServerSocket 方法：
在这里插入图片描述
如果有客户端, 和服务器建立连接,这个时候服务器的应用程序是不需要做出任何操作(也没有任何感知的),内核直接就完成了连接建立的流程(三次握手).完成流程之后,就会在内核的队列中排队(每个serverSocket 都有一个这样的队列). 应用程序要想和这个客户端进行通信,就需要通过一个 accept 方法把内核队列里已经建立好的连接对象,拿到应用程序中.

3. Socket

Socket 是客户端Socket，或服务端中接收到客户端建立连接（accept方法）的请求后，返回的服务端Socket。
不管是客户端还是服务端Socket，都是双方建立连接以后，保存的对端信息，及用来与对方收发数据的。
Socket 构造方法：
在这里插入图片描述
Socket 方法：

在这里插入图片描述
前面的文章说过,TCP是字节流通信方式.
这里的InputStream 和 OutputStream 就是 字节流!!!
可以借助这俩对象,完成数据的"发送"和"接收"通过 InputStream 进行 read 操作,就是"接收".
通过 OutputStream 进行 write 操作, 就是"发送" .

4. 利用TCP实现一个回显的程序:

服务器: 

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;

public class TcpEchoServer {
    private ServerSocket serverSocket;

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

    public void start() throws IOException {
        System.out.println("服务器启动!");
        while(true) {
            //1. 通过accept方法,把内核中已经建立好的连接拿到应用程序.
            Socket clientSocket = serverSocket.accept();
            //2. 处理一个连接的逻辑.
            processConnection(clientSocket);
        }
    }
    public void processConnection(Socket clientSocket) {
        //打印一个日志,表示有客户端连上了.
        System.out.printf("[%s:%d] 客户端上线!\n",clientSocket.getInetAddress(),clientSocket.getPort());

        //读取请求,根据请求计算响应,最后返回响应
        //Socket 对象内部包含了两个字节流对象,把InputStream(读取),OutputStream(发送)获取到,完成后续的读写.
        try(InputStream inputStream = clientSocket.getInputStream();
                OutputStream outputStream = clientSocket.getOutputStream()) {
            //一次连接中,可能会涉及多次请求和响应
            while(true) {
                //1. 读取请求并解析
                Scanner scanner = new Scanner(inputStream);
                if(!scanner.hasNext()) {
                    //没有下一行,说明读取完毕,客户端下线
                    System.out.printf("[%s:%d] 客户端下线",clientSocket.getInetAddress(),clientSocket.getPort());
                    break;
                }
                //暗含一个约定: scanner遇到空白符(\n)就返回.
                //和客户端那里相呼应.
                String request = scanner.next();
                //2. 根据请求计算响应
                String response = process(request);
                //3. 将响应发给客户端,利用PrinterWriter包裹OutputStream
                PrintWriter writer = new PrintWriter(outputStream);
                //使用PrintWriter的println方法,把响应返回给客户端
                //此处用println,而不是print就是为了结尾加上\n,与客户端对应.
                writer.println(response);
                writer.flush();

                //4. 打印日志,表示当前请求的情况.
                System.out.printf("[%s:%d] req: %s, resp: %s\n",clientSocket.getInetAddress(),clientSocket.getPort(),
                        request,response);
            }
        } 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();
    }
}

在这里插入图片描述

空白符是一类特殊的字符,有 换行, 回车符,空格, 制表符,翻页符, 垂直制表符…等等。客户端发起的请求,此处会以空白符作为结束标记(此处就约定使用 \n)


客户端: 

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 = null;
    public TcpEchoClient(String serverIp,int serverPort) throws IOException {
        //在创建socket的同时,和服务器建立"连接"此时就得告诉Socket服务器在哪里
        //所以需要传服务器 ip 和 端口号.
        socket = new Socket(serverIp,serverPort);
    }
    public void start() {
        System.out.println("客户端上线!");
        //1. 从控制台读取用户输入的内容.
        //2. 把请求发送给服务器
        //3. 从服务器读取响应.
        //4. 把响应显示到界面上.
        Scanner scanner = new Scanner(System.in);
        try(InputStream inputStream = socket.getInputStream();
            OutputStream outputStream = socket.getOutputStream()) {
            while(true) {
                //1. 从控制台读取用户输入的内容.
                System.out.println("-> ");
                String request = scanner.next();

                //2. 把请求发送给服务器
                PrintWriter writer = new PrintWriter(outputStream);
                //使用println是为了让请求后面带上 换行
                //是为了和服务器读取请求 scanner.next()呼应.
                writer.println(request);
                writer.flush();

                //3.  读取服务器返回的响应.
                Scanner scannerNetwork = new Scanner(inputStream);
                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();
    }
}

上述代码存在两个问题:

1. 服务器程序会出现文件资源泄露的情况.
前面写过的DatagramSocket, ServerSocket 都没写 close,但没关系,因为DatagramSocket 和 ServerSocket, 都是在程序中,只有这么一个对象,生命周期贯穿整个程序的. 但 clientSocket则是在循环中,每次有一个新的客户端来建立连接,都会创建出新的 clientSocket .
如果有很多客户端都来建立连接,此时,就意味着每个连接都会创建 clientSocket. 如果没有手动 close此时这个 socket 对象会占据着文件描述符表的位置,一旦占满,文件资源就泄露了.
那要怎么办呢?

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

在 processConnection方法末尾加上下面的代码即可. 

 finally {
            //手动关闭clientSocket,避免文件资源泄露.
            try {
                clientSocket.close();
            } catch (IOException e) {
                throw new RuntimeException(e);
            }
        }

既然文件资源泄露是因为clientSocket没关,那能不能在processConnection(clientSocket);执行完之后,再把clientSocket关闭呢? 

public void start() throws IOException {
        System.out.println("服务器启动!");
        while(true) {
            //1. 通过accept方法,把内核中已经建立好的连接拿到应用程序.
            Socket clientSocket = serverSocket.accept();
            //2. 处理一个连接的逻辑.
            processConnection(clientSocket);
            clientSocket.close();
        }
    }

显然是不可以的,如果 在processConnection方法执行过程中遇到问题,抛出异常.那么还没执行到clientSocket.close();循环就结束了.
考虑到抛异常的问题, 于是就将代码改成try with source结构:

    public void start() throws IOException {
        System.out.println("服务器启动!");
        while(true) {
            //1. 通过accept方法,把内核中已经建立好的连接拿到应用程序.
            try(Socket clientSocket = serverSocket.accept()) {
                //2. 处理一个连接的逻辑.
                processConnection(clientSocket);
            }
        }
    }

2. 多个客户端无法同时与服务器进行交互.

先设置允许存在多个客户端.
在这里插入图片描述
同时运行两个客户端,在服务端上只能看到第一个客户端. 第二个客户端与服务器没有进行任何交互.

在这里插入图片描述
模拟两个客户端连接服务器的过程:
① 第一个客户端过来之后accept 就返回了,得到一个clientSocket.进入了 processConnection. 又进入了一个 while 循环, 这个循环中,就需要反复处理客户端发来的请求数据.如果客户端没发请求,服务器的代码
就会阻塞scanner.hasNext处.
② 此时此刻,第二个客户端也过来建立连接了, 连接是可以成功建立的. 建立成功之后,连接对象就会在内核的队列里等待代码通过 accept. 但是第二个客户端永远不可能执行accept方法,除非第一客户端断开连接.
怎么让两个客户端同时执行呢?

关键就是,让两个循环能够"并发"执行. 这就涉及到前面学过的多线程知识了.
创建新的线程,让新的线程去调用 processConnection
主线程就可以继续执行下一次 accept 了,新线程内部负责 processConnection的循环此时意味着,每次有一个客户端,就都得给分配一个新的线程, 又因为涉及到频繁创建销毁线程. 所以更好的方式是用线程池, 不用当然也可以, 用的话效率高一些.

解法Ⅰ 服务器引入多线程:

在这里插入图片描述

    public void start() throws IOException {
        System.out.println("服务器启动!");
        while(true) {
                //1. 通过accept方法,把内核中已经建立好的连接拿到应用程序.
                Socket clientSocket = serverSocket.accept();
                Thread t = new Thread(() -> {
                    //2. 处理一个连接的逻辑.
                    processConnection(clientSocket);
                });
                t.start();
        }
    }

解法Ⅱ 避免频繁创建销毁线程, 服务器引入线程池:

在这里插入图片描述

    //服务器引入线程池
    public void start() throws IOException {
        System.out.println("服务器");
        ExecutorService service = Executors.newCachedThreadPool();
        while(true) {
            //1. 通过accept方法,把内核中已经建立好的连接拿到应用程序.
            Socket clientSocket = serverSocket.accept();
            service.submit(new Runnable() {
                @Override
                public void run() {
                    processConnection(clientSocket);
                }
            });
        }
    }


本篇博客到这里就结束啦, 感谢观看 ❤❤❤

🐎期待与你的下一次相遇😊😊😊

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

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

相关文章

NVIDIA --- 端到端自动驾驶

NVIDIA --- 端到端自动驾驶

提示：文章写完后，目录可以自动生成，如何生成可参考右边的帮助文档 文章目录 前言一、传统驾驶模型二、NVIDIA的端到端驾驶模型1.基本模型2.自查讯向量3.通用框架 总结 前言 端到端自动驾驶指的是系统接收来自摄像头雷达和激光雷达的原始传感…
阅读更多...
CSRF请求伪造

CSRF请求伪造

该漏洞主要是关乎于用户，告诫用户不可乱点击链接，提升自我防范，才能不落入Hacker布置的陷阱！ 1. cookie与session 简单理解一下两者作用 1.1. 🍪 Cookie：就像超市的会员卡 存储位置：你钱包里…
阅读更多...
（一）单机架构、应用数据分离架构、应用服务集群架构

（一）单机架构、应用数据分离架构、应用服务集群架构

文章目录 明确为什么要学习架构的演进单机架构什么是单机架构单机架构的模型单机架构的优缺点优点缺点 单机架构的技术案例 应用数据分离架构什么是应用数据分离架构架构模型应用数据分离架构的优缺点优点缺点 技术案例 应用服务集群架构什么是应用服务集群架构架构模型应用服务…
阅读更多...
Python数据分析案例72——基于股吧评论数据的情感分析和主题建模(LDA)

Python数据分析案例72——基于股吧评论数据的情感分析和主题建模(LDA)

背景 好久没更新了，最近忙其他去了。最近股市波动太大，看了不少新闻的评论。抽空写了个股吧评论数据的LDA建模和情感分析，简单写到博客上来更新一下。 数据来源 上证指数(000001)股吧_上证指数怎么样_分析讨论社区— 数据来源上述网站的东…
阅读更多...
力扣-160.相交链表

力扣-160.相交链表

题目描述 给你两个单链表的头节点 headA 和 headB ，请你找出并返回两个单链表相交的起始节点。如果两个链表不存在相交节点，返回 null 。 图示两个链表在节点 c1 开始相交： 题目数据 保证 整个链式结构中不存在环。 注意，函数返…
阅读更多...
【C++】特殊类的设计、单例模式以及Cpp类型转换

【C++】特殊类的设计、单例模式以及Cpp类型转换

📚 博主的专栏 🐧 Linux | 🖥️ C | 📊 数据结构 | 💡C 算法 | 🅒 C 语言 | 🌐 计算机网络 上篇文章： C 智能指针使用，以及shared_ptr编写 下篇文章&#xff…
阅读更多...
050_基于springboot的音乐网站

050_基于springboot的音乐网站

一、系统架构 前端：vue | element-ui | html | jquery | css | ajax 后端：springboot | mybatis 环境：jdk1.8 | mysql | maven | nodejs | idea 二、代码及数据 三、功能介绍 01. web端-注册 02. web端-登录 03. web…
阅读更多...
【论文阅读】平滑量化：对大型语言模型进行准确高效的训练后量化

【论文阅读】平滑量化：对大型语言模型进行准确高效的训练后量化

论文题目：SmoothQuant: Accurate and Efficient Post-Training Quantization for Large Language Models 论文地址：[2211.10438] SmoothQuant: Accurate and Efficient Post-Training Quantization for Large Language Models 代码地址：http…
阅读更多...
【资料推荐】LVDS Owner’s Manual

【资料推荐】LVDS Owner’s Manual

一份年代有些久远的技术资料，但是内容全面且经典！ 本用户手册提供了很多有用的信息，首先简要概述了三种最常见的高速接口技术：LVDS（包括B-LVDS和M-LVDS）、CML和LVPECL，并对其相应的特性进行了分…
阅读更多...
ARM Cortex-M (STM32)如何调试HardFault

ARM Cortex-M (STM32)如何调试HardFault

目录 步骤 1: 实现一个有效的 HardFault 处理程序 步骤 2: 复现 HardFault 并使用调试器分析 步骤 3: 解读故障信息 步骤 4: 定位并修复源代码 HardFault 是 ARM Cortex-M 处理器中的一种异常。当处理器遇到无法处理的错误，或者配置为处理特定类型错误&#xff…
阅读更多...
黑马 redis面试篇笔记

黑马 redis面试篇笔记

redis主从 version: "3.2"services:r1:image: rediscontainer_name: r1network_mode: "host"entrypoint: ["redis-server", "--port", "7001"]r2:image: rediscontainer_name: r2network_mode: "host"entrypoint:…
阅读更多...
DBdriver使用taos数据库

DBdriver使用taos数据库

首先创建连接 连接后比如数据库里有三个库 选择其中的hypon 选中localhost，右键sql编辑器，打开sql控制台 就插入了一条数据
阅读更多...
观成科技：摩诃草组织Spyder下载器流量特征分析

观成科技：摩诃草组织Spyder下载器流量特征分析

一、概述 自2023年以来，摩诃草组织频繁使用Spyder下载器下载远控木马，例如Remcos。观成安全研究团队对近几年的Spyder样本进行了深入研究，发现不同版本的样本在数据加密、流量模式等方面存在差异。基于此，我们对多个版本样本的通…
阅读更多...
AIGC实战之如何构建出更好的大模型RAG系统

AIGC实战之如何构建出更好的大模型RAG系统

一、RAG 系统核心架构解析 1. 检索模块深度优化 1.1 混合检索技术实现 技术原理：结合稀疏检索（BM25）与密集检索（DPR），通过动态权重分配提升检索精度。例如，在医疗领域，BM25 负责精…
阅读更多...
C++入门小馆: 深入了解STLlist

C++入门小馆: 深入了解STLlist

嘿，各位技术潮人！好久不见甚是想念。生活就像一场奇妙冒险，而编程就是那把超酷的万能钥匙。此刻，阳光洒在键盘上，灵感在指尖跳跃，让我们抛开一切束缚，给平淡日子加点料，注入满满的pa…
阅读更多...
小白学习java第15天：JDBC

小白学习java第15天：JDBC

1.数据库驱动 想一下我们之前是怎么操作数据库，是不是使用SQL语句对其mysql数据库管理系统，然后管理系统在进行数据库（硬盘文件里面的）进行操作。那么我现在想使用应用程序对其数据库进行操作，应该怎么办呢&#xff1…
阅读更多...
大模型应用开发（PAFR）

大模型应用开发（PAFR）

Prompt问答 特征:利用大模型推理能力完成应用的核心功能 应用场景： 文本摘要分析 舆情分析 坐席检查 AI对话 AgentFunction Calling 特征：将应用端业务能力与AI大模型推理能力结合，简化复杂业务功能开发 应用场景: 旅行指南 数据…
阅读更多...
U-Mail邮件加速服务：全球链路加速，安全稳定收发

U-Mail邮件加速服务：全球链路加速，安全稳定收发

由于跨国网络拥堵、带宽不稳定等因素，导致海外用户在使用企业邮箱收发邮件时，经常出现邮件收发不畅的问题。针对这种情况，U-Mail正式推出了邮件加速服务，U-Mail邮件加速服务依托全球优质加速链路和转发集群服务器，为海…
阅读更多...
论文精读：大规模MIMO波束选择问题的量子计算解决方案

论文精读：大规模MIMO波束选择问题的量子计算解决方案

论文精读：大规模MIMO波束选择问题的量子计算解决方案 概要： 随着大规模多输入多输出系统（MIMO）在5G及未来通信技术中的应用，波束选择问题（MBS）成为提升系统性能的关键。传统的波束选择方法面临计…
阅读更多...
uniapp-商城-37-shop 购物车 选好了 进行订单确认3 支付栏

uniapp-商城-37-shop 购物车 选好了 进行订单确认3 支付栏

支付栏 就是前面用的 car-Layout 在shop也用来这个组件 只是在那里用来的是购物车。 1、 样式 我们开始进入这个页面是点击的shop的购物篮 到这里就变成了支付栏 其实他们是同一个组件 只是做了样式区分 2、具体看看样式和代码 2.1 消失了购物车和改变了按钮名字 如何…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023