Java编程使用UDP建立群聊系统代码实例-6ren

Java编程使用UDP建立群聊系统代码实例

转载作者：qq735679552 更新时间：2022-09-27 22:32:09

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章Java编程使用UDP建立群聊系统代码实例由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

相关java类介绍。

DatagramSocket 。

public class DatagramSocket extends Object 。

此类表示用来发送和接收数据报包的套接字.

数据报套接字是包投递服务的发送或接收点。每个在数据报套接字上发送或接收的包都是单独编址和路由的。从一台机器发送到另一台机器的多个包可能选择不同的路由，也可能按不同的顺序到达.

在DatagramSocket上总是启用UDP广播发送。为了接收广播包，应该将DatagramSocket绑定到通配符地址,在某些实现中，将DatagramSocket绑定到一个更加具体的地址时广播包也可以被接收. 。

可以通过DatagramSocket的send和receive来发送和接收数据. 。

public void receive(DatagramPacket p) throws IOException 。

从此套接字接收数据报包。当此方法返回时，DatagramPacket的缓冲区填充了接收的数据。数据报包也包含发送方的IP地址和发送方机器上的端口号.

此方法在接收到数据报前一直阻塞,数据报包对象的length字段包含所接收信息的长度。如果信息比包的长度长，该信息将被截短。

如果存在安全管理器，而安全管理器的checkAccept方法不允许接收操作，则包不能被接收.

参数:

p-要放置传入数据的DatagramPacket.

抛出:

IOException-如果发生I/O错误.

SocketTimeoutException-如果先前调用了setSoTimeout且超时值已过.

PortUnreachableException-套接字连接到当前不可达的目标时可能抛出。注意，不能保证一定抛出该异常.

IllegalBlockingModeException-如果此套接字具有相关联的通道，且通道处于非阻塞模式.

public void send(DatagramPacket p) throws IOException 。

从此套接字发送数据报包。DatagramPacket包含的信息指示：将要发送的数据、其长度、远程主机的IP地址和远程主机的端口号。

如果存在安全管理器，且套接字当前没有连接到远程地址，则此方法首先执行某些安全性检查。首先，如果p.getAddress().isMulticastAddress()为true，则此方法以p.getAddress()作为参数调用安全管理器的checkMulticast方法。如果该表达式的值为false，此方法改为调用安全管理器的以p.getAddress().getHostAddress()和p.getPort()为参数的checkConnect方法。如果不允许该操作，则每次调用安全管理器方法都会导致SecurityException.

参数:

p-将要发送的DatagramPacket.

抛出:

IOException-如果发生I/O错误.

SecurityException-如果安全管理器存在并且其checkMulticast或checkConnect方法不允许进行发送.

PortUnreachableException-套接字连接到当前不可达的目标时可能抛出。注意，不能保证一定抛出该异常.

IllegalBlockingModeException-如果此套接字具有相关联的通道，且通道处于非阻塞模式.

DatagramPacket 。

public final class DatagramPacket extends Object 。

此类表示UDP数据报包,数据报包用来实现无连接包投递服务。

构造方法

DatagramPacket(byte[]buf,intlength) 。

构造DatagramPacket，用来接收长度为length的数据包。

DatagramPacket(byte[]buf,intlength,InetAddressaddress,intport) 。

构造数据报包，用来将长度为length的包发送到指定主机上的指定端口号。

UDP群聊系统的示例。

UDP是面向无连接的,群聊就是向广播地址(broadcastingaddress)发送数据,这样每个人都会收到消息;采用线程的方式,启动一个发送方线程和接收方线程,发送方读取键盘输入作为输出,接收方读到输入的信息并显示。

发送方。

UdpSender.java 。

 
    ? 
   
         package 
         cn.xidian.socket; 
        
         import 
         java.io.BufferedReader; 
        
         import 
         java.io.IOException; 
        
         import 
         java.io.InputStreamReader; 
        
         import 
         java.net.DatagramPacket; 
        
         import 
         java.net.DatagramSocket; 
        
         import 
         java.net.InetAddress; 
        
         public 
         class 
         UdpSender  
         extends 
         Thread{ 
        
         @Override 
        
         public 
         void 
         run() { 
        
         try 
         { 
        
         //建立UDP的服务 
        
         DatagramSocket socket =  
         new 
         DatagramSocket(); 
        
         //准备数据包发送 
        
         //从系统输入读取输入 
        
         BufferedReader in =  
         new 
         BufferedReader( 
         new 
         InputStreamReader(System.in)) ; 
        
         String line =  
         null 
         ; 
        
         while 
         ((line = in.readLine()) !=  
         null 
         ){ 
        
         //我做测试,写的是本机地址,群聊需要写广播地址,比如:192.168.137.255 
        
         DatagramPacket data =  
         new 
         DatagramPacket(line.getBytes(), line.getBytes().length, InetAddress.getByName( 
         "127.0.0.1" 
         ),  
         9090 
         ); 
        
         //发送数据 
        
         socket.send(data); 
        
         } 
        
         //关闭socket 
        
         socket.close(); 
        
         } 
        
         catch 
         (IOException e) { 
        
         e.printStackTrace(); 
        
         } 
        
         } 
        
         }

接收方。

UdpReceiver.java 。

 
    ? 
   
         package 
         cn.xidian.socket; 
        
         import 
         java.io.IOException; 
        
         import 
         java.net.DatagramPacket; 
        
         import 
         java.net.DatagramSocket; 
        
         public 
         class 
         UdpReceiver  
         extends 
         Thread { 
        
         @Override 
        
         public 
         void 
         run() { 
        
         try 
         { 
        
         //建立UDP的服务,监听端口 
        
         DatagramSocket socket =  
         new 
         DatagramSocket( 
         9090 
         ); 
        
         //接受数据包 
        
         byte 
         [] temp =  
         new 
         byte 
         [ 
         1024 
         ]; 
        
         DatagramPacket data =  
         new 
         DatagramPacket(temp, temp.length); 
        
         Boolean flag =  
         true 
         ; 
        
         while 
         (flag){ 
        
         socket.receive(data); 
        
         //输出发送方的相关信息 
        
         String senderAddress = data.getAddress().getHostAddress(); 
        
         String senderHostName = data.getAddress().getHostName(); 
        
         System.out.println(senderHostName+ 
         "(" 
         +senderAddress+ 
         ")" 
         + 
         " say: " 
         +  
         new 
         String(temp,  
         0 
         ,data.getLength())); 
        
         } 
        
         //关闭资源 
        
         socket.close(); 
        
         } 
        
         catch 
         (IOException e) { 
        
         e.printStackTrace(); 
        
         } 
        
         } 
        
         }

Main方法。

UdpMain.java 。

 
    ? 
   
         package 
         cn.xidian.socket; 
        
         public 
         class 
         UdpMain { 
        
         public 
         static 
         void 
         main(String[] args) { 
        
         //启动UdpReceiver线程 
        
         UdpReceiver receiver =  
         new 
         UdpReceiver(); 
        
         receiver.start(); 
        
         //启动UdpSender线程 
        
         UdpSender sender =  
         new 
         UdpSender(); 
        
         sender.start(); 
        
         } 
        
         }