一 关于消息驱动
消息驱动Bean
消息代理中间件
二 消息代理程序结构
三 使用Stream后的程序结构
四 常用消息代理中间件
RabbitMQ:使用的是AMQP协议(高级消息队列协议)。
Kafka:核心原理,使用Topic,通过健值对保存数据。
五 AMQP模型
1 模型
2 说明
生产者会将消息投递给“消息代理(RabbitMQ服务器)”,它们之间会建立通道(Channel),消息由交换器(Exchange)先进行处理,交换器会选择把消息交给哪一个队列(Message Queue),最后消息队列会将消息发给消费者。