消息队列:AMQP高级消息队列协议。MQ和JMS类似,但不同的是JMS是SUN JAVA消息中间件服务的一个标准和API定义,而MQ则是遵循了AMQP协议的具体实现和产品。
目前,Spring唯一实现了RabbitMQ,但并不是说不支持其他的。
大数据方面,一般使用Kafka。
Producer:
创建连接,是指连接到路由吗?连接后,创建通道,是否专属的意思?是否可以多条通道?
通道后声明创建队列,将消息发送至队列,等待消费者。(ready,unacked,total)
关闭资源(通道,连接)。
Consumer:
获取连接;获取通道;声明队列;定义队列的消费者;监听队列;获取消息。
简单队列 :1P 1C。
WORK队列:1P NC。又有平均分配和能者多劳两种模式,平均分配的时候是自动反馈完成状态,能者多劳时则需要手动返回完成状态。
能者多劳模式还需要设置发送消息数量为1, channel.basicQos(1); channel.basicConsume(QUEUE_NAME,false,consumer);
订阅队列 :1P X(EXCHANGE) NC。【】需要声明交换机(注意交换机类型)。
项目中,修改商品时,发送消息至rabbitmq,前台系统删除缓存,更新索引。
【】注意启动顺序,由于生产者声明交换机,所以必须先启动生产者,再启动消费者。
三种交换机:
FANOUT EXCHANGE(无绑定路由键处理,分发消息至所有队列,类似广播);
DIRECT EXCHANGE(消费者需要将一个队列绑定到交换机上,然后交换机会将路由键完全匹配的消息发送至该队列【发送消息时声明路由键,接收时也要声明路由键,一致才行】);完整匹配。
TOPIC EXCHANGE(匹配交换机:将路由键和某模式进行匹配,#匹配一个或多个词,*匹配一个词。所以item.#可以匹配item.update.web,item.*只能匹配item.update)
注意:有内存队列和持久化队列,内存交换机和持久化交换机。可以通过spring配置文件中的durable参数设置。区别就是速度效率和安全方面。
Spring整合RabbitMQ需要使用spring-amqp(包含spring-amqp和spring-rabbitmq)。
队列和交换机的绑定方式:代码、配置文件、管理界面。