【JavaEE】网络编程---TCP数据报套接字编程

一、TCP数据报套接字编程

1.1 ServerSocket API

ServerSocket 是创建TCP服务端Socket的API
ServerSocket 构造方法：
在这里插入图片描述
ServerSocket 方法：
在这里插入图片描述

1.2 Socket API

Socket 是客户端Socket，或服务端中接收到客户端建立连接（accept方法）的请求后，返回的服务端Socket。不管是客户端还是服务端Socket，都是双方建立连接以后，保存的对端信息，及用来与对方收发数据的。
Socket 构造方法：
在这里插入图片描述
Socket 方法：
在这里插入图片描述
通过上述字节流对象进行数据传输：
从InputStream读数据就相当于从网卡接收
从OutputStream写数据就相当于从网卡发送

1.3 短连接和长连接

短连接：一次连接只有一个请求
长连接：一次连接有多个请求

1.4 示例一：回显服务器（echo server）

这里我们演示长连接：

1.4.1 Tcp服务器

package 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 {
    //serverSocket是外场拉客的小哥,serverSocket有且只有一个
    //cilentSocket是内场服务的小姐姐，cilentSocket会给每个客户端分配一个
    private ServerSocket serverSocket = null;

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

    public void start() throws IOException {
        System.out.println("服务器启动！");
        while(true) {
            Socket cilentSocket = serverSocket.accept();
            processConnection(cilentSocket);  //连接后通过processConnection来处理连接
        }
    }

    //通过这个方法来处理一个连接:
    //1.读取请求
    //2.根据请求计算响应
    //3.把响应返回给客户端
    private void processConnection(Socket clientSocket) throws IOException {
        System.out.printf("[%s:%d] 客户端上线!\n", clientSocket.getInetAddress().toString(),
                clientSocket.getPort());  //提示客户端上线并打印IP地址和端口号
        //try()这种写法，允许括号中写多个流对象，中间使用“；”来分割
        try (InputStream inputStream = clientSocket.getInputStream();
             OutputStream outputStream = clientSocket.getOutputStream()) {
            Scanner scanner = new Scanner(inputStream);  //为了读取请求方便，把字节流转为字符流
            PrintWriter printWriter = new PrintWriter(outputStream); //为了返回响应方便，把字节流转为字符流

            //我们读到哪里算是一个完整的请求呢；
            //此处做一个简单的约定：
            //每个请求是个字符串（文本数据），每个请求之间使用\n来分割,不要忘记响应也要这样约定

            while(true) {  //长连接：一次连接有多个请求
                //1.读取请求
                if (!scanner.hasNext()) {  //如果客户端关闭连接了，hasNext返回false,结束while循环
                    System.out.printf("[%s:%d] 客户端下线！\n",clientSocket.getInetAddress().toString(),clientSocket.getPort());  //提示客户端下线并打印IP地址和端口号
                    break;
                }
                    //如果没有读完，直接使用scanner读取一段字符串
                String request = scanner.next();  //next会往后一直读直到读到空白符（空格、换行符、制表符、翻页符等）结束（不包含空白符）。此处尽量不要使用nextLine
                //2.根据请求计算响应
                String response = process(request);  //通过process方法来处理请求并返回响应
                //3.把响应返回给客户端(不要忘记响应里面也是要带上换行的，方便客户端区分从哪里到哪里是一个响应)
                printWriter.println(response);

                System.out.printf("[%s:%d] req:%s ; resp:%s \n",clientSocket.getInetAddress().toString(),
                        clientSocket.getPort(),request,response);
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            clientSocket.close();  //这里的cilentSocket只是给一个连接提供帮助，所以要及时释放
        }
    }

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

    public static void main(String[] args) throws IOException {
        TcpEchoServer tcpEchoServer = new TcpEchoServer(9090);
        tcpEchoServer.start();
    }
}

注意：如果没有客户端连接时，accept是会阻塞的

1.4.2 Tcp客户端

package Tcp;

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;
    private void TcpEchoServer(String serverIP, int port) throws IOException {
        //这个操作就相当于让客户端和服务端建立Tcp连接了
        socket = new Socket(serverIP,port);
    }

    public void start() throws IOException {
        Scanner scanner = new Scanner(System.in);
        try (InputStream inputStreamt = socket.getInputStream(); OutputStream outputStream = socket.getOutputStream()){
            PrintWriter printWriter = new PrintWriter(outputStream);
            Scanner scanner1 = new Scanner(inputStreamt);

            while (true) {
                //1.从键盘上读取用户输入的内容
                System.out.println("->");
                String request = scanner.next();
                //2.把输入的内容构造成请求并发送给服务器（对应服务器的接收）
                    //注意这里发送的请求带有换行
                printWriter.println(request);
                //3.从服务器读取相应内容
                String response = scanner1.next();
                //4.把响应结果显示在控制台上
                System.out.printf("req: %s; resp: %s\n", request, response);
            }
        }
    }

    public static void main(String[] args) throws IOException {
        TcpEchoClient client = new TcpEchoClient("127.0.0.1", 9090);
        client.start();
    }

}

我们运行发现：
在这里插入图片描述
在这里插入图片描述
此时服务器已经启动且客户端也上线了，我们输入的请求为什么没有响应呢？
我们服务器这里的代码：
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这两个地方加上就可以正常运行了：
在这里插入图片描述
在这里插入图片描述
这样子我们的代码貌似没什么问题了
可是这里还有一个很严重的bug:咱们的服务器一次只能给一个客户端提供服务！！
在idea中默认只能启动一个客户端，我们需要稍微设置一下：
在这里插入图片描述
此时可以有两个客户端：
在这里插入图片描述
但是我们发现只有一个客户端上线了：
在这里插入图片描述
在第一个客户端输入正常，第二个没有任何响应：
在这里插入图片描述
在这里插入图片描述

当前服务器无法服务多个客户端！！！===》代码bug

在这里插入图片描述
怎么解决这个问题呢？

我们希望能够该客户端1提供循环服务的同时又能够循环的调用accept

我们对服务器代码的start函数做如下改变：

public void start() throws IOException {
        System.out.println("服务器启动！");
        while(true) {
            Socket cilentSocket = serverSocket.accept();
            // 如果直接调用, 该方法会影响这个循环的二次执行, 导致 accept 不及时了.
            // 创建新的线程, 用新线程来调用 processConnection
            // 每次来一个新的客户端都搞一个新的线程即可
            Thread t = new Thread(() -> {
                try {
                    processConnection(cilentSocket);  //连接后通过processConnection来处理连接
                } catch (IOException e) {
                    throw new RuntimeException(e);
                }
            });
            t.start();
        }
    }

此时服务器便可同时处理多个客户端：
在这里插入图片描述

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

好用的Visio绘图文件工具 VSD Viewer最新 for mac

好用的Visio绘图文件工具 VSD Viewer最新 for mac

VSD Viewer是一款可以查看Microsoft Visio绘图文件的工具，适用于Windows和macOS操作系统。它具有以下优点： 直观易用：VSD Viewer的用户界面非常简单直观，易于使用。支持多种文件格式：VSD Viewer支持多种Visio文件格式…
阅读更多...
短视频矩阵系统搭建/源头----源码

短视频矩阵系统搭建/源头----源码

一、智能剪辑、矩阵分发、无人直播、爆款文案于一体独立应用开发 抖去推----主要针对本地生活的----移动端(小程序软件系统，目前是全国源头独立开发)，开发功能大拆解分享，功能大拆解： 7大模型剪辑法（数学阶乘&#xff…
阅读更多...
HTML页面获取URL传递的参数值

HTML页面获取URL传递的参数值

如： // 查询url上链接的参数与参数值 function getQueryString(name) {var url window.location.search; // 获取URLvar pattern new RegExp("[\?\&]" name "([^\&])", "i"); // 正则匹配URLvar matcher pattern.exec(…
阅读更多...
企业如何保护机密文件安全

企业如何保护机密文件安全

企业如何保护机密文件安全，数据加密技术有哪些 随着公司业务的不断发展，公司机密文件的保护是一家公司不可忽视的问题。机密文件包含了企业的核心信息，如客户资料、产品方案、财务数据等。 安企神数据防泄密系统下载试用 企业数据一旦泄露…
阅读更多...
HTTP响应

HTTP响应

HTTP响应分为四个部分： 首行：HTTP/1.1（首行） 200（状态码） OK（状态码描述）header：空行：表示header的结束标记body：正文 HTTP状态码：…
阅读更多...
MySQL-DML【数据操作语言】(图码结合)

MySQL-DML【数据操作语言】(图码结合)

目录 🚩DML的定义 👉DML-添加数据 🎓给指定的字段添加数据 🕶️查询表数据的方式 ❗疑惑点一【Affecter rows:行数】 ❗疑惑点二【字符集问题】 🎓给全部字段添加数据 🎓批量添加数据 &#x1f…
阅读更多...
得帆北区总经理——湛颂：得帆云iPaaS平台是满足企业集成需求的利器

得帆北区总经理——湛颂：得帆云iPaaS平台是满足企业集成需求的利器

后ERP时代的IT变革 在过去的许多年里，企业的IT发展往往都是根据各业务部门的需求而引入大量系统。十年前，面对制造业的客户群体，当他们已经引入了ERP、CRM、WMS、MES、TMS、HR、LIMS等业务系统的时候，我就在讲一个话题——后ERP时…
阅读更多...
YOLOv5算法改进（20）— 如何去写YOLOv5相关的论文（包括论文阅读+规律总结+写作方法）

YOLOv5算法改进（20）— 如何去写YOLOv5相关的论文（包括论文阅读+规律总结+写作方法）

前言：Hello大家好，我是小哥谈。最近一直在阅读关于YOLOv5的相关论文，读着读着我发现一条可以发论文的规律，特此简单总结一下，希望能够对同学们有所启迪！🌈 前期回顾： YOLOv5算法改进（1）— 如何去改进YOLOv5算法
阅读更多...
GitHub commit时出现 无法访问443 Operation timed out的解决办法

GitHub commit时出现 无法访问443 Operation timed out的解决办法

GitHub commit时出现 无法访问443 Operation timed out的解决办法 1.问题描述2. 环境3.解决方法4.如果上述方法不行，那就再试一试下面这个方法4.1 首先确认自己的网页可以打开github4.2 按照如下配置http和https代理4.2.1 找端口号 5. 参考链接 1.问题描述 当使用g…
阅读更多...
thinkphp 解决跨域的三个方式

thinkphp 解决跨域的三个方式

1. 在tp入口index.php 加上header //支持跨域 header("Access-Control-Allow-Origin:*"); header(Access-Control-Allow-Methods:*); header(Access-Control-Allow-Headers:x-requested-with, content-type,token); 2. 在route.php加上 allowCrossDomain()&#xff…
阅读更多...
吐血整理，Jmeter服务端性能测试-线程阻塞问题案例分析（超细）

吐血整理，Jmeter服务端性能测试-线程阻塞问题案例分析（超细）

目录：导读 前言一、Python编程入门到精通二、接口自动化项目实战三、Web自动化项目实战四、App自动化项目实战五、一线大厂简历六、测试开发DevOps体系七、常用自动化测试工具八、JMeter性能测试九、总结（尾部小惊喜） 前言 1、Jstack打印快照…
阅读更多...
【HarmonyOS】元服务卡片展示动态数据，并定点更新卡片数据

【HarmonyOS】元服务卡片展示动态数据，并定点更新卡片数据

【关键字】 元服务卡片、卡片展示动态数据、更新卡片数据 【写在前面】 本篇文章主要介绍开发元服务卡片时，如何实现卡片中动态显示数据功能，并实现定时数据刷新。本篇文章通过实现定时刷新卡片中日期数据为例，讲述展示动态数据与更新数据功…
阅读更多...
Banana Pi BPI-W3 ArmSoM-W3之RK3588-MIPI-DSI屏幕调试笔记

Banana Pi BPI-W3 ArmSoM-W3之RK3588-MIPI-DSI屏幕调试笔记

一. 简介 本文是基于RK3588平台，MIPI屏调试总结。 二. 环境介绍 硬件环境： ArmSoM-W3 RK3588开发板、MIPI-DSI显示屏( ArmSoM官方配件 )软件版本： OS：ArmSoM-W3 Debian11 三. MIPI屏幕调试 3.1 调试总览，调试步骤分…
阅读更多...
[尚硅谷React笔记]——第5章 React 路由

[尚硅谷React笔记]——第5章 React 路由

目录： 对SPA应用的理解对路由的理解前端路由原理路由的基本使用路由组件与一般组件NavLink的使用封装NavLink组件Switch的使用解决样式丢失问题路由的模糊匹配与严格匹配Redirect的使用嵌套路由向路由组件传递params参数向路由组件传递search参数.向路由组件传递st…
阅读更多...
第四章 文件管理 四、文件的物理结构（文件分配方式）

第四章 文件管理 四、文件的物理结构（文件分配方式）

目录 一、文件块，磁盘块 二、连续分配 1、定义： 2、计算方式： 3、注意： 4、优点： 5、缺点： 6、总结 三、链接分配----隐式链接 1、定义： 2、如何实现逻辑块号转物理块号 3、优点&…
阅读更多...
J2EE的N层体系结构

J2EE的N层体系结构

J2EE平台采用了多层分布式应用程序模型，实现不同逻辑功能的应用程序被封装到不同的构件中，处于不同层次的构件可被分别部署到不同的机器中。 RMI/IIOP：RMI（Remote Method Invocation，远程方法调用）是Java的…
阅读更多...
AUTOSAR AP 硬核知识点梳理（2）— 架构详解

AUTOSAR AP 硬核知识点梳理（2）— 架构详解

一 AUTOSAR 平台逻辑体系结构 图示逻辑体系结构描述了平台是如何组成的，有哪些模块，模块之间的接口是如何工作的。 经典平台具有分层的软件体系结构。定义明确的抽象层，每个抽象层都有精确定义的角色和接口。 对于应用程序，我们需要考虑使用的软件组件，希望它们是可重用的…
阅读更多...
Windows Server扩展卷变灰怎么办？

Windows Server扩展卷变灰怎么办？

当Windows Server中的某一个分区，特别是系统（C）分区磁盘空间不足时，您可能需要使用内置磁盘管理工具的“扩展卷”功能扩展分区了。但不幸的是，当您尝试扩展C盘驱动器时，很有可能会出现Windows Server扩展卷…
阅读更多...
SystemVerilog Assertions应用指南 Chapter1.38在序列匹配时调用子程序

SystemVerilog Assertions应用指南 Chapter1.38在序列匹配时调用子程序

SVA可以在序列每次成功匹配时调用子程序。同一序列中定义的局部变量可以作为参数传给这些子程序。对于序列的每次匹配,子程序调用的执行与它们在序列定义中的顺序相同。 module sub;logic a, b, clk;initial $vcdpluson();initial begin clk 1b0; a1b0; b1b0; repeat(2) (pos…
阅读更多...
python实验16_网络爬虫

python实验16_网络爬虫

实验16：网络爬虫 1.实验目标及要求 （1）掌握简单爬虫方法。 2. 实验主要内容 爬取中国票房网 ①　爬取中国票房网（www.cbooo.cn)2019年票房排行榜前20名的电影相关数据 代码部分: import time from selenium.webdriver impor…
阅读更多...
最新文章

Copyright @ 2022~2023