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

RabbitMq——direct交换器、fanout交换器、 topic交换器

direct交换器:

@Configuration
=发送=
@Bean
protected Queue queue(){
    Queue queue = new Queue(“myQueue”)
    return queue;
}
amqpTemplate.convertAndSend("myQueue","这是发送的内容"); 发送RabbitMq
发送成功

=接收=消费者(新项目)
@Conponent
@RabbitListener(queues=“myQueue”)注解某个方法为接收消息方法
public void Demo(String message){
}
@Conponent
  (queues=“myQueue”)注解某个方法为接收消息方法
public void Demo2(String message){
}

fanout交换器 扇形交换器:
@Configuration
=发送=
@Bean
protected Queue createQueue1(){
    Queue queue = new Queue(“myfanout1”)
    return queue;
}
@Bean
protected Queue createQu


http://www.kler.cn/a/271421.html

相关文章:

  • JAVA(SpringBoot)集成Kafka实现消息发送和接收。
  • C++中常用的十大排序方法之1——冒泡排序
  • Ubuntu安装VMware17
  • INCOSE需求编写指南-附录 D: 交叉引用矩阵
  • Maui学习笔记- SQLite简单使用案例02添加详情页
  • java——继承
  • wayland(xdg_wm_base) + egl + opengles 渲染使用纹理贴图的旋转 3D 立方体实例(十三)
  • 【NLP笔记】文本分词、清洗和标准化
  • 【学习学习】学习金字塔
  • 前端小白的学习之路(HTML5 二)
  • Fork - 将 GitHub 的某个特定仓库复制到自己的账户下
  • 【数据可视化】使用Python + Gephi,构建中医方剂关系网络图!
  • Acwing.1343 挤牛奶(区间合并or差分)
  • 爬虫基本原理介绍、实现以及问题解决
  • html编辑器
  • 分布式链路追踪(一)SkyWalking(2)使用
  • 橡胶工厂5G智能制造数字孪生可视化平台,推进橡胶工业数字化转型
  • 数据结构与算法----复习Part 16 (并查集)
  • R语言实现中介分析(1)
  • 2024 年系统架构设计师(全套资料)
  • 分布式ID(8):分布式ID生成方法
  • 使用Nginx进行负载均衡
  • 【好玩的经典游戏】Docker环境下部署经典贪吃蛇小游戏
  • CommandInvokationFailure: Failed to update Android SDK package list. 报错的解决方法
  • mac打开exe文件的三大方法 mac怎么运行exe文件 mac打开exe游戏 macbookpro打开exe
  • ArrayList和LinkedList区别