JAVA学习第六十课 — UDP协议 &基于多线程模拟简单的QQ聊天程序

UDP传输

UDP有发送端和接受端，有两大类，DatagramSocket、DatagramPacket

建立发送端和接收端

建立数据包

调用Socket的接收发送方法

关闭Socket

注意：发送端和接收端是两个独立的运行程序

UDP发送端演示

DatagramPacket(byte[] buf, int length, InetAddress address, int port)
构造数据报包，用来将长度为 length 的包发送到指定主机上的指定端口号。

public static void UDPsendDemo() throws IOException {
		System.out.println("发送端");
		/*
		 * 创建UDP传输的发送端：
		 * 1.建立UDP的Socket服务
		 * 2.将要发送的数据封装到数据包中
		 * 3.用UDP的Socket服务将数据包发送出去
		 * 4.关闭Socket服务
		 */
		//建立UDP的Socket服务,使用DatagramSocket对象
		DatagramSocket ds = new DatagramSocket();
		//不指定端口号，发送端，就是随机的
		
		//数据封装成包
		String str = "udp发送";
		
		//使用DatagramPacket将数据封装到该对象的包中
		byte[] by = str.getBytes();
		DatagramPacket dp = new DatagramPacket(by,by.length,InetAddress.getByName("127.0.0.1"),6534);
		
		//通过UDP的Socket服务将数据包发送出去，send方法
		ds.send(dp);
		ds.close();
	}

UDP接收端演示

	public static void UDPreceiveDemo() throws IOException {
		//接受端
		System.out.println("接收端");
		/*
		 * 创建UDP传输的接收端：
		 * 1.建立UDP的Socket服务，因为要接收数据，必须要明确端口号
		 * 2.创建数据包，用于存储接收到的数据，以便于用数据包的方法解析这些数据
		 * 3.使用Socket服务的receive方法接收的数据存储到数据包中
		 * 4.通过数据包中的方法解析包中数据
		 * 5.关闭
		 */
		//建立UDP的Socket服务,使用DatagramSocket对象
		DatagramSocket ds = new DatagramSocket(6534);//接收端口6534
		
		//创建数据包
		byte[] buf = new byte[1024];
		DatagramPacket dp = new DatagramPacket(buf, buf.length);
		
		//使用接收方法将数据存储到数据包
		ds.receive(dp);//注意该方法是阻塞式的
		
		//使用数据包对象的方法，解析其中的数据，如：地址、端口、内容
		String ip = dp.getAddress().getHostAddress();//获取ip地址字符串
		
		int port = dp.getPort();//获取端口
		
		String datatext = new String(dp.getData(),0,dp.getLength());//将数据封装成字符串对象
		
		System.out.println("ip:"+ip+"port : "+port+"data:"+datatext);
		
		//关闭
		ds.close();
	}

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

class Receive implements Runnable{
	private DatagramSocket ds;
	
	public Receive(DatagramSocket ds){
		this.ds = ds;
	}
	public void run()
	{
		try {
			while(true){
				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 datatext = new String(dp.getData(),0,dp.getLength());
				if(datatext.equals("over")){
					System.out.println("ip:"+ip+"port : "+port+"退出聊天室");
				}
				else{
					System.out.println("ip:"+ip+"port : "+port+"data:"+datatext);
				}
				
			
				}
		} catch (Exception e) {
			// TODO: handle exception
		}
	}
}

class Send implements Runnable{
	private DatagramSocket ds;
	public Send(DatagramSocket ds){
		this.ds = ds;
	}
	public void run()
	{
		try {
			BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
			String line = null;
			while((line = br.readLine())!=null){
				
				byte[] buf = line.getBytes();
				DatagramPacket dp = new DatagramPacket(buf,buf.length,InetAddress.getByName("127.0.0.255"),6534);
				//IP的有效位是0-254，255是广播，也就是127.0.0，这一IP字段上所有存活的电脑都可以接收到我发的信息
				ds.send(dp);
				if("over".equals(line))break;
			}
			ds.close();
		} catch (Exception e) {
			// TODO: handle exception
		}
	}
}
public class Main {
	public static void main(String[] args) throws IOException{
		
		DatagramSocket dsend =new DatagramSocket();

		DatagramSocket dr =new DatagramSocket(6534);
		Send send = new Send(dsend);
		Receive receive = new Receive(dr);
		Thread t1 = new Thread(send);
		Thread t2 = new Thread(receive);
		t1.start(); t2.start();	
	}
}