UDP简介

  • UDP协议的全称是用户数据报，在网络中它与TCP协议一样用于处理数据报。在OSI模型中，UDP位于第四层——传输层，处于IP协议额上一层。UDP有不提供数据报分组、组装以及不能对数据报排序的缺点。当报文发送之后，是无法得知其是否安全完整到达的。

  • 由于UDP不属于连接性协议的特性，因此具有资源消耗小、处理速度快的优点，所以通过音频、视频和普通数据在传送时使用UDP较多，因为它们即使偶尔丢失一两个数据包，也不会对接收结果产生太大影响，如人们聊天使用的ICQ和OICQ使用的就是UDP协议。

  • 使用java.net包下的DatagramSocket和DatagramPacket类，可以非常方便地控制用户数据报文。下面就对这两个类进行案例介绍

利用UDP通信功能，用DatagramPacket类与DatagramSocket类的常用方法，模拟实现一个功能完善的聊天程序。

1、实现聊天窗口界面，首先创建一个名称为ChatRoom的程序入口类,在该类的main()方法中获取当前服务所在端口号、聊天对象服务所在端口号,并创建DatagramSocket信息收发对象,以及通过多线程实现发送端和接收端功能,如下图所示：

相关代码

import java.net.DatagramSocket;
import java.net.SocketException;
import java.util.Scanner;

public class ChatRoom {
	public static void main(String[] args) {
		@SuppressWarnings("resource")
		Scanner sc = new Scanner(System.in);
		System.out.print("请输入聊天服务当前启动端口号：");
		int serverPort = sc.nextInt();
		System.out.print("请输入聊天服务发送信息对象的目标端口号：");
		int targetPort = sc.nextInt();
		System.out.println("聊天系统初始化完成并启动！！！");	
		try {
			DatagramSocket socket = new DatagramSocket(serverPort);
		    new Thread(new ChatReceiver(socket), "接收服务").start();
		    new Thread(new ChatSend(socket,targetPort),"发送服务").start();
		} catch (SocketException e) {
			e.printStackTrace();
		}
	}
}

2、实现聊天程序接收信息功能。创建一个ChatReceiver类作为聊天程序的接收端，用于接收其他用户发送的聊天信息。如下图所示：

相关代码

import java.net.DatagramPacket;
import java.net.DatagramSocket;

public class ChatReceiver implements Runnable {
	private DatagramSocket server;
	public ChatReceiver(DatagramSocket server) {
		this.server = server;
	}
	public void run() {
		try {
			byte[] buf = new byte[1024];
			DatagramPacket packet = new DatagramPacket(buf, buf.length);
			while (true) {
				server.receive(packet);
				String str = new String(packet.getData(), 0, packet.getLength());
				System.out.println("收到" + packet.getAddress()+":"+packet.getPort()+ " 发送的数据:" + str);
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}

3、实现聊天程序发送信息功能。创建一个ChatSend类，作为聊天程序的发送端，用于向指定的聊天程序发送聊天信息。具体如下图：

相关代码

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

public class ChatSend implements Runnable {
	private DatagramSocket client;
	private int targetPort; 
	public ChatSend(DatagramSocket client,int targetPort) {
		this.client = client;
		this.targetPort = targetPort;
	}
	public void run() {
		try {
			@SuppressWarnings("resource")
			Scanner sc = new Scanner(System.in);
			while (true) {
				String data = sc.nextLine();
				byte[] buf = data.getBytes();
				DatagramPacket packet = new DatagramPacket(buf, buf.length,
					   InetAddress.getByName("127.0.0.255"),targetPort);
				client.send(packet);
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}

4.、执行程序,查看结果。编写完所有类后，执行ChatRoom类中的main()方法,启动成功后.先单击控制台右侧工具栏上的[Pin Console]按钮锁定当前窗口，然后再通过Eelipse控制台右侧工具栏上的[Open Console]按钮下拉框选择[New Console View1新建一个Consle窗口，再次运行main()方法,具体操作过程如下图所示：

5、执行结果如下图：