一. UDP协议定义
UDP协议的全称是用户数据报,在网络中它与TCP协议一样用于处理数据包。在OSI模型中,在第四层——传输层,处于IP协议的上一层。UDP有不提供数据报分组、组装和不能对数据包的排序的缺点,也就是说,当报文发送之后,是无法得知其是否安全完整到达的。
二. 使用UDP的原因
它不属于连接型协议,因而具有资源消耗小,处理速度快的优点,所以通常音频、视频和普通数据在传送时使用UDP较多,因为它们即使偶尔丢失一两个数据包,也不会对接收结果产生太大影响。比如我们聊天用的ICQ和OICQ就是使用的UDP协议。在选择使用协议的时候,选择UDP必须要谨慎。在网络质量令人不十分满意的环境下,UDP协议数据包丢失会比较严重。
三. 在Java中使用UDP协议编程的相关类
1. InetAddress
用于描述和包装一个Internet IP地址。有如下方法返回实例:
getLocalhost():返回封装本地地址的实例。
getAllByName(String host):返回封装Host地址的InetAddress实例数组。
getByName(String host):返回一个封装Host地址的实例。其中,Host可以是域名或者是一个合法的IP地址。
InetAddress.getByAddress(addr):根据地址串返回InetAddress实例。
InetAddress.getByAddress(host, addr):根据主机地符串和地址串返回InetAddress实例。
2. DatagramSocket
用于接收和发送UDP的Socket实例。该类有3个构造函数:
DatagramSocket():通常用于客户端编程,它并没有特定监听的端口,仅仅使用一个临时的。程序会让操作系统分配一个可用的端口。
DatagramSocket(int port):创建实例,并固定监听Port端口的报文。通常用于服务端
DatagramSocket(int port, InetAddress localAddr):这是个非常有用的构建器,当一台机器拥有多于一个IP地址的时候,由它创建的实例仅仅接收来自LocalAddr的报文。
DatagramSocket具有的主要方法如下:
1)receive(DatagramPacket d):接收数据报文到d中。receive方法产生一个“阻塞”。“阻塞”是一个专业名词,它会产生一个内部循环,使程序暂停在这个地方,直到一个条件触发。
2)send(DatagramPacket dp):发送报文dp到目的地。
3)setSoTimeout(int timeout):设置超时时间,单位为毫秒。
4)close():关闭DatagramSocket。在应用程序退出的时候,通常会主动释放资源,关闭Socket,但是由于异常地退出可能造成资源无法回收。所以,应该在程序完成时,主动使用此方法关闭Socket,或在捕获到异常抛出后关闭Socket。
3. DatagramPacket
用于处理报文,它将Byte数组、目标地址、目标端口等数据包装成报文或者将报文拆卸成Byte数组。应用程序在产生数据包是应该注意,TCP/IP规定数据报文大小最多包含65507个,通常主机接收548个字节,但大多数平台能够支持8192字节大小的报文。DatagramPacket类的构建器共有4个:
DatagramPacket(byte[] buf, int length):将数据包中Length长的数据装进Buf数组,一般用来接收客户端发送的数据。
DatagramPacket(byte[] buf, int offset, int length):将数据包中从Offset开始、Length长的数据装进Buf数组。
DatagramPacket(byte[] buf, int length, InetAddress clientAddress, int clientPort):从Buf数组中,取出Length长的数据创建数据包对象,目标是clientAddress地址,clientPort端口, 通常用来发送数据给客户端。
DatagramPacket(byte[] buf, int offset, int length, InetAddress clientAddress, int clientPort):从Buf数组中,取出Offset开始的、Length长的数据创建数据包对象,目标是clientAddress地址,clientPort端口,通常用来发送数据给客户端。
主要的方法如下:
1)getData(): 从实例中取得报文的Byte数组编码。
2)setDate(byte[] buf):将byte数组放入要发送的报文中。
四. 实例解析
下面让我们来看一个UDP的服务端和客户端交互通信的例子,在本例中,服务端循环等待客户端发送的信息,并对其进行回应,客户端向服务端发送信息,并接收服务端的回应信息。代码如下:
1. UDP的服务端程序
import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.net.InetSocketAddress; import java.net.SocketException; /** * Copyright 2007 GuangZhou Cotel Co. Ltd. * All right reserved. * UTP服务类. * @author <a href="mailto:xiexingxing1121@126.com">AmigoXie</a> * @version 1.0 * Creation date: 2007-8-16 - 下午10:32:31 */ public class UdpServerSocket { private byte[] buffer = new byte[1024]; private DatagramSocket ds = null; private DatagramPacket packet = null; private InetSocketAddress socketAddress = null; private String orgIp; /** * 构造函数,绑定主机和端口. * @param host 主机 * @param port 端口 * @throws Exception */ public UdpServerSocket(String host, int port) throws Exception { socketAddress = new InetSocketAddress(host, port); ds = new DatagramSocket(socketAddress); System.out.println("服务端启动!"); } public final String getOrgIp() { return orgIp; } /** * 设置超时时间,该方法必须在bind方法之后使用. * @param timeout 超时时间 * @throws Exception */ public final void setSoTimeout(int timeout) throws Exception { ds.setSoTimeout(timeout); } /** * 获得超时时间. * @return 返回超时时间. * @throws Exception * @author <a href="mailto:xiexingxing1121@126.com">AmigoXie</a> * Creation date: 2007-8-16 - 下午10:34:36 */ public final int getSoTimeout() throws Exception { return ds.getSoTimeout(); } /** * 绑定监听地址和端口. * @param host 主机IP * @param port 端口 * @throws SocketException * @author <a href="mailto:xiexingxing1121@126.com">AmigoXie</a> * Creation date: 2007-8-16 - 下午10:36:17 */ public final void bind(String host, int port) throws SocketException { socketAddress = new InetSocketAddress(host, port); ds = new DatagramSocket(socketAddress); } /** * 接收数据包,该方法会造成线程阻塞. * @return 返回接收的数据串信息 * @throws IOException * @author <a href="mailto:xiexingxing1121@126.com">AmigoXie</a> * Creation date: 2007-8-16 - 下午10:38:24 */ public final String receive() throws IOException { packet = new DatagramPacket(buffer, buffer.length); ds.receive(packet); orgIp = packet.getAddress().getHostAddress(); String info = new String(packet.getData(), 0, packet.getLength()); System.out.println("接收信息:" + info); return info; } /** * 将响应包发送给请求端. * @param bytes 回应报文 * @throws IOException * @author <a href="mailto:xiexingxing1121@126.com">AmigoXie</a> * Creation date: 2007-8-16 - 下午11:05:31 */ public final void response(String info) throws IOException { System.out.println("客户端地址 : " + packet.getAddress().getHostAddress() + ",端口:" + packet.getPort()); DatagramPacket dp = new DatagramPacket(buffer, buffer.length, packet .getAddress(), packet.getPort()); dp.setData(info.getBytes()); ds.send(dp); } /** * 设置报文的缓冲长度. * @param bufsize 缓冲长度 * @author <a href="mailto:xiexingxing1121@126.com">AmigoXie</a> * Creation date: 2007-8-16 - 下午10:47:49 */ public final void setLength(int bufsize) { packet.setLength(bufsize); } /** * 获得发送回应的IP地址. * @return 返回回应的IP地址 * @author <a href="mailto:xiexingxing1121@126.com">AmigoXie</a> * Creation date: 2007-8-16 - 下午10:48:27 */ public final InetAddress getResponseAddress() { return packet.getAddress(); } /** * 获得回应的主机的端口. * @return 返回回应的主机的端口. * @author <a href="mailto:xiexingxing1121@126.com">AmigoXie</a> * Creation date: 2007-8-16 - 下午10:48:56 */ public final int getResponsePort() { return packet.getPort(); } /** * 关闭udp监听口. * @author <a href="mailto:xiexingxing1121@126.com">AmigoXie</a> * Creation date: 2007-8-16 - 下午10:49:23 */ public final void close() { try { ds.close(); } catch (Exception ex) { ex.printStackTrace(); } } /** * 测试方法. * @param args * @throws Exception * @author <a href="mailto:xiexingxing1121@126.com">AmigoXie</a> * Creation date: 2007-8-16 - 下午10:49:50 */ public static void main(String[] args) throws Exception { String serverHost = "127.0.0.1"; int serverPort = 3344; UdpServerSocket udpServerSocket = new UdpServerSocket(serverHost, serverPort); while (true) { udpServerSocket.receive(); udpServerSocket.response("你好,sterning!"); } } }
2. UDP客户端程序
import java.io.*; import java.net.*; /** * Copyright 2007 GuangZhou Cotel Co. Ltd. * All right reserved. * UDP客户端程序,用于对服务端发送数据,并接收服务端的回应信息. * @author <a href="mailto:xiexingxing1121@126.com">AmigoXie</a> * @version 1.0 * Creation date: 2007-8-16 - 下午10:54:23 */ public class UdpClientSocket { private byte[] buffer = new byte[1024]; private DatagramSocket ds = null; /** * 构造函数,创建UDP客户端 * @throws Exception */ public UdpClientSocket() throws Exception { ds = new DatagramSocket(); } /** * 设置超时时间,该方法必须在bind方法之后使用. * @param timeout 超时时间 * @throws Exception * @author <a href="mailto:xiexingxing1121@126.com">AmigoXie</a> * Creation date: 2007-8-16 - 下午10:55:12 */ public final void setSoTimeout(final int timeout) throws Exception { ds.setSoTimeout(timeout); } /** * 获得超时时间. * @return 返回超时时间 * @throws Exception * @author <a href="mailto:xiexingxing1121@126.com">AmigoXie</a> * Creation date: 2007-8-16 - 下午10:55:25 */ public final int getSoTimeout() throws Exception { return ds.getSoTimeout(); } public final DatagramSocket getSocket() { return ds; } /** * 向指定的服务端发送数据信息. * @param host 服务器主机地址 * @param port 服务端端口 * @param bytes 发送的数据信息 * @return 返回构造后俄数据报 * @throws IOException * @author <a href="mailto:xiexingxing1121@126.com">AmigoXie</a> * Creation date: 2007-8-16 - 下午11:02:41 */ public final DatagramPacket send(final String host, final int port, final byte[] bytes) throws IOException { DatagramPacket dp = new DatagramPacket(bytes, bytes.length, InetAddress .getByName(host), port); ds.send(dp); return dp; } /** * 接收从指定的服务端发回的数据. * @param lhost 服务端主机 * @param lport 服务端端口 * @return 返回从指定的服务端发回的数据. * @throws Exception * @author <a href="mailto:xiexingxing1121@126.com">AmigoXie</a> * Creation date: 2007-8-16 - 下午10:52:36 */ public final String receive(final String lhost, final int lport) throws Exception { DatagramPacket dp = new DatagramPacket(buffer, buffer.length); ds.receive(dp); String info = new String(dp.getData(), 0, dp.getLength()); return info; } /** * 关闭udp连接. * @author <a href="mailto:xiexingxing1121@126.com">AmigoXie</a> * Creation date: 2007-8-16 - 下午10:53:52 */ public final void close() { try { ds.close(); } catch (Exception ex) { ex.printStackTrace(); } } /** * 测试客户端发包和接收回应信息的方法. * @param args * @throws Exception * @author <a href="mailto:xiexingxing1121@126.com">AmigoXie</a> * Creation date: 2007-8-16 - 下午11:03:54 */ public static void main(String[] args) throws Exception { UdpClientSocket client = new UdpClientSocket(); String serverHost = "127.0.0.1"; int serverPort = 3344; client.send(serverHost, serverPort, ("你好,阿蜜果!").getBytes()); String info = client.receive(serverHost, serverPort); System.out.println("服务端回应数据:" + info); } }
发表评论
-
eclipse/myeclipse注释模板的修改(网摘)
2015-04-07 10:21 582本文转自:http://kaminlee.iteye.com ... -
Java爬网页方法
2012-05-18 11:31 1035/* Function name: myGetHt ... -
Java日期公用处理类
2012-05-18 11:33 1174import java.text.SimpleDateFo ... -
Java一组日期方法
2012-05-18 11:33 1153import java.text.SimpleDateFo ... -
Java控制小数点的几个常用方法
2012-05-18 11:33 1297import java.text.DecimalForma ... -
Java基础加密组件
2012-05-18 11:32 1051import java.security.MessageD ... -
Java一些格式化的通用代码
2012-05-17 10:10 1190import javax.servlet.http.Htt ... -
Java动态代理
2012-05-17 10:10 747import java.lang.reflect.Invo ... -
Java导出成Excel的方法(需要jxl.jar包)
2012-05-17 10:10 1871import java.io.File; import ... -
Java遗传算法
2012-05-17 10:09 940import java.util.*; public ... -
Java人民币转成大写
2012-05-17 10:09 792/** * 人民币转成大写 * ... -
Java各种数据库连接
2012-05-16 10:29 886MySQL: String Driv ... -
Java系统托盘的应用
2012-05-16 10:28 820import java.applet.Applet; ... -
Java获取ip地址
2012-05-16 10:27 977import java.awt.GridLayout; ... -
Java日期处理bean
2012-05-16 10:25 818import java.text.ParsePositio ... -
java访问*.properties资源文件
2012-05-16 10:23 694import java.io.FileInputStrea ...
相关推荐
JAVA udp 协议编程文档,包括类的说明和简单案例
基于java的UDP协议编程.pdf
完整版的,经过调试的一个java环境下的基于UDP协议的聊天程序,udp协议聊天程序、java开发、计算机网络课程设计
java使用udp协议进行数据收发处理,java使用udp协议进行数据收发处理
什么是UDP协议 UDP协议的全称是用户数据报,在网络中它与TCP协议一样用于处理数据包。在OSI模型中,在第四层——传输层,处于IP协议的上一层。UDP有不提供数据报分组、组装和不能对数据包的排序的缺点,也就是说,...
通过java网络编程深入理解UDP协议通信,与TCP的区别等等 源码包每一行都有注释,在代码里面每一个类都有详细的注释来解释这个类的功能这个方法的功能,调用哪一个类的哪一个功能等等。 压缩包包含实验报告(实验原理...
java网络开发,使用UDP协议进行通信,源代码可以直接运行,并且是可视化界面,方便大家学习
基于UDP协议以及java GUI的编程,通过java编写窗体,基于UDP协议实现通信,其中图片,窗体都是应用java的原生API来进行编写,不需要多余的jar包,图片可以自己进行更换。
用java编写的基于UDP和TCP两种协议编写的Socket(网络编程)案列
本程序主要演示Java网络编程中UDP协议的使用, 实现简单聊天,
在客户端左击绘一个圆环,同时服务端显示同样的圆环;右击绘一个圆形,同时服务端显示同样的圆形。
udp网络编程用来了解 udp协议通信。。。。。。。。。。。。
计算机网络课程设计——端口扫描器的实现 1.利用Socket通信机制实现一个多线程的端口扫描器。 2.设计要求: 2.1用户界面:用户可以输入IP地址或IP地址段;...2.3 采用Java网络编程包java.io中提供的编程接口实现。
c语言编程实现tcp和udp通信的源代码,有客户端和服务器端
UDP协议在IP协议之上添加的功能虽然非常有限,但...通过完成本实验项目,巩固以前所学的面向对象的分析和设计技术,掌握UDP套接字的编程范型,熟悉Java对UDP协议的支持类的编程接口,并能熟练运用于UDP协议应用编程中。
使用UDP协议 C/S的编程模式 简单的聊天程序
使用 UDP协议的 Socket 网络程序设计 java编程
主要介绍了java编程实现基于UDP协议传输数据的方法,较为详细的分析了UDP协议的原理及Java编程实现数据传输客户端与服务器端的相关技巧,需要的朋友可以参考下
基于UDP传输协议,指定主机IP以及端口号就能发送消息。