springboot整合rabbitmq附源码

前提是对rabbitmq有一定的了解,比如虚拟主机,交换机,队列,信道,绑定,路由键,direct,fanout,topic等

我使用的是docker部署的rabbitmq,看到简书的这个,镜像版本是rabbitmq:3.7.7-management

不会的可以看教程,docker安装rabbitmq
或者这里
docker安装RabbitMQ教程(2023年最详细)
确保rabbitmq环境,并且安装了延迟交换机的插件
插件安装看这里
Docker版RabbitMQ安装延迟队列插件及延迟队列项目应用实战

本教材源码地址:https://gitee.com/jackXUYY/springboot-example.git

在这里插入图片描述

目录结构
在这里插入图片描述
direct测试

DirectConfig此类是配置direct交换机,及队列,绑定关系

在这里插入图片描述
在这里插入图片描述
调用sendDirectMessage接口发送后,

在这里插入图片描述

只看出到了我们自定义的监听处理,我们先注释掉自定义的处理方式
在这里插入图片描述

在重启服务,发送一次
在这里插入图片描述
在这里插入图片描述
也许是我们传的是map,换成jsonObject就可以了

在这里插入图片描述

在这里插入图片描述

Fonout演示

配置FonoutConfig
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

topic演示
TopicConfig
在这里插入图片描述
发送消息,指定路由键为man,
在这里插入图片描述
在这里插入图片描述

在这里插入图片描述

延迟交换机测试,场景就是下单了,没付费,过期取消订单

LazyExchangeConfig

在这里插入图片描述

在这里插入图片描述

看到控制台说没有回调可用
Returned message but no callback available
3、延时插件小问题
RabbitMQ延迟队列消息路由失败(312 NO_ROUTE)原因及处理
原因:延迟插件不支持mandatory=true参数,如果启用会同时收到延迟消息和路由失败消息
解决方法
设置mandatory=false

参考:https://blog.csdn.net/bbj12345678/article/details/108433250
https://www.jianshu.com/p/aa2c42e41824

相关推荐

  1. SpringBoot 整合 RabbitMQ

    2023-12-25 14:04:03       34 阅读
  2. springboot整合RabbitMQ

    2023-12-25 14:04:03       28 阅读

最近更新

  1. TCP协议是安全的吗?

    2023-12-25 14:04:03       16 阅读
  2. 阿里云服务器执行yum,一直下载docker-ce-stable失败

    2023-12-25 14:04:03       16 阅读
  3. 【Python教程】压缩PDF文件大小

    2023-12-25 14:04:03       15 阅读
  4. 通过文章id递归查询所有评论(xml)

    2023-12-25 14:04:03       18 阅读

热门阅读

  1. obs video-io.c

    2023-12-25 14:04:03       30 阅读
  2. 策略模式(Strategy)

    2023-12-25 14:04:03       37 阅读
  3. Transformer 模型设计的灵感

    2023-12-25 14:04:03       34 阅读
  4. 【题解】洛谷 P9183 [USACO23OPEN] FEB B

    2023-12-25 14:04:03       38 阅读
  5. git拉取远程分支到本地

    2023-12-25 14:04:03       36 阅读
  6. 【前端基础】uniapp、axios 获取二进制图片

    2023-12-25 14:04:03       43 阅读
  7. 使用Uniapp随手记录知识点

    2023-12-25 14:04:03       37 阅读
  8. DrmOpenWithType

    2023-12-25 14:04:03       32 阅读
  9. go语言基础 -- 字符串及其常用函数

    2023-12-25 14:04:03       33 阅读