`

java中的UDP编程【转】

    博客分类：
  • java
编程Java网络协议应用服务器Socket 
阅读更多

一. 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的服务端程序

Code:
  1. importjava.io.IOException;
  2. importjava.net.DatagramPacket;
  3. importjava.net.DatagramSocket;
  4. importjava.net.InetAddress;
  5. importjava.net.InetSocketAddress;
  6. importjava.net.SocketException;
  8. /***//**
  9. *Copyright2007GuangZhouCotelCo.Ltd.
  10. *Allrightreserved.
  11. *UTP服务类.
  12. *@author<ahref="mailto:xiexingxing1121@126.com">AmigoXie</a>
  13. *@version1.0
  14. *Creationdate:2007-8-16-下午10:32:31
  15. */
  16. publicclassUdpServerSocket{
  17. privatebyte[]buffer=newbyte[1024];
  19. privateDatagramSocketds=null;
  21. privateDatagramPacketpacket=null;
  23. privateInetSocketAddresssocketAddress=null;
  25. privateStringorgIp;
  27. /***//**
  28. *构造函数，绑定主机和端口.
  29. *@paramhost主机
  30. *@paramport端口
  31. *@throwsException
  32. */
  33. publicUdpServerSocket(Stringhost,intport)throwsException{
  34. socketAddress=newInetSocketAddress(host,port);
  35. ds=newDatagramSocket(socketAddress);
  36. System.out.println("服务端启动!");
  37. }
  39. publicfinalStringgetOrgIp(){
  40. returnorgIp;
  41. }
  43. /***//**
  44. *设置超时时间，该方法必须在bind方法之后使用.
  45. *@paramtimeout超时时间
  46. *@throwsException
  47. */
  48. publicfinalvoidsetSoTimeout(inttimeout)throwsException{
  49. ds.setSoTimeout(timeout);
  50. }
  52. /***//**
  53. *获得超时时间.
  54. *@return返回超时时间.
  55. *@throwsException
  56. *@author<ahref="mailto:xiexingxing1121@126.com">AmigoXie</a>
  57. *Creationdate:2007-8-16-下午10:34:36
  58. */
  59. publicfinalintgetSoTimeout()throwsException{
  60. returnds.getSoTimeout();
  61. }
  63. /***//**
  64. *绑定监听地址和端口.
  65. *@paramhost主机IP
  66. *@paramport端口
  67. *@throwsSocketException
  68. *@author<ahref="mailto:xiexingxing1121@126.com">AmigoXie</a>
  69. *Creationdate:2007-8-16-下午10:36:17
  70. */
  71. publicfinalvoidbind(Stringhost,intport)throwsSocketException{
  72. socketAddress=newInetSocketAddress(host,port);
  73. ds=newDatagramSocket(socketAddress);
  74. }
  77. /***//**
  78. *接收数据包，该方法会造成线程阻塞.
  79. *@return返回接收的数据串信息
  80. *@throwsIOException
  81. *@author<ahref="mailto:xiexingxing1121@126.com">AmigoXie</a>
  82. *Creationdate:2007-8-16-下午10:38:24
  83. */
  84. publicfinalStringreceive()throwsIOException{
  85. packet=newDatagramPacket(buffer,buffer.length);
  86. ds.receive(packet);
  87. orgIp=packet.getAddress().getHostAddress();
  88. Stringinfo=newString(packet.getData(),0,packet.getLength());
  89. System.out.println("接收信息："+info);
  90. returninfo;
  91. }
  93. /***//**
  94. *将响应包发送给请求端.
  95. *@parambytes回应报文
  96. *@throwsIOException
  97. *@author<ahref="mailto:xiexingxing1121@126.com">AmigoXie</a>
  98. *Creationdate:2007-8-16-下午11:05:31
  99. */
  100. publicfinalvoidresponse(Stringinfo)throwsIOException{
  101. System.out.println("客户端地址:"+packet.getAddress().getHostAddress()
  102. +",端口："+packet.getPort());
  103. DatagramPacketdp=newDatagramPacket(buffer,buffer.length,packet
  104. .getAddress(),packet.getPort());
  105. dp.setData(info.getBytes());
  106. ds.send(dp);
  107. }
  109. /***//**
  110. *设置报文的缓冲长度.
  111. *@parambufsize缓冲长度
  112. *@author<ahref="mailto:xiexingxing1121@126.com">AmigoXie</a>
  113. *Creationdate:2007-8-16-下午10:47:49
  114. */
  115. publicfinalvoidsetLength(intbufsize){
  116. packet.setLength(bufsize);
  117. }
  119. /***//**
  120. *获得发送回应的IP地址.
  121. *@return返回回应的IP地址
  122. *@author<ahref="mailto:xiexingxing1121@126.com">AmigoXie</a>
  123. *Creationdate:2007-8-16-下午10:48:27
  124. */
  125. publicfinalInetAddressgetResponseAddress(){
  126. returnpacket.getAddress();
  127. }
  129. /***//**
  130. *获得回应的主机的端口.
  131. *@return返回回应的主机的端口.
  132. *@author<ahref="mailto:xiexingxing1121@126.com">AmigoXie</a>
  133. *Creationdate:2007-8-16-下午10:48:56
  134. */
  135. publicfinalintgetResponsePort(){
  136. returnpacket.getPort();
  137. }
  139. /***//**
  140. *关闭udp监听口.
  141. *@author<ahref="mailto:xiexingxing1121@126.com">AmigoXie</a>
  142. *Creationdate:2007-8-16-下午10:49:23
  143. */
  144. publicfinalvoidclose(){
  145. try{
  146. ds.close();
  147. }catch(Exceptionex){
  148. ex.printStackTrace();
  149. }
  150. }
  152. /***//**
  153. *测试方法.
  154. *@paramargs
  155. *@throwsException
  156. *@author<ahref="mailto:xiexingxing1121@126.com">AmigoXie</a>
  157. *Creationdate:2007-8-16-下午10:49:50
  158. */
  159. publicstaticvoidmain(String[]args)throwsException{
  160. StringserverHost="127.0.0.1";
  161. intserverPort=3344;
  162. UdpServerSocketudpServerSocket=newUdpServerSocket(serverHost,serverPort);
  163. while(true){
  164. udpServerSocket.receive();
  165. udpServerSocket.response("你好,sterning!");
  167. }
  168. }
  169. }

2. UDP客户端程序

Code:
  1. importjava.io.*;
  2. importjava.net.*;
  4. /***//**
  5. *Copyright2007GuangZhouCotelCo.Ltd.
  6. *Allrightreserved.
  7. *UDP客户端程序，用于对服务端发送数据，并接收服务端的回应信息.
  8. *@author<ahref="mailto:xiexingxing1121@126.com">AmigoXie</a>
  9. *@version1.0
  10. *Creationdate:2007-8-16-下午10:54:23
  11. */
  12. publicclassUdpClientSocket{
  13. privatebyte[]buffer=newbyte[1024];
  15. privateDatagramSocketds=null;
  17. /***//**
  18. *构造函数，创建UDP客户端
  19. *@throwsException
  20. */
  21. publicUdpClientSocket()throwsException{
  22. ds=newDatagramSocket();
  23. }
  25. /***//**
  26. *设置超时时间，该方法必须在bind方法之后使用.
  27. *@paramtimeout超时时间
  28. *@throwsException
  29. *@author<ahref="mailto:xiexingxing1121@126.com">AmigoXie</a>
  30. *Creationdate:2007-8-16-下午10:55:12
  31. */
  32. publicfinalvoidsetSoTimeout(finalinttimeout)throwsException{
  33. ds.setSoTimeout(timeout);
  34. }
  36. /***//**
  37. *获得超时时间.
  38. *@return返回超时时间
  39. *@throwsException
  40. *@author<ahref="mailto:xiexingxing1121@126.com">AmigoXie</a>
  41. *Creationdate:2007-8-16-下午10:55:25
  42. */
  43. publicfinalintgetSoTimeout()throwsException{
  44. returnds.getSoTimeout();
  45. }
  47. publicfinalDatagramSocketgetSocket(){
  48. returnds;
  49. }
  51. /***//**
  52. *向指定的服务端发送数据信息.
  53. *@paramhost服务器主机地址
  54. *@paramport服务端端口
  55. *@parambytes发送的数据信息
  56. *@return返回构造后俄数据报
  57. *@throwsIOException
  58. *@author<ahref="mailto:xiexingxing1121@126.com">AmigoXie</a>
  59. *Creationdate:2007-8-16-下午11:02:41
  60. */
  61. publicfinalDatagramPacketsend(finalStringhost,finalintport,
  62. finalbyte[]bytes)throwsIOException{
  63. DatagramPacketdp=newDatagramPacket(bytes,bytes.length,InetAddress
  64. .getByName(host),port);
  65. ds.send(dp);
  66. returndp;
  67. }
  69. /***//**
  70. *接收从指定的服务端发回的数据.
  71. *@paramlhost服务端主机
  72. *@paramlport服务端端口
  73. *@return返回从指定的服务端发回的数据.
  74. *@throwsException
  75. *@author<ahref="mailto:xiexingxing1121@126.com">AmigoXie</a>
  76. *Creationdate:2007-8-16-下午10:52:36
  77. */
  78. publicfinalStringreceive(finalStringlhost,finalintlport)
  79. throwsException{
  80. DatagramPacketdp=newDatagramPacket(buffer,buffer.length);
  81. ds.receive(dp);
  82. Stringinfo=newString(dp.getData(),0,dp.getLength());
  83. returninfo;
  84. }
  86. /***//**
  87. *关闭udp连接.
  88. *@author<ahref="mailto:xiexingxing1121@126.com">AmigoXie</a>
  89. *Creationdate:2007-8-16-下午10:53:52
  90. */
  91. publicfinalvoidclose(){
  92. try{
  93. ds.close();
  94. }catch(Exceptionex){
  95. ex.printStackTrace();
  96. }
  97. }
  99. /***//**
  100. *测试客户端发包和接收回应信息的方法.
  101. *@paramargs
  102. *@throwsException
  103. *@author<ahref="mailto:xiexingxing1121@126.com">AmigoXie</a>
  104. *Creationdate:2007-8-16-下午11:03:54
  105. */
  106. publicstaticvoidmain(String[]args)throwsException{
  107. UdpClientSocketclient=newUdpClientSocket();
  108. StringserverHost="127.0.0.1";
  109. intserverPort=3344;
  110. client.send(serverHost,serverPort,("你好，阿蜜果!").getBytes());
  111. Stringinfo=client.receive(serverHost,serverPort);
  112. System.out.println("服务端回应数据："+info);
  113. }
  114. }

转载地址：http://www.blogjava.net/amigoxie/archive/2007/08/16/137413.html

-----------基础

分享到：
| 走马观花记二--css
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

Magicbox
Global site tag (gtag.js) - Google Analytics