SpringAMQP 发布订阅-TopicExchange

根据这个模型编写代码:

    @RabbitListener(bindings = @QueueBinding(value = @Queue(name = "topic.queue1"),exchange = @Exchange(name = "itcast.topic",type = ExchangeTypes.TOPIC),key = {"china.#"}))public void listenTopicQueue1(String msg){System.out.println("从topic.queue1中获取到了消息:"+msg);}@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "topic.queue2"),exchange = @Exchange(name = "itcast.topic",type = ExchangeTypes.TOPIC),key = {"#.news"}))public void listenTopicQueue2(String msg){System.err.println("从topic.queue2中获取到了消息:"+msg);}

pulsher发送消息代码:

@Testpublic void testTopicExchangeSend() {//发送消息String DirectChangeName = "itcast.topic";//交换机的名字String msg = "这里是天气预报";rabbitTemplate.convertAndSend(DirectChangeName, "weather.news", msg);}

用@RabbitListener注解实现交换机和队列的绑定以及BingingKey的设置,TopicExchange的特点就是可以用正则表达式匹配,可以看到队列1的RoutingKey China.# 的意思接收消息的前提是china.开头。#.news 的意思是该队列接收消息的前提是以 .news结尾。

 这里看我发送消息的RoutingKey是china.news 这两个队列都满足了请求 所有都接收到了

这里看我改了一下 第二个队列不匹配 所以就没接收到消息

这里的末尾是news  只有第二个队列匹配到了 所以第二个队列接收。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.hqwc.cn/news/695553.html

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【一触即发】快来围观C3安全大会酷炫九宫格!

C3安全大会2024 2024年5月18日 南京扬子江国际会议中心 C3安全大会2024 即将揭幕! 图解C3 | 九宫格 数智变革,“AI”正以其颠覆性力量,重塑我们对未来的定义。亚信安全邀您共襄盛举,见证这场于5月18日盛大开幕的C3安全大会2024…

【C++】详解STL的适配器容器之一:优先级队列 priority_queue

目录 堆算法 概述 向下调整建堆 向上调整建堆 建堆算法 仿函数 概述 使用介绍 emtpy size top push pop 模拟实现 仿函数 框架 向下调整算法 向上调整算法 pop push empty top 要理解优先级队列,需要有如下知识 STL容器之一的vector&#xf…

《我瞎编功法你们怎么都成仙了》短剧

《我瞎编功法你们怎么都成仙了》 (舞台:一座山间小屋,屋内摆满了古朴的书架和烛台,桌上放着几本破旧的书籍。) (人物:王大锤,一个平凡的年轻人,手拿一本破旧的书&#xf…

Python自动化测试实现的思路

Python自动化测试常用于Web应用、移动应用、桌面应用等的测试 Python自动化实现思路通常分为以下几步:1. 确定自动化测试的范围和目标: 首先需要明确需要进行自动化测试的范围和目标,包括测试场景、测试用例、测试数据等。 2. 选择自动化测…

java学习之zip炸弹攻击

一、概述 Zip炸弹是一种特殊类型的Zip文件,它包含了大量的无用数据。Zip文件格式允许使用压缩算法来减小文件的大小,但是如果Zip文件中的某些内容被重复压缩,就会导致文件大小急剧增加。Zip炸弹利用这个特性,将一些无用的数据多次…

软件2班20240513

第三次作业 package com.yanyu;import java.sql.*; import java.util.ResourceBundle;public class JDBCTest01 {public static void main(String[] args) {ResourceBundle bundle ResourceBundle.getBundle("com/resources/db");// ctrl alt vString driver …

IP SSL怎么签发使用

IP证书的签发首先是需要有一个可供绑定的IP地址,作为常用数字证书之一,IP证书也因为其广泛的应用范围而深得用户的青睐和喜欢。 部署IP证书后,可以实现该IP地址的https访问,过程和域名证书相差不多。 IP证书和域名证书的区别 很…

ANet系列智能网关,边缘计算,数据采集器

安科瑞电气股份有限公司 祁洁 acrelqj 一、网关功能 智能网关主要功能——终端设备与系统平台间的数据交互桥梁。 1、数据采集 支持串口、以太网,只需配置即可兼容支持标准规约的各类仪表 2、数据上传 支持往上海分类分项能耗平台、宁夏电力需求侧平台、江苏…

Mac开发者的信任之选:CodeSigner,轻松实现代码签名与验证!

CodeSigner for Mac是一款专为Mac平台设计的软件崩溃修复工具。当用户在Mac上遇到应用无法打开或崩溃的问题时,CodeSigner for Mac可以帮助用户通过数字签名的方式解决这些问题。 该软件的主要功能包括: 数字签名:CodeSigner for Mac允许用…

玩具电动车flash语音方案wt588f02b-8 -玩具车语音芯片选型推荐!

随着科技的飞速发展,电动玩具车已不再是我们童年记忆中的简单模样。它们不仅外观酷炫,功能多样,更融入了先进的语音技术,为孩子们带来更加智能化、趣味化的玩具体验。 性能: 语音内容包括儿歌、故事片段等设计得生动…

专业音频修复软件:iZotope RX 11 for Mac 激活版

iZotope RX 专为满足后期制作专业人士的苛刻需求而设计的一款专业音频修复软件。iZotope RX 10添加了新的特性和功能,以解决当今后期项目中存在的一些最常见的修复问题,使其成为音频后期制作的最终选择。虽然包含许多其他新功能,但这里是新的…

RFID智能试剂柜:危险化学品管理新利器。

在科学实验与研究的世界中,危险化学品扮演着不可或缺的角色。然而,化学品在给我们的生活带来巨大便利的同时,一部分危险化学品也对人们的生命安全构成了极大的威胁。 危险化学品安全是安全生产工作的重中之重,在人工智能蓬勃发展的…