搜索

[25257] 2016-07-17_用Python、RabbitMQ和Nameko实现微服务

文档创建者：s7ckTeam
浏览次数：1
最后更新：2025-01-18
2016-07-17_用Python、RabbitMQ和Nameko实现微服务 用   P y t h o n 、   R a b b i t M Q   和   N a m e k o   实 现 微 服 务 原 创   译 者 ： m r - p i n g   L i n u x 中 国   2 0 1 6 - 0 7 - 1 7 " 微 服 务 是 一 股 新 浪 潮 "   -   现 如 今 ， 将 项 目 拆 分 成 多 个 独 立 的 、 可 扩 展 的 服 务 是 保 障 代 码 演 变 的 最 好 选 择 。 在   P y t h o n   的 世 界 里 ， 有 个 叫 做 “ N a m e k o ”   的 框 架 ， 它 将 微 服 务 的 实 现 变 得 简 单 并 且 强 大 。 微 服 务 微 服 务 在 最 近 的 几 年 里 ， “ 微 服 务 架 构 ” 如 雨 后 春 笋 般 涌 现 。 它 用 于 描 述 一 种 特 定 的 软 件 应 用 设 计 方 式 ， 这 种 方 式 使 得 应 用 可 以 由 多 个 独 立 部 署 的 服 务 以 服 务 套 件 的 形 式 组 成 。   -   M .   F o w l e r 推 荐 各 位 读 一 下   F o w l e r   的 文 章 [ 1 ]   以 理 解 它 背 后 的 原 理 。 好 吧 ， 那 它 究 竟 意 味 着 什 么 呢 ？ 好 吧 ， 那 它 究 竟 意 味 着 什 么 呢 ？ 简 单 来 说 ， 微 服 务 架 构 微 服 务 架 构 可 以 将 你 的 系 统 拆 分 成 多 个 负 责 不 同 任 务 的 小 的 （ 单 一 上 下 文 内 ） r e s p o n s i b i l i t i e s   b l o c k s 功 能 块 ， 它 们 彼 此 互 无 感 知 ， 各 自 只 提 供 用 于 通 讯 的 c o m m o n   p o i n t 通 用 指 向 。 这 个 指 向 通 常 是 已 经 将 通 讯 协 议 和 接 口 定 义 好 的 消 息 队 列 。 这 里 给 大 家 提 供 一 个 真 实 案 例 这 里 给 大 家 提 供 一 个 真 实 案 例 案 例 的 代 码 可 以 通 过   g i t h u b :   h t t p : / / g i t h u b . c o m / r o c h a c b r u n o / n a m e k o - e x a m p l e   访 问 ， 查 看   s e r v i c e   和   a p i   文 件 夹 可 以 获 取 更 多 信 息 。 想 象 一 下 ， 你 有 一 个   R E S T   A P I   ， 这 个   A P I   有 一 个 端 点 （ L C T T   译 注 ： R E S T   风 格 的   A P I   可 以 有 多 个 端 点 用 于 处 理 对 同 一 资 源 的 不 同 类 型 的 请 求 ） 用 来 接 受 数 据 ， 并 且 你 需 要 将 接 收 到 的 数 据 进 行 一 些 运 算 工 作 。 那 么 相 比 阻 塞 接 口 调 用 者 的 请 求 来 说 ， 异 步 实 现 此 接 口 是 一 个 更 好 的 选 择 。 你 可 以 先 给 用 户 返 回 一 个   " O K   -   你 的 请 求 稍 后 会 处 理 "   的 状 态 ， 然 后 在 后 台 任 务 中 完 成 运 算 。 同 样 ， 如 果 你 想 要 在 不 阻 塞 主 进 程 的 前 提 下 ， 在 计 算 完 成 后 发 送 一 封 提 醒 邮 件 ， 那 么 将 “ 邮 件 发 送 ” 委 托 给 其 他 服 务 去 做 会 更 好 一 些 。 场 景 描 述 场 景 描 述
用 代 码 说 话 用 代 码 说 话 让 我 们 将 系 统 创 建 起 来 ， 在 实 践 中 理 解 它 ： 环 境 环 境 我 们 需 要 的 环 境 ： 运 行 良 好 的   R a b b i t M Q （ L C T T   译 注 ： R a b b i t M Q [ 2 ]   是 一 个 流 行 的 消 息 队 列 实 现 ） 由   V i r t u a l E n v   提 供 的   S e r v i c e s   虚 拟 环 境 由   V i r t u a l E n v   提 供 的   A P I 　 虚 拟 环 境 R a b b i t 在 开 发 环 境 中 使 用   R a b b i t M Q   最 简 单 的 方 式 就 是 运 行 其 官 方 的   d o c k e r   容 器 。 在 你 已 经 拥 有   D o c k e r   的 情 况 下 ， 运 行 ： 在 浏 览 器 中 访 问   h t t p : / / l o c a l h o s t : 1 5 6 7 2   ， 如 果 能 够 使 用   g u e s t : g u e s t   验 证 信 息 登 录   R a b b i t M Q   的 控 制 面 板 ， 说 明 它 已 经 在 你 的 开 发 环 境 中 运 行 起 来 了 。 1 .   d o c k e r   r u n   - d   - - h o s t n a m e   m y - r a b b i t   - - n a m e   s o m e - r a b b i t   - p   1 5 6 7 2 : 1 5 6 7 2   - p   5 6 7 2 : 5 6 7 2   r a b b i t m q : 3 - m a n a g e m e n t
服 务 环 境 服 务 环 境 现 在 让 我 们 创 建 微 服 务 来 满 足 我 们 的 任 务 需 要 。 其 中 一 个 服 务 用 来 执 行 计 算 任 务 ， 另 一 个 用 来 发 送 邮 件 。 按 以 下 步 骤 执 行 ： 在   S h e l l   中 创 建 项 目 的 根 目 录 用   v i r t u a l e n v   工 具 创 建 并 且 激 活 一 个 虚 拟 环 境 （ 你 也 可 以 使 用   v i r t u a l e n v - w r a p p e r ） 安 装   n a m e k o   框 架 和   y a g m a i l 服 务 的 代 码 服 务 的 代 码 现 在 我 们 已 经 准 备 好 了   v i r t u a l e n v   所 提 供 的 虚 拟 环 境 （ 可 以 想 象 成 我 们 的 服 务 是 运 行 在 一 个 独 立 服 务 器 上 的 ， 而 我 们 的   A P I   运 行 在 另 一 个 服 务 器 1 .   $   m k d i r   m y p r o j e c t 2 .   $   c d   m y p r o j e c t 1 .   $   v i r t u a l e n v   s e r v i c e _ e n v 2 .   $   s o u r c e   s e r v i c e _ e n v / b i n / a c t i v a t e 1 .   ( s e r v i c e _ e n v ) $   p i p   i n s t a l l   n a m e k o 2 .   ( s e r v i c e _ e n v ) $   p i p   i n s t a l l   y a g m a i l
上 ） ， 接 下 来 让 我 们 编 码 ， 实 现   n a m e k o   的   R P C   服 务 。 我 们 会 将 这 两 个 服 务 放 在 同 一 个   p y t h o n   模 块 中 ， 当 然 如 果 你 乐 意 ， 也 可 以 把 它 们 放 在 单 独 的 模 块 里 并 且 当 成 不 同 的 服 务 运 行 ： 在 名 为     的 文 件 中 3 .   6 .   1 5 .   1 9 .   s e r v i c e . p y 1 .   i m p o r t   y a g m a i l 2 .   f r o m   n a m e k o . r p c   i m p o r t   r p c ,   R p c P r o x y 4 .   c l a s s   M a i l ( o b j e c t ) : 5 .           n a m e   =   " m a i l " 7 .           @ r p c 8 .           d e f   s e n d ( s e l f ,   t o ,   s u b j e c t ,   c o n t e n t s ) : 9 .                   y a g   =   y a g m a i l . S M T P ( ' m y n a m e @ g m a i l . c o m ' ,   ' m y p a s s w o r d ' ) 1 0 .                   #   以 上 的 验 证 信 息 请 从 安 全 的 地 方 进 行 读 取 1 1 .                   #   贴 士 :   可 以 去 看 看   D y n a c o n f   设 置 模 块 1 2 .                   y a g . s e n d ( t o = t o . e n c o d e ( ' u t f - 8 ) ,   1 3 .                                     s u b j e c t = s u b j e c t . e n c o d e ( ' u t f - 8 ) ,   1 4 .                                     c o n t e n t s = [ c o n t e n t s . e n c o d e ( ' u t f - 8 ) ] ) 1 6 .   c l a s s   C o m p u t e ( o b j e c t ) : 1 7 .           n a m e   =   " c o m p u t e " 1 8 .           m a i l   =   R p c P r o x y ( ' m a i l ' )         2 0 .           @ r p c 2 1 .           d e f   c o m p u t e ( s e l f ,   o p e r a t i o n ,   v a l u e ,   o t h e r ,   e m a i l ) : 2 2 .                   o p e r a t i o n s   =   { ' s u m ' :   l a m b d a   x ,   y :   i n t ( x )   +   i n t ( y ) , 2 3 .                                               ' m u l ' :   l a m b d a   x ,   y :   i n t ( x )   *   i n t ( y ) , 2 4 .                                               ' d i v ' :   l a m b d a   x ,   y :   i n t ( x )   /   i n t ( y ) , 2 5 .                                               ' s u b ' :   l a m b d a   x ,   y :   i n t ( x )   -   i n t ( y ) } 2 6 .                   t r y : 2 7 .                           r e s u l t   =   o p e r a t i o n s [ o p e r a t i o n ] ( v a l u e ,   o t h e r ) 2 8 .                   e x c e p t   E x c e p t i o n   a s   e : 2 9 .                           s e l f . m a i l . s e n d . a s y n c ( e m a i l ,   " A n   e r r o r   o c c u r r e d " ,   s t r ( e ) )
现 在 我 们 已 经 用 以 上 代 码 定 义 好 了 两 个 服 务 ， 下 面 让 我 们 将   N a m e k o   R P C   s e r v i c e   运 行 起 来 。 注 意 ： 我 们 会 在 控 制 台 中 启 动 并 运 行 它 。 但 在 生 产 环 境 中 ， 建 议 大 家 使 用   s u p e r v i s o r d   替 代 控 制 台 命 令 。 在   S h e l l   中 启 动 并 运 行 服 务 测 试 测 试 在 另 外 一 个   S h e l l   中 （ 使 用 相 同 的 虚 拟 环 境 ） ， 用   n a m e k o   s h e l l   进 行 测 试 ： 现 在 你 已 经 处 在   R P C   客 户 端 中 了 ， S h e l l   的 测 试 工 作 是 通 过   n . r p c   对 象 来 进 行 的 ， 它 的 使 用 方 法 如 下 ： 2 9 .                           s e l f . m a i l . s e n d . a s y n c ( e m a i l ,   " A n   e r r o r   o c c u r r e d " ,   s t r ( e ) ) 3 0 .                           r a i s e 3 1 .                   e l s e : 3 2 .                           s e l f . m a i l . s e n d . a s y n c ( 3 3 .                                   e m a i l ,   3 4 .                                   " Y o u r   o p e r a t i o n   i s   c o m p l e t e ! " ,   3 5 .                                   " T h e   r e s u l t   i s :   % s "   %   r e s u l t 3 6 .                           ) 3 7 .                           r e t u r n   r e s u l t 1 .   ( s e r v i c e _ e n v ) $   n a m e k o   r u n   s e r v i c e   - - b r o k e r   a m q p : / / g u e s t : g u e s t @ l o c a l h o s t 2 .   s t a r t i n g   s e r v i c e s :   m a i l ,   c o m p u t e 3 .   C o n n e c t e d   t o   a m q p : / / g u e s t : * * @ 1 2 7 . 0 . 0 . 1 : 5 6 7 2 / / 4 .   C o n n e c t e d   t o   a m q p : / / g u e s t : * * @ 1 2 7 . 0 . 0 . 1 : 5 6 7 2 / / 1 .   ( s e r v i c e _ e n v ) $   n a m e k o   s h e l l   - - b r o k e r   a m q p : / / g u e s t : g u e s t @ l o c a l h o s t 2 .   N a m e k o   P y t h o n   2 . 7 . 9   ( d e f a u l t ,   A p r     2   2 0 1 5 ,   1 5 : 3 3 : 2 1 )   3 .   [ G C C   4 . 9 . 2 ]   s h e l l   o n   l i n u x 2 4 .   B r o k e r :   a m q p : / / g u e s t : g u e s t @ l o c a l h o s t 5 .   > > > 1 .   > > >   n . r p c . m a i l . s e n d ( " n a m e @ e m a i l . c o m " ,   " t e s t i n g " ,   " J u s t   t e s t i n g " )
上 边 的 代 码 会 发 送 一 封 邮 件 ， 我 们 同 样 可 以 调 用 计 算 服 务 对 其 进 行 测 试 。 需 要 注 意 的 是 ， 此 测 试 还 会 附 带 进 行 异 步 的 邮 件 发 送 。 在 在   A P I   中 调 用 微 服 务 中 调 用 微 服 务 在 另 外 一 个   S h e l l   中 （ 甚 至 可 以 是 另 外 一 台 服 务 器 上 ） ， 准 备 好   A P I   环 境 。 用   v i r t u a l e n v   工 具 创 建 并 且 激 活 一 个 虚 拟 环 境 （ 你 也 可 以 使 用   v i r t u a l e n v - w r a p p e r ） 安 装   N a m e k o 、   F l a s k   和   F l a s g g e r 注 意 ：   在   A P I   中 并 不 需 要   y a g m a i l   ， 因 为 在 这 里 ， 处 理 邮 件 是 服 务 的 职 责 创 建 含 有 以 下 内 容 的     文 件 ： 1 .   > > >   n . r p c . c o m p u t e . c o m p u t e ( ' s u m ' ,   3 0 ,   1 0 ,   " n a m e @ e m a i l . c o m " ) 2 .   4 0 3 .   > > >   n . r p c . c o m p u t e . c o m p u t e ( ' s u b ' ,   3 0 ,   1 0 ,   " n a m e @ e m a i l . c o m " ) 4 .   2 0 5 .   > > >   n . r p c . c o m p u t e . c o m p u t e ( ' m u l ' ,   3 0 ,   1 0 ,   " n a m e @ e m a i l . c o m " ) 6 .   3 0 0 7 .   > > >   n . r p c . c o m p u t e . c o m p u t e ( ' d i v ' ,   3 0 ,   1 0 ,   " n a m e @ e m a i l . c o m " ) 8 .   3 1 .   $   v i r t u a l e n v   a p i _ e n v 2 .   $   s o u r c e   a p i _ e n v / b i n / a c t i v a t e 1 .   ( a p i _ e n v ) $   p i p   i n s t a l l   n a m e k o 2 .   ( a p i _ e n v ) $   p i p   i n s t a l l   f l a s k 3 .   ( a p i _ e n v ) $   p i p   i n s t a l l   f l a s g g e r a p i . p y 1 .   f r o m   f l a s k   i m p o r t   F l a s k ,   r e q u e s t 2 .   f r o m   f l a s g g e r   i m p o r t   S w a g g e r 3 .   f r o m   n a m e k o . s t a n d a l o n e . r p c   i m p o r t   C l u s t e r R p c P r o x y
4 .   8 .   9 .   5 .   a p p   =   F l a s k ( _ _ n a m e _ _ ) 6 .   S w a g g e r ( a p p ) 7 .   C O N F I G   =   { ' A M Q P _ U R I ' :   " a m q p : / / g u e s t : g u e s t @ l o c a l h o s t " } 1 0 .   @ a p p . r o u t e ( ' / c o m p u t e ' ,   m e t h o d s = [ ' P O S T ' ] ) 1 1 .   d e f   c o m p u t e ( ) : 1 2 .           " " " 1 3 .           M i c r o   S e r v i c e   B a s e d   C o m p u t e   a n d   M a i l   A P I 1 4 .           T h i s   A P I   i s   m a d e   w i t h   F l a s k ,   F l a s g g e r   a n d   N a m e k o 1 5 .           - - - 1 6 .           p a r a m e t e r s : 1 7 .               -   n a m e :   b o d y 1 8 .                   i n :   b o d y 1 9 .                   r e q u i r e d :   t r u e 2 0 .                   s c h e m a : 2 1 .                       i d :   d a t a 2 2 .                       p r o p e r t i e s : 2 3 .                           o p e r a t i o n : 2 4 .                               t y p e :   s t r i n g 2 5 .                               e n u m : 2 6 .                                   -   s u m 2 7 .                                   -   m u l 2 8 .                                   -   s u b 2 9 .                                   -   d i v 3 0 .                           e m a i l : 3 1 .                               t y p e :   s t r i n g 3 2 .                           v a l u e : 3 3 .                               t y p e :   i n t e g e r 3 4 .                           o t h e r : 3 5 .                               t y p e :   i n t e g e r 3 6 .           r e s p o n s e s : 3 7 .               2 0 0 : 3 8 .                   d e s c r i p t i o n :   P l e a s e   w a i t   t h e   c a l c u l a t i o n ,   y o u ' l l   r e c e i v e   a n   e m a i l   w i t h   r e s u l t s
5 2 .   在 其 他 的   s h e l l   或 者 服 务 器 上 运 行 此 文 件 然 后 访 问   h t t p : / / l o c a l h o s t : 5 0 0 0 / a p i d o c s / i n d e x . h t m l   这 个   u r l ， 就 可 以 看 到   F l a s g g e r   的 界 面 了 ， 利 用 它 可 以 进 行   A P I   的 交 互 并 可 以 发 布 任 务 到 队 列 以 供 服 务 进 行 消 费 。 3 9 .           " " " 4 0 .           o p e r a t i o n   =   r e q u e s t . j s o n . g e t ( ' o p e r a t i o n ' ) 4 1 .           v a l u e   =   r e q u e s t . j s o n . g e t ( ' v a l u e ' ) 4 2 .           o t h e r   =   r e q u e s t . j s o n . g e t ( ' o t h e r ' ) 4 3 .           e m a i l   =   r e q u e s t . j s o n . g e t ( ' e m a i l ' ) 4 4 .           m s g   =   " P l e a s e   w a i t   t h e   c a l c u l a t i o n ,   y o u ' l l   r e c e i v e   a n   e m a i l   w i t h   r e s u l t s " 4 5 .           s u b j e c t   =   " A P I   N o t i f i c a t i o n " 4 6 .           w i t h   C l u s t e r R p c P r o x y ( C O N F I G )   a s   r p c : 4 7 .                   #   a s y n c h r o n o u s l y   s p a w n i n g   a n d   e m a i l   n o t i f i c a t i o n 4 8 .                   r p c . m a i l . s e n d . a s y n c ( e m a i l ,   s u b j e c t ,   m s g ) 4 9 .                   #   a s y n c h r o n o u s l y   s p a w n i n g   t h e   c o m p u t e   t a s k 5 0 .                   r e s u l t   =   r p c . c o m p u t e . c o m p u t e . a s y n c ( o p e r a t i o n ,   v a l u e ,   o t h e r ,   e m a i l ) 5 1 .                   r e t u r n   m s g ,   2 0 0 5 3 .   a p p . r u n ( d e b u g = T r u e ) 1 .   ( a p i _ e n v )   $   p y t h o n   a p i . p y   2 .     *   R u n n i n g   o n   h t t p : / / 1 2 7 . 0 . 0 . 1 : 5 0 0 0 /   ( P r e s s   C T R L + C   t o   q u i t )
注 意 ：   你 可 以 在   s h e l l   中 查 看 到 服 务 的 运 行 日 志 ， 打 印 信 息 和 错 误 信 息 。 也 可 以 访 问   R a b b i t M Q   控 制 面 板 来 查 看 消 息 在 队 列 中 的 处 理 情 况 。 N a m e k o   框 架 还 为 我 们 提 供 了 很 多 高 级 特 性 ， 你 可 以 从   h t t p s : / / n a m e k o . r e a d t h e d o c s . o r g / e n / s t a b l e /   获 取 更 多 的 信 息 。 别 光 看 了 ， 撸 起 袖 子 来 ， 实 现 微 服 务 ! v i a :   h t t p : / / b r u n o r o c h a . o r g / p y t h o n / m i c r o s e r v i c e s - w i t h - p y t h o n - r a b b i t m q - a n d - n a m e k o . h t m l 作 者 :   B r u n o   R o c h a [ 3 ]   译 者 :   m r - p i n g [ 4 ]   校 对 :   w x y [ 5 ] 本 文 由   L C T T [ 6 ]   原 创 编 译 ， L i n u x 中 国 [ 7 ]   荣 誉 推 出 [ 1 ] :   h t t p : / / m a r t i n f o w l e r . c o m / a r t i c l e s / m i c r o s e r v i c e s . h t m l [ 2 ] :   h t t p : / / r a b b i t m q . m r - p i n g . c o m / d e s c r i p t i o n . h t m l [ 3 ] :   h t t p : / / f a c e b o o k . c o m / r o c h a c b r u n o [ 4 ] :   h t t p : / / w w w . m r - p i n g . c o m
[ 5 ] :   h t t p s : / / g i t h u b . c o m / w x y [ 6 ] :   h t t p s : / / g i t h u b . c o m / L C T T / T r a n s l a t e P r o j e c t [ 7 ] :   h t t p s : / / l i n u x . c n / 推 荐 文 章 推 荐 文 章 点 击 标 题 或 输 入 文 章   I D   直 达 该 文 章 将 文 章 分 享 给 朋 友 是 对 我 们 最 好 的 赞 赏 ！ 阅 读 原 文
回复

举报

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

使用Markdown编辑器编辑 使用富文本编辑器编辑

Archiver| 手机版| 小黑屋|
Powered by Discuz! X3.4 Copyright © 2001-2020, Tencent Cloud. 商业源码建议获取授权，如侵犯您的权益，请联系客服处理