日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時間：8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
硬肝一次 Python 微服務(wù)是一種什么體驗(yàn)？

本文轉(zhuǎn)載自微信公眾號「AirPython」，作者星安果。轉(zhuǎn)載本文請聯(lián)系A(chǔ)irPython公眾號。

為桓仁等地區(qū)用戶提供了全套網(wǎng)頁設(shè)計(jì)制作服務(wù)，及桓仁網(wǎng)站建設(shè)行業(yè)解決方案。主營業(yè)務(wù)為成都網(wǎng)站制作、網(wǎng)站設(shè)計(jì)、外貿(mào)網(wǎng)站建設(shè)、桓仁網(wǎng)站設(shè)計(jì)，以傳統(tǒng)方式定制建設(shè)網(wǎng)站，并提供域名空間備案等一條龍服務(wù)，秉承以專業(yè)、用心的態(tài)度為用戶提供真誠的服務(wù)。我們深信只要達(dá)到每一位用戶的要求，就會得到認(rèn)可，從而選擇與我們長期合作。這樣，我們也可以走得更遠(yuǎn)！

1. 前言

大家好，我是安果!

考慮到 Python 性能及效率性，Python Web 端一直不溫不火，JAVA 和 Golang 的微服務(wù)生態(tài)一直很繁榮，也被廣泛用于企業(yè)級應(yīng)用開發(fā)當(dāng)中

本篇文章將介紹一款 Python 微服務(wù)框架：「 Nameko 」

2. Nameko 介紹

Nameko 是一款小巧、簡潔的、異步通信方式的微服務(wù)架構(gòu)

它采用 RabbitMQ 消息隊(duì)列作為消息中間件，基于發(fā)布者、訂閱者模式

其中，消費(fèi)者與生產(chǎn)者基于 RPC 進(jìn)行通訊

項(xiàng)目地址：https://github.com/nameko/nameko

3. 實(shí)戰(zhàn)一下

下面以 Flask 為例聊聊搭建 Python 微服務(wù)的步驟

3-1 安裝 RabbitMQ 及啟動

這里推薦利用 Docker 安裝 RabbitMQ，以 Centos 為例

 
 
 
      
  
  
  1. # 1、下載某個版本的RabbitMQ的鏡像 
    2.   
  
  
  2. # MQ版本號：3.9.5 
    3.   
  
  
  3. docker pull rabbitmq:3.9.5-management 
    4.   
  
  
  4.  
    5.   
  
  
  5. # 2、查看鏡像 
    6.   
  
  
  6. docker images 
    7.   
  
  
  7.  
    8.   
  
  
  8. # 3、啟動MQ容器 
    9.   
  
  
  9. # p：指定應(yīng)用端口及Web控制臺端口 
    10.   
  
  
  10. # hostname：主機(jī)名 
    11.   
  
  
  11. # e：環(huán)境變量 
    12.   
  
  
  12. # RABBITMQ_DEFAULT_VHOST：虛擬機(jī)名稱 
    13.   
  
  
  13. # RABBITMQ_DEFAULT_USER：用戶名 
    14.   
  
  
  14. # RABBITMQ_DEFAULT_PASS：密碼 
    15.   
  
  
  15. # 3e83da0dc938：MQ鏡像ID 
    16.   
  
  
  16. docker run -d --name rabbitmq3.9.5 -p 5672:5672 -p 15672:15672 -v `pwd`/data:/var/lib/rabbitmq --hostname myRabbit -e RABBITMQ_DEFAULT_VHOST=my_vhost  -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin 3e83da0dc938 
    17.

需要注意的是，啟動 MQ 容器時，利用 -p 指定了兩個端口

  • 5672

應(yīng)用訪問端口

  • 15672

控制臺 Web 訪問端口號

然后，開放防火墻的 5672、15672 端口號

PS：如果是云服務(wù)器，需要另外配置安全組

最后，在瀏覽器中通過下面的連接進(jìn)入到 MQ 后臺 Web 管理頁面

地址：http://ip地址:15672

3-2 安裝依賴包

使用 pip 命令在虛擬環(huán)境下安裝 nameko、flask 依賴包

 
 
 
      
  
  
  1. # 安裝依賴包 
    2.   
  
  
  2. # nameko 
    3.   
  
  
  3. pip3 install nameko 
    4.   
  
  
  4.  
    5.   
  
  
  5. # flask 
    6.   
  
  
  6. pip3 install flask 
    7.

3-3 創(chuàng)建服務(wù)生產(chǎn)者 Producer

自定一個類，使用 name 屬性定義服務(wù)的名稱為「 generate_service 」

然后使用裝飾器「 rpc 」注冊服務(wù)中具體的方法

 
 
 
      
  
  
  1. # producer_service.py 
    2.   
  
  
  2.  
    3.   
  
  
  3. from nameko.rpc import rpc 
    4.   
  
  
  4.  
    5.   
  
  
  5. class GenerateService(object): 
    6.   
  
  
  6.     # 定義微服務(wù)名稱 
    7.   
  
  
  7.     name = "generate_service" 
    8.   
  
  
  8.  
    9.   
  
  
  9.     @rpc 
    10.   
  
  
  10.     def hello_world(self, msg): 
    11.   
  
  
  11.         print('hello,i am been called by customer（消費(fèi)者）,返回消息：{}'.format(msg)) 
    12.   
  
  
  12.  
    13.   
  
  
  13.         # 返回結(jié)果 
    14.   
  
  
  14.         return "Hello World!I Am a msg from producer!" 
    15.

3-4 發(fā)布注冊服務(wù)

使用 nameko 命令在終端將目標(biāo)文件中的服務(wù)注冊到 MQ 中

 
 
 
      
  
  
  1. # 注冊服務(wù) 
    2.   
  
  
  2. # producer_service：目標(biāo)文件 
    3.   
  
  
  3. # admin:admin：MQ用戶名及密碼 
    4.   
  
  
  4. # ip地址:5672：MQ服務(wù)器ip地址及應(yīng)用端口號 
    5.   
  
  
  5. # my_vhost：虛擬機(jī)名 
    6.   
  
  
  6. nameko run producer_service --broker amqp://admin:admin@ip地址:5672/my_vhost 
    7.

其中，my_vhost 對應(yīng) MQ 容器啟動時配置的虛擬機(jī)名

3-5 Flask 定義 API 及消費(fèi)者調(diào)用服務(wù)

為了演示方便，這里使用 Flask 編寫一個簡單的 API

首先，定義 MQ 連接信息

然后，編寫一個 API 接口，請求方式為 GET

最后，使用 nameko 中的「 ClusterRpcProxy 」拿到消費(fèi)者對象去調(diào)用服務(wù)中的具體方法

 
 
 
      
  
  
  1. from flask import Flask 
    2.   
  
  
  2. from nameko.standalone.rpc import ClusterRpcProxy 
    3.   
  
  
  3.  
    4.   
  
  
  4. app = Flask(__name__) 
    5.   
  
  
  5.  
    6.   
  
  
  6. # MQ配置 
    7.   
  
  
  7. config_mq = {'AMQP_URI': "amqp://admin:admin@ip地址:5672/my_vhost"} 
    8.   
  
  
  8.  
    9.   
  
  
  9. @app.route('/hello_world', methods=['GET']) 
    10.   
  
  
  10. def call_service(): 
    11.   
  
  
  11.     with ClusterRpcProxy(config_mq) as rpc: 
    12.   
  
  
  12.         # 消費(fèi)者調(diào)用微服務(wù)(生產(chǎn)者)，獲取服務(wù)（生產(chǎn)者）的返回值 
    13.   
  
  
  13.         result = rpc.generate_service.hello_world(msg="xag msg") 
    14.   
  
  
  14.  
    15.   
  
  
  15.         # 返回結(jié)果 
    16.   
  
  
  16.         return result, 200 
    17.   
  
  
  17.  
    18.   
  
  
  18. app.run(debug=True) 
    19.

3-6 測試一下

使用 Postman 調(diào)用上面的 API 接口，就能完成消費(fèi)者調(diào)用生成者服務(wù)中的方法，拿到返回結(jié)果的完整流程

 
 
 
      
  
  
  1. # 調(diào)用API接口 
    2.   
  
  
  2. http://127.0.0.1:5000/hello_world 
    3.   
  
  
  3. Method：GET 
    4.

4. 最后

上面以 Flask 為例講解了微服務(wù)的搭建的完整流程

如果是其他 Web 框架( 比如 Django、FastAPI 等 )集成微服務(wù)流程是類似的，只需要修改生成 API 部分的邏輯即可，更多進(jìn)階內(nèi)容大家可以參考官方文檔

官方文檔：https://nameko.readthedocs.io/en/stable/


網(wǎng)站標(biāo)題：硬肝一次 Python 微服務(wù)是一種什么體驗(yàn)？
網(wǎng)址分享：http://m.5511xx.com/article/djjhsdi.html