Java开发之路

文章32 |   阅读 14698 |   点赞0

来源：https://blog.csdn.net/sunnyyoona

[Java]UDP通信的简单例子

x33g5p2x  于2021-03-13 发布在 其他  
字(7.0k)|赞(0)|评价(0)|浏览(404)
  1. package com.sjf;
  3. import java.io.IOException;
  4. import java.net.DatagramPacket;
  5. import java.net.DatagramSocket;
  6. import java.net.InetAddress;
  7. import java.net.InetSocketAddress;
  8. import java.net.SocketException;
  10. /**
  11.  * @time 2015-05-27
  12.  * @desc UDP通信
  13.  * @author sjf0115
  14.  *
  15.  */
  16. public class Server {    
  18.     private byte[] buffer = new byte[1024];    
  19.     private DatagramSocket socket = null;    
  20.     private DatagramPacket packet = null;    
  21.     private InetSocketAddress socketAddress = null;    
  22.     private InetAddress clientAddress;
  23.     private String clientIP;
  24.     private int clientPort;
  25.     private String clientData;
  27.     //+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
  28.     /**  
  29.      * 构造函数，绑定主机和端口.  
  30.      * @param ip  IP 地址
  31.      * @param port 端口  
  32.      * @throws Exception  
  33.      */    
  34.     public Server(String ip, int port) throws Exception 
  35.     {    
  36.         // 绑定IP地址和端口. 
  37.         Bind(ip,port); 
  38.         System.out.println("[服务端启动]");    
  39.     }
  40.     //++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
  41.     public Server() throws SocketException
  42.     {
  43.         // 构造数据报套接字并将其绑定到本地主机上任何可用的端口
  44.         socket = new DatagramSocket();    
  45.         System.out.println("[服务端启动]");    
  46.     }
  47.   //+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
  48.     /**  
  49.      * 绑定监听地址和端口.  
  50.      * @param ip IP地址  
  51.      * @param port 端口  
  52.      * @throws SocketException  
  53.      */    
  54.     public void Bind(String ip, int port) throws SocketException {    
  55.         // 根据 IP 地址和端口号创建套接字地址
  56.         socketAddress = new InetSocketAddress(ip, port);  
  57.         // 创建数据报套接字，将其绑定到指定的本地地址
  58.         socket = new DatagramSocket(socketAddress);
  59.         packet = new DatagramPacket(buffer, buffer.length);
  60.     }    
  61.     //+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
  62.     public final String getOrgIp() 
  63.     {    
  64.         return clientIP;    
  65.     }    
  66.     //+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
  67.     /**  
  68.      * 设置超时时间  
  69.      * @param timeout 超时时间  
  70.      * @throws Exception  
  71.      */    
  72.     public void SetTimeout(int timeout) throws Exception 
  73.     {    
  74.         /* 启用/禁用带有指定超时值的 SO_TIMEOUT，以毫秒为单位。
  75.          * 将此选项设为非零的超时值时，对此 DatagramSocket 调用 receive() 将只阻塞此时间长度。
  76.          * 如果超过超时值，将引发 java.net.SocketTimeoutException，虽然 DatagramSocket 仍旧有效。
  77.          * 选项必须在进入阻塞操作前被启用才能生效。
  78.          */
  79.         socket.setSoTimeout(timeout);    
  80.     }    
  81.     //+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
  82.     /**  
  83.      * 获得超时时间.  
  84.      * @return 返回超时时间.  
  85.      * @throws Exception  
  86.      */    
  87.     public int GetTimeout() throws Exception 
  88.     {    
  89.         return socket.getSoTimeout();    
  90.     }    
  91.     //+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
  92.     /**  
  93.      * 接收数据包，该方法会造成线程阻塞.  
  94.      * @return 返回接收的数据串信息  
  95.      * @throws IOException   
  96.      */    
  97.     public String Receive() throws IOException 
  98.     {    
  99.         /*
  100.          * 从此套接字接收数据报包。当此方法返回时，DatagramPacket 的缓冲区填充了接收的数据。
  101.          * 数据报包也包含发送方的 IP 地址和发送方机器上的端口号。此方法在接收到数据报前一直阻塞。
  102.          * 数据报包对象的 length 字段包含所接收信息的长度。如果信息比包的长度长，该信息将被截短。
  103.          */
  104.         socket.receive(packet);
  105.         // 数据报包包含发送方的 IP 地址
  106.         clientAddress = packet.getAddress();
  107.         clientIP = clientAddress.getHostAddress();
  108.         // 数据报包包含发送方的端口号
  109.         clientPort = packet.getPort();
  110.         // 数据报包包含发送方的数据
  111.         clientData = new String(packet.getData(), 0, packet.getLength());     
  112.         return " ["+clientData+"]";    
  113.     }    
  114.     //+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
  115.     /**  
  116.      * 将响应包发送给请求端.  
  117.      * @param bytes 回应报文  
  118.      * @throws IOException  
  119.      */    
  120.     public void Send(String info) throws IOException 
  121.     {    
  122.         packet.setAddress(clientAddress);
  123.         packet.setPort(clientPort);
  124.         packet.setData(info.getBytes()); 
  125.         /*
  126.          * 从此套接字发送数据报包。DatagramPacket 包含的信息指示：将要发送的数据、其长度、远程主机的 IP 地址和远程主机的端口号。
  127.          */
  128.         socket.send(packet);    
  129.     }    
  130.     //+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
  131.     /**  
  132.      * 关闭udp监听口.  
  133.      */    
  134.     public void close() 
  135.     {    
  136.         try 
  137.         {    
  138.             socket.close();    
  139.         } 
  140.         catch (Exception ex) 
  141.         {    
  142.             ex.printStackTrace();    
  143.         }    
  144.     }    
  145.     //+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
  146.     /**  
  147.      * 测试方法.  
  148.      * @param args  
  149.      * @throws Exception  
  150.      */    
  151.     public static void main(String[] args) throws Exception {    
  152.         String serverHost = "127.0.0.1";    
  153.         int serverPort = 3344;    
  154.         Server udpServerSocket = new Server(serverHost, serverPort);    
  155.         while (true) 
  156.         {    
  157.             String info = udpServerSocket.Receive();  
  158.             System.out.println("["+udpServerSocket.clientPort+"]->"+info);
  159.             udpServerSocket.Send("Reponse-----"+info);    
  160.         }    
  161.     }    
  162. }   
  1. package com.sjf;
  3. import java.io.*;  
  4. import java.net.*;  
  6. /** 
  7.  * @time 2015-05-27
  8.  * @desc UDP通信
  9.  * @author QPING
  10.  */  
  11. public class Client {  
  13.     private byte[] buffer = new byte[1024];  
  14.     private DatagramSocket socket = null;  
  15.     private InetSocketAddress socketAddress = null;    
  16.     private String clientIP;
  17.     private int clientPort;
  18.     private String clientData;
  19.     private InetAddress clientAddress;
  20.     private DatagramPacket sendPacket;
  21.     private DatagramPacket receivePacket;
  22.     //++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
  23.     public Client(String host, int port) throws Exception 
  24.     {    
  25.          // 根据 IP 地址和端口号创建套接字地址
  26.         socketAddress = new InetSocketAddress(host, port);  
  27.         // 创建数据报套接字，将其绑定到指定的本地地址
  28.         socket = new DatagramSocket(socketAddress);    
  29.         System.out.println("服务端启动!");    
  30.     }
  31.     //++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
  32.     /** 
  33.      * 构造函数，创建UDP客户端 
  34.      * @throws Exception 
  35.      */  
  36.     public Client() throws Exception 
  37.     {  
  38.         socket = new DatagramSocket();  
  39.     }  
  40.     //+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++  
  41.     /** 
  42.      * 设置超时时间，该方法必须在bind方法之后使用. 
  43.      * @param timeout 超时时间 
  44.      * @throws Exception 
  45.      */  
  46.     public final void SetTimeout(final int timeout) throws Exception 
  47.     {  
  48.         socket.setSoTimeout(timeout);  
  49.     }  
  50.     //+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
  51.     /** 
  52.      * 获得超时时间. 
  53.      * @return 返回超时时间 
  54.      * @throws Exception 
  55.      */  
  56.     public int GetTimeout() throws Exception 
  57.     {  
  58.         return socket.getSoTimeout();  
  59.     }
  60.     //+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
  61.     public DatagramSocket GetSocket() 
  62.     {  
  63.         return socket;  
  64.     }  
  65.     //+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
  66.     /** 
  67.      * 向指定的服务端发送数据信息. 
  68.      * @param ip 服务器主机地址 
  69.      * @param port 服务端端口 
  70.      * @param bytes 发送的数据信息 
  71.      * @return 返回构造后俄数据报 
  72.      * @throws IOException 
  73.      */  
  74.     public DatagramPacket Send(String ip,int port,String info) throws IOException 
  75.     {  
  76.         byte[] bytes = info.getBytes();
  77.         sendPacket = new DatagramPacket(bytes, bytes.length);
  78.         sendPacket.setAddress(InetAddress.getByName(ip));
  79.         sendPacket.setPort(port);
  80.         socket.send(sendPacket);  
  81.         return sendPacket;  
  82.     }  
  83.     //+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
  84.     /** 
  85.      * 接收从指定的服务端发回的数据. 
  86.      * @param lhost 服务端主机 
  87.      * @param lport 服务端端口 
  88.      * @return 返回从指定的服务端发回的数据. 
  89.      * @throws Exception 
  90.      */  
  91.     public String Receive(String lhost,int lport)   throws Exception 
  92.     {  
  93.         receivePacket = new DatagramPacket(buffer, buffer.length);  
  94.         socket.receive(receivePacket);  
  95.         // 数据报包包含发送方的 IP 地址
  96.         clientAddress = receivePacket.getAddress();
  97.         clientIP = clientAddress.getHostAddress();
  98.         // 数据报包包含发送方的端口号
  99.         clientPort = receivePacket.getPort();
  100.         // 数据报包包含发送方的数据
  101.         clientData = new String(receivePacket.getData(), 0, receivePacket.getLength());     
  102.         return "["+clientData+"]"; 
  103.     }  
  104.     //++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
  105.     /** 
  106.      * 关闭udp连接. 
  107.      */  
  108.     public void close() 
  109.     {  
  110.         try 
  111.         {  
  112.             socket.close();  
  113.         } 
  114.         catch (Exception ex) 
  115.         {  
  116.             ex.printStackTrace();  
  117.         }  
  118.     }  
  119.     //++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
  120.     /** 
  121.      * 测试客户端发包和接收回应信息的方法. 
  122.      * @param args 
  123.      * @throws Exception 
  124.      */  
  125.     public static void main(String[] args) throws Exception {  
  127.         String serverHost = "127.0.0.1";  
  128.         int serverPort = 3344;
  130.         String myIP = "127.0.0.2";
  131.         int myPort = 3333;
  133.         Client client = new Client(myIP,myPort);  
  134.         while(true)
  135.         {
  136.             BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
  137.             System.out.println("["+myPort+"] ");
  138.             String str = br.readLine();
  140.             client.Send(serverHost, serverPort, str);
  142.             String info = client.Receive(serverHost, serverPort);  
  143.             System.out.println("["+client.clientPort+"]->" + info);  
  144.         }
  145.     }  
  146. }

内容来源于网络，如有侵权，请联系作者删除！

相关文章

    查看更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com