• RabbitMQ基本使用一


    消息队列(MQ)
    MQ全称Message Queue,是一种应用程序对应用程序的通信方式。应用程序通过读写出入队列的消息来通信,而无需专用连接来连接它们。消息传递指的是程序之间通过在消息中发送数据进行通信,而不是通过直接调用彼此来进行通信(直接调用通常是用于诸如远程过程调用的技术)。

    消息队列是典型的:生产者、消费者模型。 生产者不断向消息队列中生产消息,消费者不断的从队列中获取消息。因为消息的生产和消费都是异步的,而且只关心消息的发送和接收,没有业务逻辑的侵入,这样就实现了生产者和消费者的解耦。

    就比如在一个电商项目中:

    商品的原始数据保存在数据库中,增删改查都在数据库中完成。
    搜索服务数据来源是索引库(Elasticsearch),如果数据库商品发生变化,索引库数据不能及时更新。
    商品详情做了页面静态化处理,静态页面数据也不会随着数据库商品更新而变化。
    如果我们在后台修改了商品的价格,就需要搜索页面和商品详情页也对商品价格进行修改。 当商品价格出现改动时,后台会向MQ发送一条消息(比如包含商品id的消息)。 搜索服务和静态页面服务监听MQ,接收消息,然后分别对索引库和静态页面进行更新。

    在这个过程中商品服务只管发送消息,而不用关心消息被谁接收,搜索服务和静态页面服务接收消息,分别去处理索引库和静态页面。如果以后有其它系统也依赖商品服务的数据,同样监听消息即可,商品服务无需任何代码修改。

    AMQP和JMS
    MQ是消息通信的模型,并不是具体实现。现在实现MQ的有两种主流方式:AMQP、JMS。

    AMQP( Advanced Message Queuing Protocol),是一个提供统一消息服务的应用层标准高级消息队列协议,是应用层协议的开放标准为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息,并不受客户端中间件不同产品,不同的开发语言等条件的限制。Eang中的实现有 Rabbits等

    JMS (Java Messageservice),是由Sun公司早期提出的消息标准,旨在为Java应用提供统一的消息操作,包括 create、send、 receive 等。JMS已经成为 java Enterprise Edition的一部分。从使用角度看,JMS和JDBC担任差不多的角色,用户都是根据相应的接口可以和实现了MS的服务进行通信,进行相关的操作。

    两者间的区别和联系:

    JMS是定义了统一的接口,来对消息操作进行统一;AMQP是通过规定协议来统一数据交互的格式
    JMS限定了必须使用Java语言;AMQP只是协议,不规定实现方式,因此是跨语言的。
    JMS规定了两种消息模型;而AMQP的消息模型更加丰富

    想学习更多JAVA知识的看这里哦

    https://www.bilibili.com/video/BV1qL411u7eEicon-default.png?t=M7J4https://www.bilibili.com/video/BV1qL411u7eE

  • 相关阅读:
    前端开发趋势:WebAR、VR与沉浸式体验
    【数学建模】熵权法
    基于linux系统的CAN总线移动机器人- 板子烧入linux系统
    Pandas+Matplotlib 数据分析
    mysql中使用聚合函数结果集为空,仍显示size为1,所有元素为Null问题的解决
    微服务(Microservice)那点事儿
    Hadoop Hbase
    2024年山东省职业院校技能大赛中职组“网络安全”赛项竞赛试题-C
    MODOBUS伺服通讯设置
    如何用C/C++实现去除字符串头和尾指定的字符
  • 原文地址:https://blog.csdn.net/Abcd6578787_/article/details/126638152