1.一种消息批量传输的仿真系统,其特征在于,装载在无人机集群组网架构中多个无人机客户端上,所述系统包括:主线程、消息收集器以及发送线程;所述主线程用于创建批量消息,并将所述批量消息缓存至消息收集器;所述批量消息包括多组子批量消息;所述消息收集器用于根据预设的队列容量划分所述批量消息的缓存空间,得到多组缓存队列,所述缓存队列采用双端队列存储所述子批量消息;所述发送线程用于获取所述消息收集器中所述缓存队列的所述子批量消息,并转变所述子批量消息的保存形式,得到协议请求;所述协议请求通过请求连接模块与消息中心建立所述子批量消息的发送连接,以使所述子批量消息通过所述消息中心发送至对应的多个目标无人机客户端;所述发送线程包括创建请求、在请求中和选择器,对于每一个批量消息的提取,所述发送线程先为所述批量消息的提取创建请求,将已创建的请求发送至所述选择器,并由所述选择器发送至对应的运行节点;当大批的批量消息同时被调用时,根据调用时间先后创建请求,并将每个批量消息的请求暂存至所述在请求中的对应链路中;所述在请求中用于缓存待提交的所述批量消息对应的请求,根据所述选择器对于请求处理后的反馈,在请求中按序调取对应链路的请求,并将已调取的请求所提取的所述消息收集器中的批量消息进行清理,及时挪出缓存批量消息的空间。
2.根据权利要求1所述的一种消息批量传输的仿真系统,其特征在于,所述批量消息为多个无人机客户端在特定时间内发送的消息量。
3.根据权利要求1所述的一种消息批量传输的仿真系统,其特征在于,所述主线程包括:生产者、序列化以及分发器,所述生产者创建的消息经所述序列化和所述分发器逐级处理后缓存至所述消息收集器;所述生产者为所述无人机集群组网架构中任意个无人机客户端组成的无人机集群。
4.根据权利要求1所述的一种消息批量传输的仿真系统,其特征在于,所述消息收集器,还用于查找新写入的批量消息对应的双端队列,若所述双端队列存在,则从所述双端队列的尾部获取一个子批量消息,若所述子批量消息为空,则写入所述批量消息至所述双端队列的尾部,若所述子批量消息不为空,则新建一个子批量消息作为所述双端队列尾部的子批量消息;若新建的子批量消息的大小不大于所述队列容量划分的缓存空间大小,则按照所述队列容量划分的缓存空间大小存储新写入的批量消息;若新建的子批量消息的大小大于所述队列容量划分的缓存空间大小,则按照新建的子批量消息的大小创建缓存空间存储新写入的批量消息;若所述双端队列不存在,则新建一个双端队列。
5.根据权利要求1所述的一种消息批量传输的仿真系统,其特征在于,所述发送线程,还用于获取所述消息收集器中所述缓存队列的所述子批量消息的保存形式<Node,批量消息>,将所述子批量消息的保存形式<Node,批量消息>转变为所述子批量消息的队列保存形式<Node,list(批量消息)>,封装所述子批量消息的队列保存形式<Node,list(批量消息)>,得到协议请求<Node,Request>。
6.根据权利要求1所述的一种消息批量传输的仿真系统,其特征在于,所述发送线程,还用于所述消息中心接收到所述协议请求分别发送至多个目标无人机客户端,同时回传响应信息至在请求中,通过比对所述在请求中所述缓存队列的响应信息的大小与预设的缓存请求数,获取所述目标无人机客户端未响应结果,若所述响应结果为过载,则减少所述发送线程获取所述缓存队列的请求数。
7.一种消息批量传输的仿真系统的实现方法,其特征在于,应用于权利要求1至6任一项所述一种消息批量传输的仿真系统中,所述方法包括:获取无人机集群组网中若干个无人机发送的消息,得到集群批量消息;所述集群批量消息根据预设的缓存区大小划分为多组子批量消息,将每一组所述子批量消息写入消息收集器中双端缓存队列的尾部进行消息聚合,得到多个批次消息;每一个所述批次消息包括多个所述子批量消息;多个所述批次消息采用异步发送方式发送至消息中心。
8.根据权利要求7所述的方法,其特征在于,多个所述批次消息采用异步发送方式发送至消息中心,包括:所述无人机将所述批次消息发送至消息中心的缓冲区后,所述消息中心从所述缓冲区将调取的所述批次消息写入磁盘中,并发送确认消息至所述无人机。
9.一种计算机设备,包括存储器和处理器,所述存储器存储有计算机程序,其特征在于,所述处理器执行所述计算机程序时实现权利要求7至8中任一项所述方法的步骤。