天玑阁

vuePress-theme-reco gqsu    2018 - 2021
天玑阁 天玑阁

Choose mode

  • dark
  • auto
  • light
主页
时间轴
文档
  • vuepress-reco
分类
  • elasticsearch
  • Hadoop
  • life
  • linux
  • note
  • Apache James
  • collection
  • Dubbo
  • git
  • jwt
  • k8s
  • mongodb
  • ali
  • netty-socketio
  • nginx
  • node
  • oracle
  • own
  • rabbitmq
  • shell
  • vuepress
  • springDataJpa
  • web
  • wechat
  • redis
  • springBoot
  • rabbitmq,springBoot
  • springCloud
  • sql
  • study
  • util
标签
author-avatar

gqsu

156

Article

42

Tag

    主页
    时间轴
    文档
    • vuepress-reco
    分类
    • elasticsearch
    • Hadoop
    • life
    • linux
    • note
    • Apache James
    • collection
    • Dubbo
    • git
    • jwt
    • k8s
    • mongodb
    • ali
    • netty-socketio
    • nginx
    • node
    • oracle
    • own
    • rabbitmq
    • shell
    • vuepress
    • springDataJpa
    • web
    • wechat
    • redis
    • springBoot
    • rabbitmq,springBoot
    • springCloud
    • sql
    • study
    • util
    标签

    rabbitmq,springBoot Categories

    vuePress-theme-reco gqsu    2018 - 2021
    • elasticsearch 20
    • Hadoop 2
    • life 6
    • linux 9
    • note 9
    • Apache James 2
    • collection 1
    • Dubbo 1
    • git 1
    • jwt 1
    • k8s 1
    • mongodb 1
    • ali 2
    • netty-socketio 2
    • nginx 2
    • node 3
    • oracle 1
    • own 1
    • rabbitmq 2
    • shell 1
    • vuepress 1
    • springDataJpa 1
    • web 2
    • wechat 2
    • redis 6
    • springBoot 27
    • rabbitmq,springBoot 1
    • springCloud 13
    • sql 6
    • study 24
    • util 5
    rabbitmq--整合springBoot

    # 基础知识

    # 1、队列、生产者、消费者

    队列(queue)是RabbitMQ的内部对象,用于存储消息。 生产者(proverder ),生产消息并投递到队列中。 消费者(consumer)可以从队列中获取消息并消费。如果有多个消费者,队列中的消息会平均分摊给各个消费者,而不是每个消费者能获取所有的队列消息并处理。

    实际情况,一般是生产者绑定Exchange(交换机),通过指定一个Binding key,将Exchange与Queue绑定关联起来。 于是,生产者可以通过Routing key指定具体的路由规则,决定消息流向那个Queue中。Bindingkey与Rounting key一致才能取出该队列。

    # 2、Exchange交换机

    RabbitMQ常用的Exchange Type有四种:fanout、direct、topic、headers 。

    • direct:(默认方式)创建消息队列的时候,指定一个BindingKey。当发送者发送消息的时候,指定对应的Key。当Key和消息队列的BindingKey一致的时候,消息将会被发送到该消息队列中。先匹配,在投送。

    • topic:转发信息主要是依据通配符(.和*),队列和交换机的绑定主要是依据一种模式(通配符+字符串),而当发送消息的时候,只有指定的Key和该模式相匹配的时候,消息才会被发送到该消息队列中。最为灵活的方式。

    • headers:队列和交换机的绑定的通过指定的一组键值对,而发送消息的时候也会指定一组键值对规则,当两组键值对规则相匹配的时候,消息会被发送到匹配的消息队列中。

    • fanout:把所有发送到该Exchange的消息投递到所有与它绑定的队列中,设置的任何Key此时都无效。消息广播方式。

    “quick.orange.rabbit”指定了两个队列 *.orange和 *.rabbit

    简而言之,分为6种, 一对一生产消费模式,一对多生产消费模式、订阅发布模式、路由模式、主题模式、远程调用模式。 参考

    gqsu 2018/6/28上午9:46:04 springBoot
    Prev 1 ... 1 ... 1 Next Jump To Go