RabbitMQ学习

AMQP协议

AMQP(高级消息队列协议)是一个能让符合统一标准的客户端和中间件进行消息传输的消息协议。是RabbitMQ主要实现支持的协议的一种。

涉及到的相关概念的介绍
publisher:发送消息到broker的客户端。
receiver:接受broker发来的消息的客户端。

AMQP消息模型

Publisher发送到broker的消息,首先被发到了broker中的ExchangesExchanges根据被称作bindings的规则,将消息的拷贝发送到对应的queues中,然后broker会将queues中的消息发送到订阅相应queues的consumer。

Exchanges,bindings和queues被统称为amqp的实体

Excange and Exchange Types

pulisher实际是发送消息到broker中的Exchanges,然后Exchanges将消息路由到对应的queues。路由规则是由Exchange type和bindings来决定的。

Exchange Types

Name Default pre-declared names
Direct exchange (Empty string) and amq.direct
Fanout exchange amq.fanout
Topic exchange amq.topic
Headers exchange amq.match (and amq.headers in RabbitMQ)

在声明Exchange时,除了可以指定Exchange Type,还可以指定一些其它的属性:

  • Name
  • Durability (定义Exchange是永久还是临时的,临时性的Exchange在broker重启后就会消失)
  • Auto-delete (定义这个属性后,当没有任何queue和此Exchange绑定时,此Exchange会被自动删除)
  • Arguments (optional, used by plugins and broker-specific features)

Default Exchange

default exchange 是被broker预先声明的name为空的direct exchange。
当使用default exchange 时,我们声明一个名为"xxxxx"的queue,这个queue会以值为"xxxxx"的route-key绑定到default exchange。(即声明的queue会自动以queue name作为routing key绑定)

Direct Exchange

direct exchange根据消息的routing key将消息发送给相应的queue。
direct exchange对用于将任务循环分配给多个worker的场景。消息会被负载均衡到多个consumer,不是负载均衡到多个queue。

自己理解的完整消息转发流程

在exchange type 为direct的情况下,broker会把匹配上routing_key的消息完整的发送给每一个合适的queue里,然后queue会将消息均衡到绑定到器上的


Fanout Exchange

broker会把发送到fanout exchange的消息转发给所有绑定到此exchange的queue,不会去匹配routing key。


Topic Exchange

Headers Exchange

headers exchange 通过消息头部的属性而不是routing_key进行消息路由。


java客户端代码开发示例

主要接口和方法

Exchange 声明

exchangeDeclare(String exchange, BuiltinExchangeType type,boolean durable, boolean autoDelete):声明non-autodelete, non-durable

DIRECT

服务端安装和配置

安装(ubuntu14.04)

直接通过apt repository进行安装

    echo 'deb http://www.rabbitmq.com/debian/ testing main' | sudo tee /etc/apt/sources.list.d/rabbitmq.list
    wget -O- https://www.rabbitmq.com/rabbitmq-release-signing-key.asc | sudo apt-key add -
    sudo apt-get update
    sudo apt-get install rabbitmq-server

** 安装相关问题参考地址:http://http://www.rabbitmq.com/install-debian.html **

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 217,509评论 6 504
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 92,806评论 3 394
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 163,875评论 0 354
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,441评论 1 293
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,488评论 6 392
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,365评论 1 302
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,190评论 3 418
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 39,062评论 0 276
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,500评论 1 314
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,706评论 3 335
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,834评论 1 347
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,559评论 5 345
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,167评论 3 328
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,779评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,912评论 1 269
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,958评论 2 370
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,779评论 2 354

推荐阅读更多精彩内容