就是 我想控制从生产者一次发送1000条数据到rabbitMQ，如何实现。就是当我生产者这边的数据到1000条的时候，我才向rabbitMQ去push一次，是有什么参数去控制吗？
rabbitMQ如何控制一次发送消息的数量
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
分享- 邀请回答
-
1条回答 默认 最新
oyljerry 2016-06-06 13:07关注这个你可以把消息放到一个list等链表。插入数据的时候查看一下链表大小。有1000了。就把list中的数据push到rabbitmq。然后清空list。，再插入新数据
解决 无用评论 打赏举报 分享
- 2021-10-12 11:31回答 4 已采纳 一个思路 ： 使用延迟队列 ，设置ttl时间 ，每次设置ttl时 加1s
- 2021-10-16 14:09回答 1 已采纳 可以参考试试：
- 2021-10-13 14:06回答 1 已采纳 不需要using释放掉连接，消费端本来就是需要保持长久连接的。消息是可以手动确认的，每处理一条就手动确认一条，确认后队列就会移除该条消息。看我的代码示例 //队列消费者 public class Re
- 2021-08-04 22:53Modify_QmQ的博客 2.2、四大核心概念 生产者 产生数据发送消息的程序是生产者 交换机 交换机是 RabbitMQ 非常重要的一个部件，一方面它接收来自生产者的消息，另一方面它将消息 推送到队列中。交换机必须确切知道如何处理它接收到的...
- 2018-12-29 12:34回答 1 已采纳 The provided code seems fine except that you are using the default exchange and providing a route
- 2019-02-07 19:47回答 1 已采纳 but still getting only one message, not a pack of five. what i'm doing wrong? You don't under
- 2022-09-02 09:45回答 2 已采纳 1、消费者获取到消息，并且业务正常处理完成之后，再确认ack；2、如果消息重复消息，业务代码里面也要有幂等性校验，这时候发现重复消费（即之前已完成业务处理），这时候也要确认ack；
- 2021-03-23 23:23张维鹏的博客 RabbitMQ消息队列常见面试题总结； 1、什么是消息队列？消息队列的优缺点？ 2、Kafka、ActiveMQ、RabbitMQ、RocketMQ的区别？ 3、如何保证消息不被重复消费？ 4、如何保证消息不丢失，进行可靠性传输？ 5、如何保证...
- 2017-11-21 07:53回答 1 已采纳 According to the AMQP reference, a channel exception is raised when a message gets acknowledged fo
- 2015-10-20 16:24回答 1 已采纳 Here: $ch->queue_bind($queue, $exchange, $queue); you bind the queue using the $queue routing k
- 2022-07-26 08:45
Springboot集成的rabbitmq，在生产者消息发送成功后，RabbitMQ Managent却没有任何变化，没有创建队列也没有收到消息。不知道哪里的问题。
rabbitmq
spring boot
分布式
回答 2 已采纳 运行test是否有报错信息？ - 2021-06-30 20:38胜天半子-祁同伟的博客 RabbitMQ——使用事务控制消息的发送和接收
- 2018-11-08 08:45回答 1 已采纳 This is a known issue in version 2.8.0 of PhpAmqpLib. The official recommendation is to fall back
- 2021-09-08 23:36菜鸡的挣扎的博客 rabbitMQ 会做一个系列，包括：安装、基础使用、高级队列、集群。 使用环境： jdk 8 、springboot 2.4.10 常见概念： AMQP：高级消息队列协议，这是一个消息应用的规范。 Broker： 接收和分发消息的应用，RabbitMQ ...
- 2022-05-18 23:28String-int的博客 1.1. MQ 的相关概念 ...使用了 MQ 之后，消息发送上游只需要依赖 MQ，不 用依赖其他服务。 1.1.2. 为什么要用 MQ 1.流量消峰 举个例子，如果订单系统最多能处理一万次订单，这个处理能力应付正常时段的下单
- 没有解决我的问题, 去提问
