pibbtimq高階使用技術,雙向通訊

2022-09-12 22:42:29 字數 2230 閱讀 5858

本案例目是是服務端傳送客戶端,客戶端收到反應給服務端,雙向通訊

客戶端**如下:

import pika

import time

connection = pika.blockingconnection(pika.connectionparameters(

host='localhost'))

channel = connection.channel()

channel.queue_declare(queue='rpc_queue')

def fib(n):

if n == 0:

return 0

elif n == 1:

return 1

else:

return fib(n - 1) + fib(n - 2)

edef on_request(ch, method, props, body):

n = int(body)

print(" [.] fib(%s)" % n)

response = fib(n)

ch.basic_publish(exchange='',

routing_key=props.reply_to,

properties=pika.basicproperties(correlation_id= \

props.correlation_id),

body=str(response))

ch.basic_ack(delivery_tag=method.delivery_tag)

channel.basic_qos(prefetch_count=1)

channel.basic_consume(on_request, queue='rpc_queue')

print(" [x] awaiting rpc requests")

channel.start_consuming()

rpcclient

服務端**:

import pika

import uuid

class fibonaccirpcclient(object):

def __init__(self):

self.connection = pika.blockingconnection(pika.connectionparameters(

host='localhost'))

self.channel = self.connection.channel()

result = self.channel.queue_declare(exclusive=true)

self.callback_queue = result.method.queue

self.channel.basic_consume(self.on_response, no_ack=true,

queue=self.callback_queue)

def on_response(self, ch, method, props, body):

if self.corr_id == props.correlation_id:

self.response = body

def call(self, n):

self.response = none

self.corr_id = str(uuid.uuid4())

self.channel.basic_publish(exchange='',

routing_key='rpc_queue',

properties=pika.basicproperties(

reply_to=self.callback_queue,

correlation_id=self.corr_id,

),body=str(n))

while self.response is none:

self.connection.process_data_events()

return int(self.response)

fibonacci_rpc = fibonaccirpcclient()

print(" [x] requesting fib(30)")

response = fibonacci_rpc.call(30)

print(" [.] got %r" % response)

以上代整於老男孩14期自動 運維

雙快取技術

做了幾個遊戲發現每次刷屏時都會閃爍。這個問題怎麼解決呢?當然是雙快取技術最好,解決問題面也最廣!網上有很多雙快取技術的文章,可是很多說的不全。要你和我一樣用了雙快取技術卻還是閃屏,也許你直接看第五點就可以解決你的問題。首先,簡單講一下雙快取技術 網上文章都會講,知道就跳過此段 雙快取技術就是在記憶體...

雙緩衝技術

理解 通常我們進行繪圖時,都是直接使用cdc cpaintdc等 物件在螢幕上繪製圖形,如我們經常在onpaint函式中使用 cpaintdc dc this dc.rectangle 0,0,100,100 在螢幕上繪製矩形。但如果應用需要頻繁的繪製圖形,比如每秒要在螢幕上繪製1000個矩形。因此...

2013 4 15 雙緩衝技術

主要原理 當乙個動畫爭先顯示時,程式有在改變他,前面還沒有顯示完,程式又請求重新繪製,這樣螢幕就會不停的閃爍。為了避免閃爍,可以用雙緩衝技術,將要哦處理的都在記憶體中處理好之後,再將其顯示到螢幕上。這樣顯示出來的總是完整的影象,不會出現閃爍的現象。核心技術 先通過setbitmap方法將要繪製哦所有...