【Java网络编程】基于UDP-Socket 实现客户端、服务器通信

本文涉及的产品
全局流量管理 GTM,标准版 1个月
公共DNS(含HTTPDNS解析),每月1000万次HTTP解析
云解析 DNS,旗舰版 1个月
简介: 【Java网络编程】基于UDP-Socket 实现客户端、服务器通信

 

Socket 套接字可以理解为是操作系统提供给程序员的一组用于网络编程的API (接口)——传输层的接口,传输层给应用层提供的一组 API,统称为 Socket API 。网络通信的底层逻辑都已经被操作系统封装好了,开发人员就可以根据接口开发实现网络通信。

Socket 套接字主要针对传输层协议分为如下三类:

    • 字节流套接字:使用传输层TCP协议
    • 数据报套接字:使用传输层UDP协议
    • 原始套接字:用于自定义传输层协议

    本篇博客主要讲述面向数据报的网络编程。


    一、Java基于UDP数据报套接字通信模型

    UDP 协议的特点:

      1. 面向无连接:传输数据之前,通信双方不依赖于建立连接,只需要知道谁发给谁即可。
      2. 不可靠传输:只负责发送,不关注数据是否传输成功,即使没发送成功啥也不干,也没有反馈
      3. 面向数据报:使用 UDP 数据报的形式传输,数据报可以理解为数据是一块一块的传输。image.gif编辑
      4. 有缓存区的概念:接收缓冲区,发送缓冲区:在进行网络数据通信时,用于存储待发送或已接收数据的缓冲区。
      5. 数据传输大小受限制:一个UDP 数据报最大占 64k, 1k = 1024字节
      6. 全双工通信:通信双方都可以同时进行信息交互

      总结:UDP 协议,具有面向无连接,面向数据报特点,即使通信双方没有建立连接,也会传输数据,并且一次性发送全部的数据报,一次性接受全部的数据报。

      Java 中基于UDP协议通信,主要使用 DatagramSocket 类来创建数据报套接字,并使用
      DatagramPacket 作为发送或接收的UDP数据报。


      针对一个客户端对服务器发出一次请求,服务器针对该请求给予响应流程如下:

      image.gif编辑在真实的网络环境中,一个服务器往往会给多个客户端提供响应。

      举个实际的例子根据以上流程图理解一下,张三老铁使用手机百度浏览器搜索 “美女图片”,此时前端页面就会将这条搜索记录 “美女图片” 拿到后台打包成UDP 数据报,以请求的形式发给百度服务器,百度服务器拿到请求后,解析数据报查看:哦~ 要美女啊,我这有很多,于是将“本地”存储的美女图片作为 UDP 数据报的形式响应给请求端,百度浏览器拿到百度服务器响应的数据后,通过解析,将图片展示在张三的手机界面上。


      二、UDP 数据报套接字编程

      2.1  DatagramSocket API

      DatagramSocket 是Socket 套接字基于UDP 协议来发送和接受数据报的类.

      Datagram : 数据报

      Socket : 说明这个对象是一个 Socket 对象

      Socket 对象相当于操作系统一个特殊的文件,这个文件并非对应对应的硬盘上的某个数据存储区域,而是对应到,网卡这个硬件!!!

      往 socket 对象中写数据,相当于通过网卡发送消息

      从 socket 对象中读数据,相当于通过网卡接收消息

      所以想要进行网络编程使得两个设备相互通信,就需要有 socket 文件这样的对象,借助这个 socket 文件对象来间接的操作网卡,操作系统基本设计思想:一切皆文件,为了简化系统内核的逻辑设计,socket 对象面向字节流读写


      image.gif编辑

      此处Socket 对象可以被客户端 / 服务端使用,服务器这边的 Socket 必须要关联一个具体的端口号,每个联网的设备在启动时或随机或指定都会绑定一个端口号,作为该应用程序的唯一标识,就相当于数据被你的设备接收,经解析需要知道这些数据需要交给那个应用程序处理。例如,qq 、微信没见过消息发串了的情况吧。

      客户端这边可以不需要手动指定,系统会自动随机分配,端口号的取值范围是 [0, 65535]。

      小于等于1024 的端口号,会提供给知名的服务器使用,不建议使用这一类。


      image.gif编辑

      socket 也是文件,用完了要关闭资源。


      2.2  DatagramPacket API

      DatagramPacket 类是用于基于UDP 协议的Socket 发送和接收的数据报。

      image.gif编辑

      只有两个参数的版本,不需要设计地址,通常用来接收消息。另一个多参数的版本需要显式的设置地址进去,通常要用来发送消息。


      image.gif编辑

      构造UDP 发送的数据报时,需要传入 socketAddress对象,这个对象可以使用 InetSocketAddress 来创建 。

      InetSocketAddress API 的构造方法:

      image.gif编辑


      三、基于UDP Socket 实现客户端,服务器程序

      分析客户端的程序的功能:

      1.发出请求(消息)

      2. 等待服务器响应(回应)

      3. 解析服务器的响应

      分析服务端的程序的功能:

      1. 尝试读取客户端的请求并解析

      2. 根据客户端的请求,统筹响应的数据

      3. 把响应返回到客户端


      3.1 服务端程序设计

      首先我们定义一个服务端的类:UdpEchoServer

      定义一个 Socket 对象文件,与网卡交互。

      //需要线定义一个 socket 对象
      //通过网络通信,必须要使用 socket 对象
      private DatagramSocket socket = null;

      image.gif

      利用 UdpEchoServer类 的构造方法为 socket 构造,并指定需要绑定的端口号

      public UdpEchoServer(int serverPort) throws SocketException {
              //构造 socket 的同时,指定要的关联/ 绑定的端口
              socket = new DatagramSocket(serverPort);
        }

      image.gif

      绑定一个端口,不一定能成功,如果某个端口已经被别的进程占用了,此时这里的绑定操作就会出错,同时一个主机上,一个端口,同一时刻,只能被一个进程绑定。所以这里会抛出异常。


      定义一个启动方法:start()

      方法内部采用循环的方式,每次循环,做三件事:

      1. 读取请求并解析,2. 根据请求计算响应,3. 把响应的结果写回客服端

      public void start() throws IOException {
              System.out.println("服务器启动!");
              while (true) {
                  // 每次循环,要做三件事情:
                  // 1. 读取请求并解析
                  // 构造接受请求的“空盒子”,指定盒子的大小 4096 字节
                  DatagramPacket requestPacket = new DatagramPacket(new byte[4096], 4096);
                  // 数据从网卡上来的
                  socket.receive(requestPacket);// 获取客户端的请求、
                  //为了方便处理这个请求,把二进制数据转换成 String
                  String request = new String(requestPacket.getData(), 0, requestPacket.getLength());
                  // 2. 根据请求计算响应 调用方法
                  String response = process(request);
                  /* 3. 把响应结果写回客服端
                  根据response 字符串,构造一个 DatagramPacket
                  和请求 packet 不同,此处构造响应的时候,需要指定这个包要发给谁 */
                  DatagramPacket responsePacket = new DatagramPacket(response.getBytes(), response.getBytes().length, requestPacket.getSocketAddress());
                  // response.getBytes() 转换为 byte二进制流
                  // requestPacket 是从客户端这里收来的,getSocketAddress 就会得到客户端的 IP 和 端口
                  socket.send(responsePacket);// 响应
                  // 可以保存以下日志
                  String now3 = df.format(System.currentTimeMillis()); // 返回当前系统时间
                  try(Writer writer = new FileWriter("outPut.txt", true)) {
                      writer.write(requestPacket.getAddress().toString() +
                              requestPacket.getPort() + " " + now3 +
                              " req: " + request + " resp:  " + response + "\n");
                  }
                  // 打印一下本次客户端与服务端的交互
                  System.out.printf("[%s:%d] req: %s, resp: %s\n", requestPacket.getAddress().toString(),
                          requestPacket.getPort(), request, response);
              }
          }

      image.gif

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

      image.gif

      2. 根据客户端的请求,统筹响应的数据,我们将第二步计算响应以函数的方式封装实现,参数 request 请求我们已经转换为字符串了,所以我们就可以依据请求做出对应的处理了,如果是需要搜索什么,就可以根据请求的内容将服务器的中存储的被搜索内容作为响应返回给客户端,如果是互相发消息,那就需要根据请求判断需要发给谁,此时需要双方约定在请求中添加接收方的IP 和 端口,这样才能找到接收方,作为服务器端来讲就需要使用多线程的思想,每一个客户端发来请求都会分配一个线程来处理。

      public String process(String request) { //这里直接将客户端的请求,作为响应返回
              return "服务器响应:" + request;
          }

      image.gif

      这个部分可以依据客户端的请求,进行对应的业务处理。


      3.2 客户端程序设计

      首先定义一个客户端的类:UdpEchoClient

      定义一个 Socket 对象文件,与网卡交互。

      定义 serverIP 的成员变量,用于存储服务器端的IP 地址

      定义 serverPort 的成员变量,用于存储服务器的端口号

      private DatagramSocket socket = null;
      private String serverIP = null; // IP
      private int serverPort = 0; // 端口号 —— 代表进程的标识

      image.gif

      利用 UdpEchoClient 类 的构造方法为 socket 构造,并为成员方法关联服务器的 IP 地址和端口

      //客户端启动,需要知道服务器在哪儿!!
          public UdpEchoClient(String serverIP, int serverPort) throws SocketException {
              //对于客户端来说,不需要显示关联端口
              // 不代表没有端口,而是系统自动分配了个空闲的端口
              socket = new DatagramSocket(); //获取随机端口号
              this.serverIP = serverIP;
              this.serverPort = serverPort;
          }

      image.gif

      定义一个启动方法:start()

      方法内部采用循环的方式,每次循环,做4件事:

      1. 从控制台获取用户输入的信息

      2. 将获取的信息构造成 UDP 数据报,并向服务器发送请求

      3. 客户端尝试获取读取服务器返回的响应

      4. 将获取的的响应根据业务需求做进一步的处理

      public void start() throws IOException {
              // 通过这个客户端可以多次和服务器进行交互
              System.out.println("客户端启动!");
              Scanner in = new Scanner(System.in);
              while (true) {
                  //1.先从控制台,读取一个字符串过来
                  //先打印一个提示符,提示用户要输入内容
                  System.out.print("->");
                  String request = in.next();
                  //2. 把字符串构造成 UDP packet, 并进行发送
                  DatagramPacket requestPacket = new DatagramPacket(
                          request.getBytes(),
                          request.getBytes().length,
                          //----如果参数为null,获得的是本机的IP地址
                          InetAddress.getByName(serverIP),// 确定主机的 IP 地址----在给定主机名的情况下确定主机的IP地址
                          serverPort);
                  socket.send(requestPacket); //响应
                  //3. 客户端尝试读取服务器返回的响应
                  DatagramPacket responsePacket = new DatagramPacket(new byte[4096], 4096);
                  socket.receive(responsePacket);
                  //4. 把响应的数据转换成 String 显示出来,利用 String 的构造方法转换
                  String response = new String(responsePacket.getData(), 0, responsePacket.getLength());
                  System.out.printf("req: %s, resp: %s\n", request, response);
              }
          }

      image.gif

      public static void main(String[] args) throws IOException {
              UdpEchoClient udpEchoClient = new UdpEchoClient("127.0.0.1",9090);
              udpEchoClient.start(); // 启动客户端
          }

      image.gif


      3.3 总结:

      以上客户端服务器代码使用了 Socket “ 文件流”, 但是没有调用 close() 方法释放资源,是因为文件流会随着进程的关闭而关闭,但是在实际开发中一定要记得随手关闭哦~

      启动客户端和服务器展示效果:

      image.gif编辑

      image.gif编辑

      image.gif编辑

      以上操作流程执行图。image.gif编辑

      一定是先启动服务器,再启动客户端,

      UDP(User Datagram Protocol)是一个无连接的传输层协议,它不保证数据包可靠传输。UDP比TCP更快,而且在对网络延迟要求较低、对数据准确性要求不高的情况下使用。本文将讨论基于UDP Socket的客户端服务器开发总结。

      UDP Socket

      Socket是一种用于在计算机之间进行通信的 API(应用程序接口)。UDP Socket是基于UDP协议进行通信的套接字,它提供了一种快速发送和接收数据包的方法,但是与TCP不同,它不会重复数据或者检查是否有缺失的数据包。

      编写UDP客户端的基本步骤如下:

        1. 创建一个UDP socket。
        2. 将要发送的数据打包到UDP数据包中。
        3. 使用UDP socket发送数据包到特定的IP地址和端口号。

        编写UDP服务器的基本步骤如下:

          1. 创建一个UDP socket并监听特定的端口号。
          2. 接收客户端发送的数据包。
          3. 处理数据包,然后将响应打包到另一个UDP数据包中。
          4. 使用UDP socket向客户端发送响应数据包。

          总结:

          在使用UDP Socket进行客户端和服务器开发时,需要注意以下几点:

            • UDP不会保证数据包的可靠传输,因此需要在应用程序中处理数据包的丢失或者损坏情况。
            • 由于UDP没有连接状态,因此可以同时与多个客户端通信。
            • 在UDP通信中,需要指定目标地址和端口号。
            相关文章
            |
            23天前
            |
            人工智能 Java 物联网
            JAVA网络编程的未来:URL与URLConnection的无限可能,你准备好了吗?
            随着技术的发展和互联网的普及,JAVA网络编程迎来新的机遇。本文通过案例分析,探讨URL与URLConnection在智能API调用和实时数据流处理中的关键作用,展望其未来趋势和潜力。
            42 7
            |
            23天前
            |
            安全 Java API
            深入探索Java网络编程中的HttpURLConnection:从基础到进阶
            本文介绍了Java网络编程中HttpURLConnection的高级特性,包括灵活使用不同HTTP方法、处理重定向、管理Cookie、优化安全性以及处理大文件上传和下载。通过解答五个常见问题,帮助开发者提升网络编程的效率和安全性。
            |
            23天前
            |
            JSON 安全 算法
            JAVA网络编程中的URL与URLConnection:那些你不知道的秘密!
            在Java网络编程中,URL与URLConnection是连接网络资源的两大基石。本文通过问题解答形式,揭示了它们的深层秘密,包括特殊字符处理、请求头设置、响应体读取、支持的HTTP方法及性能优化技巧,帮助你掌握高效、安全的网络编程技能。
            46 9
            |
            1月前
            |
            Python
            Socket学习笔记(二):python通过socket实现客户端到服务器端的图片传输
            使用Python的socket库实现客户端到服务器端的图片传输,包括客户端和服务器端的代码实现,以及传输结果的展示。
            139 3
            Socket学习笔记(二):python通过socket实现客户端到服务器端的图片传输
            |
            1月前
            |
            JSON 数据格式 Python
            Socket学习笔记(一):python通过socket实现客户端到服务器端的文件传输
            本文介绍了如何使用Python的socket模块实现客户端到服务器端的文件传输,包括客户端发送文件信息和内容,服务器端接收并保存文件的完整过程。
            150 1
            Socket学习笔记(一):python通过socket实现客户端到服务器端的文件传输
            |
            27天前
            |
            Web App开发 缓存 网络协议
            不为人知的网络编程(十八):UDP比TCP高效?还真不一定!
            熟悉网络编程的(尤其搞实时音视频聊天技术的)同学们都有个约定俗成的主观论调,一提起UDP和TCP,马上想到的是UDP没有TCP可靠,但UDP肯定比TCP高效。说到UDP比TCP高效,理由是什么呢?事实真是这样吗?跟着本文咱们一探究竟!
            52 10
            |
            23天前
            |
            JSON Java API
            JAVA网络编程新纪元:URL与URLConnection的神级运用,你真的会了吗?
            本文深入探讨了Java网络编程中URL和URLConnection的高级应用,通过示例代码展示了如何解析URL、发送GET请求并读取响应内容。文章挑战了传统认知,帮助读者更好地理解和运用这两个基础组件,提升网络编程能力。
            41 5
            |
            1月前
            |
            Java 流计算
            Flink-03 Flink Java 3分钟上手 Stream 给 Flink-02 DataStreamSource Socket写一个测试的工具!
            Flink-03 Flink Java 3分钟上手 Stream 给 Flink-02 DataStreamSource Socket写一个测试的工具!
            37 1
            Flink-03 Flink Java 3分钟上手 Stream 给 Flink-02 DataStreamSource Socket写一个测试的工具!
            |
            27天前
            |
            Java
            [Java]Socket套接字(网络编程入门)
            本文介绍了基于Java Socket实现的一对一和多对多聊天模式。一对一模式通过Server和Client类实现简单的消息收发;多对多模式则通过Server类维护客户端集合,并使用多线程实现实时消息广播。文章旨在帮助读者理解Socket的基本原理和应用。
            22 1
            |
            5月前
            |
            缓存 监控 Java
            Java Socket编程最佳实践:优化客户端-服务器通信性能
            【6月更文挑战第21天】Java Socket编程优化涉及识别性能瓶颈,如网络延迟和CPU计算。使用非阻塞I/O(NIO)和多路复用技术提升并发处理能力,减少线程上下文切换。缓存利用可减少I/O操作,异步I/O(AIO)进一步提高效率。持续监控系统性能是关键。通过实践这些策略,开发者能构建高效稳定的通信系统。
            171 1
            下一篇
            无影云桌面