echo/rabbitmq-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fixed rpc client.

Browse Source
This commit is contained in:
Your Name 2010-11-30 14:04:31 +00:00
parent f6a8e53251
commit f58bb9cd0f
2 changed files with 25 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
python/rpc_client.py
View File

@ -12,26 +12,30 @@ class FibonacciClient(object):
result = self.channel.queue_declare(auto_delete=True)
self.callback_queue = result.queue
self.requests = {}
self.channel.basic_consume(self.on_response, no_ack=True,
queue=self.callback_queue)
def on_response(self, ch, method, props, body):
corr_id = props.correlation_id
if corr_id in self.requests:
self.requests[corr_id] = body
def call(self, n):
correlation_id = str(uuid.uuid4())
corr_id = str(uuid.uuid4())
self.requests[corr_id] = None
self.channel.basic_publish(exchange='',
routing_key='rpc_queue',
properties=pika.BasicProperties(
reply_to = self.callback_queue,
correlation_id = correlation_id,
correlation_id = corr_id,
),
body=str(n))
response = []
def on_basic_deliver(ch, method, props, body):
if props.correlation_id == correlation_id:
response.append(body)
self.channel.basic_consume(on_basic_deliver,
queue=self.callback_queue,
no_ack=True)
while not response:
while self.requests[corr_id] is None:
pika.asyncore_loop(count=1)
return int(response[0])
response = self.requests[corr_id]
del self.requests[corr_id]
return int(response)
fibonacci_rpc = FibonacciClient()

17
python/rpc_server.py
View File

@ -1,14 +1,6 @@
#!/usr/bin/env python
import pika
def fib(n):
if n == 0:
return 0
elif n == 1:
return 1
else:
return fib(n-1) + fib(n-2)
connection = pika.AsyncoreConnection(pika.ConnectionParameters(
host='127.0.0.1',
@ -18,6 +10,15 @@ 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)
def on_request(ch, method, props, body):
n = int(body)