JAVA 网络编程 - 实现 群聊 程序

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 UDPChatTest {

	
	public static void main(String[] args)  throws IOException{
		
		/*
		 * 
		 * 案例一:  通过 UDP 实现 群聊程序.
		 * 
		 * 思路:
		 * 
		 * 	这个程序中 既有 收 又有 发 , 那么 需要同时 执行, 需要使用 多线程 技术.
		 * 
		 * 	一个线程 负责发, 一个 线程 负责收, 需要两个任务.(线程任务);
		 * 
		 * */
		
	// 发送端 的Socket , 接收端 的 Socket;
		
		DatagramSocket sendSocket = new DatagramSocket();
		DatagramSocket receSocket = new DatagramSocket(10000);
	
		// 创建 任务 对象.
		
		Send send = new Send(sendSocket);
		
		Rece rece = new Rece(receSocket);
		
		
		// *** 创建 线程 并开启.
		
		Thread t1 = new Thread(send); // *** 发
		
		Thread t2 = new Thread(rece); // *** 收
		
		t1.start();
		
		t2.start();
		
	}
}


/*
 * 
 * 
 * 	255 广播 地址, 我发一句, 到 广播地址, 广播 地址 发给 这个 网段中 所有的 主机, 你看到,我也会看到, 就实现了 聊天 功能,只要我们在 同一个 局域网中.就哦了.
 * 
 * 
 * */
// 发送任务                      这里 先把 架子 搭起来 , 都需要 哪些 东西.

class Send implements Runnable{
	
	private DatagramSocket ds;
	
	public Send(DatagramSocket ds) {
		
		this.ds = ds;
		
	}
	
	@Override
	public void run() {
		
	//	System.out.println("UDP2 发送端 run ");
		
		// *** 这里写的端口号 如果 已经 有 程序在使用了, 就不能用 这个 端口号了, 程序会启动不起来, 因为 端口号 冲突了.(会 发生 地址 已被  占用 异常.)
		// *** 数据来自于 键盘录入.
		
		
		try {
			

			BufferedReader bufin = new BufferedReader(new InputStreamReader(System.in)); // *** 键盘 录入 也是 阻塞式的, 你没录入 就不会 停止, 一直 阻塞在 这里.
			String line = null;
			while((line = bufin.readLine()) != null) {
				
				
				
				
				byte[] buf= line.getBytes(); // *** 将数据 转成 数组.
				
				DatagramPacket dp = new DatagramPacket( buf,buf.length,InetAddress.getByName("192.168.1.255"),10000);
				// *** 这里的 地址 可以写成 其他人的  IP 地址 和 端口号 ,就可以 进行 聊天了.
				ds.send(dp);
				
				// *** 既然是 键盘 录入, 那么 就一定要 加一个 结束 标记.
				
				if("886".equals(line)) {
					
					break;
					
				}	
				
				
			}
			
			// *** 关闭 资源
			ds.close();
		} catch (IOException e) {
		
		}
		
		
		
	}
		
}
	


// 接收任务.
class Rece implements Runnable{

	
	private DatagramSocket ds;
	
	public Rece(DatagramSocket ds) {
		
		this.ds = ds;
	}
	@Override
	public void run() {
	//	System.out.println("udp2 接收端 run ");
		
		while(true) {
		
			
			try {
				
				byte[] buf = new byte[1024];
				
				DatagramPacket dp = new DatagramPacket(buf, buf.length);
				
				
					ds.receive(dp); // *** 阻塞, 如果 没有接收到 数据 就会 一直阻塞在这里.
			
				
				String ip = dp.getAddress().getHostAddress();
				
				int port = dp.getPort();
				
				String text = new String(dp.getData(),0,dp.getLength());
				
				System.out.println(ip + ":" + port+ ":" + text);
				
				if(text.equals("886")) {
					
					System.out.println(ip + "...离开 聊天室" );
					
				}
			 }catch(IOException e) {			 
			 }
		
			// ds.close();  *** 一直在 接收, 收 别人 发过来的 数据, 我就不用 关闭 资源了.
		
		
		}
		
	}
		
}