标签 RabbitMQ - OSCHINA - 中文开源技术交流社区

软件主页

关注

RabbitMQ 是由 LShift 提供的一个 Advanced Message Queuing Protocol (AMQP) 的开源实现，由以高性能、健壮以及可伸缩性出名的 Erlang 写成，因此也是继承了这些优点。...

加载中

回答

最近再纠结要不要给kafka单独出一个服务A，其它服务调用服务A然后服务A和kafka连接。xxl-job,rabbitmq同理。如果需要单独出一个服务...

smallcatooo

2021/09/17 15:57

回答

在单节点的情况下，如果保证一个客户端同时只消费一个，消费完成后再消费下一个。

zb81851764

2021/07/19 17:03

回答

比如秒杀环节,怎么做到让用户点击抢购被异步削峰,但是又要实时把抢购的结果反馈给用户.

行走的旅程

2021/04/06 17:25

回答

smallcatooo 的回答 2020/10/20 14:55

最佳答案

最终我们解决的方式是：先入库，然后每5分钟查询过期两天的数据（这里为了确保数据不遗漏，是用时间段来控制，每一次执行完，把结束时间记录下来，就是下次的开始时间），并把数据推送到mq中，然后消费者消费数据。并另起一个任务，每小时监测一次数据处理情况。

阅读全文

回答

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

calm01

2018/11/02 14:32

回答

polly 的回答 2020/07/27 13:53

最佳答案

springboot自动装配mq的方式是池化的，无法修改，如果需要动态连接，你考虑下是否可以每次直接连接。 public static Connection getConnection() { try { Connection connection = null; //定义一个连接工厂 Con...

阅读全文

回答

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

Anur

2018/05/16 09:33

回答

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

嘵建

2020/04/02 11:33

回答

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

灵风

2020/04/09 10:09

回答

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

prb_qb

2020/03/19 16:58

没有更多内容

加载失败，请刷新页面

RabbitMQ

RabbitMQ 相关标签

Java

Spring

Apache ActiveMQ

AMQP

Spring Boot

PHP

Redis

Spring AMQP

Erlang

Apache Kafka