springboot整合rabbitmq向不同交换机发送消息


1.导入依赖

<dependency>

    <groupId>org.springframework.boot</groupId>

    <artifactId>spring-boot-starter-amqp</artifactId>

</dependency>


2.yml配置rabbitmq

virtual-host: /默认就是斜杠,具体查看rabbitmq后台admin栏。如果默认这行不用写。

spring: 

    rabbitmq: 

        host: 127.0.0.1

        username: admin    

        password: admin    

        virtual-host: /  #可以不用写



3.发送direct消息

direct 类型的行为是”先匹配, 再投送”. 即在绑定时设定一个routing_key, 消息的routing_key匹配时, 才会被交换器投送到绑定的队列中去.

(1).我们在RabbitMQ后台新建一个交换机,demo-direct交换机名,direct交换机类型,Durable持久化:

(2).再新建一个消息队列,取名为demo:

(3).点击demo-direct交换机进入绑定消息队列demo:

如果没有指定routingkey,消息队列的名称就是routingkey

(4).绑定成功后查看:



你可以直接在交换机页面下方的Publish message发送消息,在消息队列的Get message查看消息,不过我们实际生产比较多使用编程:

在Spring Boot创建单元测试

demo-direct交换机名

demo是该交换机绑定的消息队列名

发送消息

此时发送消息我们在rabbitmq网页发现消息是经序列化后的,我们如果想改变序列化机制为JSON,也很简单,只需要注入一个人Bean:

然后我们再启动测试,发送。

接收消息

demo是消息队列名,也就是消费者只需要得到消息队列的名字就可以接收队列中的消息。

查看打印

{msg=true,key=值}



4.广播fanout消息

转发消息到所有绑定队列(广播:忽略routing_key )

1.首先我们需要在RabbitMQ后台创建一个广播交换机:

2.再创建一些(demo1,demo2)消息队列,以一个作为演示:

3.进入创建的交换机页面:

4.交换机与消息队列(demo1,demo2)进行绑定:

如果没有指定routingkey,消息队列的名称就是routingkey

在Spring Boot创建单元测试

注意在广播模式下会忽略忽略routing_key

发送消息

接收消息

打印输出:

{name='<西游记>',anthony='吴承恩'}



5.发送topic消息

按规则转发消息(使用通配符)

1.在rabbitmq后台新建一个topic交换机

2.新建一个消息队列demo

3.交换机绑定消息队列,注意此处的路由键Routing key使用了通配符

*表示一个词.

#表示零个或多个词.

那我们如何区分几个字母为一个单词呢?

答案是通过”点分”的 routing_key 形式,比如两个单词是*.demohello.demo,

如果路由键为demo.#,那可以匹配demo.开头的所有路由键。

4.查看此时的交换机

在Spring Boot创建单元测试

发送消息

接收消息

打印输出

msg=true,key=topic交换机}


6.代码创建交换机与消息队列

(1).上面演示的是通过RabbitMQ网页后台创建,通过编程的方式也非常简单:

(2).登录后台查看,创建成功!



7.监听消息队列

监听消息队列,当有消息发到消息队列,立马获取并操作。方法也很简单。

1.开启基于注解的Rabbit模式

2.@RabbitListener注解实现监听

注意此时你的消息队列已经有了demo和demo.news

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 230,825评论 6 546
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 99,814评论 3 429
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 178,980评论 0 384
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 64,064评论 1 319
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 72,779评论 6 414
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 56,109评论 1 330
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 44,099评论 3 450
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 43,287评论 0 291
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 49,799评论 1 338
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 41,515评论 3 361
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 43,750评论 1 375
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 39,221评论 5 365
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 44,933评论 3 351
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 35,327评论 0 28
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 36,667评论 1 296
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 52,492评论 3 400
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 48,703评论 2 380

推荐阅读更多精彩内容

  • http://liuxing.info/2017/06/30/Spring%20AMQP%E4%B8%AD%E6%...
    sherlock_6981阅读 15,978评论 2 11
  • 1 RabbitMQ安装部署 这里是ErLang环境的下载地址http://www.erlang.org/down...
    Bobby0322阅读 2,251评论 0 11
  • 本文大纲 RabbitMQ 历史 RabbitMQ 应用场景 RabbitMQ 系统架构 RabbitMQ 基本概...
    Java_Explorer阅读 16,470评论 1 40
  • 应用场景 异步处理 场景说明:用户注册后,需要发注册邮件和注册短信,传统的做法有两种: 1.串行的方式 2.并行的...
    lijun_m阅读 1,847评论 0 3
  • 什么叫消息队列? 消息(Message)是指在应用间传送的数据。消息可以非常简单,比如只包含文本字符串,也可以更复...
    Agile_dev阅读 2,386评论 0 24