spring boot 整合rabbitmq

spring boot的环境怎么搭建这边就不提了, 这里引入spring boot -AMQP的依赖:

配置连接,创建交换机,队列

首先 我和上面一样 先要配置连接信息这里 可以选用yml的方式 也可以选用 javaConfig 的方式 这里两种方式我都贴出来 你们自己选

Yml 方式

yml: 参数什么意思刚刚介绍过了 这里吧你自己的参数填进去就好了

这样 spring boot 会帮你把 rabbitmq 其他相关的东西都自动装备好,

javaConfig:

配置完连接之后 我们就可以开始发送消息和接收消息了(因为我们上面刚刚测试rabbitmq的时候创建过队列和交换机等等这种东西了 当然 spring boot也可以创建)

spring boot创建交换机 队列 并绑定:

发送消息:

发送消息比较简单, spring 提供了一个RabbitTemplate 来帮助我们完成发送消息的操作

如果想对于RabbitTemplate 这个类进行一些配置(至于有哪些配置我们后面会讲到) 我们可以在config类中 把他作为Bean new出来并配置

我们只需要写一个类 然后交给spring 管理 在类里面注入RabbitTemplate 就可以直接调用api来发送消息了

接受消息:

这里我新建了一个项目(最好新建一个 当然 不新建也没关系) 来接收信息(之前的配置这里就不贴出来了 和上面基本一样)

不出意外的话运行起来能看见效果, 这里就不贴效果图了

那么至此rabbitmq的一个快速开始 以及和spring boot整合 就完毕了, 下面开始会讲一些rabbitmq的一些高级特性 以及原理等




HTTPX 基础教程-新乡seo|网站优化,网站建设_微信公众号:zeropython—昊天博客