RabbitMq同一队列多个消费者问题
RabbitMQ只有Queue,如果多个消费者绑定同一个queue,那么一条消息,只能被其中一个消费者取走(轮询)。本质上,RabbitMq的消费者的消息确认机制,就注定不可能让多个消费者同时去消费同一个队列中的同一条消息,只能轮询的方式去消费。
我感觉我们的目的是想用rabbitmq 实现发布订阅的模式,其实不用纠结于多个消费者怎么取消费同一个队列里面的消息,我的理解是,
1、消息生产者 关心的是 1 消息 2 路由key 3 交换机 而队列与交换机的绑定是消费者应该关心的事。
2、基于这个,作为生产者,想发布一个消息,只需要提供消息类型 ,路由key规则,对应交换机。
3、至于谁想订阅这个消息作为生产者可以不用管,消息订阅者按照生产者提供的协议去创建一个队列对接就是。
实现方式采用topic交换机-通配符路由
本文来自网络,不代表协通编程立场,如若转载,请注明出处:https://net2asp.com/01e70a207e.html
相关推荐
-
微服务框架SpringcloudAlibaba+Nacos集成RabbitMQ
目前公司使用jeepluscloud版本,这个版本没有集成消息队列,这里记录一下,集成的过程;这个框架跟ruoyi的那个微服务版本结构一模一样,所以也可以快速上手。 1.项目结构图…
1天前 -
项目分享:大数据股票数据可视化分析与预测系统
1. 项目简介 股票市场行情分析与预测是数据分析领域里面的重头戏,其符合大数据的四大特征:交易量大、频率高、数据种类多、价值高。 本项目基于 Python 利用网络爬虫技术从某财经…
1天前 -
Hudi Java Client总结|读取Hive写Hudi代码示例
前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家。点击跳转到网站:https://www.captainai.net/dongkelun 前言 Hu…
大数据 1天前 -
【pyspark从入门到放弃】DataFrame
环境安装 pyspark支持通过pypip、conda下载,或者手动下载。 笔者通过pip install命令从pypip下载并配置安装了3.5.0版本的Spark。 创建实例 使…
大数据 1天前 -
第2.4章:StarRocks表设计–分区分桶与副本数
StarRocks采用Range-Hash的组合数据分布方式,也就是我们一直在提的分区分桶方式。 1分区 StarRocks中的分区是在建表时通过PARTITION BY RANG…
1天前 -
Spark 大数据实战:基于 RDD 的大数据处理分析
之前笔者参加了公司内部举办的一个 Big Data Workshop,接触了一些 Spark 的皮毛,后来在工作中陆陆续续又学习了一些 Spark 的实战知识。 本文笔者从小白的视…
1天前 -
kafka查看消息两种方式(命令行和软件)+另附发送消息方式
1、命令行方式 ①找到kafka安装文件夹 ②执行命令 #指定offset为指定时间作为消息起始位置 kafka-consumer-groups.sh \ –bootstrap-…
1天前 -
服务攻防-数据库安全-服务应用的安全问题以及测试流程-Mysql&Hadoop&未授权访问&RCE-漏洞复现
目录 一、服务应用的安全问题 1、配置不当——未授权访问 2、安全机制——特定安全漏洞 3、安全机制——弱口令爆破攻击 二、服务应用的安全测试思路 1、判断服务是否开放 2、判断服…
1天前 -
Tomcat安装测试、Eclipse配置Tomcat步骤
一. 安装tomcat并测试 1.1.1到Apache Tomcat官网下载安装包。在选择中间位置的版本较为稳定然后选择对应操作系统的安装包(本次选择8.5版本)。 1.1.2 解…
1天前 -
智能优化之粒子群算法(PSO)(Matlab,python,C++实现)
一、算法简介 粒子群算法(Particle swarm optimization, PSO)是一种仿生算法,它是一种 在求解空间中寻找最优解 的简单算法。它与其他优化算法的不同之处…
1天前
