需求：
可以對指定機器異步的執行多個命令
例子：
>>:run "df -h" --hosts 192.168.3.55 10.4.3.4 task id: 45334 >>: check_task 45334 >>:
注意，每執行一條命令，即立刻生成一個任務ID,不需等待結果返回，通過命令check_task TASK_ID來得到任務結果
README
1 基于RabbitMQ rpc實現的主機管理 2 可以對指定機器異步的執行多個命令 3 例子： 4 >>:run "df -h" --hosts 192.168.3.55 10.4.3.4 5 task id: 45334 6 >>: check_task 45334 #查看任務信息 7 8 程序結構: 9 RabbitMQ_PRC/#綜合目錄10 |- - -PRC_CLIENT/#client程序主目錄11 | |- - -__init__.py12 | |- - -bin/#執行程目錄13 | | |- - -__init__.py14 | | |- - -clien_start.py #客戶端執行文件15 | |16 | |17 | |- - -core #主邏輯程序目錄18 | | |- - -__init__.py19 | | |- - -clien_class.py#客戶端執行主要邏輯 類20 | |21 | |22 |23 |24 |- - -PRC_SERVER/#服務端程序目錄25 | |- - -__init__.py26 | |- - -bin/#執行目錄27 | | |- - -__init__.py28 | | |- - -server_start.py#服務端程序執行文件29 | |30 | |31 | |- - -core/##主邏輯程序目錄32 | | |- - -server_class.py#主邏輯 相關類33 | |34 |35 |- - -README
程序結構: RabbitMQ_PRC/#綜合目錄 |- - -PRC_CLIENT/#client程序主目錄 | |- - -__init__.py | |- - -bin/#執行程目錄 | | |- - -__init__.py | | |- - -clien_start.py #客戶端執行文件
1 import os ,sys2 BASE_DIR=os.path.dirname(os.path.dirname(os.path.abspath(__file__)))#獲取相對路徑轉為絕對路徑賦于變量3 sys.path.append(BASE_DIR)#增加環境變量4 5 from core.client_class import Threa6 7 if __name__ == '__main__':8 RPCS=Threa()9 response=RPCS.th_start()
| |- - -core #主邏輯程序目錄 | | |- - -__init__.py | | |- - -clien_class.py#客戶端執行主要邏輯 類
1 import pika 2 import uuid 3 import threading 4 import random 5 6 class FibonacciRpcClient(object): 7 def __init__(self): 8 #self.credentials=pika.PlainCredentials("test","test") 9 self.connection = pika.BlockingConnection(pika.ConnectionParameters(host="localhost"))#生成連接的服務端 ip 10 #self.connection = pika.BlockingConnection(pika.ConnectionParameters("192.168.11.51",15672,'/',self.credentials))#生成連接的服務端 ip 11 self.channel = self.connection.channel()#創建一個管道 12 13 def get_respon(self,cal_queue,cal_id):#取任務信息 14 self.response=None 15 self.callback_id=cal_id#隊列名 16 self.channel.basic_consume(self.on_response,queue=cal_queue)# 使用回調函數 17 while self.response is None: 18 self.connection.process_data_events()#非阻塞模式接收消息 19 return self.response#返回 20 21 def on_response(self, ch, method, props, body):#回調函數 22 if self.callback_id == props.correlation_id:#判斷服務端返回的隊列名是否與當前所生成的隊列名一致 23 self.response = body# 將服務端的結果賦于返回來的結果變量 24 ch.basic_ack(delivery_tag = method.delivery_tag)##確保消息被 接收 25 26 def call(self, queues,n):#發送消息的函數 27 result = self.channel.queue_declare(exclusive=False)#隨機生成一個隊列，收消息后不刪除 28 self.callback_queue = result.method.queue#賦于管道 變量 29 self.corr_id = str(uuid.uuid4())#生成一個服務端返回消息的隊列名 30 self.channel.basic_publish(exchange='', 31 routing_key=queues,#隊列名 32 properties=pika.BasicProperties( 33 reply_to = self.callback_queue,#發送的管道隊列名 34 correlation_id = self.corr_id,#發送給服務端，用于返回消息的隊列名 35 ), 36 body=str(n))#發送的內容數據 37 return self.callback_queue,self.corr_id#返回管道名 隊列id號 38 39 class Threa(object):#線程 類 40 def __init__(self): 41 self.info={}#生成一個字典 42 self.help_info=''' 指令示例
主站蜘蛛池模板：
欧日韩一区二区三区
|
欧美综合在线视频
|
超在线视频
|
欧美成人性色生活18黑人
|
日韩在线网
|
国产一区在线观看视频
|
国产精品特级毛片一区二区三区
|
日本黄 色 成 年 人免费观看
|
欧美第四页
|
国产成人久久一区二区三区
|
精品一区二区三区视频日产
|
亚洲全黄
|
成人午夜精品久久久久久久小说
|
久久久久免费精品国产小说
|
日韩电影免费看
|
好骚综合在线
|
国产精品手机视频一区二区
|
亚洲精品乱码久久久久
|
国产成人精品一区二三区
|
国产美女精品久久久久中文
|
性久久久久久久久
|
图片区 日韩 欧美 亚洲
|
99久久精品国产一区二区小说
|
欧美亚洲国产精品久久久
|
欧美极品尤物在线播放一级
|
国产午夜精品视频
|
国产高清不卡码一区二区三区
|
一区二区三区四区电影
|
亚洲激情影院
|
亚洲欧美综合图区官网
|
国产区在线视频
|
91系列在线观看免费
|
亚洲免费一区
|
亚洲性久久久影院
|
性夜影院爽黄a爽免费看网站
|
国产不卡在线视频
|
久久大香香蕉国产免费网vrr
|
国产精品美女一区二区三区
|
成人国产一区二区
|
国产特级黄色片
|
精品一区二区三区五区六区七区
|