当前位置: 首页 > news >正文

rabbitMq路由键介绍

rabbitTemplate.convertAndSend() 是 Spring AMQP 中用于发送消息到 RabbitMQ 的方法。下面是对您提供的代码示例的解释:

rabbitTemplate.convertAndSend("ums-platform.ex", "ums.report.routing", param);

这行代码主要完成以下几个操作:

rabbitTemplate:这是一个 RabbitTemplate 对象,它是 Spring AMQP 提供的用于与 RabbitMQ 进行交互的模板类。在发送消息时,我们使用这个对象来调用相应的方法。convertAndSend() 方法:这是 RabbitTemplate 类的一个方法,用于将消息发送到指定的交换机和路由键。"ums-platform.ex":这是交换机的名称,表示要将消息发送到名为 "ums-platform.ex" 的交换机。"ums.report.routing":这是路由键,表示消息将根据该路由键进行匹配,并被路由到相应的队列。在这个例子中,消息会被发送到与 "ums.report.routing" 路由键匹配的队列中。param:这是要发送的消息内容,可以是任意类型的对象。

总结起来,上述代码的作用是将 param 对象作为消息发送到名为 “ums-platform.ex” 的交换机,并使用 “ums.report.routing” 路由键进行路由。

请注意,在实际运行代码之前,您需要确保已经正确配置了 RabbitMQ 连接和交换机/队列等相关信息。另外,您还需要在项目中引入 Spring AMQP 相关的依赖。

当使用 “ums.report.routing” 路由键进行路由时,RabbitMQ会将消息发送到与该路由键匹配的队列。下面是一个示例来说明这个过程:

假设我们有以下的交换机和队列配置:

交换机名称:"ums-platform.ex"
队列1名称:"ums.report.queue1"
队列2名称:"ums.report.queue2"

我们使用 “ums.report.routing” 路由键进行路由。

首先,我们需要将队列1和队列2绑定到交换机,同时指定它们的路由键:

@Bean
public Binding binding1(Queue queue1, DirectExchange exchange) {return BindingBuilder.bind(queue1).to(exchange).with("ums.report.routing");
}@Bean
public Binding binding2(Queue queue2, DirectExchange exchange) {return BindingBuilder.bind(queue2).to(exchange).with("ums.report.routing");
}

在上述代码中,binding1 方法将队列1绑定到交换机,并使用 “ums.report.routing” 路由键进行绑定。同样,binding2 方法将队列2绑定到交换机,并使用相同的路由键进行绑定。

然后,我们可以通过以下方式发送消息到交换机,并使用 “ums.report.routing” 路由键进行路由:

rabbitTemplate.convertAndSend("ums-platform.ex", "ums.report.routing", message);

在上述代码中,我们使用 rabbitTemplate.convertAndSend() 方法将 message 消息发送到交换机 “ums-platform.ex”,并指定路由键为 “ums.report.routing”。

根据上述配置和代码,如果消息发送成功,RabbitMQ 将根据路由键 “ums.report.routing” 将该消息路由到与之匹配的队列。在我们的示例中,消息将被路由到队列1和队列2。

请注意,这只是一个示例,实际使用时您需要确保正确设置交换机、队列以及它们之间的绑定关系,并且确保消费者正确监听相应的队列以接收消息。

相关文章:

rabbitMq路由键介绍

rabbitTemplate.convertAndSend() 是 Spring AMQP 中用于发送消息到 RabbitMQ 的方法。下面是对您提供的代码示例的解释: rabbitTemplate.convertAndSend("ums-platform.ex", "ums.report.routing", param);这行代码主要完成以下几个操作&…...

【python基础】python切片—如何理解[-1:],[:-1],[::-1]的用法

文章目录 前言一、基本语法二、切片1.a[i:j]2.a[i:j:k] 总结:[-1] [:-1] [::-1] [n::-1] 前言 在python中,序列是python最基本的数据结构,包括有string,list,tuple等数据类型,切片对序列型对象的一种索引方…...

剑指JUC原理-9.Java无锁模型

👏作者简介:大家好,我是爱吃芝士的土豆倪,24届校招生Java选手,很高兴认识大家📕系列专栏:Spring源码、JUC源码🔥如果感觉博主的文章还不错的话,请👍三连支持&…...

汽车托运使用的场景

在托运车辆时,要仔细的检查车辆的性能,比如电瓶电量是否充足,发动机的性能是否良好,轮胎是否是正常的气压,冬季时需使用防冻液,车内禁止放易燃易爆物品。 托运时还需选择一家好的托运公司,首先要…...

机器学习 - 加油站数据分析

一、实验数据 数据集:“加油站数据.xls” 数据集介绍:该表记录了用户在11月和12月一天24小时内的加油信息,包括:持卡人标识(cardholder)、卡号(cardno)、加油站网点号(n…...

基于CMFB余弦调制滤波器组的频谱响应matlab仿真

目录 1.算法运行效果图预览 2.算法运行软件版本 3.部分核心程序 4.算法理论概述 4.1、CMFB余弦调制滤波器组原理 4.2、CMFB调制过程 4.3、CMFB特点 5.算法完整程序工程 1.算法运行效果图预览 2.算法运行软件版本 matlab2022a 3.部分核心程序 ......................…...

helm一键部署grafana

一键部署命令 helm repo add prometheus-community https://prometheus-community.github.io/helm-charts helm repo update helm install prometheus prometheus-community/kube-prometheus-stack暴露服务 kubectl port-forward --address 0.0.0.0 deployment/prometheus-gr…...

pytorch复现_NMS

NMS(非极大值抑制)阈值是用于控制在一组重叠的边界框中保留哪些边界框的参数。当检测或识别算法生成多个边界框可能涵盖相同物体时,NMS用于筛选出最相关的边界框,通常是根据它们的置信度分数。 具体来说,NMS的工作原理…...

备份doris数据到minio

1、MINIO 设置 创建服务账户,记住ACCESS_KEY和SECRET_KEY 创建Buckets doris 设置region 在首页查看服务ip和端口号 2、创建S3备份库 因为minio是兼容S3协议的,所以可以通过s3协议链接minio。 CREATE REPOSITORY minio WITH S3 ON LOCATION "s3://…...

Linux中正则表达式等

grep命令:主要作用就是过滤查找文本内容 常用的选项有: -m 数字:匹配几次之后停止,按行匹配,不是按字符个数,例如 -v:取反 例如: -n:显示匹配的行号 例如: -c:仅显示匹配的行数,不显示匹配内…...

记一次并发问题 Synchronized 失效

记一次并发问题 Synchronized 失效 场景:为避免信息提交重复,给事务方法增加了synchronized修饰符,实际场景中仍然无法完全避免重复,原因是因为在第一个线程执行完synchronized代码段后,此时spring还未完成事务提交&a…...

手机平板摄像头如何给电脑用来开视频会议

环境: Iriun Webcam EV虚拟摄像头 钉钉会议 问题描述: 手机平板摄像头如何给电脑用来开视频会议 解决方案: 1.下载软件 手机端和电脑端都下载这个软件,连接同一局域网打开软件连接好 另外一款软件Iriun 也是一样操作 2.打…...

windows docker desktop 更换镜像 加速

最近 docker hub 访问不了; 经过研究 可以通过添加 代理镜像网址 添加代理服务器的方式 实现完美访问 1添加镜像网站 修改成国内镜像地址就能享受到飞一般的速度,但有一个问题,部分站点镜像不全或者镜像比较老,建议使用多个镜像站。 https…...

linux下多机器ssh免密码登录配置

20,21,22,23等4台机器配置ssh免密登陆 确认sshd配置 查看/etc/ssh/sshd_config文件,确认如下配置没有被注释掉: AuthorizedKeysFile .ssh/authorized_keys每一台机器修改hosts配置主机名(可选) 执行ssh命令,如…...

【IDEA使用maven package时,出现依赖不存在以及无法从仓库获取本地依赖的问题】

Install Parent project C:\Users\lxh\.jdks\corretto-1.8.0_362\bin\java.exe -Dmaven.multiModuleProjectDirectoryD:\学习\projectFile\study\study_example_service "-Dmaven.homeD:\Program Files\JetBrains\IntelliJ IDEA2021\plugins\maven\lib\maven3" "…...

Flink 统计接入的数据量-滚动窗口和状态的使用

1、概述 在生产场景值,经常需要和上游、下游对数,离线场景可以直接 group by 再 count ,但是实时场景中,如果使用 kafka 作为中间件,中间经过几个 job 的过滤转化后,再对照像 Doris 或 Clickhouse 中最终层…...

SpringBoot快速整合canal1.1.5(TCP模式)

SpringBoot快速整合canal1.1.5(TCP模式) 安装并配置MySQL主从⭐ 1:Docker安装MySQL8.0.28 docker pull mysql:8.0.282:创建目录: mkdir -p /usr/local/mysql8/data mkdir -p /usr/local/mysql8/log mkdir -p /usr/…...

docker打包container成image,然后将image上传到docker hub

第一步&#xff1a;停止正在运行的容器 docker stop <container_name> eg: docker stop xuanjie_mlir 第二步&#xff1a;将对应的container打包成image docker commit <container_id> <镜像名&#xff1a;版本> eg&#xff1a;docker commit 005672e6d97a…...

设计模式—创建型模式之原型模式

设计模式—创建型模式之原型模式 原型模式&#xff08;Prototype Pattern&#xff09;用于创建重复的对象&#xff0c;同时又能保证性能。 本体给外部提供一个克隆体进行使用。 比如我们做一个SjdwzMybatis&#xff0c;用来操作数据库&#xff0c;从数据库里面查出很多记录&…...

Zygote进程通信为什么用Socket而不是Binder?

Zygote进程是Android系统中的一个特殊进程&#xff0c;它在系统启动时被创建&#xff0c;并负责孵化其他应用进程。它的主要作用是预加载和共享应用进程的资源&#xff0c;以提高应用启动的速度。 在Android系统中&#xff0c;常用的进程通信方式有以下几种&#xff1a; Intent…...

YOLO X Layout案例集:10类典型文档(发票/简历/论文/合同/说明书)Layout识别效果汇总

YOLO X Layout案例集&#xff1a;10类典型文档Layout识别效果汇总 获取更多AI镜像 想探索更多AI镜像和应用场景&#xff1f;访问 CSDN星图镜像广场&#xff0c;提供丰富的预置镜像&#xff0c;覆盖大模型推理、图像生成、视频生成、模型微调等多个领域&#xff0c;支持一键部署…...

bert-base-chinese详细步骤:如何将test.py改造成支持流式文本处理的微服务

bert-base-chinese详细步骤&#xff1a;如何将test.py改造成支持流式文本处理的微服务 1. 项目背景与价值 在实际的工业场景中&#xff0c;我们经常需要处理大量的文本数据流。传统的批处理方式虽然简单&#xff0c;但无法满足实时性要求高的应用场景。比如智能客服系统需要实…...

yz-bijini-cosplay真实案例:COSER试装前预览、服装打样视觉参考图

yz-bijini-cosplay真实案例&#xff1a;COSER试装前预览、服装打样视觉参考图 1. 项目概述 yz-bijini-cosplay是一个专为RTX 4090显卡优化的Cosplay风格文生图系统&#xff0c;基于通义千问Z-Image底座和专属LoRA权重开发。这个系统能够帮助COSER在试装前预览效果&#xff0c…...

RexUniNLU开源镜像免配置教程:自动下载权重+端口映射一步到位

RexUniNLU开源镜像免配置教程&#xff1a;自动下载权重端口映射一步到位 1. 这不是另一个NLP工具&#xff0c;而是一站式中文语义理解中枢 你有没有遇到过这样的情况&#xff1a;想快速验证一段中文文本里藏着多少信息——谁说了什么、发生了什么事、情绪是好是坏、背后有哪些…...

SGLang-v0.5.6优化技巧:合理配置GPU内存利用率

SGLang-v0.5.6优化技巧&#xff1a;合理配置GPU内存利用率 1. 引言 在大模型推理的实际部署中&#xff0c;GPU内存管理往往是决定服务稳定性和性能的关键因素。SGLang-v0.5.6作为专为高效推理设计的框架&#xff0c;提供了精细化的GPU内存控制机制。本文将深入解析如何通过合…...

PostgreSQL实战:使用pg_dump精准导出特定模式下的表结构

1. 为什么需要精准导出特定模式下的表结构 在实际的数据库管理工作中&#xff0c;我们经常会遇到只需要导出特定模式&#xff08;schema&#xff09;下表结构的需求。比如在微服务架构中&#xff0c;每个服务可能对应数据库中的一个模式&#xff1b;或者在进行数据库迁移时&…...

KubeSphere Core 离线部署实战:从镜像搬运到私有仓库配置

1. 离线部署KubeSphere Core的核心挑战 在企业内网环境中部署KubeSphere Core时&#xff0c;最大的障碍就是如何解决容器镜像的获取问题。我去年给某金融机构做私有云改造时就遇到过这种情况——他们的生产环境完全隔离&#xff0c;所有服务器都无法直接访问公网。当时为了部署…...

UE5 Python远程执行:利用UDP组播实现高效命令分发

1. 为什么需要UE5 Python远程执行&#xff1f; 想象一下这个场景&#xff1a;你正在开发一个大型UE5项目&#xff0c;团队里有10个设计师需要同时修改场景参数。传统做法是每个人手动操作编辑器&#xff0c;或者通过RPC一个个连接。这种方式的效率有多低&#xff0c;相信每个开…...

别再手动调参了!用Matlab+NRBO-BP+NSGAII搞定工艺优化,自动生成最优参数组合Excel

工艺优化新范式&#xff1a;基于NRBO-BP与NSGAII的智能参数寻优系统 在化工、材料、制造等领域的工艺优化过程中&#xff0c;工程师和研究人员常常面临一个共同的挑战&#xff1a;如何在有限的实验资源和时间约束下&#xff0c;从海量的参数组合中找到最优解。传统的手动调参方…...

告别Moom!用Hammerspoon实现Mac窗口精准控制(附完整快捷键表+配置文件)

用Hammerspoon打造Mac高效工作流&#xff1a;从窗口管理到自动化脚本 每次看到同事花十几秒拖动窗口调整大小&#xff0c;或者在不同显示器间来回切换应用时&#xff0c;我总忍不住想分享这个改变我工作效率的神器。Hammerspoon——这个完全免费的开源工具&#xff0c;让我彻底…...