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

相关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();

									    }

									}