一种基于异步队列的计量信息交互平台及方法

摘要

本发明公开一种基于异步队列的计量信息交互平台及方法。本发明通过设计基于异步队列的计量信息交互平台，将下层机构的计量周转柜管理系统通过计量服务总线与上层机构的计量包管理系统通信连接，利用计量周转柜管理系统在当前网络处于在线状态时，通过计量服务总线在异步队列中写入第一计量表管理消息，利用计量包管理系统通过计量服务总线在异步队列中读取第一计量表管理消息，利用计量包管理系统在当前网络处于在线状态时，通过计量服务总线在异步队列中写入计量包管理消息，利用计量周转柜管理系统通过计量服务总线在异步队列中读取计量包管理消息，能够保证计量周转柜的信息交互，提高应急抢修效率，有利于提升电力系统的负载能力和容灾能力。

权利要求

1.一种基于异步队列的计量信息交互平台，其特征在于，包括下层机构的至少一个计量周转柜管理系统、上层机构的计量包管理系统、用于连接所述下层机构和所述上层机构的计量服务总线；所述计量周转柜管理系统通过所述计量服务总线与所述计量包管理系统通信连接；

所述计量周转柜管理系统，用于在当前网络处于在线状态时，通过所述计量服务总线在异步队列中写入第一计量表管理消息；

所述在当前网络处于在线状态时，通过所述计量服务总线在异步队列中写入第一计量表管理消息，具体为：当获取到预设数量的所述第一计量表管理消息时，分别为每一所述第一计量表管理消息设置优先级，按照优先级从高到低的顺序，通过所述计量服务总线在所述异步队列中依序写入所有所述第一计量表管理消息；

所述计量包管理系统，用于通过所述计量服务总线在所述异步队列中读取所述第一计量表管理消息；

所述计量包管理系统，还用于在当前网络处于在线状态时，通过所述计量服务总线在所述异步队列中写入计量包管理消息；

所述计量周转柜管理系统，还用于通过所述计量服务总线在所述异步队列中读取所述计量包管理消息；

所述计量周转柜管理系统，还用于在当前网络处于离线状态时，根据用户输入的计量表领取指令，向所述用户派发计量表，并在当前网络恢复在线状态时，根据所述用户补发的计量表使用信息，生成第二计量表管理消息，以通过所述计量服务总线在所述异步队列中写入所述第二计量表管理消息。

2.如权利要求1所述的基于异步队列的计量信息交互平台，其特征在于，还包括所述下层机构的智能仓储控制系统；所述智能仓储控制系统通过所述计量服务总线与所述计量包管理系统通信连接；

所述智能仓储控制系统，用于在当前网络处于在线状态时，通过所述计量服务总线在所述异步队列中写入仓储管理消息；

所述计量包管理系统，用于通过所述计量服务总线在所述异步队列中读取所述仓储管理消息；

所述智能仓储控制系统，还用于通过所述计量服务总线在所述异步队列中读取所述计量包管理消息。

3.如权利要求1所述的基于异步队列的计量信息交互平台，其特征在于，还包括所述上层机构的营销管理系统；所述营销管理系统通过所述计量服务总线与所述计量周转柜管理系统通信连接；

所述营销管理系统，用于在当前网络处于在线状态时，通过所述计量服务总线在所述异步队列中写入营销管理消息；

所述计量周转柜管理系统，用于通过所述计量服务总线在所述异步队列中读取所述营销管理消息；

所述营销管理系统，还用于通过所述计量服务总线在所述异步队列中读取所述第一计量表管理消息。

4.如权利要求3所述的基于异步队列的计量信息交互平台，其特征在于，还包括所述上层机构的计量生产管理系统；所述计量生产管理系统与所述营销管理系统通信连接。

5.如权利要求1所述的基于异步队列的计量信息交互平台，其特征在于，所述在当前网络处于在线状态时，通过所述计量服务总线在异步队列中写入第一计量表管理消息，具体为：在当前网络处于在线状态时，判断当前网络是否出现堵塞，若是，则缓存所述第一计量表管理消息，以待网络恢复畅通时，通过所述计量服务总线在所述异步队列中写入所述第一计量表管理消息。

6.一种基于异步队列的计量信息交互方法，其特征在于，适用于一种基于异步队列的计量信息交互平台，所述基于异步队列的计量信息交互平台包括下层机构的至少一个计量周转柜管理系统、上层机构的计量包管理系统、用于连接所述下层机构和所述上层机构的计量服务总线；所述计量周转柜管理系统通过所述计量服务总线与所述计量包管理系统通信连接；

所述基于异步队列的计量信息交互方法，包括：

通过所述计量周转柜管理系统，在当前网络处于在线状态时，通过所述计量服务总线在异步队列中写入第一计量表管理消息；

所述在当前网络处于在线状态时，通过所述计量服务总线在异步队列中写入第一计量表管理消息，具体为：当获取到预设数量的所述第一计量表管理消息时，分别为每一所述第一计量表管理消息设置优先级，按照优先级从高到低的顺序，通过所述计量服务总线在所述异步队列中依序写入所有所述第一计量表管理消息；

通过所述计量包管理系统，通过所述计量服务总线在所述异步队列中读取所述第一计量表管理消息；

通过所述计量包管理系统，在当前网络处于在线状态时，通过所述计量服务总线在所述异步队列中写入计量包管理消息；

通过所述计量周转柜管理系统，通过所述计量服务总线在所述异步队列中读取所述计量包管理消息；

通过所述计量周转柜管理系统，在当前网络处于离线状态时，根据用户输入的计量表领取指令，向所述用户派发计量表，并在当前网络恢复在线状态时，根据所述用户补发的计量表使用信息，生成第二计量表管理消息，以通过所述计量服务总线在所述异步队列中写入所述第二计量表管理消息。

7.如权利要求6所述的基于异步队列的计量信息交互方法，其特征在于，所述基于异步队列的计量信息交互平台还包括所述下层机构的智能仓储控制系统；所述智能仓储控制系统通过所述计量服务总线与所述计量包管理系统通信连接；

所述基于异步队列的计量信息交互方法，还包括：

通过所述智能仓储控制系统，在当前网络处于在线状态时，通过所述计量服务总线在所述异步队列中写入仓储管理消息；

通过所述计量包管理系统，通过所述计量服务总线在所述异步队列中读取所述仓储管理消息；

通过所述智能仓储控制系统，通过所述计量服务总线在所述异步队列中读取所述计量包管理消息。

8.如权利要求6所述的基于异步队列的计量信息交互方法，其特征在于，所述基于异步队列的计量信息交互平台还包括所述上层机构的营销管理系统；所述营销管理系统通过所述计量服务总线与所述计量周转柜管理系统通信连接；

所述基于异步队列的计量信息交互方法，还包括：

通过所述营销管理系统，在当前网络处于在线状态时，通过所述计量服务总线在所述异步队列中写入营销管理消息；

通过所述计量周转柜管理系统，通过所述计量服务总线在所述异步队列中读取所述营销管理消息；

通过所述营销管理系统，通过所述计量服务总线在所述异步队列中读取所述第一计量表管理消息。

说明书

一种基于异步队列的计量信息交互平台及方法

技术领域

[0001] 本发明涉及电力系统技术领域，尤其涉及一种基于异步队列的计量信息交互平台及方法。

背景技术

[0002] 目前，国内供电企业的基层供电所库房数量多、分布散、库存量不大，主要由资产管理人员将零散备用的计量表存放在库房中。当应急抢修时，配电抢修人员需要向资产管理人员申请领取计量表，严重影响了应急抢修效率。

[0003] 为提升供电企业对单相电能表、三项电能表、电能互感器等多种计量表的储备管理水平，供电企业逐步应用计量周转柜对计量表使用业务进行集中管理。但计量周转柜与计量包管理系统间的网络容易出现接口调用超时、数据传输失败的问题，这在一定程度上仍限制了应急抢修效率，难以提高整个电力系统的负载能力和容灾能力。

发明内容

[0004] 为了克服现有技术的缺陷，本发明提供一种基于异步队列的计量信息交互平台及方法，能够保证计量周转柜的信息交互，提高应急抢修效率，有利于提升整个电力系统的负载能力和容灾能力。

[0005] 为了解决上述技术问题，第一方面，本发明一实施例提供一种基于异步队列的计量信息交互平台，包括下层机构的至少一个计量周转柜管理系统、上层机构的计量包管理系统、用于连接所述下层机构和所述上层机构的计量服务总线；所述计量周转柜管理系统通过所述计量服务总线与所述计量包管理系统通信连接；

[0006] 所述计量周转柜管理系统，用于在当前网络处于在线状态时，通过所述计量服务总线在异步队列中写入第一计量表管理消息；

[0007] 所述计量包管理系统，用于通过所述计量服务总线在所述异步队列中读取所述第一计量表管理消息；

[0008] 所述计量包管理系统，还用于在当前网络处于在线状态时，通过所述计量服务总线在所述异步队列中写入计量包管理消息；

[0009] 所述计量周转柜管理系统，还用于通过所述计量服务总线在所述异步队列中读取所述计量包管理消息。

[0010] 进一步地，所述基于异步队列的计量信息交互平台，还包括所述下层机构的智能仓储控制系统；所述智能仓储控制系统通过所述计量服务总线与所述计量包管理系统通信连接；

[0011] 所述智能仓储控制系统，用于在当前网络处于在线状态时，通过所述计量服务总线在所述异步队列中写入仓储管理消息；

[0012] 所述计量包管理系统，用于通过所述计量服务总线在所述异步队列中读取所述仓储管理消息；

[0013] 所述智能仓储控制系统，还用于通过所述计量服务总线在所述异步队列中读取所述计量包管理消息。

[0014] 进一步地，所述基于异步队列的计量信息交互平台，还包括所述上层机构的营销管理系统；所述营销管理系统通过所述计量服务总线与所述计量周转柜管理系统通信连接；

[0015] 所述营销管理系统，用于在当前网络处于在线状态时，通过所述计量服务总线在所述异步队列中写入营销管理消息；

[0016] 所述计量周转柜管理系统，用于通过所述计量服务总线在所述异步队列中读取所述营销管理消息；

[0017] 所述营销管理系统，还用于通过所述计量服务总线在所述异步队列中读取所述第一计量表管理消息。

[0018] 进一步地，所述基于异步队列的计量信息交互平台，还包括所述上层机构的计量生产管理系统；所述计量生产管理系统与所述营销管理系统通信连接。

[0019] 进一步地，所述计量周转柜管理系统，还用于在当前网络处于离线状态时，根据用户输入的计量表领取指令，向所述用户派发计量表，并在当前网络恢复在线状态时，根据所述用户补发的计量表使用信息，生成第二计量表管理消息，以通过所述计量服务总线在所述异步队列中写入所述第二计量表管理消息。

[0020] 进一步地，所述在当前网络处于在线状态时，通过所述计量服务总线在异步队列中写入第一计量表管理消息，具体为：

[0021] 在当前网络处于在线状态时，判断当前网络是否出现堵塞，若是，则缓存所述第一计量表管理消息，以待网络恢复畅通时，通过所述计量服务总线在所述异步队列中写入所述第一计量表管理消息。

[0022] 进一步地，所述在当前网络处于在线状态时，通过所述计量服务总线在异步队列中写入第一计量表管理消息，具体为：

[0023] 当获取到预设数量的所述第一计量表管理消息时，分别为每一所述第一计量表管理消息设置优先级，按照优先级从高到低的顺序，通过所述计量服务总线在所述异步队列中依序写入所有所述第一计量表管理消息。

[0024] 第二方面，本发明一实施例提供一种基于异步队列的计量信息交互方法，适用于一种基于异步队列的计量信息交互平台，所述基于异步队列的计量信息交互平台包括下层机构的至少一个计量周转柜管理系统、上层机构的计量包管理系统、用于连接所述下层机构和所述上层机构的计量服务总线；所述计量周转柜管理系统通过所述计量服务总线与所述计量包管理系统通信连接；

[0025] 所述基于异步队列的计量信息交互方法，包括：

[0026] 通过所述计量周转柜管理系统，在当前网络处于在线状态时，通过所述计量服务总线在异步队列中写入第一计量表管理消息；

[0027] 通过所述计量包管理系统，通过所述计量服务总线在所述异步队列中读取所述第一计量表管理消息；

[0028] 通过所述计量包管理系统，在当前网络处于在线状态时，通过所述计量服务总线在所述异步队列中写入计量包管理消息；

[0029] 通过所述计量周转柜管理系统，通过所述计量服务总线在所述异步队列中读取所述计量包管理消息。

[0030] 进一步地，所述基于异步队列的计量信息交互平台还包括所述下层机构的智能仓储控制系统；所述智能仓储控制系统通过所述计量服务总线与所述计量包管理系统通信连接；

[0031] 所述基于异步队列的计量信息交互方法，还包括：

[0032] 通过所述智能仓储控制系统，在当前网络处于在线状态时，通过所述计量服务总线在所述异步队列中写入仓储管理消息；

[0033] 通过所述计量包管理系统，通过所述计量服务总线在所述异步队列中读取所述仓储管理消息；

[0034] 通过所述智能仓储控制系统，通过所述计量服务总线在所述异步队列中读取所述计量包管理消息。

[0035] 进一步地，所述基于异步队列的计量信息交互平台还包括所述上层机构的营销管理系统；所述营销管理系统通过所述计量服务总线与所述计量周转柜管理系统通信连接；

[0036] 所述基于异步队列的计量信息交互方法，还包括：

[0037] 通过所述营销管理系统，在当前网络处于在线状态时，通过所述计量服务总线在所述异步队列中写入营销管理消息；

[0038] 通过所述计量周转柜管理系统，通过所述计量服务总线在所述异步队列中读取所述营销管理消息；

[0039] 通过所述营销管理系统，通过所述计量服务总线在所述异步队列中读取所述第一计量表管理消息。

[0040] 本发明的实施例，具有如下有益效果：

[0041] 通过设计基于异步队列的计量信息交互平台，将下层机构的计量周转柜管理系统通过计量服务总线与上层机构的计量包管理系统通信连接，利用计量周转柜管理系统在当前网络处于在线状态时，通过计量服务总线在异步队列中写入第一计量表管理消息，利用计量包管理系统通过计量服务总线在异步队列中读取第一计量表管理消息，利用计量包管理系统在当前网络处于在线状态时，通过计量服务总线在异步队列中写入计量包管理消息，利用计量周转柜管理系统通过计量服务总线在异步队列中读取计量包管理消息，实现计量周转柜管理系统与计量包管理系统之间的信息交互。相比于现有技术，本发明的实施例通过在计量信息交互平台中应用异步队列技术，将若干个计量周转柜管理系统产生的第一计量表管理消息和计量包管理系统产生的计量包管理消息存储于异步队列中进行多系统间信息交互，得益于异步队列技术的高响应速率，极大地缩短了计量周转柜管理系统的信息交互时间，且在网络处于离线状态时也可接收计量包管理消息，从而能够保证计量周转柜的信息交互，提高应急抢修效率，有利于提升整个电力系统的负载能力和容灾能力。

附图说明

[0042] 图1为本发明第一实施例中的一种基于异步队列的计量信息交互平台的结构示意图；

[0043] 图2为本发明第一实施例中示例的一种基于异步队列的计量信息交互平台的结构示意图；

[0044] 图3为本发明第二实施例中的一种基于异步队列的计量信息交互方法的流程示意图。

具体实施方式

[0045] 下面将结合本发明中的附图，对本发明中的技术方案进行清楚、完整地描述，显然，所描述的实施例仅仅是本发明一部分实施例，而不是全部的实施例。基于本发明中的实施例，本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例，都属于本发明保护的范围。

[0046] 需要说明的是，文中的步骤编号，仅为了方便具体实施例的解释，不作为限定步骤执行先后顺序的作用。本实施例提供的方法可以由相关的终端设备执行，且下文均以服务器作为执行主体为例进行说明。

[0047] 如图1所示，第一实施例提供一种基于异步队列的计量信息交互平台，包括下层机构1的至少一个计量周转柜管理系统11、上层机构2的计量包管理系统21、用于连接下层机构1和上层机构2的计量服务总线3；计量周转柜管理系统11通过计量服务总线3与计量包管理系统21通信连接；计量周转柜管理系统11，用于在当前网络处于在线状态时，通过计量服务总线3在异步队列中写入第一计量表管理消息；计量包管理系统21，用于通过计量服务总线3在异步队列中读取第一计量表管理消息；计量包管理系统21，还用于在当前网络处于在线状态时，通过计量服务总线3在异步队列中写入计量包管理消息；计量周转柜管理系统11，还用于通过计量服务总线3在异步队列中读取计量包管理消息。

[0048] 作为示例性地，选择供电所作为下层机构1，在各个供电所中配置若干个计量周转柜管理系统11，以实现供电所作业流程信息化、智能化管理，每一计量周转柜管理系统11可通过串口与至少一个微控制单元（Microcontroller Unit，MCU）连接；选择省级中心作为上层机构2，在省级中心中配置计量包管理系统21（Warehouse Manage System，WMS），分别将供电所的每一计量周转柜管理系统11通过计量服务总线3与计量包管理系统21通信连接，设计如图2所示的基于异步队列的计量信息交互平台，以实现计量周转柜管理系统11与计量包管理系统21之间的信息交互。

[0049] 应用基于异步队列的计量信息交互平台，计量周转柜管理系统11在当前网络处于在线状态时，响应用户发起的计量表入库请求、计量表出库请求等计量表管理请求生成第一计量表管理消息，通过计量服务总线3在异步队列中写入第一计量表管理消息，使得计量包管理系统21可通过计量服务总线3在异步队列中读取第一计量表管理消息；计量包管理系统21在当前网络处于在线状态时，响应用户发起的计量表维修请求、计量表采购请求、计量表保养请求等计量包管理请求生成计量包管理消息，通过计量服务总线3在异步队列中写入计量包管理消息，使得计量周转柜管理系统11可通过计量服务总线3在异步队列中读取计量包管理消息。

[0050] 其中，第一计量表管理消息包括计量表领取数据、监控记录、门禁开启数据、门禁关闭数据等等；计量包管理消息包括计量设备抢修任务、计量设备采购任务、计量设备保养任务等等。

[0051] 可以理解的是，高速异步队列系统可以基于kafka、redis、zookeeper等第三方开源组件进行搭建，高速异步队列系统不进行消息的处理，只进行消息的存储，是异步的服务间通信方式，适用于分布式和微服务架构。消息在被处理和删除之前一直存储在队列上，可被用于分离重量级处理、缓冲或批处理工作以及缓解高峰期工作负载。高速异步队列系统通常包括消息生产者（Producer）、消息处理中心（Broker）、以及消息消费者（Consumer）。其中，消息生产者负责产生和发送消息到消息处理中心；消息处理中心负责消息存储、确认、重试等，一般其中会包含多个队列（queue）；消息消费者负责从消息处理中心获取消息，并进行相应处理。

[0052] 高速异步队列系统的响应时间快，相比于实时交互的方法，能够缩短计量周转柜管理系统11的等待时间，提升海量数据并发时的交互效率和存储效率，实现离线吞吐，大大减轻了主站服务器数据处理的压力，减少采购硬件资源所造成的消耗。

[0053] 高速异步队列系统可以按照元素被推入列表（List）中的顺序来存储元素，能满足“先进先出”的需求，这些元素既可以是文字数据，又可以是二进制数据。生产者将消息插入到队列的头部后，消费者再依次读取队列中的消息。

[0054] 由于采用了异步队列技术，计量周转柜管理系统11的生产与计量包管理系统21的消费不用同时进行，计量包管理系统21可以选择不同的调度策略，按照闲时、忙时、正常时间，对队列中的第一消息进行处理，起到了业务削峰填谷的作用，保证了计量包管理系统21性能的平稳性，避免了同一时间被频繁调用而导致服务器宕机的情况。

[0055] 本实施例通过在计量信息交互平台中应用异步队列技术，将若干个计量周转柜管理系统11产生的第一计量表管理消息和计量包管理系统21产生的计量包管理消息存储于异步队列中进行多系统间信息交互，得益于异步队列技术的高响应速率，极大地缩短了计量周转柜管理系统11的信息交互时间，且在网络处于离线状态时也可接收计量包管理消息，从而能够保证计量周转柜的信息交互，提高应急抢修效率，有利于提升整个电力系统的负载能力和容灾能力。

[0056] 在优选的实施例当中，所述基于异步队列的计量信息交互平台，还包括下层机构1的智能仓储控制系统12；智能仓储控制系统12通过计量服务总线3与计量包管理系统21通信连接；智能仓储控制系统12，用于在当前网络处于在线状态时，通过计量服务总线3在异步队列中写入仓储管理消息；计量包管理系统21，用于通过计量服务总线3在异步队列中读取仓储管理消息；智能仓储控制系统12，还用于通过计量服务总线3在异步队列中读取计量包管理消息。

[0057] 作为示例性地，如图2所示，选择地市局作为下级机构，在地市局中配置智能仓储控制系统12，智能仓储控制系统12（Warehouse Control System，WCS）是计量包实现信息化的基础，可以实现对各种智能存储设备的集成，对各设备进行统一调度、管理，协调完成仓库的出入库任务需求，并通过实时收集设备层反馈，做到对设备的实时监控及对任务执行状况的实时跟踪。

[0058] 应用基于异步队列的计量信息交互平台，智能仓储控制系统12在当前网络处于在线状态时，响应用户发起的计量表调度请求等仓储管理请求生成仓储管理消息，通过计量服务总线3在异步队列中写入仓储管理消息，使得计量包管理系统21可通过计量服务总线3在异步队列中读取仓储管理消息；计量包管理系统21在当前网络处于在线状态时，响应用户发起的计量表维修请求、计量表采购请求、计量表保养请求等计量包管理请求生成计量包管理消息，通过计量服务总线3在异步队列中写入计量包管理消息，使得智能仓储控制系统12可通过计量服务总线3在异步队列中读取计量包管理消息。

[0059] 本实施例通过在下层机构1中增设智能仓储控制系统12，可以实现与省级中心的计量包管理系统21无缝对接，并可以与各地市局计量包智能存储设备（射频门、扫码枪等）有效集成交互，使其成为全省计量资产全生命周期管控的有机整体，支撑地市局顺利完成计量包智能化改造。

[0060] 在优选的实施例当中，所述基于异步队列的计量信息交互平台，还包括上层机构2的营销管理系统22；营销管理系统22通过计量服务总线3与计量周转柜管理系统11通信连接；营销管理系统22，用于在当前网络处于在线状态时，通过计量服务总线3在异步队列中写入营销管理消息；计量周转柜管理系统11，用于通过计量服务总线3在异步队列中读取营销管理消息；营销管理系统22，还用于通过计量服务总线3在异步队列中读取第一计量表管理消息。

[0061] 作为示例性地，如图2所示，在省级中心中配置营销管理系统22，营销管理系统22可以实现供电企业的销售项目、客户信息、销售合同等经营信息的智能化管理。

[0062] 应用基于异步队列的计量信息交互平台，营销管理系统22在当前网络处于在线状态时，响应用户发起的项目管理请求等营销管理请求生成营销管理消息，通过计量服务总线3在异步队列中写入营销管理消息，使得计量周转柜管理系统11可通过计量服务总线3在异步队列中读取营销管理消息；计量周转柜管理系统11在当前网络处于在线状态时，响应用户发起的计量表入库请求、计量表出库请求等计量表管理请求生成第一计量表管理消息，通过计量服务总线3在异步队列中写入第一计量表管理消息，使得营销管理系统22可通过计量服务总线3在异步队列中读取第一计量表管理消息。

[0063] 本实施例通过在上层机构2中增设营销管理系统22，可以实现计量周转柜管理系统11与营销管理系统22的信息交互，保证计量周转柜管理系统11根据供电企业的营销管理需求进行计量表综合管理。

[0064] 在优选的实施例当中，所述基于异步队列的计量信息交互平台，还包括上层机构2的计量生产管理系统23；计量生产管理系统23与营销管理系统22通信连接。

[0065] 本实施例通过在上层机构2中增设计量生产管理系统23，使计量生产管理系统23直接与营销管理系统22进行信息交互，从而实现计量生产管理系统23对营销管理系统22的全局调控。

[0066] 在优选的实施例当中，计量周转柜管理系统11，还用于在当前网络处于离线状态时，根据用户输入的计量表领取指令，向用户派发计量表，并在当前网络恢复在线状态时，根据用户补发的计量表使用信息，生成第二计量表管理消息，以通过计量服务总线3在异步队列中写入第二计量表管理消息。

[0067] 可以理解的是，基于异步队列技术，对计量周转柜管理系统11新增计量周转柜离线取用计量表的功能，可以在应急抢修时使用户先领取计量表再上传计量表使用信息，完成数据的自动补单，有效提高了应急抢修效率，大大减少了供电所抢修用表不及时、工单超时导致客户投诉的风险。

[0068] 在优选的实施例当中，所述在当前网络处于在线状态时，通过计量服务总线3在异步队列中写入第一计量表管理消息，具体为：在当前网络处于在线状态时，判断当前网络是否出现堵塞，若是，则缓存第一计量表管理消息，以待网络恢复畅通时，通过计量服务总线3在异步队列中写入第一计量表管理消息。

[0069] 作为示例性地，计量周转柜管理系统11在当前网络处于在线状态时，根据当前网络的可用带宽或延时等网络质量参数与预设阈值的比较结果判断当前网络是否出现堵塞，若是，则先缓存第一计量表管理消息，持续监测网络质量直至网络恢复畅通时，再通过计量服务总线3在异步队列中写入第一计量表管理消息。

[0070] 在优选的实施例当中，所述在当前网络处于在线状态时，通过计量服务总线3在异步队列中写入第一计量表管理消息，具体为：当获取到预设数量的第一计量表管理消息时，分别为每一第一计量表管理消息设置优先级，按照优先级从高到低的顺序，通过计量服务总线3在异步队列中依序写入所有第一计量表管理消息。

[0071] 作为示例性地，生产者，即计量周转柜管理系统11为一批量的各个第一计量表管理消息设置优先级，按照优先级从高到低的顺序，通过计量服务总线3在异步队列中依序写入所有第一计量表管理消息。

[0072] 可以理解的是，计量周转柜管理系统11也可直接通过计量服务总线3在异步队列中依序写入所有第一计量表管理消息，消费者按优先级排序对所有第一计量表管理消息进行读取。

[0073] 相比于常规的计量信息交互系统，应用基于异步队列的计量信息交互平台，性能指标提升如下：

[0074] （1）实现了计量周转柜连续24小时长时域不停用，每日稳定运行时长比应用该技术前提升了50%；

[0075] （2）计量周转柜单次业务处理时间从3分钟降低至1分钟，处理时间降低了66%；

[0076] （3）计量包管理系统21、营销管理系统22下发任务至计量周转柜的成功率从73.52%提升至99%；

[0077] （4）计量周转柜系统上送消息的成功率从40.98%提升至99%；

[0078] （5）计量包取用数据的准确率从81.98%提升至99%；

[0079] （6）“离线预领计量设备”功能在上线后15个月，使用了195.5万次，服务了51万次现场领表工作，大大减少了基层班所抢修用表不及时、工单超时导致客户投诉的风险。

[0080] 本实施例提供的基于异步队列的计量信息交互平台，可以利用异步队列技术的分布式属性，实现计量服务总线3的集群部署与柔性扩展，增加电力系统连续正常运行时长，提高了整个电力系统的负载能力、容灾能力、以及信息交互的稳定性，也可以在大规模信息并发时扩展集群，解决可能因为并发量过大而导致的主站宕机问题。另外，工作人员能够稳定完成计量周转柜的业务，遇到网络波动时也可继续进行后续操作，当网络在线时，计量周转柜管理系统11可以正常获取工单、完成数据同步；当网络处于离线状态或业务高峰时，可将部分非紧急消息延后处理，优先完成现有工单运转、临时操作计量周转柜取出计量表，从而极大地提高了电力系统稳定性，保障电力系统稳定高效运转，有效解决管理中的网络波动、设备离线等问题，且显著提高地市局基层人员及系统运维人员的工作效率。

[0081] 基于与第一实施例相同的发明构思，第二实施例提供如图3所示的一种基于异步队列的计量信息交互方法，适用于一种基于异步队列的计量信息交互平台，所述基于异步队列的计量信息交互平台包括下层机构1的至少一个计量周转柜管理系统11、上层机构2的计量包管理系统21、用于连接下层机构1和上层机构2的计量服务总线3；计量周转柜管理系统11通过计量服务总线3与计量包管理系统21通信连接；所述基于异步队列的计量信息交互方法，包括步骤S1 S4：~

[0082] S1、通过计量周转柜管理系统11，在当前网络处于在线状态时，通过计量服务总线3在异步队列中写入第一计量表管理消息；

[0083] S2、通过计量包管理系统21，通过计量服务总线3在异步队列中读取第一计量表管理消息；

[0084] S3、通过计量包管理系统21，在当前网络处于在线状态时，通过计量服务总线3在异步队列中写入计量包管理消息；

[0085] S4、通过计量周转柜管理系统11，通过计量服务总线3在异步队列中读取计量包管理消息。

[0086] 在优选的实施例当中，所述基于异步队列的计量信息交互平台还包括下层机构1的智能仓储控制系统12；智能仓储控制系统12通过计量服务总线3与计量包管理系统21通信连接；所述基于异步队列的计量信息交互方法，还包括：

[0087] 通过智能仓储控制系统12，在当前网络处于在线状态时，通过计量服务总线3在异步队列中写入仓储管理消息；

[0088] 通过计量包管理系统21，通过计量服务总线3在异步队列中读取仓储管理消息；

[0089] 通过智能仓储控制系统12，通过计量服务总线3在异步队列中读取计量包管理消息。

[0090] 在优选的实施例当中，所述基于异步队列的计量信息交互平台还包括上层机构2的营销管理系统22；营销管理系统22通过计量服务总线3与计量周转柜管理系统11通信连接；所述基于异步队列的计量信息交互方法，还包括：

[0091] 通过营销管理系统22，在当前网络处于在线状态时，通过计量服务总线3在异步队列中写入营销管理消息；

[0092] 通过计量周转柜管理系统11，通过计量服务总线3在异步队列中读取营销管理消息；

[0093] 通过营销管理系统22，通过计量服务总线3在异步队列中读取第一计量表管理消息。

[0094] 在优选的实施例当中，所述基于异步队列的计量信息交互平台，还包括上层机构2的计量生产管理系统23；计量生产管理系统23与营销管理系统22通信连接。

[0095] 在优选的实施例当中，所述基于异步队列的计量信息交互方法，还包括：

[0096] 通过计量周转柜管理系统11，在当前网络处于离线状态时，根据用户输入的计量表领取指令，向用户派发计量表，并在当前网络恢复在线状态时，根据用户补发的计量表使用信息，生成第二计量表管理消息，以通过计量服务总线3在异步队列中写入第二计量表管理消息。

[0097] 在优选的实施例当中，所述在当前网络处于在线状态时，通过计量服务总线3在异步队列中写入第一计量表管理消息，具体为：在当前网络处于在线状态时，判断当前网络是否出现堵塞，若是，则缓存第一计量表管理消息，以待网络恢复畅通时，通过计量服务总线3在异步队列中写入第一计量表管理消息。

[0098] 在优选的实施例当中，所述在当前网络处于在线状态时，通过计量服务总线3在异步队列中写入第一计量表管理消息，具体为：当获取到预设数量的第一计量表管理消息时，分别为每一第一计量表管理消息设置优先级，按照优先级从高到低的顺序，通过计量服务总线3在异步队列中依序写入所有第一计量表管理消息。

[0099] 综上所述，实施本发明的实施例，具有如下有益效果：

[0100] 通过设计基于异步队列的计量信息交互平台，将下层机构1的计量周转柜管理系统11通过计量服务总线3与上层机构2的计量包管理系统21通信连接，利用计量周转柜管理系统11在当前网络处于在线状态时，通过计量服务总线3在异步队列中写入第一计量表管理消息，利用计量包管理系统21通过计量服务总线3在异步队列中读取第一计量表管理消息，利用计量包管理系统21在当前网络处于在线状态时，通过计量服务总线3在异步队列中写入计量包管理消息，利用计量周转柜管理系统11通过计量服务总线3在异步队列中读取计量包管理消息，实现计量周转柜管理系统11与计量包管理系统21之间的信息交互。本发明的实施例通过在计量信息交互平台中应用异步队列技术，将若干个计量周转柜管理系统11产生的第一计量表管理消息和计量包管理系统21产生的计量包管理消息存储于异步队列中进行多系统间信息交互，得益于异步队列技术的高响应速率，极大地缩短了计量周转柜管理系统11的信息交互时间，且在网络处于离线状态时也可接收计量包管理消息，从而能够保证计量周转柜的信息交互，提高应急抢修效率，有利于提升整个电力系统的负载能力和容灾能力。

[0101] 以上所述是本发明的优选实施方式，应当指出，对于本技术领域的普通技术人员来说，在不脱离本发明原理的前提下，还可以做出若干改进和润饰，这些改进和润饰也视为本发明的保护范围。

[0102] 本领域普通技术人员可以理解实现上述实施例中的全部或部分流程，是可以通过计算机程序来指令相关的硬件来完成，所述的程序可存储于一计算机可读取存储介质中，该程序在执行时，可包括如上述各实施例的流程。其中，所述的存储介质可为磁碟、光盘、只读存储记忆体（Read‑Only Memory，ROM）或随机存储记忆体（Random Access Memory，RAM）等。