RabbitMQ使用参考-YS.pdf
70墨值下载
RabbitMQ使用参考
邹 业 盛 2 0 1 6 - 0 1 - 1 0 1 6 : 5 5 更 新
1 . 安 装
从 网 站 h t t p : / / w w w . r a b b i t m q . c o m / i n s t a l l - g e n e r i c - u n i x . h t m l 下 载 到 二 进 制
源 码 , 进 入 s b i n 目 录 , 直 接 运 行 s e r v e r 即 可 .
默 认 服 务 监 听 在 5 6 7 2 端 口 上 ( 带 上 S S L 默 认 在 5 6 7 1 上 ) .
2 . 基 本 概 念
R a b b i t M Q , 是 一 个 使 用 e r l a n g 编 写 的 A M Q P ( 高 级 消 息 队 列 协 议 ) 的 服 务 实 现 .
简 单 来 说 , 就 是 一 个 功 能 强 大 的 消 息 队 列 服 务 .
通 常 我 们 谈 到 队 列 服 务 , 会 有 三 个 概 念 , 发 消 息 者 , 队 列 , 收 消 息 者 . ( 消 息 本 来 也 应
该 算 是 一 个 独 立 的 概 念 , 但 是 简 单 处 理 之 下 , 它 可 能 并 没 有 太 多 的 内 涵 )
流 程 上 是 , 发 消 息 者 把 消 息 放 到 队 列 中 去 , 然 后 收 消 息 者 从 队 列 中 取 出 消 息 .
R a b b i t M Q 在 这 个 基 本 概 念 之 上 , 多 做 了 一 层 抽 象 , 在 发 消 息 者 和 队 列 之 间 , 加 入 了
交 换 器 ( E x c h a n g e ) . 这 样 发 消 息 者 和 队 列 就 没 有 直 接 联 系 , 转 而 变 成 发 消 息 者 把
消 息 给 交 换 器 , 交 换 器 根 据 调 度 策 略 再 把 消 息 再 给 队 列 .
当 然 , 多 一 层 抽 象 会 增 加 复 杂 度 , 但 是 同 时 , 功 能 上 也 更 灵 活 . 事 实 上 , 很 多 时 候 面 对 具 体
场 景 时 , 在 这 种 " 四 段 式 " 的 结 构 下 , 你 可 选 择 的 方 案 不 止 一 种 的 . 不 过 也 不 必 过 于 担 心 ,
在 一 些 自 我 规 定 的 " 原 则 " 之 下 , " 正 确 " 的 方 案 也 不 会 那 么 纠 结 .
总 结 一 下 4 + 1 个 概 念 , 或 者 说 , 五 种 角 色 :
P r o d u c i n g , 生 产 者 , 产 生 消 息 的 角 色 .
E x c h a n g e , 交 换 器 , 在 得 到 生 产 者 的 消 息 后 , 把 消 息 扔 到 队 列 的 角 色 .
Q u e u e , 队 列 , 消 息 暂 时 呆 的 地 方 .
C o n s u m i n g , 消 费 者 , 把 消 息 从 队 列 中 取 出 的 角 色 .
消 息 M e s s a g e , R a b b i t M Q 中 的 消 息 有 自 己 的 一 系 列 属 性 , 某 些 属 性 对 信 息 流 有 直 接
影 响 .
在 使 用 过 程 中 , 我 们 通 常 还 会 关 注 如 下 的 机 制 :
持 久 化 , 服 务 重 启 时 , 是 否 能 恢 复 队 列 中 的 数 据 .
调 度 策 略 , 交 换 器 如 何 把 消 息 给 到 哪 些 队 列 , 是 每 个 队 列 给 一 条 , 或 者 把 一 条 消 息 给 多 个
队 列 .
分 配 策 略 , 队 列 面 对 消 费 者 时 , 如 何 把 消 息 吐 出 去 , 来 一 个 消 费 者 就 把 消 息 全 给 它 , 还 是
只 给 一 条 .
状 态 反 馈 , 当 消 息 从 某 一 个 队 列 中 被 提 出 后 , 这 个 消 息 的 生 命 周 期 就 此 结 束 , 还 是 说 需 要
一 个 具 体 的 信 号 以 明 确 标 识 消 息 已 被 正 确 处 理 .
上 面 这 些 内 容 , 初 看 之 下 好 像 情 况 有 些 复 杂 了 , 不 过 在 具 体 使 用 过 程 中 , 这 些 东 西 都 是 很
自 然 地 需 要 考 虑 的 . 当 一 套 服 务 跑 起 来 之 后 , 这 些 细 枝 末 节 自 然 消 失 在 无 形 之 中 .
3 . 基 本 形 式
当 服 务 启 在 5 6 7 2 端 口 之 后 , 我 们 就 可 以 开 始 使 用 R a b b i t M Q 了 .
根 据 前 面 的 内 容 , 我 们 需 要 站 在 两 个 角 度 ( 消 息 的 提 供 方 , 和 消 息 的 使 用 方 ) , 去 分 别 考 虑
五 种 角 色 的 情 况 . 当 然 , 在 使 用 时 其 实 只 是 两 个 角 度 , 每 边 四 种 角 色 的 情 况 . 因 为 消 息 的
提 供 方 不 关 心 使 用 方 , 反 之 , 消 息 的 使 用 方 也 不 关 心 消 息 的 提 供 方 . 这 种 关 系 上 的 无 依 赖
本 身 是 " 队 列 服 务 " 的 一 个 最 大 使 用 意 义 所 在 , 用 于 业 务 间 的 分 离 ( 不 管 是 分 了 好 , 还 是 必
须 分 ) .
我 们 先 看 如 何 产 生 消 息 , 即 把 消 息 放 到 队 列 当 中 , 等 待 下 一 步 的 处 理 .
( 之 后 的 代 码 , 使 用 P y t h o n , 相 应 的 A M Q P 协 议 实 现 的 模 块 是 p i k a )
# -*- coding: utf-8 -*-
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.exchange_declare(exchange='first', type='fanout')
channel.queue_declare(queue='hello')
channel.queue_bind(exchange='first', queue='hello')
channel.basic_publish(exchange='first', routing_key='', body='Hello World!')
上 面 代 码 的 细 节 先 不 用 管 它 , 但 是 直 观 看 到 做 的 事 有 :
获 取 连 接 .
of 27
70墨值下载
【版权声明】本文为墨天轮用户原创内容，转载时必须标注文档的来源（墨天轮），文档链接，文档作者等基本信息，否则作者和墨天轮有权追究责任。如果您发现墨天轮中有涉嫌抄袭或者侵权的内容，欢迎发送邮件至：contact@modb.pro进行举报，并提供相关证据，一经查实，墨天轮将立刻删除相关内容。
下载排行榜
评论