RabbitMQ

软件主页
关注
RabbitMQ 是由 LShift 提供的一个 Advanced Message Queuing Protocol (AMQP) 的开源实现,由以高性能、健壮以及可伸缩性出名的 Erlang 写成,因此也是继承了这些优点。...
加载中
5
回答
rabbitmq延迟队列时间两天,并且有几十万条数据,这样的还适合用延迟队列来做吗
smallcatooo 的回答 10/20 14:55
最佳答案
最终我们解决的方式是:先入库,然后每5分钟查询过期两天的数据(这里为了确保数据不遗漏,是用时间段来控制,每一次执行完,把结束时间记录下来,就是下次的开始时间),并把数据推送到mq中,然后消费者消费数据。并另起一个任务,每小时监测一次数据处理情况。
1
回答
rabbitmq 事务消息是否支持?

想请教一下rabbitmq是否支持分布式事务消息? rocketmq4.3开始支持分布式事务消息. 如果rabbitmq不支持事务消息,一般采取什么机制?

2018/11/02 14:32
4
回答
spring boot 运行中动态切换rabbitmq连接
polly 的回答 07/27 13:53
最佳答案
springboot自动装配mq的方式是池化的,无法修改,如果需要动态连接,你考虑下是否可以每次直接连接。 public static Connection getConnection() { try { Connection connection = null; //定义一个连接工厂 Con...
2
回答
rabbitmq持久化后,重启服务队列内容丢失

队列已经持久化了,也有内容了。 重启服务后,队列名称在,但是内容没了。 望指教!

2018/10/12 12:08
6
回答
RabbitMQ怎么实现类似ActiveMQ topic模式 (websoket 集群实现场景)不知道怎么实现 ,求大佬指导
进入休眠期 的回答 07/02 09:47
最佳答案
ActiveMQ用的不多,只记得有订阅和队列模式,而RabbitMQ多了一个Exchange(交换机)的概念,消息入MQ以后都是通过Exchange分发的,Exchange与Queue通过Bindding绑定(设置Binding Key),Exchange又分为3个类型(Direct,Topi...
4
回答
RabbitMQ 中的生产者指定的CorrelationData,在消费者怎么拿到?

rabbitTemplate.convertAndSend(exchange, routingKey, message, correlationData)...

2018/05/16 09:33
4
回答
springboot在写单元测试的时候怎才能不创建真实的连接mock rabbitMQ

自己的项目在单元测试很多的情况下跑覆盖率时在MAC机器上100%会出现oom,以为创建的线程数超出了系统限制。怎么才能够降低创建的线程数量?我看单元测试日...

04/02 11:33
2
回答
spring boot 之前集成了rabbitMq, 使用的是默认配置. 现需要新增一个mq. 如何在不更改之前的mq逻辑下, 把新的MQ集成上呢?

配置了 第二个MQ 以后, 之前代码里面的 第一个MQ 好像也被连到这个来了, 请问这个怎么处理呢?

05/21 17:06
1
回答
rabbitmq客户端一直报socket closed。

用spring 框架集成rabbitmq,作为消费者,服务启动时,一直报错,以前也是这么配置的没有问题。大家有遇到过吗? 2018-12-03 14:30...

2018/12/07 14:11
4
回答
请问rabbitmq为什么比kafka可靠啊

kafka我记得也有ack确认机制啊

04/09 10:09
2
回答
RabbitMq 如何保证一个进程内,多条消息的一致性?

我有一个应用场景 进程: 1.商品上架 i-- 商品上架成功 ii-- 发送 更新库存消息 iii-- 发送 发送提示有...

03/19 16:58
8
回答
RabbitMQ 延时队列的问题
OLESHI 的回答 2018/05/23 15:16
最佳答案
这是正常现象
3
回答
rabbitmq spring boot 动态根据配置文件创建消费者监听器

因为现在用注解创建消费者监听器,都是通过:@RabbitListener 所有没有是很什么方法动态创建队列,比如我配置文件里面配置 了 队列名名称:que...

2018/12/05 22:20
8
回答
rabbitmq erlang安装问题
agong 的回答 2018/03/29 16:48
最佳答案
引用来自“agong”的评论 问题解决了吗? 我 遇到相同问题, 我下的是20.3的erlang 我解决了,要从这里下载:https://bintray.com/rabbitmq/rpm/erlang/20.3-1 不要从这里下载:https://www.erlang-solutions.co...
3
回答
windows下 rabbitMQ无法启动

报错如图, 防火墙关了, hosts也添加了, cmd也是管理身份运行的,第一次安装的时候运行起来了,所有都是成功的, 之后一直没用,今天想起来运行一下,...

2018/05/02 18:10
3
回答
用消息队列的服务如何安全重启?
LiYong_Luke 的回答 2019/12/26 10:54
最佳答案
你这是好几个问题哦 1、服务重启或kill 进程如何处理运行中的业务? 一是设计就要考虑此种情况,比如 考虑设计为有状态:未运行、运行中、成功结束、失败结束,同时需要有功能去查看这种异常状态的任务。然后考虑自动或人工开启重新消费。 二是考虑优雅停服方案,实现尽量等待消费结束然后停服,减少异常情...
2
回答
rabbitmq cluster 问题

上图可以看到,我在rabbitmq-env.conf中设置nodename 是 rabbit@node1 我的host 10.13.3.xx 是node1...

2016/05/03 15:04
1
回答
springboot rabbitmq消费端多次消息发送问题

我设置了消费者手动应答,最小和最大消费者是1,消费端加了重试.然后在消费端用了一个线程池处理,发现消费端接收到的消息有些重复接收了好几次

2019/12/17 13:55
4
回答
RabbitMQ 如何在分布式的环境下,保证同时只有一个节点消费,并且直到该节点消费完成后,其他节点竞态获取接收下一个消息?

1、问题情况如题; 2、现状是即使设置了 prefetchCount ,消息也是在不同的节点中轮询接收,而不能做到只有一个节点消费,其他节点都不允许消费的...

2019/11/22 16:24
3
回答
rabbitmq集群的吞吐量(msg/s)不如单机?

我用三台配置一样的机器做的集群,两个ram一个disk,Haproxy做得负载,测试跑起来发现集群的吞吐量还不如单机,这是什么原因?是不是集群只能线性的增...

2018/03/27 11:00

没有更多内容

加载失败,请刷新页面

返回顶部
顶部