最近在使用RabbitMQ作消息转发，供消费者使用，遇到了多消费者消费同一批数据的问题。
1.多个消费者消费同一批数据；
2.每条数据每个消费者都要消费
生产端不创建队列，只负责把消息发送到交换机并指定routingKey，这里为了避免消息投递到RabbitMQ失败，采用了手动确认方式，如
# spring配置
# 手动确认消息投递情况
spring.rabbitmq.publisher-confirms: true
spring.rabbitmq.publisher-returns: true
spring.rabbitmq.template.mandatory: true
# java代码
@PostConstruct
public void init() {
rabbitTemplate.setConfirmCallback((correlationData, ack, error) -> {
System.out.println("消息唯一标识：" + correlationData);
System.out.println("确认结果：" + ack);
System.out.println("失败原因：" + error);
});
rabbitTemplate.setMandatory(true);
rabbitTemplate.setReturnCallback((message, replyCode, replyText, exchange, routingKey) -> {
System.out.println("消息主体 message : " + message);
System.out.println("响应 code : " + replyCode);
System.out.println("描述：" + replyText);
System.out.println("消息使用的交换器 exchange : " + exchange);
System.out.println("消息使用的路由键 routing : " + routingKey);
});
}
消费端创建不自动删除的持久化队列，指定exchange、routingKey、queueName，如
@RabbitListener(
bindings = {
@QueueBinding(
value = @Queue(value = "dynamicQueue", autoDelete = "false", durable = "true"),
exchange = @Exchange(value = "exchange", durable = "true", type = ExchangeTypes.DIRECT),
key = "routingKey"
)
}
)
public void dynamicQueue(Message message, Channel channel) {
System.out.println("接收消息：" + new String(message.getBody()));
}
上述代码会自动创建队列并使用routingKey绑定交换机
要想保证正确消费，消费端最好使用手动确认，手动确认的代码如
// 第二个参数的含义是是否批量确认，会把小于当前消息id（自增）的全部确认
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
尤其需要注意的是，下述配置含义是强制消费端手动确认，不确认RabbitMQ会认为没有消费
spring.rabbitmq.listener.simple.acknowledge-mode: manual
spring.rabbitmq.listener.simple
spring.rabbitmq.listener.direct
这两项配置似乎不同，经实践得到，生产者发送消息到队列需配置simple项，配置direct项无效，
发送到交换机可配置direct或simple项，下面是一个例子，配置实现“发送完毕就删除消息，不论消费者是否确认”
spring.rabbitmq.listener.simple.acknowledge-mode: none # 发送到队列不需要确认，配置下一项是无效的
spring.rabbitmq.listener.direct.acknowledge-mode: none # 发送到交换机不需要确认，配置上一项同样有效
文章浏览阅读86次。首发地址：https://yq.aliyun.com/articles/221708谈到机器学习，相信很多除学者都是通过斯坦福大学吴恩达老师的公开课《Machine Learning》开始具体的接触机器学习这个领域，但是学完之后又不知道自己的掌握情况，缺少一些实际的项目操作。对于机器学习的相关竞赛挑战，有些项目的门槛有些高，参加后难以具体的实现，因此造..._scrath五子棋下载
文章浏览阅读83次。原标题：Oracle 12c新特性系列专题-安徽Oracle授权认证中心 随着Oracle database 12c的普及，数据库管理员 (DBA) 的角色也随之发生了转变。 Oracle 12c数据库对 DBA 而言是下一代数据管理。它让 DBA 可以摆脱单调的日常管理任务，能够专注于如何从数据中获取更多价值。未来我们会推出基于Oracle12c的技术文章，帮助DBA尽快掌握新一代数据库的新特性..._ilm add policy row store compress advanced row after
文章浏览阅读150次。问题及代码：*Copyright(c)2016,烟台大学计算机与控制工程学院 *All right reserved. *文件名称：负数把正数赶出队列.cpp *作者：张冰 *完成日期；2016年10月09日 *版本号；v1.0 * *问题描述： 设从键盘输入一整数序列a1，a2，…an，试编程实现： 当ai>0时，ai进队，当ai<0时，将队首元素出队，当ai
文章浏览阅读376次。贪心+构造
文章浏览阅读150次。本文讲的是Linux命名空间学习教程（二） IPC，【编者的话】Docker核心解决的问题是利用LXC来实现类似VM的功能，从而利用更加节省的硬件资源提供给用户更多的计算资源。而 LXC所实现的隔离性主要是来自内核的命名空间, 其中pid、net、ipc、mnt、uts 等命名空间将容器的进程、网络、消息、文件系统和hostname 隔离开。本文是Li..._主机的 ipc 命名空间
文章浏览阅读2w次，点赞5次，收藏7次。在设备上强制安装apk。在app已有的情况下使用-r参数在app版本低于现有版本使用-d参数命令adb install -r -d xxx.apk_adb绕过安装程序强制安装app
文章浏览阅读290次。如果是越界进入硬件错误中断，MSP 或者 PSP 保存错误地址，跳转前会保存上一次执行的地址，lr 寄存器会保存子函数的地址，所以如果在 HardFault_CallBack 中直接调用 C 语言函数接口会间接修改了 lr，为了解决这个问题，直接绕过 lr 的 C 语言代码，用汇编语言提取 lr 寄存器再决定后面的操作。由于 STM32 加入了 FreeRTOS 操作系统，可能导致无法准确定位，仅供参考（日常编程需要考虑程序的健壮性，特别是对数组的访问，非常容易出现越界的情况）。_stm32flash地址越界怎么解决
文章浏览阅读1.8k次。学到了一种操作，说实话，我从来没想过还能这样正常情况下，为了管理方便，许多管理员都会开放MySQL数据库的secure_file_priv，这时就可以导入或者导出数据当我如图输入时，就会在D盘创建一个名为123456.php，内容为<?php phpinfo();?>的文件我们可以利用这一点运用到SQL注入中，从拿下数据库到拿下目标的服务器比如我们在使用联合查询注入，正常是这样的语句http://xxx?id=-1 union select 1,'你想知道的字段的内容或查询语句',
文章浏览阅读2.9w次，点赞12次，收藏63次。感谢原文：https://blog.csdn.net/abc5382334/article/details/24260817感谢原文：https://blog.csdn.net/jiaqingge/article/details/52564348Html CSS的三种链接方式css文本的链接方式有三种：分别是内联定义、链入内部css、和链入外部css1.代码为：<html>..._html链接css代码
文章浏览阅读625次。近几年，蓝牙耳机市场发展迅速，越来越多的消费者希望抛弃线缆，更自由地听音乐，对于运动人士来说，蓝牙耳机的便携性显得尤为重要。但目前市面上的大多数蓝牙耳机实际上都是“有线”的，运动过程中产生的听诊器效应会严重影响听歌的感受。而在“真无线”耳机领域，除了苹果的AirPods外，可供选择的产品并不多，而AirPods又不是为运动场景打造的，防水能力非常差。那么对于喜欢运动又想要“自由”的朋友来说，有没有一款产品能够满足他们的需求呢？下面这十款小编专门为大家搜罗的蓝牙耳机或许就能找到适合的！网红击音F1_适合游戏与运动的高音质蓝牙耳机
文章浏览阅读1k次，点赞6次，收藏7次。在本篇博文中，我们在 iOS 17 beta 4（SwiftUI 5.0）测试版中发现了 SwiftUI 视图首次显示时状态的改变会导致动画“副作用”的问题，并提出多种解决方案。
文章浏览阅读1.9k次。 在 上篇文章–Flutter 实现支持上拉加载和下拉刷新的 ListView 中，我们最终实现的效果是在 listView 上面留下了一段空白，本意是用来加载轮播图的，于是今天就开发了一下，希望能给各位灵感。一 、效果如下说一下大体思路 其实图片展示是用的 PageView ，然后，下面的指示器 是用的 TabPageSelector ，当然整体是用 Stack 包裹起来的。1、..._flutter pageview轮播图 site:csdn.net