【网络编程】UDP数据报套接字编程和TCP流套接字编程

文章目录

  • 1. 网络编程基础
    • 1.1 为什么需要网络编程？
    • 1.2 网络编程是什么？
    • 1.3 概念
  • 2. Socket套接字
  • 3. UDP数据报套接字编程
    • 3.1 DatagramSocket API
    • 3.2 DatagramPacket API
    • 3.3 InetSocketAddress API
  • 4. UDP构建服务端客户端（一发一收）
    • 4.1 创建服务端UdpServer.java：
    • 4.2 创建客户端UdpClient.java：
  • 5. UDP构建服务端客户端（翻译）
  • 6. TCP流套接字编程
    • 6.1 ServerSocket API
    • 6.2 Socket API
    • 6.3 TCP中的长短连接
  • 7. TCP构建服务端客户端（一发一收）
    • 7.1 创建服务端TcpServer.java
    • 7.2 创建客户端TcpClient.java
  • 8. 启动多个客户端

1. 网络编程基础

1.1 为什么需要网络编程？

这是因为在我们本地资源中，里面的内容并不丰富，而且下载的资源大多最终还是来源于网络。
而在网络世界中，里面有大量的资源。例如：当我们在网页中打开一个视频，听一段音乐，看一篇文章等，这些都属于网络资源（能从网络中获得的数据资源）。
这些资源都是通过网络编程进行数据传输，所以网络编程的需要是必不可少的。

1.2 网络编程是什么？

网络编程就是指网络主机通过不同的进程，以编程的方式进行网络通信（或称网络数据传输）。
1

1.3 概念

  1. 发送端：数据发送方的进程，称发送端。发送端的主机即网络通信中的源主机。
  2. 接收端：数据接受方的进程，称接受端。接受端的主机即网络通信中的目的主机。
  3. 收发端：发送端和接受端简称收发端。
    注意：
    发送端和接收端只是相对的，只是一次网络数据传输产生数据流向后的概念。
    如上图：进程1请求获得资源时，进程1就是发送端，进程2是接收端，进程2响应时，进程2就是发送端，进程1就是接收端。
  4. 服务端：提供服务的一端，称为服务端。
  5. 客户端：获取服务的一端，称为客户端。
    如上图：主机1发出请求，主机2做出响应，那么我们就可以称主机1为客户端，主机2为服务端。

2. Socket套接字

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

  1. 流套接字：使用传输层TCP协议。
    TCP的特点：
    有连接
    可靠传输
    面向字节流
    有接收缓冲区，也有发送缓冲区
    大小不限
  2. 数据报套接字：使用传输层UDP协议
    UDP的特点：
    无连接
    不可靠传输
    面向数据报
    有接收缓冲区，无发送缓冲区
    大小受限：一次最多传输64k
  3. 原始套接字：原始套接字用于自定义传输层协议，用于读写内核没有处理的IP协议数据。

3. UDP数据报套接字编程

3.1 DatagramSocket API

DatagramSocket 是UDP Socket，用于发送和接收UDP数据报。

DatagramSocket 构造方法：

方法作用
DatagramSocket()创建一个UDP数据报套接字的Socket，绑定到本机任意一个随机端口（一般用于客户端）
DatagramSocket()创建一个UDP数据报套接字的Socket，绑定到本机指定的端口（一般用于服务端）
        //创建一个UDP数据报套接字的Socket，绑定到本机任意一个随机端口DatagramSocket socket1 = new DatagramSocket();//创建一个UDP数据报套接字的Socket，绑定到本机9090端口DatagramSocket socket2 = new DatagramSocket(9090);

DatagramSocket 方法：

方法作用
void receive(DatagramPacket p)从此套接字接收数据报（如果没有接收到数据报，该方法会阻塞等待）
void send(DatagramPacketp)从此套接字发送数据报包（不会阻塞等待，直接发送）
void close()关闭此数据报套接字

3.2 DatagramPacket API

DatagramPacket是UDP Socket发送和接收的数据报。

DatagramPacket 构造方法：

方法作用
DatagramPacket(byte[] buf, int length)构造一个DatagramPacket以用来接收数据报，接收的数据保存在字节数组（第一个参数buf）中，接收指定长度（第二个参数length)
DatagramPacket(byte[] buf, int offset, int length, SocketAddress address)构造一个DatagramPacket以用来发送数据报，发送的数据为字节数组（第一个参数buf）中，从0到指定长度（第二个参数length）。address指定目的主机的IP和端口号

DatagramPacket 方法:

方法作用
InetAddress getAddress()从接收的数据报中，获取发送端主机IP地址；或从发送的数据报中，获取接收端主机IP地址
int getPort()从接收的数据报中，获取发送端主机的端口号；或从发送的数据报中，获取接收端主机端口号
byte[] getData()获取数据报中的数据

3.3 InetSocketAddress API

构造UDP发送的数据报时，需要传入 SocketAddress ，该对象可以使用 InetSocketAddress 来创建。

InetSocketAddress （ SocketAddress 的子类 ）构造方法：

方法作用
InetSocketAddress(InetAddress addr, int port)创建一个Socket地址，包含IP地址和端口号

4. UDP构建服务端客户端（一发一收）

知道上面的，就可以创建一个简单的服务端客户端，一发一收，就是客户端请求服务端，请求什么，客户端收到什么。

4.1 创建服务端UdpServer.java：

public class UdpServer {//创建服务器socket，不实例化private DatagramSocket socket = null;public UdpServer(int port) throws SocketException {服务器socket绑定固定的端口socket = new DatagramSocket(port);}public void start() throws IOException {System.out.println("服务器启动！");//服务器放入死循环中，我们并不知道客户端什么时候访问客户端，需要不停的接受客户端的UDP数据报while(true){//1.创建数据报，读取客户端发送数据DatagramPacket requestPacket = new DatagramPacket(new byte[4096],4096);socket.receive(requestPacket);//转义String request = new String(requestPacket.getData(),0,requestPacket.getLength());//2.响应String response = process(request);//3.返回客户端//计算机内部处理数据的基本单位是字节。通过将接收到的数据转义为字节，长度要用字节长度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 {//实例化服务端，端口号为9092UdpServer udpServer = new UdpServer(9092);//启动服务端udpServer.start();}
}

4.2 创建客户端UdpClient.java：

public class UdpClient {private DatagramSocket socket = null;private String serverIp;private int serverPort;public UdpClient(String ip, int port) throws SocketException {serverIp = ip;serverPort = port;socket = new DatagramSocket();}public void start() throws IOException {System.out.println("客户端启动");Scanner sc = new Scanner(System.in);while(true){//1.输入System.out.println("-> ");String request = sc.next();//2.发送
//            InetSocketAddress inetAddress = new InetSocketAddress(serverIp,serverPort);
//            DatagramPacket requestPacket = new DatagramPacket(request.getBytes(),request.getBytes().length,
//                    inetAddress);
//			  计算机内部处理数据的基本单位是字节。通过将接收到的数据转义为字节，长度要用字节长度DatagramPacket requestPacket = new DatagramPacket(request.getBytes(),request.getBytes().length,InetAddress.getByName(serverIp),serverPort);socket.send(requestPacket);//3.读取DatagramPacket responsePacket = new DatagramPacket(new byte[4096],0,4096);socket.receive(responsePacket);String response = new String(responsePacket.getData(),0,responsePacket.getLength());//4.显示System.out.println(response );}}public static void main(String[] args) throws IOException {UdpClient udpClient = new UdpClient("127.0.0.1",9092);udpClient.start();}
}

运行结果：
33
44

5. UDP构建服务端客户端（翻译）

4中服务器并没有什么功能，那么我们也可以为服务器赋予一些功能，例如：翻译。
我们只需要基于4代码的基础上，对服务器进行修改。

创建翻译服务端UdpServer.java：

public class UdpServer {//创建服务器socket，不实例化private DatagramSocket socket = null;//翻译集合private Map<String,String> dict = new HashMap<>();public UdpServer(int port) throws SocketException {//服务器socket绑定固定的端口socket = new DatagramSocket(port);//添加单词dict.put("cat","小猫");dict.put("dog","小狗");dict.put("bird","鸟");}public void start() throws IOException {System.out.println("服务器启动！");//服务器放入死循环中，我们并不知道客户端什么时候访问客户端，需要不停的接受客户端的UDP数据报while(true){//1.创建数据报，读取客户端发送数据DatagramPacket requestPacket = new DatagramPacket(new byte[4096],4096);socket.receive(requestPacket);//转义，计算机内部处理数据的基本单位是字节。通过将接收到的数据转义为字节，服务器可以更容易地处理和解析数据，不会出错String request = new String(requestPacket.getData(),0,requestPacket.getLength());//2.响应String response = process(request);//3.返回客户端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 dict.getOrDefault(request,"我还是个小菜鸡");}public static void main(String[] args) throws IOException {//实例化服务端，端口号为9092UdpServer udpServer = new UdpServer(9092);//启动服务端udpServer.start();}
}

运行结果：
在这里插入图片描述
在这里插入图片描述
其实，相对于4只是修改了一些方法和属性，那么，我们也可以重新写一个类继承4中的服务器，这样会更加的简单。

6. TCP流套接字编程

ServerSocket 是创建TCP服务端Socket的API。

6.1 ServerSocket API

ServerSocket 构造方法：

方法作用
ServerSocket(int port)创建一个服务端流套接字Socket，并绑定到指定端口

ServerSocket 方法：

方法作用
Socket accept()开始监听指定端口（创建时绑定的端口），有客户端连接后，返回一个服务端Socket对象，并基于该Socket建立与客户端的连接，否则阻塞等待
void close()关闭此套接字

6.2 Socket API

Socket 是客户端Socket，或服务端中接收到客户端建立连接（accept方法）的请求后，返回的服务端Socket。
不管是客户端还是服务端Socket，都是双方建立连接以后，保存的对端信息，及用来与对方收发数据的。

Socket 构造方法：

方法作用
Socket(String host, intport)创建一个客户端流套接字Socket，并与对应IP的主机上，对应端口的进程建立连接

Socket 方法：

方法作用
InetAddress getInetAddress()返回套接字所连接的地址
InputStream getInputStream()返回此套接字的输入流
OutputStream getOutputStream()返回此套接字的输出流

6.3 TCP中的长短连接

TCP发送数据时，需要先建立连接，什么时候关闭连接就决定是短连接还是长连接：

  1. 短连接：每次接收到数据并返回响应后，都关闭连接，即是短连接。也就是说，短连接只能一次收发数据。
  2. 长连接：不关闭连接，一直保持连接状态，双方不停的收发数据，即是长连接。也就是说，长连接可以多次收发数据。

对比以上长短连接，两者区别如下：

  1. 建立连接、关闭连接的耗时：短连接每次请求、响应都需要建立连接，关闭连接；而长连接只需要第一次建立连接，之后的请求、响应都可以直接传输。相对来说建立连接，关闭连接也是要耗时的，长连接效率更高。
  2. 主动发送请求不同：短连接一般是客户端主动向服务端发送请求；而长连接可以是客户端主动发送请求，也可以是服务端主动发。
  3. 两者的使用场景有不同：短连接适用于客户端请求频率不高的场景，如浏览网页等。长连接适用于客户端与服务端通信频繁的场景，如聊天室，实时游戏等。

7. TCP构建服务端客户端（一发一收）

7.1 创建服务端TcpServer.java

public class TcpServer {private ServerSocket serverSocket = null;private ExecutorService service = Executors.newCachedThreadPool();public TcpServer(int port) throws IOException {serverSocket = new ServerSocket(port);}public void start() throws IOException {System.out.println("服务器启动！");while(true){Socket socket = serverSocket.accept();service.submit(new Runnable() {@Overridepublic void run() {processConnection(socket);}});
//            Thread thread = new Thread(() -> {
//                processConnection(socket);
//            });
//            thread.start();}}public void processConnection(Socket socket){System.out.printf("客户端上线: [%s:%d]\n",socket.getInetAddress().toString(),socket.getPort());try(InputStream inputStream = socket.getInputStream();OutputStream outputStream = socket.getOutputStream()){while(true){Scanner sc = new Scanner(inputStream);if(!sc.hasNext()){System.out.printf("客户端下线: [%s:%d]\n",socket.getInetAddress().toString(),socket.getPort());break;}String request = sc.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",socket.getInetAddress().toString(),socket.getPort(),request,response);}}catch (IOException e){e.printStackTrace();}finally {try {socket.close();} catch (IOException e) {e.printStackTrace();}}}public String process(String request) {return request;}public static void main(String[] args) throws IOException {TcpServer tcpServer = new TcpServer(9090);tcpServer.start();}
}

7.2 创建客户端TcpClient.java

public class TcpClient {private Socket socket = null;public TcpClient(String ip, int port) throws IOException {socket = new Socket(ip,port);}public void start(){System.out.println("客服端启动！");Scanner sc = new Scanner(System.in);try(InputStream inputStream = socket.getInputStream();OutputStream outputStream = socket.getOutputStream()){while(true){System.out.println("-> ");String request = sc.next();PrintWriter writer = new PrintWriter(outputStream);writer.println(request);writer.flush();Scanner scanner = new Scanner(inputStream);String response = scanner.next();System.out.println(response);}} catch (IOException e) {e.printStackTrace();}}public static void main(String[] args) throws IOException {TcpClient tcpClient = new TcpClient("127.0.0.1",9090);tcpClient.start();}
}

Tcp简单翻译和Udp修改规则相同。

8. 启动多个客户端

1.这里是引用
2.在这里插入图片描述
3. 在这里插入图片描述
4.
在这里插入图片描述

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

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

相关文章

osg实现鼠标框选

osg实现鼠标框选

目录 1. 需求的提出 2. 具体实现 2.1. 禁止场景跟随鼠标转动 2.2. 矩形框前置绘制 3. 附加说明 3.1. 颜色设置说明 3.2.矩形框显示和隐藏的另一种实现 1. 需求的提出 有时需要在屏幕通过按住键盘上的某个键如Ctrl键且按住鼠标左键&#xff0c;拖出一个矩形&#xff0c;实现框…
阅读更多...
ValueError: check_hostname requires server_hostname

ValueError: check_hostname requires server_hostname

使用jupyter 下载js2py 异常 !pip install js2py ValueError: check_hostname requires server_hostname 一开始以为是数据源问题&#xff0c;切换阿里云 还是这个异常 结果发现是开魔法导致的&#xff0c;关闭魔法即可
阅读更多...
怒刷LeetCode的第23天（Java版）

怒刷LeetCode的第23天（Java版）

目录 第一题 题目来源 题目内容 解决方法 方法一&#xff1a;贪心算法 方法二&#xff1a;动态规划 方法三&#xff1a;回溯算法 方法四&#xff1a;并查集 第二题 题目来源 题目内容 解决方法 方法一&#xff1a;排序和遍历 方法二&#xff1a;扫描线算法 方法…
阅读更多...
英伟达NVIDIA驱动安装

英伟达NVIDIA驱动安装

一般&#xff0c;我们新的显卡上机或者新系统可能就需要重新安装显卡驱动。或者是我们在配置深度学习环境时候&#xff0c;需要手动安装驱动。 官网地址&#xff1a;官方高级驱动搜索 | NVIDIA 我们选择好自己需要的驱动后直接安装即可 下载的时候&#xff0c;选择自己需要的驱…
阅读更多...
计算机竞赛 深度学习卷积神经网络垃圾分类系统 - 深度学习 神经网络 图像识别 垃圾分类 算法 小程序

计算机竞赛 深度学习卷积神经网络垃圾分类系统 - 深度学习 神经网络 图像识别 垃圾分类 算法 小程序

文章目录 0 简介1 背景意义2 数据集3 数据探索4 数据增广(数据集补充)5 垃圾图像分类5.1 迁移学习5.1.1 什么是迁移学习&#xff1f;5.1.2 为什么要迁移学习&#xff1f; 5.2 模型选择5.3 训练环境5.3.1 硬件配置5.3.2 软件配置 5.4 训练过程5.5 模型分类效果(PC端) 6 构建垃圾…
阅读更多...
JavaSE | 初识Java(一) | JDK \ JRE \ JVM

JavaSE | 初识Java(一) | JDK \ JRE \ JVM

Java初识 Java 是一门半编译型、半解释型语言。先通过 javac 编译程序把源文件进行编译&#xff0c;编译后生成的 .class 文件是由字节 码组成的平台无关、面向 JVM 的文件。最后启动 java 虚拟机 来运行 .class 文件&#xff0c;此时 JVM 会将字节码转换成平台能够理…
阅读更多...
线程的概述

线程的概述

#include <pthread.h> int pthread_create(pthread_t *thread, const pthread_attr_t *attr, void *(*start_routine) (void *), void *arg); 功能&#xff1a;创建一个子线程 参数&#xff1a; -thread:传出参数&#xff0c;线程创建成功后&#xff0c;子线程的ID被写到…
阅读更多...
日常工作报告生成器微信小程序源码 支持日报,周报,月报,年终终结

日常工作报告生成器微信小程序源码 支持日报,周报,月报,年终终结

相信大家上班都会有做工作报告的情况吧 那么这款小程序就是大家的福音了 只要输入你的工作内容或者岗位自动生成你的工作报告 支持报,周报,月报,年终终结 源码下载&#xff1a;https://download.csdn.net/download/m0_66047725/88391810 源码下载2&#xff1a;评论留言或私信…
阅读更多...
竞赛选题 机器视觉的试卷批改系统 - opencv python 视觉识别

竞赛选题 机器视觉的试卷批改系统 - opencv python 视觉识别

文章目录 0 简介1 项目背景2 项目目的3 系统设计3.1 目标对象3.2 系统架构3.3 软件设计方案 4 图像预处理4.1 灰度二值化4.2 形态学处理4.3 算式提取4.4 倾斜校正4.5 字符分割 5 字符识别5.1 支持向量机原理5.2 基于SVM的字符识别5.3 SVM算法实现 6 算法测试7 系统实现8 最后 0…
阅读更多...
因为在此系统上禁止运行脚本

因为在此系统上禁止运行脚本

问题&#xff1a; 解决办法&#xff1a; vue项目搭建中"因为在此系统上禁止运行脚本"报错&#xff0c;解决方法 - 你的剧本 - 博客园 (cnblogs.com)
阅读更多...
RDP协议流程详解（一）Connection Initiation阶段

RDP协议流程详解（一）Connection Initiation阶段

Connetction Initiation是RDP连接的第一个阶段&#xff0c;具体包含两个消息RDP Negotiation Request和RDP Negotiation Response&#xff0c;下面结合协议数据包详细分析。 &#xff08;1&#xff09;RDP Negotiation Request 从数据包可以清晰看到此时的协议栈依次是TCP-TPKT…
阅读更多...
反序列化漏洞

反序列化漏洞

原理 反序列化是对象变成可以传输的字符串。 PHP反序列化的时候&#xff0c;基本都是围绕着serialize()&#xff0c;unserialize()这两个函数 serialize() 和 unserialize() 在 PHP内部没有漏洞的&#xff0c;产生反序列化漏洞是因为应用程序在处理对象、魔术函数以及序列化…
阅读更多...
mysql面试题12：讲一讲MySQL中什么是半同步复制？底层实现？

mysql面试题12：讲一讲MySQL中什么是半同步复制？底层实现？

该文章专注于面试，面试只要回答关键点即可，不需要对框架有非常深入的回答，如果你想应付面试，是足够了，抓住关键点 面试官：讲一讲mysql中什么是半同步复制？底层实现？ MySQL中的半同步复制（Semi-Synchronous Replication）是一种复制模式，它在主服务器将数据写入到二…
阅读更多...
10.2 调试事件获取DLL装载

10.2 调试事件获取DLL装载

理解了如何通过调试事件输出当前进程中寄存器信息&#xff0c;那么实现加载DLL模块也会变得很容易实现&#xff0c;加载DLL模块主要使用LOAD_DLL_DEBUG_EVENT这个通知事件&#xff0c;该事件可检测进程加载的模块信息&#xff0c;一旦有新模块被加载或装入那么则会触发一个通知…
阅读更多...
k8s集群-6（daemonset job cronjob控制器）

k8s集群-6（daemonset job cronjob控制器）

Daemonset 一个节点部署一个节点 当有节点DaemonSet 确保全部 (或者某些) 节点上运行一个 Pod 的副本。加入集群时&#xff0c;也会为他们新增一个 Pod 。当有节点从集群移除时&#xff0c;这些Pod 也会被回收。删除 DaemonSet 将会删除它创建的所有 Pod。 DaemonSet 的典型用…
阅读更多...
Swift SwiftUI CoreData 过滤数据 1

Swift SwiftUI CoreData 过滤数据 1

Xcode: Version 14.3.1 (14E300c) iOS: 16 预览&#xff1a; Code: import SwiftUI import CoreDatastruct TodosSearch: View {State private var search_title "测试"FetchRequest var todos_search: FetchedResults<Todo>init() {let request: NSFetchReq…
阅读更多...
《机器学习实战》学习记录-ch2

《机器学习实战》学习记录-ch2

PS: 个人笔记&#xff0c;建议不看 原书资料&#xff1a;https://github.com/ageron/handson-ml2 2.1数据获取 import pandas as pd data pd.read_csv(r"C:\Users\cyan\Desktop\AI\ML\handson-ml2\datasets\housing\housing.csv")data.head() data.info()<clas…
阅读更多...
Access注入---Cookie注入

Access注入---Cookie注入

Access注入----Cookie注入Access数据库&#xff08;微软&#xff09; 逐渐淘汰 &#xff08;没有库的概念&#xff0c;是表的集合&#xff09;Access没有系统自带库Cookie注入&#xff08;头注入HEAD注入的&#xff09;php中产生Cookie注入的可能性小&#xff0c;但ASP产生Cook…
阅读更多...
代码随想录算法训练营第五十七天 | 动态规划 part 15 | 392.判断子序列、115.不同的子序列

代码随想录算法训练营第五十七天 | 动态规划 part 15 | 392.判断子序列、115.不同的子序列

目录 392.判断子序列思路代码 115.不同的子序列思路代码 392.判断子序列 Leetcode 思路 dp[i][j] 表示以下标i-1为结尾的字符串s&#xff0c;和以下标j-1为结尾的字符串t&#xff0c;相同子序列的长度为dp[i][j]递推公式&#xff1a; 初始化&#xff1a;为0遍历顺序&#xff…
阅读更多...
【Spring】Bean作用域和生命周期

【Spring】Bean作用域和生命周期

Bean作用域和生命周期 一. Bean 的作用域1. Bean 的 6 种作⽤域&#xff1a;①. singleton②. prototype③. request④. session⑤. application⑥. websocket单例作用域(singleton) VS 全局作⽤域(application) 2. 设置作用域 二. Spring 执行流程和 Bean 的生命周期1. Spring…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023