publisher-confirms ,实现一个监听器用于监听 broker 端给我们返回的确认请求: Rabb...[作者空间]
MessageConverter 即消息转换器 我们在进行发送消息的时候,正常情况下消息体为二进制的数据方式进行传...[作者空间]
MessageListenerAdapter 即消息监听适配器 这一节,我们先写一下代码,再总结 MessageL...[作者空间]
SimpleMessageListenerContainer 即简单消息监听容器。 这个类非常的强大,我们可以对他...[作者空间]
RabbitTemplate 即消息模板 它是在之前于 SpringAMQP 整合的时候进行发送消息的关键类。 它...[作者空间]
RabbitAdmin 类可以很好的操作 rabbitMQ,在 Spring 中直接进行注入即可。 RabbitA...[作者空间]
死信队列: DLX,dead-letter-exchange 利用 dlx,当消息在一个队列中变成死信 (dead...[作者空间]
消费端的手工 ACK 和 NACK 消费端进行消费的时候,如果由于业务异常导致失败了,返回 NACK 达到最大重试...[作者空间]
假设一个场景,由于我们的消费端突然全部不可用了,导致 rabbitMQ 服务器上有上万条未处理的消息,这时候如果没...[作者空间]
之前的文章里面,我都是在消费端的代码里面编写 while 循环,进行 consumer.nextDelivery ...[作者空间]
1.confirm 消息确认机制 消息的确认是指生产者投递消息后,如果 Broker 接收到消息,则会给生产者一个...[作者空间]
一、什么是幂等性 可以参考数据库乐观锁机制,比如执行一条更新库存的 SQL 语句,在并发场景,为了性能和数据可靠性...[作者空间]
一. 生产端的可靠性投递 在实际生产中,很难保障前三点的完全可靠,比如在极端的环境中,生产者发送消息失败了,发送...[作者空间]
交换机属性 交换机属性: 1.direct exchange类型 注意:direct模式可以使用 rabbitMQ...[作者空间]
流程: 首先是获取连接工厂 ConnectionFactory --> 获取一个连接 Connection -->...[作者空间]
服务端后台方式启动: 查看端口占用情况,确认启动成功: 查看所有队列: 查看所有虚拟主机: 如上图所示,rabbi...[作者空间]
1.安装一些必要的命令环境,在 centos 执行下面的命令 2.下载 RabbitMQlsof、erlang、s...[作者空间]
本次主要对比:ActiveMQ、kafka、RocketMQ、RabbitMQ 衡量消息中间件的指标:服务性能,数...[作者空间]
首先来看看一线大厂的 架构图 如上图所示,中间是我们的 MQ 集群架构, 在上层利用 keepalived 和 H...[作者空间]
延迟插件的作用: 比如消息的延迟推送、定时任务(消息)的执行。包括一些消息重试策略的配合使用,以及用于业务削峰...[作者空间]