中间件

Apache Kafka是一个开源的分布式事件流处理平台，主要用于高性能数据管道、流式分析、数据集成和关键任务应用。

本书作者：测试开发刚哥，文章版权归个人所有，未经授权请勿转载。 消息队列 RabbitMQ是一个消息队列，它能够接收和转发消息。这个过程就像寄快递一样，把物件打包给快递小哥，快递小哥会负责把物件派送到正确的地址。 生产者和消费者 生产者就是用来生产消息（发送消息）的： 消费者就是用来消费消息（接收消息）的： 在生产者和消费者之间的就是消息队列： 它相当于消息缓冲区，最多能存储多少数据只受限于机器的内存和磁盘。多个生产者可以发送消息给同一个队列，多个消费者也可以从同一个队列接收消息。 Windows安装RabbitMQ 参考mall商城学习教程的RabbitMQ部分内容： http://www.macrozheng.com/#/architect/mall_arch_09?id=rabbitmq 原文中rabbitmq-server-3.7.14.exe下载地址失效了，改从这里下载： https://github.com/rabbitmq/rabbitmq-server/releases/tag/v3.7.14 安装完成后，确认服务已开启： 进入RabbitMQ安装目录下的sbin目录： 在地址栏输入cmd并回车启动命令行，然后输入以下命令启动管理功能： rabbitmq-plugins enable rabbitmq_management RabbitMQ运行在本地机器上： http://localhost:15672/ 默认用户名密码为guest / guest： Java客户端 amqp-client-5.7.1.jar是RabbitMQ官方提供的Java客户端： https://www.rabbitmq.com/tutorials/tutorial-one-java.html 既可以直接下载jar包，也可以在Maven中添加依赖： <dependency> <groupId>com.rabbitmq</groupId> <artifactId>amqp-client</artifactId> <version>5.14.2</version> </dependency> 生产消息 导包： import com.rabbitmq.client.ConnectionFactory; import com.rabbitmq.client.Connection; import com.rabbitmq.client.Channel; 创建类Send，定义队列名为hello： public class Send { private final static String QUEUE_NAME = "hello"; public static void main(String[] argv) throws Exception { ... } } 建立连接： ...