随着国家电网公司“互联网+”电力运营模式的提出，电力营销业务的数据规模越来越大，由于早期设计的局限性，现有用电信息采集系统扩展能力有限，已逐渐难以适应业务快速增长对系统性能提出的要求。另一方面，用电信息采集系统作为整个营销业务中最重要的数据支撑和数据来源，必然对海量用电数据并发的处理能力提出了新的需求。
　　本文采用一种结合传统用电信息采集系统研发技术和消息队列技术重构用电信息采集系统的设计方案。首先，针对用电信息采集业务特征，研究常见消息队列，根据Apache Kafka高吞吐量和支持大规模数据分析处理的功能特性，选取ApacheKafka分布式消息队列作为系统设计组件。其次，结合Apache Kafka对用电信息采集系统相关模块进行重构设计，在深入研究Apache Kafka工作原理、体系结构和消息数据结构的基础上，在用电数据上报流程中设计了消息生产服务，消息处理服务等消息队列相关功能模块，改善现有用电信息采集系统在应对海量数据并发请求方面的性能瓶颈，以满足电信息采集及营销等其他业务的业务量大规模增长对系统单位时间吞吐能力提出的需求。最后，测试了用电信息采集系统在结合Apache Kafka后的系统性能，并给出了主系统站的功能面板及下属功能模块的系统实现，为今后大规模用户用电数据的分析挖掘等服务提供强有力的技术支持。