赞
踩
查看整个RabbitMQ的信息,包括Ready:待消费的消息总数。Unacked:待应答的消息总数。Total:总数 Ready+Unacked,所有队列的消费情况以及节点信息。
可以看到一共创建了两个ConnectionFactory,同一个项目只用一个ConnectionFactory,
ConnectionFactory为Connection的制造工厂。
Connection是与RabbitMQ服务器的socket链接,它封装了socket协议及身份验证相关部分逻辑。
点击进入某个Name,可以看到这个Connection下有多个Channels,每个Channels对应一个监听的消费者。
channel是代表消费者监听的管道,每一个消费者都有一个特定的channel来接收消息。
转发器Exchanges一共有Direct、Topic、Headers和Fanout四种类型。
该模式下不需要通过绑定关键字来区分消息分配的Queue,添加了也不会生效。广播模式下消息都会分发到绑定这个交换机(Exchange)下的所有队列(Queue)中,也就是没有消费之前,绑定该交换机的队列里面的数据都是一样的。
Queue(队列)是RabbitMQ的内部对象,用于存储消息,用下图表示。
也可以多个
值得注意的是:队列是有Channel声明的,而且这个操作是幂等的。同名的队列多次声明也只会创建一次。
所以有时候如果修改队列的属性,需要删除该队列之后再新建。
在Web管理界面,新建Queue中,发现可以给queue添加一些参数
对该队列的信息设置有效期,例如30s,在有效期内没有被消费,1.舍弃,2.转发到死信队列
转个思路,也就是可以实现延时功能,例如PDD中,半个小时内支付,如果不支付,则取消订单。
将未支付订单写入一个设置了有效期和死信路由器的队列中,超时之后消息会从原队列转发到死信队列,再监听死信队列进行业务处理,则可以起到延时的效果。不用定期轮训数据库,减轻数据库压力。
这个Tab就是查看和管理用户。
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。