需求：
可以對指定機器異步的執行多個命令
例子：
>>: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=''' 指令示例
主站蜘蛛池模板：
亚洲不卡中文字幕|
久久精品国产亚洲一区二区|
亚洲黄色免费在线观看|
免费久久人人爽人人爽av|
亚洲欧洲日产国码一级毛片|
蜜桃传媒一区二区亚洲AV|
99在线视频免费观看视频
|
色拍自拍亚洲综合图区|
a级特黄毛片免费观看|
狠狠亚洲狠狠欧洲2019|
一级做a爱片特黄在线观看免费看|
国产免费观看视频|
日韩亚洲人成网站|
亚洲福利精品一区二区三区|
日韩毛片一区视频免费|
亚洲无线一二三四区手机|
一级一级一级毛片免费毛片|
亚洲无码精品浪潮|
国产成人免费ā片在线观看老同学
|
欧美a级成人网站免费|
亚洲国产精品综合久久网各|
免费观看美女用震蛋喷水的视频|
亚洲另类图片另类电影|
九九精品免费视频|
亚洲GV天堂无码男同在线观看|
性色av免费观看|
黄页网站在线观看免费|
亚洲精品无码日韩国产不卡?V|
精品一区二区三区免费观看
|
无码不卡亚洲成?人片|
caoporm超免费公开视频|
亚洲区小说区激情区图片区|
99久久免费精品视频|
亚洲首页国产精品丝袜|
国产成人免费全部网站|
国产特黄一级一片免费|
久久久亚洲欧洲日产国码aⅴ
|
亚洲国产精品成人AV在线
|
性做久久久久久免费观看|
99亚洲乱人伦aⅴ精品|
日本红怡院亚洲红怡院最新|