public class Rec implements Runnable{
? ? private DatagramSocket ds;
? ? public Rec(DatagramSocket ds){
? ? ? ? this.ds = ds;
? ? }
? ? @Override
? ? public void run() {
? ? ? ? while(true){
? ? ? ? ? ? //接受數(shù)據(jù)和打印數(shù)據(jù)
? ? ? ? ? ? byte[] buf= new byte[1024];
? ? ? ? ? ? DatagramPacket pac = null;
? ? ? ? ? ? try {
? ? ? ? ? ? ? ? pac = new DatagramPacket(buf,buf.length);
? ? ? ? ? ? ? ? ds.receive(pac);//接收數(shù)據(jù)
? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? }
? ? ? ? ? ? //獲得消息
? ? ? ? ? ? String info = new String(pac.getData(),0,pac.getLength());
? ? ? ? ? ? //獲得ip地址
? ? ? ? ? ? String ip = pac.getAddress().getHostAddress();
? ? ? ? ? ? String port = pac.getPort()+"";
? ? ? ? ? ? String name = info.substring(0, info.lastIndexOf(":"));
? ? ? ? ? ? if(!name.equals(Thread.currentThread().getName())){
? ? ? ? ? ? ? ? System.out.println(info);
? ? ? ? ? ? }
? ? ? ? }
? ? }
}

這是發(fā)送udp的實現(xiàn)類：

public class Send implements Runnable {
? ? ? ? private DatagramSocket ds;//負責(zé)發(fā)送和接受數(shù)據(jù)
? ? ? ? private int receport;//準(zhǔn)備發(fā)送的端口號
? ? ? ? private String ipAddress; //準(zhǔn)備發(fā)送的ip地址
? ? ? ? public Send(DatagramSocket ds,int receport,String ipAddress){
? ? ? ? ? ? this.ds = ds;
? ? ? ? ? ? this.ipAddress = ipAddress;
? ? ? ? ? ? this.receport = receport;
? ? ? ? }
? ? ? ? @Override
? ? ? ? public void run() {
? ? ? ? ? ? // 多線程發(fā)送消息
? ? ? ? ? ? Scanner sc = new Scanner(System.in);
? ? ? ? ? ? InetAddress ip = null;
? ? ? ? ? ? try {
? ? ? ? ? ? ? ?// String ipad = ipAddress.substring(0, ipAddress.lastIndexOf(":"));//ip地址
? ? ? ? ? ? ? ? ip = InetAddress.getByName(ipAddress);
? ? ? ? ? ? } catch (UnknownHostException e) {
? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? }
? ? ? ? ? ? while(true){
? ? ? ? ? ? ? ? String info = sc.nextLine();
? ? ? ? ? ? ? ? info=Thread.currentThread().getName()+":"+info;
? ? ? ? ? ? ? ? byte[] bs = info.getBytes();
? ? ? ? ? ? ? ? //把數(shù)據(jù)封裝為數(shù)據(jù)包
? ? ? ? ? ? ? ? //數(shù)據(jù)包有四個部分組成
? ? ? ? ? ? ? ? DatagramPacket pack = new DatagramPacket(bs,bs.length,ip,receport);
? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? ds.send(pack);
? ? ? ? ? ? ? ? ? ? String content=info.substring(info.lastIndexOf(":")+1);
? ? ? ? ? ? ? ? ? ? if(content.equals("886")){
? ? ? ? ? ? ? ? ? ? ? ? System.out.println("已退出聊天室");
? ? ? ? ? ? ? ? ? ? ? ? break;
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? }
? ? }

服務(wù)端：

我是模擬的本地多用戶，端口號不能重復(fù)所以設(shè)置了6001-6005，線上只需同一接收udp端口號即可。

public class ServerCilent {
? ? public static void main(String[] args) throws IOException {
? ? ? ? //接受數(shù)據(jù)包
? ? ? ? DatagramSocket rec = new DatagramSocket(6262);//接收端口號
? ? ? ? //建立發(fā)送類
? ? ? ? DatagramSocket send = new DatagramSocket(); //發(fā)送數(shù)據(jù)
? ? ? ? List<String> addressList=new ArrayList<>();//存放所有發(fā)送數(shù)據(jù)用戶的ip
? ? ? ? while (true) {
? ? ? ? ? ? //定義一個數(shù)據(jù)包接受數(shù)據(jù)
? ? ? ? ? ? byte[] bs = new byte[1024];
? ? ? ? ? ? DatagramPacket dp = new DatagramPacket(bs, bs.length);
? ? ? ? ? ? //接受數(shù)據(jù)
? ? ? ? ? ? rec.receive(dp);
? ? ? ? ? ? InetAddress address = dp.getAddress();
? ? ? ? ? ? String s = address.toString();
? ? ? ? ? ? String ip = s.substring(s.lastIndexOf("/") + 1);//ip
? ? ? ? ? ? //判斷ip是否已存在List中
? ? ? ? ? ? int index=1;
? ? ? ? ? ? for (String s1 : addressList) {
? ? ? ? ? ? ? ? if(s1.equals(ip)){
? ? ? ? ? ? ? ? ? ? index=-1;
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? ? ? if(index>0){
? ? ? ? ? ? ? ? addressList.add(ip);
? ? ? ? ? ? }
? ? ? ? ? ? //取出數(shù)據(jù)
? ? ? ? ? ? //dp.getData()獲取發(fā)送數(shù)據(jù)的字節(jié)數(shù)組，dp.getLength()獲取發(fā)送內(nèi)容的長度
? ? ? ? ? ? String info = new String(dp.getData(), 0, dp.getLength());
? ? ? ? ? ? System.out.println("客戶端發(fā)送來的信息：" + info);
? ? ? ? ? ? //--------------------服務(wù)器轉(zhuǎn)發(fā)--------------------------//
? ? ? ? ? ? String content=info.substring(info.lastIndexOf(":")+1);
? ? ? ? ? ? if (content.equals("886")) {
? ? ? ? ? ? ? ? String name=info.substring(0,info.lastIndexOf(":"));
? ? ? ? ? ? ? ? info=name+":退出了聊天室";
? ? ? ? ? ? }
? ? ? ? ? ? //建立數(shù)據(jù)包 并轉(zhuǎn)發(fā)信息
? ? ? ? ? ? byte[] bs1 = info.getBytes();
? ? ? ? ? ? for (String s1 : addressList) {
? ? ? ? ? ? ? ? for (int i=6001;i<=6005;i++){
? ? ? ? ? ? ? ? ? ? DatagramPacket dp1 = new DatagramPacket(bs1, bs1.length, InetAddress.getByName(s1), i);
? ? ? ? ? ? ? ? ? ? send.send(dp1);
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? }
? ? }
}

客戶端測試：

public class Test1 {
? ? public static void main(String[] args) throws SocketException {
? ? ? ? Send s=new Send(new DatagramSocket(),6262,"127.0.0.1");
? ? ? ? Rec rec=new Rec(new DatagramSocket(6001));
? ? ? ? new Thread(s,"宸").start();
? ? ? ? new Thread(rec,"宸").start();
? ? }
}