【JavaEE】网络编程示例1-UDP套接字数据报编程 == 一发一收

本文涉及的产品
云解析 DNS,旗舰版 1个月
全局流量管理 GTM,标准版 1个月
公共DNS(含HTTPDNS解析),每月1000万次HTTP解析
简介: JavaEE & 网络编程示例1 & UDP套接字数据报编程 ==> 一发一收

JavaEE & 网络编程示例1 & UDP套接字数据报编程 ==> 一发一收

1. 协议分层(回顾)

应用层

应用程序所在(程序员),数据的用途

传输层

关注传输过程的起点和终点

网络层

负责整个传输过程的路径规划

数据链路层

针对两个相邻节点之间的数据传输

物理层

硬件设备,基础设施

对于2 和 3 是操作系统内核封装的


对于4 和 5 是硬件和驱动控制的


一般程序员只需要关注1 和 2 即可~

毕竟 1 要传出去或者接受要经过 2


eb35ba9f8021429c836b0d1b0df4603a.png

2. 套接字 Socket

程序员编写网络程序主要编写的是应用层代码


那么,我们就需要第下层协议的提供服务,即 应用层调用传输层提供的API


socket API,网络编程的重要API

socket - 插座,不要纠结名词,用就是了~

这些API是C / C++ 风格的,因为操作系统本身就是C / C++ 写的


JDK针对这些API,封装成Java风格的API

Java程序员这需要正常使用这些API就足够了~

系统给咱们提供了两组socket API


基于UDP的API

基于TCP的API

Destination User Prompter


Transmission Control Protocol


2.1 UDP与TCP两组协议的主要区别

这两个协议有各自的特点~

当然还有其他特点,不做细讲~

2.1.1 UDP无连接,TCP有链接

连接:是一种抽象的连接

就比如说谈恋爱和结婚,结婚就是一种有效的抽象连接


通信双方都隆重地记录了对方的信息~

如果我们的两台机器在通信的时候,需要单独保存记录两台机器的信息就是有连接,不需要则是无连接


注意:不代表无连接就没用到对方的信息,而是只是用到,就仅仅是用到

短期恋爱~

小例子:


DUP无连接

发送就完事了,不需要连接

e6bfa88fed814941a04c2f6500c04ccb.png


TCP有连接:

先连接才能通信

496abc5ae58b44869da49d78fb7a7e8f.png

2.1.2 UDP不可靠传输,TCP可靠传输

可靠传输 不代表百分百能够有效传输,但是会尽力的传输~!

传没传成功,是可以心知肚明的

不可靠传输 则代表,“无所谓,你收不到不是我的锅“

以上面的那个例子继续说:


DUP不可靠传输

我发了就发了,并不在意对方收没收到

我还记得我高中的时候,老人机发短信给我老爸,叫他来学校载我,结果我不知道我爸没收到,导致我等了2 - 3小时 T.T


a874feef019f4cfb9b82a7c4deb83974.png


TCP可靠传输

不说每次都能通信,但是我一定能知道有没有成功



2.1.3 UDP面向数据报,TCP面向字节流

这个跟IO操作的字符流字节流是相似的~

TCP面向字节流:


数据传输以字节为基本单位,读写方便灵活

不在本章讲解


bef44d7e1e1f40239a1b9db42d24d553.png

UDP面向数据报:


数据运算是以一个UDP数据报为基本单位(待会儿的重点)

读写操作不大灵活

d0a3c49a27fd4a74af16a01087a6d1e3.png


2.1.4 UDP与TCP 全双工

单双工:一条路径,单向通信


一边通信完了,另一边才能过去

全双工:一条路径,双向通信


这一边朝另一边,另一边朝这一边,是不需要等的

除非另一边需要这一边的数据作为前提~

例如马路:



对于单双工

c0cc79764f124f048fddeed1b930c485.png


对于全双工

则很有秩序~

而两种协议都是全双工的,所以不用操心~

d90e67eaa8614578a73b964d56ccd525.png


3. 网络编程示例1 ==> 一发一收

UDP要比TCP简单,先难后易

接受新知识的过程可能会很困难,但是这也算是固定写法

熟练最重要!!!

TCP将在后续文章讲到!

这是本文章重点!

3.1 DatagramSocket 与 DatagramPacket

ed78534d9d7040b5980072e801966040.png


Socket ==> 数据报的Socket对象

Packet ==> 这个对象就是一个UDP数据报

71c7dc483b234cd9ab27d02d07334f9a.png


DUP数据运算的基本单位


3.1.1 Socket对象

在文件操作系统中,在文件操作的 时候提到,不是目录不是普通文件的文件


这样特殊的文件有很多,其中就有socket文件

而一个Socket对象就对应一个socket文件~

而socket文件并非对应到硬盘的某一个存储区,而是对应到网卡的一个硬件设备


打开命令行(win + R + cmd)输入ipconfig:


有线网卡


e28984bcc170412c8a46ccff30386439.png

无线网卡:


3e6e45a5eeae4f1ea76e0e6580b268ba.png

一般网卡都是集成在主板上面的


caf5665fdc36deb261318f3206823f33.jpg

文件:


广义:指代系统资源

计算机上的 软件 / 硬件

操作系统的基本设计思想: “一切皆文件”【简化逻辑】

狭义:指代硬盘上的一块数据存储区域

所以,要相进行网络通信,就需要socket文件对应的这个对象(内存中的变量)去搞事情,从而间接操控网卡


输入信息到Socket对象里,就相当于输入信息到socket文件里,就相当于通过网卡发送信息

提取Socket对象里的信息,就相当于读取socket文件里的信息,就相当于通过网卡接受信息

3.1.2 DatagramSocket的一些方法

方法名 方法说明

DatagramSocket() 创建一个Socket,绑定本机任意一个空闲的端口

DatagramSocket(int port) 创建一个Socket,绑定指定的端口(port)

对于不带参数的构造方法,一般用于客户端

系统分配一个端口~

对于待参数的构造方法,一般用于服务端

小例子:

08e102ef38c34ff8a0d7800c33aa65f7.png


6813a6d599974f8f83b7deb5704cce79.png



方法名 方法说明

void receive(DatagramPacket p) 接受数据报并读取到已有数据报

void send(DatagramPacket p) 发送数据报

void close() 关闭socket文件(避免文件资源泄露,但是很少有关闭的时候,这也符合实际情况)

不纸上谈兵了,等一下实战你就懂了!

3.1.3 DatagramPacket的一些方法

本体:


方法名 方法说明

DatagramPacket(byte[] buf, int length) 成员buf取参数字节数组的头开始,长度length的部分

DatagramPacket(byte[] buf, int offset, int length, SocketAddress address) 成员buf取参数为字节数组的头开始长度length的部分,并且传入offset(缓冲区偏移量)和socket地址

DatagramPacket(byte[] buf, int length, InetAddress address, int port) 成员buf取参数为字节数组的头开始长度length的部分,并传入包装IP的InetAddress对象,和端口号

对于不带地址的版本:一般就是接受消息的

对于带地址的版本:一般就是用来发送消息的

这个地址包括目的地的IP和端口号~

IP — 确认电脑

端口号port — 确定应用程序

对于第三个构造方法,一般也用于发送信息给服务器的~

InetAddress是对服务器IP地址的包装

端口号代表服务器程序所在的“位置”

方法名 方法说明

InetAddress getAddress() 获取客户端or服务器的IP地址

int getPort() 获取客户端or服务器的端口号

byte[] getData() 获取数据报里的数据

不纸上谈兵了,等一下实战你就懂了!

3.2 基于UDP 的 Socket 写一个简单的客户端服务器程序



73a2294fc9a148b69690fde417774417.png



13376a6140514dd1b31ca12db75b4ee6.png

578cd7c751ea47c398570b4c575a2b2a.png

回显服务器(echo server)

即,客户端发起的请求,服务器响应一个一模一样的响应

请求就是“没有请求”

e3ef08fa8e90411f845538cd26724617.png


就像这样,老板没给我做,给我回了句一模一样的话

接下来就是书写代码的环节了!


第一遍不懂很正常,最终的总结分析可能会对你有很大帮助!

3.2.1 服务器

三个核心工作:


读取请求并解析

根据请求求得对应响应(回显服务器 无此操作)

把响应返回给客户端

构建一个Socket对象

14165815d49e465487c11360806b88ce.png


写一个构造方法


服务器的固定端口!

要处理异常,因为并不是每一次都能绑定成功对应的端口号~

此端口号被占用,就会出错!

在一个主机里,一个端口在同一时刻只能被一个进程绑定

public UDPEchoServer(int port) throws SocketException {
        this.socket = new DatagramSocket(port);
    }


启动服务器的主方法

public void start() {
    System.out.println("启动服务器成功");
    //服务器一直工作 或者 等待客户端请求
    //所以说才很少关闭~
    while(true) {
        //做那三件事!
    }
}


3.2.1.1 读取请求并解析

再次重点强调【数据报】是什么


数据报是一个对象,而服务器要响应的是里面的【数据String】~

数据报为了确定发送对象和确定身份,增加了很多属性和东西~


7f2b17c819cc485f88af02de79bb3c74.png

而我们只需要用socket对象与网卡进行联系,这样就能实现应用层和传输层的数据交换~


而UDP协议,数据传输的基本单位就是【数据报】!

994547698cdd4bfdb739f17ee170ea43.png



public void start() throws IOException {
    System.out.println("启动服务器成功");
    //服务器一直工作 或者 等待客户端请求
    while(true) {
        DatagramPacket request = new DatagramPacket(new byte[1024], 1024);
        //****************  自带饭盒 ****************
        socket.receive(request);//request --- 载体
        //io操作都可能会有IOException异常
        //盛饭,从网卡里面拿的请求,将其录入已存在的数据报里
        String request = new String(requestPacket.getData(), 0,                                      requestPacket.getLength());
    }
}

34cba2274ccc46adaf1bd96434ec4a72.png

Java中的“二进制数据”,可以通过这样构造字符串去解析~

解析utf8编码 -------- 三个字节 ==> 一个字符

解析二进制数据不要与unicode混了~

Unicode跟char类型有关~ 两个字节

4daab30c88764d94a0bd626aea807e76.png


死循环是因为一个服务器无时无刻都要尝试获取请求~


输出型参数:

指的是方法并没有返回一个值,而是将值录入到参数里。起到返回的作用

不用申请多的空间,也不需要拷贝一份返回并修改原指向

例如Set的对象里有一个toArray(T[] ts)方法

这个方法也用到了输出型参数

37496c9147114018b66a41fe30e290f6.png


再例如字符串转字符数组:


6513f7d2f6cd4725ac2c53848d44ee7a.png



public String process(String request) {
    //回显服务器直接返回原值~
    return request;
}

此时,如果还没有客户端发来的数据,咋办?


receive阻塞等待就行了

直到客户端发来请求

有点类似于阻塞队列~

3.2.1.2 计算请求信息为响应信息

String response = process(request);
//计算该字符串的响应



3.2.1.3 将响应信息打包成【数据报】

DatagramPacket responsePacket = new DatagramPacket(response.getBytes(),
        response.getBytes().length,
        requestPacket.getSocketAddress());


getSocketAddress ==> 数据报里的客户端主机IP
* 传给客户端得转化为数据报才行
* 而计算数据报的信息计算只能以字符串为对象
3.2.1.4 响应数据报信息发送给客户端
socket.send(responsePacket);
//发送数学报,数据报有客户端的信息,所以可以具体的转发到对方机器
//响应


3.2.1.5 打印日志

System.out.printf("客户端[%s, %d], 发来请求[request]:%s, 其将收到响应[response]:%s\n",
        requestPacket.getAddress(), requestPacket.getPort(),
        request, response);


3.2.1.6 图片分析

7c9e8067a28f4e8598ffd03282e43bda.png


3.2.2 客户端

三个核心工作:


输入台输入请求核心信息,并打包成数据报

发送数据报给服务器

等待服务器响应

public class UDPEchoClient {
    private DatagramSocket socket = null;
    private String serverIP;
    private int serverPort;
}


客户端一些必备的属性

自己的socket对象,只不过端口号可以随机~

服务器的IP和端口 — 决定了发送请求的对象!

//确定服务器
public UDPEchoClient(String serverIP, int serverPort) throws SocketException {
    this.socket = new DatagramSocket();
    this.serverIP = serverIP;
    this.serverPort = serverPort;


构造方法~

传入服务器信息~

socket对象本身就自动获得该机器的IP

经过socket对象的方法,数据报也会染上socket对象的信息也就是发送方的信息~

也就是说

在服务器视角,收到的请求数据报是有客户端的地址的,而客户端发出需要有服务器的地址

在客户端视角,收到的响应数据报是有服务器的地址的,而服务器发出需要有客户端的地址

socket对象操作默认填入socket对象的信息~

3.2.2.1 控制台输入请求

public void start() throws IOException {
    //客户端输入信息
    Scanner scanner = new Scanner(System.in);
    while(true) {
        System.out.print("-> ");
        String request = scanner.nextLine();
        //next方法以空格或者回车分割!
        //控制台输入数据报的【主信息】
    }
}


死循环 ==> 客户端无时无刻都可以发送请求

3.2.2.2 请求信息打包成【数据报】

现在可没有现成的数据报来获取IP和端口号地址~

这里需要可以利用这个构造方法~


InetAddress对象就是IP的一种包装~


InetAddress.getByName,打包对应的IP地址


这里传入了serverIP,即服务器IP


不用理解太深,用就是了


750fbedaef9f4e149b514ce3eee07fd7.png


DatagramPacket requestPacket = new DatagramPacket(request.getBytes(),
        request.getBytes().length,
        InetAddress.getByName(serverIP), serverPort);
//打包信息成数据报
//根据ip打包成InetAddress对象

4124c6a9a2684016a06f405b7da9b2f7.png



3.2.2.3 通过socket对象将【数据报】发送给服务器

socket.send(requestPacket);
//发送给服务器


3.2.2.4 等待服务器响应

DatagramPacket responsePacket = new DatagramPacket(new byte[1024], 1024);
//等待服务器返回响应
//而两个机器之间是通过数据报传输
socket.receive(responsePacket);


做好“饭盒” - 【空数据报】,服务器一旦返回响应,就接下~

同样的,服务器返回前,要阻塞等待~


3.2.2.5 提取数据报信息并打印日志

String response = new String(responsePacket.getData(), 0, responsePacket.getLength());
//获取数据报里面的响应信息!
System.out.printf("服务器[%s, %d], 收到请求[request]:%s, 发来响应[response]:%s\n", serverIP,
        serverPort, request, response);
//打印日志


获取【数据报】里的“核心数据”,做成字符串~


32523068bc3f4e9cb111356b26bbc82b.png

3.2.2.6 图片分析

c73f0cfb1dab483488a1354aaa4552e6.png


3.2.3 测试与总结

在服务器里,有一个main线程:

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


在客户端也有一个main线程:

public static void main(String[] args) throws IOException {
    UDPEchoClient udpEchoClient = new UDPEchoClient("10.61.10.239", 9090);
    udpEchoClient.start();
}


对,没错,这是两个进程!


服务器端口号9090是我随便给的!

要对应好!

服务器IP要自己去找!

win + R + cmd + ipconfig

e07a1e57d59f4a2b9df684457b44eaa3.png



运行测试:


47f95c6a12e440cfbe0cfa32dcf78580.gif


f1ea07c961df45d28773b58e7832a6ae.png


总结图示:

79558db01c454bc8b8ec608d093d645a.png



当然可以将服务器打包成jar包导入你的虚拟机

那么别人就可能通过客户端代码发送请求给你了~

不做演示~

3.3 socket文件怎么存储数据的

3120857480984a5481ee06dbd3170a18.png

目录
相关文章
|
2天前
|
监控 安全
公司上网监控:Mercury 在网络监控高级逻辑编程中的应用
在数字化办公环境中,公司对员工上网行为的监控至关重要。Mercury 作为一种强大的编程工具,展示了在公司上网监控领域的独特优势。本文介绍了使用 Mercury 实现网络连接监听、数据解析和日志记录的功能,帮助公司确保信息安全和工作效率。
68 51
|
15天前
|
Web App开发 缓存 网络协议
不为人知的网络编程(十八):UDP比TCP高效?还真不一定!
熟悉网络编程的(尤其搞实时音视频聊天技术的)同学们都有个约定俗成的主观论调,一提起UDP和TCP,马上想到的是UDP没有TCP可靠,但UDP肯定比TCP高效。说到UDP比TCP高效,理由是什么呢?事实真是这样吗?跟着本文咱们一探究竟!
42 10
|
14天前
|
Java
[Java]Socket套接字(网络编程入门)
本文介绍了基于Java Socket实现的一对一和多对多聊天模式。一对一模式通过Server和Client类实现简单的消息收发;多对多模式则通过Server类维护客户端集合,并使用多线程实现实时消息广播。文章旨在帮助读者理解Socket的基本原理和应用。
15 1
|
1月前
|
存储 网络协议 Java
【网络】UDP回显服务器和客户端的构造,以及连接流程
【网络】UDP回显服务器和客户端的构造,以及连接流程
49 2
|
1月前
|
存储 网络协议 Java
【网络】UDP和TCP之间的差别和回显服务器
【网络】UDP和TCP之间的差别和回显服务器
56 1
|
1月前
|
网络协议 测试技术 网络安全
Python编程-Socket网络编程
Python编程-Socket网络编程
|
2月前
|
网络协议 算法 网络性能优化
C语言 网络编程(十五)套接字选项设置
`setsockopt()`函数用于设置套接字选项,如重复使用地址(`SO_REUSEADDR`)、端口(`SO_REUSEPORT`)及超时时间(`SO_RCVTIMEO`)。其参数包括套接字描述符、协议级别、选项名称、选项值及其长度。成功返回0,失败返回-1并设置`errno`。示例展示了如何创建TCP服务器并设置相关选项。配套的`getsockopt()`函数用于获取这些选项的值。
|
2月前
|
C语言
C语言 网络编程(九)并发的UDP服务端 以线程完成功能
这是一个基于UDP协议的客户端和服务端程序,其中服务端采用多线程并发处理客户端请求。客户端通过UDP向服务端发送登录请求,并根据登录结果与服务端的新子线程进行后续交互。服务端在主线程中接收客户端请求并创建新线程处理登录验证及后续通信,子线程创建新的套接字并与客户端进行数据交换。该程序展示了如何利用线程和UDP实现简单的并发服务器架构。
|
2月前
|
网络协议
关于套接字socket的网络通信。&聊天系统 聊天软件
关于套接字socket的网络通信。&聊天系统 聊天软件
|
2月前
|
网络协议
网络协议概览:HTTP、UDP、TCP与IP
理解这些基本的网络协议对于任何网络专业人员都是至关重要的,它们不仅是网络通信的基础,也是构建更复杂网络服务和应用的基石。网络技术的不断发展可能会带来新的协议和标准,但这些基本协议的核心概念和原理将继续是理解和创新网络技术的关键。
124 0