Java网络编程——UDP聊天程序

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、执行结果如下图：

巴特西

Java网络编程——UDP聊天程序

UDP简介

最新文章

热门文章