手动清除RabbitMQ队列的消息缓存
手动清除rabbitmq的队列消息缓存
RabbitMQ多消费者实例时,保证只有一个消费者进行消费(单活消费者模式)
rabbitmq多实例单活消费者
查看rabbitmq日志,Rabbitmq Trace日志
rabbitmq中提供一个插件rabbitmq_tracing用于记录消息的日志,默认是未打开的,需要自己用命令打开。Pattern:用来设置匹配的模式,和Firehose的类似。recevied是到queue的时候,并不是推送到消费者的时间,如果消费慢,那么积压是必然的,可能会很久后才被处理,这个
【物联网】使用RabbitMQ作为MQTT服务端并自定义设备连接权限
物联网项目在使用RabbitMQ作为MQTT服务器时,使用的主题和权限控制策略,经过一段时间的实际使用,在此分享给有需求的小伙伴们。
什么是RabbitMQ?
RabbitMQ是一个由erlang开发的消息队列。消息队列用于应用间的异步协作。
RabbitMQ如何保证幂等性
幂等性是分布式中比较重要的一个概念,是指在多作业操作时候避免造成重复影响,其实就是保证同一个消息不被消费者重复消费两次,但是可能存在网络波动等问题,生产者无法接受消费者发送的ack信息,因此这条消息将会被重复发送给其他消费者进行消费,实际上这条消息已经被消费过了,这就是重复消费的问题。如何避免重复消
RabbitMQ手动ACK与死信队列
RabbitMQ手动ACK与死信队列
Rabbitmq - rabbitmq Listener监听
rabbitmq 监听配置以及listener参数讲解
Centos7安装RabbitMQ与使用(超详细)
第一步、安装任何软件包之前,建议使用以下命令更新软件包和存储库第二步、Erlang在默认的YUM存储库中不可用,因此您将需要安装EPEL存储库第三步、RabbitMQ是基于Erlang(面向高并发的语言)语言开发,所以在安装RabbitMQ之前,需要先安装Erlang语言第四步、检查Erlang版本
Rabbit health check failed
说明:项目并未配置rabbitmq,但是每次项目启动的时候总是会报错,rabbitmq连接异常,健康检查失败,但是不影响项目运行。具体报错信息如下:具体查看报错内容后发现:原来是项目配置了spring健康检查:解决:在配置文件中添加rabbitmq的健康检查忽略再次启动项目,报错没有了~~~
springboot实现rabbitmq动态创建交换机,队列以及交换机、队列绑定
springboot实现rabbitmq动态创建交换机,队列以及交换机、队列绑定。
使用StreamBridge实现RabbitMq 消息收发 && ack确认 && 延时消息
使用StreamBridge实现RabbitMq 消息收发 && ack确认 && 延时消息
RabbitMQ 能保证消息可靠性吗
前面我们在做MQ组件选型时,提到了rabbitMQ的消息可靠性,那么它到底可靠到什么程度?又是如何保证消息可靠性的呢?
RabbitMQ + SpringCloud使用及避坑(大章)
本来还想一篇解决完的,写到一半我就发现这玩意儿根本就一篇搞不定,这篇就是一些基础的知识了解,还有一些简单的使用MQ 的时候大概率遇到的一些坑,但是代码中应该怎么解决这些问题还没有说。而且现在也是简单的用amqp 来实现了几种rabbitMQ 的交换器调用,原生代码的调用方式、stream 中间件的调
RabbitMQ重复消费
造成RabbitMq重复消费的原因,以及如何解决RabbitMq的重复消费。
rabbitMQ登录报错user can only log in via localhost
rabbitMQ登录报错user can only log in via localhost
RabbitMQ安装教程(Windows版本)
RabbitMQ安装教程(Windows版本)
Docker中RabbitMQ的密码修改
Docker中RabbitMQ的密码修改
RabbitMQ常见的应用问题
如果消费者接收消息出现了异常,接收失败了,第三步发送延迟消息就起到了保证消息可靠性的重要环节,生产者会发生一个延迟消息到Q3队列中,回调系统也会从Q3队列中读取延迟消息,延迟消息和正常消息是一模一样的,回调检查系统会把延迟消息的ID与MQ数据库中的消息ID进行比对,如果存在数据那么久不会再做任何处理