佛山网站推广排名,项目从立项到施工的程序,网站建设专业,广州哪家做网站最好概念
在网络编程中主要的对象有两个#xff1a;客户端和服务器。客户端是提供请求的#xff0c;归用户使用#xff0c;发送的请求会被服务器接收#xff0c;服务器根据请求做出响应#xff0c;然后再将响应的数据包返回给客户端。
作为程序员#xff0c;我们主要关心应…概念
在网络编程中主要的对象有两个客户端和服务器。客户端是提供请求的归用户使用发送的请求会被服务器接收服务器根据请求做出响应然后再将响应的数据包返回给客户端。
作为程序员我们主要关心应用层和传输层我们编写的程序属于应用层需要调用传输层的接口来进行数据的传输。Java给我们提供了两套接口一套是属于UDP 协议的另一套是属于 TCP 协议的。本篇文章重点讲解UDP 数据报套接字编程。
Socket套接字是由系统提供用于网络通信的技术是基于TCP/IP协议的网络通信的基本操作单元。 基于Socket套接字的网络程序开发就是网络编程。
UDP数据报套接字
DatagramSocket
DatagramSocket 简单来理解就是定位你所在的位置用于接收和发送数据报
构造方法
方法名说明DatagramSocket()无参构造方法不指定端口号由操作系统自行分配DatagramSocket(int port)port 就是端口号这个构造方法就是由程序员自行指定端口号
接收和发送数据包的方法
方法名说明send(DatagramPacket p)发送数据包receive(DatagramPacket p接收数据包这里是输出型参数传输层把数据内容填充到你传入的数据包中
什么是输出型参数 该参数在方法内部会被改变并且会影响到方法外部的实参。
关闭方法
方法名说明close()关闭资源
注意了网络编程使用 Socket 也是和内存、文件一样都会消耗资源的。
DatagramPacket
DatagramPacket 就是数据报也就是你发送和接收的数据报这里数据报和数据包不作区分大家知道就好了。
构造方法 字节数组就是用来填充数据的也是输出型参数。 offset 是指定偏移量 length 是指定要填充多少个字节 address 就是传入地址SocketAddress 就是一个完整的地址包含IP 和端口号InetAddress 只是包含 IP地址port 就是我们熟悉的端口号。
其他方法
方法名说明返回值getAddress()获得该数据包的 IP 地址InetAddressgetPort()获得该数据包端口号intgetSocketAddress()获得该数据包的完整地址(包含IP地址和端口号)SocketAddressgetData()或者数据内容byte[]getLength()获得数据的长度以字节为单位int
InetSocketAddress
构造方法
方法名说明InetSocketAddress(InetAddress addr, int port)创建一个 Socket 地址包含IP地址和端口号
其他方法
方法名说明注意getByName(String host)将主机名转化为机器能识别的IP地址静态方法
这个方法有什么用 我们知道一个IP地址我们习惯用十进制来表示类似”xxx.xxx.xxx.xxx我们通常传入的这个IP地址是一个字符串这个方法就能将这个字符串转化为机器能识别的二进制的 IP 地址。
回显服务器编写
这里简单介绍一下回显服务器就是你发什么我就回什么例如客户端发送一个 hello服务器直接返回 hello这就是回显服务器此服务器是用来我们学习套接字的。现在我来带领大家完成服务器代码的编写。
首先创建一个服务器的类这里定义为 UdpEchoServerEcho 就是回显的意思。 在类里面先定义字段 DatagramSocket socket private DatagramSocket socket;//给服务器指定一个端口号public UdpEchoServer(int port) throws SocketException {socket new DatagramSocket(port);}在构造方法这里要指定对应的端口号服务器的位置一定要固定下来防止客户端那边找不到服务器。 启动程序
服务器是 7 * 24 小时为用户提供的服务的所以这里我们直接写一个死循环 while(true) {} 每一次循环都是在处理一次请求。
首先我们要接收客户端的数据包先创建好一个空的数据包来接收数据这里为什么不传入地址因为我们这个数据包只是用来接收数据的并且就在服务器中使用不需要添加地址。
//构建请求数据包
DatagramPacket requestPacket new DatagramPacket(new byte[4096],4096);然后接收
//获取请求
socket.receive(requestPacket);//输出型参数如果没有数据可以接收的话服务器程序会一直在这里阻塞住。
解析数据包并计算请求由于这里是回显服务器所以我们直接构造出 String然后形式上进行响应的处理
//解析请求数据包
String request new String(requestPacket.getData(), 0, requestPacket.getLength());//计算响应值
//这里是回显服务器直接返回原数据
String response process(request);//计算响应服务器的核心代码区域private String process(String request) {return request;}在真实的服务器代码中我们在响应这里的处理是服务器的核心逻辑由于是回显服务器也就显得没有什么感受。 之后就要把响应的数据包发送回客户端那边。
注意由于 UDP 是不会保存对端的 IP地址和端口号的所以我们在构建响应数据包的时候一定要传入目的 IP 和 目的端口号这里的目的 IP 和 目的端口号可以从请求的数据包获取因为请求的数据包保存了客户端的IP 和 端口号。
//构建响应数据包
//UDP 不存放对端的源 IP 和 源端口所以需要传入对方的地址
DatagramPacket responsePacket new DatagramPacket(response.getBytes(), response.getBytes().length,
requestPacket.getSocketAddress());//发送响应数据包
socket.send(responsePacket);还要注意数据的长度一定是response.getBytes().length不要写出字符串的长度因为我们的数据是字节字节的大小和字符的大小是不一样的。 最后我们可以打印一个日志
//打印日志
System.out.printf([%s : %d] request: %s response: %s\n,requestPacket.getAddress().toString(),requestPacket.getPort(),request,response);因为 getAddress() 的返回值是 InetAddress 所以要使用 toString() 转化为字符串进行打印。
最终代码
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;//服务器程序
public class UdpEchoServer {private DatagramSocket socket;//给服务器指定一个端口号public UdpEchoServer(int port) throws SocketException {socket new DatagramSocket(port);}//服务器启动运行程序public void start() throws IOException {System.out.println(服务器启动...);//服务器持续运行//每次循环处理一次请求while(true) {//构建请求数据包DatagramPacket requestPacket new DatagramPacket(new byte[4096],4096);//获取请求socket.receive(requestPacket);//输出型参数//解析请求数据包String request new String(requestPacket.getData(), 0, requestPacket.getLength());//计算响应值//这里是回显服务器直接返回原数据String response process(request);//构建响应数据包//UDP 不存放对端的源IP 和 源端口所以需要传入对方的地址DatagramPacket responsePacket new DatagramPacket(response.getBytes(), response.getBytes().length,requestPacket.getSocketAddress());//发送响应数据包socket.send(responsePacket);//打印日志System.out.printf([%s : %d] request: %s response: %s\n,requestPacket.getAddress().toString(),requestPacket.getPort(),request,response);}}//计算响应服务器的核心代码区域private String process(String request) {return request;}public static void main(String[] args) throws IOException {UdpEchoServer server new UdpEchoServer(9090);server.start();}
}客户端编写
客户端是一定要知道请求是发到哪一个服务器上的所以我们需要保存好服务器的IP 地址和端口号。
private DatagramSocket socket;
private String serverIP;
private int serverPort;构造方法注意一定要传入服务器的 IP地址 和 端口号socket 使用的是 DatagramScoket 的无参构造方法。 为什么使用的是 DatagramScoket 的无参构造方法 首先我们作为程序员不知道用户那边的主机的端口使用情况如果固定用户的端口号正好用户此时已经有进程占用了这个端口号这时候我们的客户端程序是跑不起来的这就是端口冲突。 为了避免端口的冲突我们不指定端口号而是交给用户主机的操作系统自行指定端口号。 public UdpEchoClient(String serverIP, int serverPort) throws SocketException {this.serverPort serverPort;this.serverIP serverIP;socket new DatagramSocket();//不用指定客户端的端口号让用户自己的操作系统自己去安排端口号避免端口号冲突}启动程序
这里我们直接让用户从控制台输入要发送的数据我们构建好请求数据包并发送到服务器上
//构建请求数据包
DatagramPacket requestPacket new DatagramPacket(request.getBytes(),request.getBytes().length,
InetAddress.getByName(serverIP),serverPort);//发送数据包
socket.send(requestPacket);这里我们就使用了InetAddress.getByName()这个方法将本身是 String 类型的IP地址转化为机器能识别的IP地址。 然后要注意数据的长度一定是request.getBytes().length不要写出字符串的长度因为我们的数据是字节字节的大小和字符的大小是不一样的。
最后就是传入目的地址也就是服务器的源IP和源端口号然后发送给服务器那边。 接着就是接收服务器的响应我们构建一个空的响应数据包来接收
//接收数据包
DatagramPacket responsePacket new DatagramPacket(new byte[4096], 4096);
socket.receive(responsePacket);最后就是解析并打印响应内容了。
//打印响应数据
String response new String(responsePacket.getData(),0,responsePacket.getLength());
System.out.println(响应 response);最终代码
import java.io.IOException;
import java.net.*;
import java.util.Scanner;//客户端程序
public class UdpEchoClient {private DatagramSocket socket;private String serverIP;private int serverPort;public UdpEchoClient(String serverIP, int serverPort) throws SocketException {this.serverPort serverPort;this.serverIP serverIP;socket new DatagramSocket();//不用指定客户端的端口号让用户自己的操作系统自己去安排端口号避免端口号冲突}public void start() throws IOException {System.out.println(欢迎来到客户端...);Scanner scan new Scanner(System.in);while(true) {//用户从控制台输入数据System.out.println(请输入你要发送的数据);while(!scan.hasNext()) {break;}String request scan.nextLine();//构建请求数据包DatagramPacket requestPacket new DatagramPacket(request.getBytes(),request.getBytes().length,InetAddress.getByName(serverIP),serverPort);//发送数据包socket.send(requestPacket);//接收数据包DatagramPacket responsePacket new DatagramPacket(new byte[4096], 4096);socket.receive(responsePacket);//打印响应数据String response new String(responsePacket.getData(),0,responsePacket.getLength());System.out.println(响应 response);}}public static void main(String[] args) throws IOException {UdpEchoClient client new UdpEchoClient(127.0.0.1,9090);client.start();}
}由于我这里是使用一台主机的两个进程来模拟客户端和服务器的所以IP地址指定为127.0.0.1这是每台主机默认的IP地址端口号这里指定为 9090最后大家运行两个程序就可以看到下面的效果了。
效果展示
