摘要:如今，互联网已进入日常生活的各个方面，大数据影响到了生活的各个领域，如何找到一个性能好，延迟低，可靠性强的数据传输方式就显得至关重要。消息队列能够高效解决大规模系统中的信息传递问题，被很多的企业采用。
消息队列（Message Queue，简称MQ），是指在消息的传递过程中作为储存消息的容器。“消息”就是计算机进程间传输的信息。“队列”的作用在于提供路由以及确保消息的传输。若接收方未及时接收到新的消息，消息队列能够储存消息到成功传输为止。
本文将以ActiveMQ、Kafka、ZeroMQ这三种消息队列为例，介绍各自的功能及特点，并分别设计一段程序，测试128B、512B、1KB和10KB四个数据，发送接收50万次，每5万次记录一次执行时间，在多次条件相同的数据中取得均值。从吞吐量和消息延迟这两个指标入手，使用图表直观展示三种消息队列在传输数据时的优缺点。
综合对比发现，ZeroMQ适用于海量高实时性场景，在传输较小的数据时优势明显，在证券金融业及社交网络中应用广泛。ActiveMQ的传输受数据的影响较小，相比其他消息队列更为稳定，更适合传输较大的数据。ActiveMQ在跨平台跨语言的情况下优势明显，在电子商务中被较多使用。Kafka接收数据时吞吐量较大，更适合接收、收集数据，在日志收集、用户活动跟踪，以及消息推送等场景中有广泛应用。
关键词 消息队列；Kafka；ActiveMQ；ZeroMQ
目录
摘要
Abstract
1绪论-1
1.1 课题研究背景和意义-1
1.2 消息队列国外研究现状-1
1.3 消息队列国内研究现状-2
1.4 论文主要工作-2
1.5 论文结构与安排-2
2相关消息队列介绍-3
2.1 ZeroMQ-3
2.1.1 概述-3
2.1.2 特点-3
2.2 ActiveMQ-4
2.2.1 概述-4
2.2.2 特点-5
2.3 Kafka-5
2.3.1 概述-5
2.3.2 特点-6
3 测试设计与程序实现-7
3.1 测试设计-7
3.1.1 测试流程-7
3.1.2 测试数据-7
3.2 ZeroMQ-7
3.2.1 Pub发送端-7
3.2.2 Sub接收端-8
3.3 ActiveMQ-8
3.3.1 Sender发送端-8
3.3.2 Receiver接收端-8
3.4 Kafka-9
3.4.1 producer发送端-9
3.4.2 consumer接收端-9
4 数据分析-10
4.1 ZeroMQ数据分析-10
4.2 ActiveMQ数据分析-13
4.3 Kafka数据分析-15
4.4 性能对比-18
4.5 应用实例-19
5 应用场景-20
5.1 消息队列应用场景-20
5.1.1 异步处理-20
5.1.2 应用解耦-20
5.1.3 流量削峰-20
5.1.4 日志处理-20
5.2 ZeroMQ应用场景-21
5.2.1 数据流传输-21
5.2.2 服务器负载均衡-21
5.2.3 股票证券业-21
5.3 ActiveMQ应用场景-21
5.3.1 多客户端应用集成-21
5.3.2 替代RPC-21
5.3.3 异步流程-21
5.4 Kafka应用场景-22
5.4.1 日志收集-22
5.4.2 用户活动跟踪-22
5.5 企业实例-22
5.5.1 京东-22
5.5.2 阿里巴巴-22
5.6 综合对比-23
结论-25
致谢-26
参考文献-27
附录-28
附录1 完整程序-28
附录2 数据-35
