【Java网络编程02】套接字编程

【Java网络编程02】套接字编程

1. Socket套接字

概念：Socket套接字，就是系统提供用于实现网络通信的技术，是基于TCP/IP协议的网络通信基本操作单元。基于Socket套接字的网络程序开发就是网络编程。
分类：
我们可以把Socket套接字分为两类

  1. 流套接字：使用传输层TCP协议

TCP，即Transmission Control Protocol（传输控制协议）
以下为TCP的特点：（细节后续有专门章节解释）

  • 有连接的
  • 可靠传输
  • 面向字节流的
  • 全双工的
  1. 数据报套接字：使用传输层UDP协议

UDP，即User Datagram Protocol（用户数据报协议）
一下为UDP的特点（细节后续有专门章节解释）

  • 无连接的
  • 不可靠传输
  • 面向数据报
  • 全双工

这里简单介绍一些相关概念：

面向字节VS面向数据报：
这里与文件流中的字符流与字节流很类似，面向字节表明网络传输数据是以字节为单位的，而面向数据报表明UDP传输依靠UDP数据报进行传输（稍后我们在代码中会体现）

全双工VS半双工：
半双工：通信双方基于管道进行传输，但是数据只能单向流动，如图所示：
image.png
全双工：通信双方可以实现数据的双向流动，如图所示：
image.png

2. UDP数据报套接字编程

2.1 相关API

在运用UDP进行网络编程之前，我们需要先熟悉UDP套接字编程相关API的使用，只有掌握了这些API工具才能更好地进行编程的实现，我们主要学习的有两个类：DatagramSocket，DatagramPacket

  1. DatagramSocket：OS提供了网络编程所需的API，也叫做"Socket API"，而Java又进行了一层封装，使用提供的类DatagramSocket就可以实现对于网卡等硬件设备文件的读写操作。
  2. DatagramPacket：前面我们有介绍过，UDP协议是面向数据报的，因此网络传输单位不是字节而是数据报，Java提供类DatagramPacket相当于数据报的抽象，因此实例化该对象相当于构建了一个数据报。在编程中我们发送的与接收数据的参数就是DatagramPacket对象

DatagramSocket（列举部分）：

修饰符+返回类型签名说明
构造方法DatagramSocket()无参构造，创建一个实例对象（通常用于客户端）
构造方法DatagramSocket(int port)含参构造，参数为端口号，创建一个实例对象（通常用于服务器端）
voidsend(DatagramPacket p)向socket中发送一个数据报
voidreceive(DatagramPacket p)从socket中接收一个数据报（接收不到就阻塞等待）

DatagramPacket（列举部分）：

修饰符+返回类型签名说明
构造方法DatagramPacket(byte[] buf, int length)构建一个用于接收数据长度为length的数据报对象
构造方法DatagramPacket(byte[] buf, int length, InetAddress address, int port)构建一个将要发送的数据长度为length的数据报，并指定发送目的IP与端口号
byte[]getData()从数据缓冲区中读取数据
intgetLength()返回发送或接收的数据长度

2.2 UDP编程代码

2.2.1 实现需求

作为我们的第一个UDP实验，我们希望实现一个回显服务器的效果（这相当于网络编程的"Hello World"），需求如下：

  1. 程序分为两部分，服务器端和客户端
  2. 客户端可以接收键盘输入内容，封装报文向指定服务器发送数据报
  3. 服务器端接收数据报后在显示器上打印格式为[/127.0.0.1, 52523]服务器接收到请求: xxx，并回复给客户端OK
  4. 客户端发送数据报后等待服务器响应内容，然后将响应内容打印在显示器上
  5. 要求服务器可以持续接收客户端请求，客户端可以不停接收用户键盘输入
2.2.2 代码编写

UDP服务器端代码：

/*** UDP服务器端代码*/
public class UdpServer {private int serverPort = 0; // 服务器端端口private DatagramSocket socket = null;public UdpServer(int port) throws SocketException {this.serverPort = port;this.socket = new DatagramSocket(port);}public void start() throws IOException {System.out.println("服务器开始启动....");// 1. 循环处理客户端请求while (true) {// 2. 阻塞等待客户端请求DatagramPacket request = new DatagramPacket(new byte[4096], 4096);socket.receive(request);// 3. 获得请求后进行处理String responseMsg = process(request);// 4. 将响应回传客户端DatagramPacket response = new DatagramPacket(responseMsg.getBytes(), responseMsg.getBytes().length, request.getSocketAddress());socket.send(response);}}public String process(DatagramPacket request) {// 根据请求数据读取构造字符串String msg = new String(request.getData(), 0, request.getLength());System.out.printf("[%s, %d]服务器接收到请求: %s\n", request.getAddress(), request.getPort(), msg);// 服务器端返回OKreturn "OK";}public static void main(String[] args) throws IOException {UdpServer udpServer = new UdpServer(9090);udpServer.start();}
}

UDP客户端代码：

/*** UDP客户端代码*/
public class UdpClient {private String serverIP;private int serverPort;private DatagramSocket socket;public UdpClient(String serverIP, int serverPort) throws SocketException {this.serverIP = serverIP;this.serverPort = serverPort;this.socket = new DatagramSocket();}public void start() throws IOException {System.out.println("客户端启动....");Scanner scanner = new Scanner(System.in);// 1. 用户持续输入System.out.print("->");while (scanner.hasNext()) {String input = scanner.next();// 2. 将用户输入内容构造成数据报DatagramPacket request = new DatagramPacket(input.getBytes(), input.getBytes().length, InetAddress.getByName(serverIP), serverPort);// 3. 向服务器端发送数据报socket.send(request);// 4. 阻塞等待服务器端响应DatagramPacket response = new DatagramPacket(new byte[4096], 4096);socket.receive(response);// 5. 打印响应内容String responseMsg = new String(response.getData(), 0, response.getLength());System.out.println(responseMsg);System.out.print("->");}}public static void main(String[] args) throws IOException {UdpClient udpClient = new UdpClient("127.0.0.1", 9090);udpClient.start();}
}

运行效果：

客户端：
image.png

服务器端：
image.png

2.2.3 流程分析

我们以客户端输入"hello"为例分析客户端和服务器端各自的执行流程

  1. 服务器端执行socket.receive(request);进入阻塞状态，等待客户端的请求
  2. 客户端执行while(scanner.hasNext()) {...}阻塞等待用户键盘输入
  3. 客户端用户在键盘敲下"hello"，客户端停止阻塞，执行以下代码
String input = scanner.next();
// 2. 将用户输入内容构造成数据报
DatagramPacket request = new DatagramPacket(input.getBytes(), input.getBytes().length, InetAddress.getByName(serverIP), serverPort);
// 3. 向服务器端发送数据报
socket.send(request);
// 4. 阻塞等待服务器端响应
DatagramPacket response = new DatagramPacket(new byte[4096], 4096);
socket.receive(response);

将用户输入内容构造成DatagramPacket对象，然后执行socket.send(request)向服务器发送请求。然后执行socket.receive(response);进入阻塞状态，等待服务器响应
image.png

  1. 服务器端停止阻塞，开始执行以下代码
// 3. 获得请求后进行处理
String responseMsg = process(request);
// 4. 将响应回传客户端
DatagramPacket response = new DatagramPacket(responseMsg.getBytes(), responseMsg.getBytes().length, request.getSocketAddress());
socket.send(response);

服务器获得请求数据报后开始解析，然后构建响应数据报返回给客户端，即调用socket.send(response);，向客户端发送数据报socket.send(response);，之后再次执行while循环执行socket.receive(request);，阻塞等待下一次的客户端请求
image.png

  1. 客户端接收到服务器端响应，停止阻塞，执行以下代码
// 5. 打印响应内容
String responseMsg = new String(response.getData(), 0, response.getLength());
System.out.println(responseMsg);
System.out.print("->");

将响应内容显示在屏幕上后，继续执行while(scanner.hasNext()) {...}进入阻塞等待下一次用户输入，由此进入闭环。

总结：无论是客户端还是服务器端，都需要各自执行通过套接字发送请求、接收响应的过程即客户端调用一次send、一次receive方法，服务器端调用一次send、一次receive方法。而且send方法中的参数一定是载有实际发送内容的字节数组，而receive方法参数所需的DatagramPacket对象内部则为空的字节数据，是需要被响应内容所填充的 输出型参数。

完整流程图：

image.png

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

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

相关文章

docker 部署 sentinel

docker 部署 sentinel

docker 部署 sentinel 环境安装 拉取镜像 目前稳定的版本是1.8.0 docker pull bladex/sentinel-dashboard:1.8.0启动服务 docker run --name sentinel -p 8858:8858 -td bladex/sentinel-dashboard:1.8.0登录 登录的时候账号和密码都是sentinel
阅读更多...
算法训练营Day45

算法训练营Day45

#Java #动态规划 Feeling and experiences： 最长公共子序列：力扣题目链接 给定两个字符串 text1 和 text2，返回这两个字符串的最长 公共子序列 的长度。如果不存在 公共子序列 ，返回 0 。 一个字符串的 子序列 是指这样一个新…
阅读更多...
泛型..

泛型..

1.泛型 所谓泛型 其实就是一种类型参数(我们平常所见到的参数指的就是方法中的参数 他接收有外界传递来的值 然后在方法中进行使用) 并且还提高了代码的复用率 何以见得提高了代码的复用率 其实就是通过对比使用了泛型技术和没有使用泛型技术之间的区别： 以下是没有…
阅读更多...
QTcpSocket 对象的可工作线程

QTcpSocket 对象的可工作线程

QTcpSocket 对象的可工作线程: QTcpSocket 对象创建成功，并设置好底层socket描述符后；在qt中只能在一个线程中工作【即收发网络数据】这个线程就是创建这个QTcpSocket对象的线程，原理上这就与这个对象依附线程是同一个线程；但是注…
阅读更多...
windows如何切换访问NAS共享文件夹用户

windows如何切换访问NAS共享文件夹用户

从资源管理器对NAS共享文件夹输入用户名与密码进行访问后，想切换访问用户，搜索了一圈，网上介绍的方法都无效，最后只能注销windows7登陆，然后重新登陆，再访问NAS共享时才能切换用户，各位观众如有…
阅读更多...
深入理解与运用Lombok的@Cleanup注解：自动化资源管理利器

深入理解与运用Lombok的@Cleanup注解：自动化资源管理利器

前言 在Java编程中，正确地管理和释放诸如文件流、数据库连接等资源至关重要。若处理不当，可能会引发内存泄漏或系统资源耗尽等问题。为此，Lombok库提供了一个名为Cleanup的便捷注解，它允许我们以简洁且安全的方式自动关闭实现了j…
阅读更多...
Linux C语言开发（九）链表

Linux C语言开发（九）链表

目录 一.前言 二.链表构建 一.前言 C语言的链表是一种常见且实用的数据结构，它用于存储和管理数据元素。链表由一系列节点组成，每个节点包含两个部分：数据域和指针域。数据域用于存储实际的数据元素，而指针域则用于指向链表中的下一个节点。 链表的主要特点是其存储空间的…
阅读更多...
练习题 有奖问答

练习题 有奖问答

题目 问题描述 小蓝正在参与一个现场问答的节目。活动中一共有 3030 道题目, 每题只有答对和答错两种情况, 每答对一题得 10 分，答错一题分数归零。 小蓝可以在任意时刻结束答题并获得目前分数对应的奖项，之后不能再答任何题目。最高奖项需要 100 分,…
阅读更多...
深度学习记录--Momentum gradient descent

深度学习记录--Momentum gradient descent

Momentum gradient descent 正常的梯度下降无法使用更大的学习率，因为学习率过大可能导致偏离函数范围，这种上下波动导致学习率无法得到提高，速度因此减慢(下图蓝色曲线) 为了减小波动，同时加快速率，可以使用momentum…
阅读更多...
【软件测试】学习笔记-制定性能测试的目标

【软件测试】学习笔记-制定性能测试的目标

之前有同学交流过，在测试执行过程中他并不清楚测试得到的结果到底能不能满足这次活动的需求。经过追问，发现他连本次活动规则涉及的模块和接口都不是十分清楚，像这样的测试就是没有做性能测试目标的分析。虽然说做了性能测试，但几…
阅读更多...
学习CANopen --- [12] Abort报文

学习CANopen --- [12] Abort报文

当我们使用SDO进行读写操作时，有时device会返回abort报文，意味着本次SDO读写失败。本文使用例子来讲解Abort报文，以及如何解读失败原因。 一 Device例子 下面是device的python代码，文件名叫device.py，device的CANopen…
阅读更多...
Kotlin协程学习之-02

Kotlin协程学习之-02

协程的基本使用 GlobalScope.launch 生命周期与进程一致，且无法取消 runBlocking 会阻塞线程，一般在测试阶段可以使用 val coroutineScope CoroutineScope(context) coroutineScope.launch 通过context参数去管理和控制协程的生命周期 用法 va…
阅读更多...
Linux配置主机名-使用主机名访问服务器

Linux配置主机名-使用主机名访问服务器

主要需要对Hosts文件进行操作， Hosts是一个没有扩展名的系统文件，可以用记事本等工具打开，其作用就是将一些常用的网址域名与其对应的IP地址建立一个关联“数据库”， 先将自己的主机名设置成有意义，别人好记的样子&a…
阅读更多...
上位机图像处理和嵌入式模块部署（开篇）

上位机图像处理和嵌入式模块部署（开篇）

【 声明：版权所有，欢迎转载，请勿用于商业用途。 联系信箱：feixiaoxing 163.com】 图像处理是现实生活当中很实用的一门技术。工业上一般采用的是机器视觉，以传统算法和光源控制为主，部分采用了深度学习技术…
阅读更多...
【51单片机】外部中断

【51单片机】外部中断

0、前言 参考&#xff1a;普中 51 单片机开发攻略 第16章 及17章 1、硬件 2、软件 #include <reg52.h> #include <intrins.h> #include "delayms.h"typedef unsigned char u8; typedef unsigned int u16;sbit led P2^0; sbit key3 P3^2;//外部中断…
阅读更多...
【深度学习】详解利用Matlab和Python中 LSTM 网络实现序列分类

【深度学习】详解利用Matlab和Python中 LSTM 网络实现序列分类

🔗 运行环境：Matlab、Python 🚩 撰写作者：左手の明天 🥇 精选专栏：《python》 🔥 推荐专栏：《算法研究》 🔐#### 防伪水印——左手の明天 ####🔐 💗 大家好🤗🤗🤗，我是左手の明天！好久不见💗 💗今天分享Matlab深度学习—— LSTM 网络实现序列分
阅读更多...
【深度学习：数据增强 】提高标记数据质量的 5 种方法

【深度学习：数据增强 】提高标记数据质量的 5 种方法

【深度学习&#xff1a;数据增强 】提高标记数据质量的 5 种方法 计算机视觉中常见的数据错误和质量问题&#xff1f;为什么需要提高数据集的质量&#xff1f;提高标记数据质量的五种方法使用复杂的本体结构作为标签人工智能辅助标签识别标签错误的数据改进注释者管理 计算机视…
阅读更多...
spark 入门教程

spark 入门教程

一、安装scala环境 官网下载地址 Download | The Scala Programming Language,本次使用版本为sacla2.11.12,将压缩包解压至指定目录&#xff0c;配置好环境变量&#xff0c;控制台验证是否安环境是否可用&#xff1a; 二、添加pom依赖 创建一个maven项目 1、添加scala的sdk依…
阅读更多...
MySQL中对数值类型数据的处理

MySQL中对数值类型数据的处理

⭕️前些天发现了一个巨牛的人工智能学习网站&#xff0c;通俗易懂&#xff0c;风趣幽默&#xff0c;忍不住分享一下给大家(点击跳转到网站)⭕️ MySQL针对日期的处理、运算符等 常见运算符 算术运算符&#xff1a;加减乘除、求余数 、-、、/、% 比较运算符&#xff1a;等于…
阅读更多...
github 推送报错 ssh: connect to host github.com port 22: Connection timed out 解决

github 推送报错 ssh: connect to host github.com port 22: Connection timed out 解决

&#x1f680; 作者主页&#xff1a; 有来技术 &#x1f525; 开源项目&#xff1a; youlai-mall &#x1f343; vue3-element-admin &#x1f343; youlai-boot &#x1f33a; 仓库主页&#xff1a; Gitee &#x1f4ab; Github &#x1f4ab; GitCode &#x1f496; 欢迎点赞…
阅读更多...
最新文章

Copyright @ 2022~2023