论文部分内容阅读
随着智慧城市的到来,智慧水务也成为了一个很重要的命题。而对于自来水供水企业,如何高效便捷的管理供水、智能收费也就成为了当前水务信息化建设的重要组成部分,在此需求下,智能水表系统作为一种高效的解决方案应运而生。智能水表系统在设计上就被拆分成Web管理模块、数据采集模块、数据存储服务、数据传输服务,模块之间均是相互独立,互不影响,该设计能大幅降低系统内部的内部耦合。现有的数据传输服务方案是建立在数据共享的方式上,由于Web管理模块与数据采集模块之间的消息命令传输存在一些特异性,此方案并不能有效地解决以下问题:1)数据传输的高效性、可靠性,并且数据可以被实时处理或离线处理。2)数据库的读写压力大,会影响其它数据的存储和其他功能的运转。为解决上述问题,本文开展的主要研究工作如下:1)通过分析、测试对比主流的消息队列,最终确定Kafka消息系统作为智能水表系统内部数据通信服务的解决方案。2)结合智能水表系统设计基于Kafka消息系统的生产者、消费者实现方案,数据传输格式方案,消息分类处理的方案。3)在智能水表系统中应用Kafka消息系统后,本文针对Kafka生产者、消费者的性能进行相关参数的压力测试。本文最终应用Kafka消息系统于智能水表系统中,提高了整个系统内部数据传输以及处理的效率,实现了模块间的独立并行性,同时也保证了整个系统数据信息的实时性,增强整个系统的可靠性和容错性,取得较好的效果。