UDP协议实现群聊

以下是UDP实现群聊功能代码示例
在java中，通过两个特定类来实现UDP协议顶层数据报，分别是DatagramPacket和DatagramSocket，其中类DatagramPacket是一个数据容器，是数据报包，用来保存即将要传输的数据，将地址信息和要发送的数据以字节数组的方式同时压缩入这个类创建的对象中；而类DatagramSocket表示用来发送和接收DatagramPacket的套接字，实现了数据报的通信方式。数据报套接字是包投递服务的发送或接收点。

UDP协议是一种基于数据报的快速的(无需花时间去保证数据是否损坏，无需花时间确定接受方是否存在并等待响应)、无连接的、不可靠的信息包传输协议。

下面是UDP的一个示例，当所有人都在一个局域网内运行这个程序的时候，可以实现简单的群聊：
?

package com.demo;

import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.util.Scanner;

/**
 * 发送消息
 * @author LIU
 */
class Send implements Runnable{
	DatagramSocket ds;
	public Send(DatagramSocket ds){
		this.ds = ds;
	}
	@Override
	public void run() {
		// TODO Auto-generated method stub
		try {
			Scanner s = new Scanner(System.in);
			while(true){
				String sendBuf = s.nextLine();
				// 发送的 内容，长度，IP，端口
				DatagramPacket dpSend = new DatagramPacket(sendBuf.getBytes(), sendBuf.getBytes().length, InetAddress.getByName("192.168.8.255"), 9988);
				ds.send(dpSend);
				
				System.out.println("我说：" + sendBuf);
			}
		} catch (Exception e) {
			// TODO: handle exception
		}
		
	}
	
}



/**
 * 接收消息
 * @author LIU
 */
class Recv implements Runnable{
	DatagramSocket ds;
	public Recv(DatagramSocket ds){
		this.ds = ds;
	}
	@Override
	public void run() {
		// TODO Auto-generated method stub
		try {
			while(true){
				byte[] recvBuf = new byte[1024];
				//接收的 内容，长度
				DatagramPacket dpRecv = new DatagramPacket(recvBuf, 1024);
				ds.receive(dpRecv);
				String str = new String(dpRecv.getData(), 0, dpRecv.getLength());
				
				System.out.println(dpRecv.getAddress().getHostAddress() + "说：" + str);
			}
		} catch (Exception e) {
			// TODO: handle exception
		}
	}
	
}



/**
 * 开始执行对话
 * @author LIU
 */
public class Udp {

	public static void main(String[] args) {
		// TODO Auto-generated method stub
		try {
			DatagramSocket ds = new DatagramSocket(9988);
			
			new Thread(new Send(ds)).start();
			new Thread(new Recv(ds)).start();
			
		} catch (Exception e) {
			// TODO: handle exception
		}
	}

}