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

RabbitMQ入门

RabbitMQ 是一个基于 ​​AMQP 协议​​ 的开源消息队列,用于实现系统间的 ​​异步通信​​、​​解耦​​ 和 ​​流量削峰​​。

同步和异步

什么时候时候用同步调用

下一步的操作必须要依赖上一步的操作执行的结果,比如说扣款,扣完款必须要知道是否扣款成功,没扣款成功肯定是不能走下一步;还有查询,必须要查询到东西才能走下一步。能立刻得到响应结果。需要阻塞等待

同步调用的问题

拓展性差,性能下降,级联失败(链路上一个点掉了,整个链全阻塞)

异步调用

异步调用实际上就是基于消息通知。

消息发送者:投递消息的人,就是原来的调用方

消息代理:管理、暂存、转发消息,你可以把它理解成微信服务器

消息接收者:接收和处理消息的人,就是原来的服务提供方。监听消息代理即可

优点:

缺点:

消息队列无法拿到接收者的消息,接收者执行的怎么样了,完全不知道

不能立刻得到调用结果,时效性差。不确定下游应用是否执行成功。业务安全性依赖于消息代理,如果消息代理挂了,后面业务全都挂

什么时候用异步调用

对后面业务的返回结果不关心,调用链太长的情况


rabbitMQ快速入门

交换机是路由转发消息的,本身没有存储消息的能力

交换机必须和队列有绑定,才能将消息转发至队列,队列存储消息,在适时发送给消费者

怎么实现数据隔离

可以自己定义添加virtualHost。不同的虚拟主机就可以实现数据隔离。

也可以创建不同用户,管理不同的虚拟主机,用户权限也可以自定义,不能操作别人的虚拟主机

所以应该给每一个项目创建一个用户,一个虚拟主机。


java怎么操作rabbitMQ

官方的api太复杂了,我们使用springAMQP(基础抽象)

发消息
引入依赖--编写yml文件(配置rabbitMQ主机、端口、用户名、密码等)--使用RabbitTemplate工具类就可以放松消息--接收消息,在方法上加@RabbitListener(指定队列名),方法参数直接接收。

发送者和消费者都要配置yml文件(配置rabbitMQ主机、端口、用户名、密码等)。

相关文章:

  • 大数据+智能零售:数字化变革下的“智慧新零售”密码
  • 【Docker 02】Docker 安装
  • 【Mac 从 0 到 1 保姆级配置教程 16】- Docker 快速安装配置、常用命令以及实际项目演示
  • Maven入门(够用)
  • windows10下搭建nfs服务器
  • Maven的使用
  • maven 1.0.0idea的使用说明
  • amd64 -- buildx linux 镜像 Docker docker
  • 0x-3-Oracle 23 ai-sqlcl 25.1 集成安装-配置和优化
  • 大数据治理的常见方式
  • uniapp跳转到webview组件的时候,要注意:移除所有不可见字符(包括零宽空格)
  • Fetch API 使用详解:Bearer Token 与 localStorage 实践
  • spring中的@KafkaListener 注解详解
  • uni-app学习笔记二十三--交互反馈showToast用法
  • LeetCode - 560. 和为 K 的子数组
  • 【西门子杯工业嵌入式-5-串口实现数据收发】
  • java中static学习笔记
  • ubuntu下编译osg3.6.5源码
  • AT_abc409_e [ABC409E] Pair Annihilation
  • 【JAVA】javadoc —— 如何生成标准的 Java API 文档
  • 花钱做网站需要所有权/搜狗网页版
  • 中小企业网站建设示范平台/南宁网站运营优化平台
  • 新建网站seo优化怎么做/百度关键词查询网站
  • 企业门户网站建设论文/关键词有哪几种
  • 网站开发投标文件/百度软文推广怎么做
  • 地级市政府网站建设评估/安装百度到手机桌面