使用DatagramSocket发送、接收数据(Socket之UDP套接字)_jiangxinyu的博客-程序员资料_datagramsocket

技术标签: Java AND Android  

http://book.51cto.com/art/201203/322540.htm

17.4.2 使用DatagramSocket发送、接收数据(1)

Java使用DatagramSocket代表UDP协议的Socket,DatagramSocket本身只是码头,不维护状态,不能产生IO流,它的唯一作用就是接收和发送数据报,Java使用DatagramPacket来代表数据报,DatagramSocket接收和发送的数据都是通过DatagramPacket对象完成的。

先看一下DatagramSocket的构造器。

DatagramSocket():创建一个DatagramSocket实例,并将该对象绑定到本机默认IP地址、本机所有可用端口中随机选择的某个端口。

DatagramSocket(int prot):创建一个DatagramSocket实例,并将该对象绑定到本机默认IP地址、指定端口。

DatagramSocket(int port, InetAddress laddr):创建一个DatagramSocket实例,并将该对象绑定到指定IP地址、指定端口。

通过上面三个构造器中的任意一个构造器即可创建一个DatagramSocket实例,通常在创建服务器时,创建指定端口的DatagramSocket实例--这样保证其他客户端可以将数据发送到该服务器。一旦得到了DatagramSocket实例之后,就可以通过如下两个方法来接收和发送数据。

receive(DatagramPacket p):从该DatagramSocket中接收数据报。

send(DatagramPacket p):以该DatagramSocket对象向外发送数据报。

从上面两个方法可以看出,使用DatagramSocket发送数据报时,DatagramSocket并不知道将该数据报发送到哪里,而是由DatagramPacket自身决定数据报的目的地。就像码头并不知道每个集装箱的目的地,码头只是将这些集装箱发送出去,而集装箱本身包含了该集装箱的目的地。

下面看一下DatagramPacket的构造器。

DatagramPacket(byte[] buf,int length):以一个空数组来创建DatagramPacket对象,该对象的作用是接收DatagramSocket中的数据。

DatagramPacket(byte[] buf, int length, InetAddress addr, int port):以一个包含数据的数组来创建DatagramPacket对象,创建该DatagramPacket对象时还指定了IP地址和端口--这就决定了该数据报的目的地。

DatagramPacket(byte[] buf, int offset, int length):以一个空数组来创建DatagramPacket对象,并指定接收到的数据放入buf数组中时从offset开始,最多放length个字节。

DatagramPacket(byte[] buf, int offset, int length, InetAddress address, int port):创建一个用于发送的DatagramPacket对象,指定发送buf数组中从offset开始,总共length个字节。

当Client/Server程序使用UDP协议时,实际上并没有明显的服务器端和客户端,因为两方都需要先建立一个DatagramSocket对象,用来接收或发送数据报,然后使用DatagramPacket对象作为传输数据的载体。通常固定IP地址、固定端口的DatagramSocket对象所在的程序被称为服务器,因为该DatagramSocket可以主动接收客户端数据。

在接收数据之前,应该采用上面的第一个或第三个构造器生成一个DatagramPacket对象,给出接收数据的字节数组及其长度。然后调用DatagramSocket 的receive()方法等待数据报的到来,receive()将一直等待(该方法会阻塞调用该方法的线程),直到收到一个数据报为止。如下代码所示:

 
  
  1. // 创建一个接收数据的DatagramPacket对象
  2. DatagramPacket packet=new DatagramPacket(buf, 256);
  3. // 接收数据报
  4. socket.receive(packet);

在发送数据之前,调用第二个或第四个构造器创建DatagramPacket对象,此时的字节数组里存放了想发送的数据。除此之外,还要给出完整的目的地址,包括IP地址和端口号。发送数据是通过DatagramSocket的send()方法实现的,send()方法根据数据报的目的地址来寻径以传送数据报。如下代码所示:

 
  
  1. // 创建一个发送数据的DatagramPacket对象
  2. DatagramPacket packet = new DatagramPacket(buf, length, address, port);
  3. // 发送数据报
  4. socket.send(packet);

使用DatagramPacket接收数据时,会感觉DatagramPacket设计得过于烦琐。开发者只关心该DatagramPacket能放多少数据,而DatagramPacket是否采用字节数组来存储数据完全不想关心。但Java要求创建接收数据用的DatagramPacket时,必须传入一个空的字节数组,该数组的长度决定了该DatagramPacket能放多少数据,这实际上暴露了DatagramPacket的实现细节。接着DatagramPacket又提供了一个getData()方法,该方法又可以返回Datagram Packet对象里封装的字节数组,该方法更显得有些多余--如果程序需要获取DatagramPacket里封装的字节数组,直接访问传给 DatagramPacket构造器的字节数组实参即可,无须调用该方法。

当服务器端(也可以是客户端)接收到一个DatagramPacket对象后,如果想向该数据报的发送者"反馈"一些信息,但由于UDP协议是面向非连接的,所以接收者并不知道每个数据报由谁发送过来,但程序可以调用DatagramPacket的如下3个方法来获取发送者的IP地址和端口。

InetAddress getAddress():当程序准备发送此数据报时,该方法返回此数据报的目标机器的IP地址;当程序刚接收到一个数据报时,该方法返回该数据报的发送主机的IP地址。

int getPort():当程序准备发送此数据报时,该方法返回此数据报的目标机器的端口;当程序刚接收到一个数据报时,该方法返回该数据报的发送主机的端口。

SocketAddress getSocketAddress():当程序准备发送此数据报时,该方法返回此数据报的目标SocketAddress;当程序刚接收到一个数据报时,该方法返回该数据报的发送主机的SocketAddress。

getSocketAddress()方法的返回值是一个SocketAddress对象,该对象实际上就是一个IP地址和一个端口号。也就是说,SocketAddress对象封装了一个InetAddress对象和一个代表端口的整数,所以使用SocketAddress对象可以同时代表IP地址和端口。

 

http://book.51cto.com/art/201203/322542.htm

17.4.2 使用DatagramSocket发送、接收数据(2)

下面程序使用DatagramSocket实现了Server/Client结构的网络通信。本程序的服务器端使用循环1000次来读取DatagramSocket中的数据报,每当读取到内容之后便向该数据报的发送者送回一条信息。服务器端程序代码如下。

程序清单:codes\17\17.4\UdpServer.java

 
  
  1. public class UdpServer
  2. {
  3. public static final int PORT = 30000;
  4. // 定义每个数据报的最大大小为4KB
  5. private static final int DATA_LEN = 4096;
  6. // 定义接收网络数据的字节数组
  7. byte[] inBuff = new byte[DATA_LEN];
  8. // 以指定字节数组创建准备接收数据的DatagramPacket对象
  9. private DatagramPacket inPacket =
  10. new DatagramPacket(inBuff , inBuff.length);
  11. // 定义一个用于发送的DatagramPacket对象
  12. private DatagramPacket outPacket;
  13. // 定义一个字符串数组,服务器端发送该数组的元素
  14. String[] books = new String[]
  15. {
  16. "疯狂Java讲义",
  17. "轻量级Java EE企业应用实战",
  18. "疯狂Android讲义",
  19. "疯狂Ajax讲义"
  20. };
  21. public void init()throws IOException
  22. {
  23. try(
  24. // 创建DatagramSocket对象
  25. DatagramSocket socket = new DatagramSocket(PORT))
  26. {
  27. // 采用循环接收数据
  28. for (int i = 0; i < 1000 ; i++ )
  29. {
  30. // 读取Socket中的数据,读到的数据放入inPacket封装的数组里
  31. socket.receive(inPacket);
  32. // 判断inPacket.getData()和inBuff是否是同一个数组
  33. System.out.println(inBuff == inPacket.getData());
  34. // 将接收到的内容转换成字符串后输出
  35. System.out.println(new String(inBuff
  36. , 0 , inPacket.getLength()));
  37. // 从字符串数组中取出一个元素作为发送数据
  38. byte[] sendData = books[i % 4].getBytes();
  39. // 以指定的字节数组作为发送数据,以刚接收到的DatagramPacket的
  40. // 源SocketAddress作为目标SocketAddress创建DatagramPacket
  41. outPacket = new DatagramPacket(sendData
  42. , sendData.length , inPacket.getSocketAddress());
  43. // 发送数据
  44. socket.send(outPacket);
  45. }
  46. }
  47. }
  48. public static void main(String[] args)
  49. throws IOException
  50. {
  51. new UdpServer().init();
  52. }
  53. }

上面程序中的粗体字代码就是使用DatagramSocket发送、接收DatagramPacket的关键代码,该程序可以接收1000个客户端发送过来的数据。

客户端程序代码也与此类似,客户端采用循环不断地读取用户键盘输入,每当读取到用户输入的内容后就将该内容封装成DatagramPacket数据报,再将该数据报发送出去;接着把DatagramSocket中的数据读入接收用的DatagramPacket中(实际上是读入该DatagramPacket所封装的字节数组中)。客户端程序代码如下。

 

17.4.2 使用DatagramSocket发送、接收数据(3)

程序清单:codes\17\17.4\UdpClient.java

 
  
  1. public class UdpClient
  2. {
  3. // 定义发送数据报的目的地
  4. public static final int DEST_PORT = 30000;
  5. public static final String DEST_IP = "127.0.0.1";
  6. // 定义每个数据报的最大大小为4KB
  7. private static final int DATA_LEN = 4096;
  8. // 定义接收网络数据的字节数组
  9. byte[] inBuff = new byte[DATA_LEN];
  10. // 以指定的字节数组创建准备接收数据的DatagramPacket对象
  11. private DatagramPacket inPacket =
  12. new DatagramPacket(inBuff , inBuff.length);
  13. // 定义一个用于发送的DatagramPacket对象
  14. private DatagramPacket outPacket = null;
  15. public void init()throws IOException
  16. {
  17. try(
  18. // 创建一个客户端DatagramSocket,使用随机端口
  19. DatagramSocket socket = new DatagramSocket())
  20. {
  21. // 初始化发送用的DatagramSocket,它包含一个长度为0的字节数组
  22. outPacket = new DatagramPacket(new byte[0] , 0
  23. , InetAddress.getByName(DEST_IP) , DEST_PORT);
  24. // 创建键盘输入流
  25. Scanner scan = new Scanner(System.in);
  26. // 不断地读取键盘输入
  27. while(scan.hasNextLine())
  28. {
  29. // 将键盘输入的一行字符串转换成字节数组
  30. byte[] buff = scan.nextLine().getBytes();
  31. // 设置发送用的DatagramPacket中的字节数据
  32. outPacket.setData(buff);
  33. // 发送数据报
  34. socket.send(outPacket);
  35. // 读取Socket中的数据,读到的数据放在inPacket所封装的字节数组中
  36. socket.receive(inPacket);
  37. System.out.println(new String(inBuff , 0
  38. , inPacket.getLength()));
  39. }
  40. }
  41. }
  42. public static void main(String[] args)
  43. throws IOException
  44. {
  45. new UdpClient().init();
  46. }
  47. }

上面程序中的粗体字代码同样也是使用DatagramSocket发送、接收DatagramPacket的关键代码,这些代码与服务器端代码基本相似。而客户端与服务器端的唯一区别在于:服务器端的IP地址、端口是固定的,所以客户端可以直接将该数据报发送给服务器端,而服务器端则需要根据接收到的数据报来决定"反馈"数据报的目的地。

读者可能会发现,使用DatagramSocket进行网络通信时,服务器端无须也无法保存每个客户端的状态,客户端把数据报发送到服务器端后,完全有可能立即退出。但不管客户端是否退出,服务器端都无法知道客户端的状态。

当使用UDP协议时,如果想让一个客户端发送的聊天信息被转发到其他所有的客户端则比较困难,可以考虑在服务器端使用Set集合来保存所有的客户端信息,每当接收到一个客户端的数据报之后,程序检查该数据报的源SocketAddress是否在Set集合中,如果不在就将该SocketAddress添加到该Set集合中。这样又涉及一个问题:可能有些客户端发送一个数据报之后永久性地退出了程序,但服务器端还将该客户端的SocketAddress保存在Set集合中……总之,这种方式需要处理的问题比较多,编程比较烦琐。幸好Java为UDP协议提供了MulticastSocket类,通过该类可以轻松地实现多点广播。

 

Socket之UDP套接字

UDP套接字:UDP套接字的使用是通过DatagramPacket类和DatagramSocket类,客户端和服务器端都是用DatagramPacket类来接收数据,使用DatagramSocket类来发送数据。

UDP客户端:也是主要执行三个步骤。

1.创建DatagramSocket实例;

2.使用DatagramSocket类的send()和receive()方法发送和接收DatagramPacket实例;

3.最后使用DatagramSocket类的close()方法销毁该套接字。

下面是例子,它主要执行三个步骤,

1.向服务器发送信息;

2.在receive()方法上最多阻塞等待3秒钟,在超时前若没有收到响应,则重发请求(最多重发5次);

3.关闭客户端。

//UDPEchoClientTimeout.java

import java.net.DatagramSocket;
import java.net.DatagramPacket;
import java.net.InetAddress;
import java.io.IOException;
import java.io.InterruptedIOException;

public class UDPEchoClientTimeout {

	private static final int TIMEOUT = 3000;   // 设置超时为3秒
	private static final int MAXTRIES = 5;     // 最大重发次数5次
	
	public static void main(String[] args) throws IOException {
	
	    if ((args.length < 2) || (args.length > 3)) { // Test for correct # of args
	      throw new IllegalArgumentException("Parameter(s): <Server> <Word> [<Port>]");
	    }
	    InetAddress serverAddress = InetAddress.getByName(args[0]); // 服务器地址
	    // Convert the argument String to bytes using the default encoding
	    //发送的信息
	    byte[] bytesToSend = args[1].getBytes();
	
	    int servPort = (args.length == 3) ? Integer.parseInt(args[2]) : 7;
	
	    DatagramSocket socket = new DatagramSocket();
	
	    socket.setSoTimeout(TIMEOUT); // 设置阻塞时间
	
	    DatagramPacket sendPacket = new DatagramPacket(bytesToSend, // 相当于将发送的信息打包
	        bytesToSend.length, serverAddress, servPort);
	
	    DatagramPacket receivePacket =                              // 相当于空的接收包
	        new DatagramPacket(new byte[bytesToSend.length], bytesToSend.length);
	
	    int tries = 0;      // Packets may be lost, so we have to keep trying
	    boolean receivedResponse = false;
	    do {
	      socket.send(sendPacket);          // 发送信息
	      try {
	        socket.receive(receivePacket); // 接收信息
	
	        if (!receivePacket.getAddress().equals(serverAddress)) {// Check source
	          throw new IOException("Received packet from an unknown source");
	        }
	        receivedResponse = true;
	      } catch (InterruptedIOException e) { // 当receive不到信息或者receive时间超过3秒时,就向服务器重发请求
	        tries += 1;
	        System.out.println("Timed out, " + (MAXTRIES - tries) + " more tries...");
	      }
	    } while ((!receivedResponse) && (tries < MAXTRIES));
	
	    if (receivedResponse) {
	      System.out.println("Received: " + new String(receivePacket.getData()));
	    } else {
	      System.out.println("No response -- giving up.");
	    }
	    socket.close();
	}
}


例子只是简单的向指定的服务器发送信息,并将发送的信息由服务器返回给指定客户端。

UDP服务器端:典型的UDP服务器要执行三个步骤,

1.创建一个指定了本地端口的DatagramSocket实例;

2.使用DatagramSocket的receive()方法接收一个来自客户端的DatagramPacket实例,而这个DatagramPacket实例在客户端创建时就包含了客户端的地址,这样我们就知道回复信息要发送到哪里了;

3.使用DatagramSocket类的send()和receive()方法来发送和接收DatagramPacket实例。

下面是例子

//UDPEchoServer.java
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;

public class UDPEchoServer {

	private static final int ECHOMAX = 255; // 发送或接收的信息最大字节数
	
	public static void main(String[] args) throws IOException {
	
	    if (args.length != 1) { // Test for correct argument list
	      throw new IllegalArgumentException("Parameter(s): <Port>");
	    }
	
	    int servPort = Integer.parseInt(args[0]);
	
	    DatagramSocket socket = new DatagramSocket(servPort);
	    DatagramPacket packet = new DatagramPacket(new byte[ECHOMAX], ECHOMAX);
	
	    while (true) { // 不断接收来自客户端的信息及作出相应的相应
	      socket.receive(packet); // Receive packet from client
	      System.out.println("Handling client at " + packet.getAddress().getHostAddress() + " on port " + packet.getPort());
	      socket.send(packet); // 将客户端发送来的信息返回给客户端
	      packet.setLength(ECHOMAX); 
		 // 重置packet的内部长度,因为处理了接收到的信息后,数据包的内部长度将被                                                       
		 //设置为刚处理过的信息的长度,而这个长度可能比缓冲区的原始长度还要短,
		 //如果不重置,而且接收到的新信息长于这个内部长度,则超出长度的部分将会被截断,所以这点必须注意到。
	    }
	    /* NOT REACHED */
	}
}


例子只是简单地将客户端发送过来的信息再回复给客户端,服务器端会不断地receive来自客户端的信息,如果receive不到任何客户端请求,则将会进入阻塞状态,直到receive到有客户端请求位置。

 

 

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/jiangxinyu/article/details/8161044

智能推荐

Labelme制作Mask-Rcnn数据集,并批量转换json文件_向死而生zzz的博客-程序员资料

Labelme制作Mask-Rcnn数据集步骤。一、安装anaconda查看博客https://mp.csdn.net/postedit/85069386二、安装labelme 1、打开anaconda prompt2、conda create --name=labelme python=3.5(创建名称为labelme的环境,Python版本为3.5)3、activat...

桌面计算机安,最新版本:Win7 dream桌面安装64位,_计算机基本知识_IT /计算机_信息..._六号轨迹的博客-程序员资料

下载压缩包并解压缩,找到“ Install.bat”文件,右键单击-“以管理员身份运行”,它将无法正常工作,估计直接双击即可,您必须以管理员! !记住~~记住~~~! ,出现安装界面,并出现“按任意键继续”,然后单击Enter-“ vista version:[6,3],如果是64位win7,则输入数字6,如果是32位(即是,通常的X86版本)输入数字3,并且***将显示Windows Dream...

Yolov5训练FLIR红外线数据集_Fighting_1997的博客-程序员资料_flir数据集

训练Yolov5的博客很多了,只要放好数据集位置即可本博客使用的yolov5-5.0版本最近确实事情较多,博客写的比较简练,如果有问题,直接评论即可,我会短时间内回复!主要就是下图的文件放置创建flir.yaml文件,这个是yolov5中voc.yaml文件,我直接复制一下修改后:(建议在ubuntu系统中训练)修改train.py参数训练过程中如果出现关于channel错误信息的,直接点进去,修改通道数为1即可。训练结果..._1671465600

魔术方法_clone( )_独酌山外小阁楼的博客-程序员资料

clone():克隆对象的时候自动调用。测试代码如下:class Wo{public $username='king';public function say(){echo 'hello '.$this-&gt;username.'&lt;br/&gt;';}}$w1=new Wo; //创建一个新的对象echo $w1-&gt;username.'&lt;br/&g...

import torch报错:from torch._C import * ImportError: DLL load failed: 找不到指定的程序,完美解决!_一个努力吃胖的小瘦子的博客-程序员资料_from torch._c import * importerror: dll load faile

import torch报错:from torch._C import * ImportError: DLL load failed: 找不到指定的程序,完美解决!1. 问题描述昨天刚收到新买的笔记本电脑,就迫不及待的着手安装Pytorch。首先安装了Ananconda一切顺利,但是当我用conda命令安装完pytorch,在命令行输入"import torch"后发现报错,错误提示为:“im...

Delphi 的绘图功能[9] - TextRect_kuaidi8的博客-程序员资料_delphi textrect

======================================================注:重要!程序员如何有效的放松身心!下班后做什么?======================================================#1楼 2008-02-17 19:34 保权这部分是gdi吧?抽空我也去研究一下。回复 引用 查看#

随便推点

杭电OJ-2054_A == B ?_A__yes的博客-程序员资料

Time Limit: 1000/1000 MS (Java/Others)    Memory Limit: 32768/32768 K (Java/Others)Total Submission(s): 76226    Accepted Submission(s): 12101Problem DescriptionGive you two numbers A and B,

emp和emn是什么文件_emn格式文件_吴寿鹤的博客-程序员资料

常用的 IDF 文件格式,如 emn,emp,brd,bdf 等。 2. 走线文件格式:GERBER,ODB++。 3. 当器件非常多时,通过 CSV 文件导入功耗、热阻等属性。 4. 简化的 ......3. 将该电路板,另存为*.Brd 格式。此时会生成两个文件:扩展名是 brd 和 pro。将它们分 别修改为 emn 和 emp。特别注意:EMP 文件中,记录了各个器件的封装......是一...

SAP发家史_david_lv的博客-程序员资料

一、SAP创立SAP创立于1972年,德国。SAP的主要创始人来自IBM,德国的IBM,而且是博士学历出身、IBM德国的高管VP。当时全世界都是以硬件销售为主,软件走的是...

38个常用Python库:数值计算、可视化、机器学习等8大领域_鹏鹏俊玲的博客-程序员资料

01 数值计算数值计算是数据挖掘、机器学习的基础。Python提供多种强大的扩展库用于数值计算,常用的数值计算库如下所示。1. NumPy支持多维数组与矩阵运算,也针对数组运算提供大量的数学函数库。通常与SciPy和Matplotlib一起使用,支持比Python更多种类的数值类型,其中定义的最重要的对象是称为ndarray的n维数组类型,用于描述相同类型的元素集合,可以使用基于0的索...

那些年,我们一起写的设计模式(一)——单例模式(Singleton Pattern)_VickyMouse1010的博客-程序员资料

题记 *度娘上对设计模式(Design pattern)的定义是:“一套被反复使用、多数人知晓的、经过分类编目的、代码设计经验的总结。”它由著名的“四人帮”,又称 GOF (即 Gang of Four),在《设计模式》(《Design Patterns: Elements of Reusable Object-Oriented Software》)一书中提升到理论高度,并将之规范化。在我

typora相关_DDTS_ZD的博客-程序员资料

typora相关1.目录2.标题3.代码块4.引用块5.分割线6.清单列表7.字体8.插入表格9.彩蛋1.目录输入 [toc] 回车,即可看到整个内容所用的标题,按照标题级别显示2.标题输入 #+空格+标题名称 回车或者光标离开。记住一定要有空格。3.代码块输入 三个波浪号 ~~~ 或者 三个反引号 ```,回车。记得修改 markdown 配置,然后重启 typora。可以显示行号4.引用块输入 &gt; ,回车即可5.分割线输入 *** 或者 --- ,回车6.清单列表

推荐文章

热门文章

相关标签