通过 Socket 实现 UDP 编程 入门

avatar 2017年12月04日22:59:12 5 2329 views
博主分享免费Java教学视频，B站账号：Java刘哥
上一篇文章介绍了基于 TCP 协议的 Socket 通信，本文介绍基于 UDP 协议的 Socket 通信，还是一个用户登录的例子。   UDP协议（用户数据报协议）是无连接、不可靠、无序的。 UDP协议以数据报作为数据传输载体。   进行数据传输时，首先要将要传输的数据定义成数据报（Datagram），在数据报中指明所要达到的 Socket（主机地址和端口），然后再将数据报发送出去。 相关操作类： DatagramPacket：表示数据报包 DatagramSocket：进行端到端通信的类  

DatagramPacket 构造器和成员方法

1、Datagram 构造方法   2、DatagramPacket 成员方法  

DatagramSocket 构造器和成员方法

1、DatagramSocket 构造器   2、DatagramSocket 成员方法    

一个服务端和支持多个客户端的对话demo

1、Server.java
  1. package com.liuyanzhao.udp;
  3. import java.io.IOException;
  4. import java.net.DatagramPacket;
  5. import java.net.DatagramSocket;
  6. import java.net.InetAddress;
  8. /**
  9.  * @author 言曌
  10.  * @date 2017/12/4 下午9:38
  11.  */
  13. public class Server {
  15.     public static void main(String[] args) throws IOException {
  16.         DatagramSocket socket = new DatagramSocket(8888);
  17.         byte[] data = new byte[1024];
  18.         DatagramPacket packet;
  19.         packet = new DatagramPacket(data, data.length);
  20.         System.out.println("服务器已启动");
  21.         while (true){
  22.             socket.receive(packet);//在接收到数据包之前一直阻塞
  23.             ServerThread thread = new ServerThread(socket, packet);
  24.             thread.run();
  25.         }
  26.     }
  28. }
  2、ServerThread.java
  1. package com.liuyanzhao.udp;
  3. import java.io.IOException;
  4. import java.net.DatagramPacket;
  5. import java.net.DatagramSocket;
  6. import java.net.InetAddress;
  8. /**
  9.  * @author 言曌
  10.  * @date 2017/12/4 下午10:24
  11.  */
  13. public class ServerThread implements Runnable {
  15.     private DatagramSocket socket;
  16.     private DatagramPacket packet;
  18.     public ServerThread(DatagramSocket socket, DatagramPacket packet) {
  19.         this.socket = socket;
  20.         this.packet = packet;
  21.     }
  23.     @Override
  24.     public void run() {
  26.         byte[] data = packet.getData();
  28.         String info = new String (data, 0, packet.getLength());
  29.         System.out.println("我是服务器，客户端说：" + info);
  31.         InetAddress address = packet.getAddress();
  32.         int port = packet.getPort();
  33.         byte[] data2 = "欢迎您！".getBytes();
  34.         DatagramPacket reply = new DatagramPacket(data2, data2.length, address, port);
  35.         try {
  36.             socket.send(reply);
  37.         } catch (IOException e) {
  38.             e.printStackTrace();
  39.         }
  40.     }
  41. }
  3、Client.java
  1. package com.liuyanzhao.udp;
  3. import java.io.IOException;
  4. import java.net.DatagramPacket;
  5. import java.net.DatagramSocket;
  6. import java.net.InetAddress;
  8. /**
  9.  * 客户端
  10.  * @author 言曌
  11.  * @date 2017/12/4 下午9:44
  12.  */
  14. public class Client {
  16.     public static void main(String args[]) throws IOException {
  18.         //1、定义服务器的地址、端口号、数据
  19.         InetAddress address = InetAddress.getByName("localhost");
  20.         int port = 8888;
  21.         byte[] data = "用户名：admin;密码：123456".getBytes();
  22.         //2、创建数据报
  23.         DatagramPacket packet = new DatagramPacket(data,data.length,address,port);
  24.         //3、创建DatagramSocket对象
  25.         DatagramSocket socket = new DatagramSocket();
  26.         //4、向服务器端发送数据
  27.         socket.send(packet);
  30.         /**
  31.          * 接受服务器端的响应的数据
  32.          */
  33.         //1、创建数据报，用于接受服务器响应的数据
  34.         byte[] data2 = new byte[1024];
  35.         DatagramPacket packet2 = new DatagramPacket(data2,data2.length);
  36.         //2、接受服务器响应的数据
  37.         socket.receive(packet2);
  38.         //3、读取服务器端响应的数据
  39.         String reply = new String(data2,0,packet2.getLength());
  40.         System.out.println("我是客户端，服务器说："+reply);
  41.         //4、关闭资源
  42.         socket.close();
  43.     }
  44. }
 

运行效果

1、先运行 Server 类   2、再运行 Client 类 服务器端界面   客户端界面   3、再启动一个 Client 类 服务器端界面     本文参考慕课网 本文地址：https://liuyanzhao.com/6924.html
历史上的今天
十二月
04日
  • 微信
  • 交流学习，有偿服务
  • weinxin
  • 博客/Java交流群
  • 资源分享，问题解决，技术交流。群号：590480292
  • weinxin
avatar

发表评论

avatar 登录者：匿名
匿名评论，评论回复后会有邮件通知

  

已通过评论：0   待审核评论数：0