无法发送到 rpc_server 我的请求 我在 Heroku 上使用 RabbitMQ 和 pika
Cannot send to rpc_server my request i am using RabbitMQ on Heroku with pika
我刚刚在 heroku 中设置了一个 RabbitMQ 插件。在开发我的应用程序以在本地实例上排队和使用消息 运行 后,我将其部署到 Heroku,但尚未成功发送我的消息。
rpc_queue 从来没有收到任何东西,我的网址是正确的,我的 rpc_server 听得很好,但从来没有收到任何东西
server.py
parameters = pika.URLParameters('amqp://djeo4uf8:f4323HekqiVXgt_vlnqPfJnvJruzszbn@sad-groundsel-39.bigwig.lshift.net:10723/fl1sX7CbcDds')
connection = pika.BlockingConnection(parameters)
channel = connection.channel()
channel.queue_declare(queue='rpc_queue')
def on_request(ch, method, props, body):
data = loads( b64decode(body) )
response = getattr(functions, data["command"] )(data["args"])
response = b64encode( dumps(response) )
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()
client.py
class RpcClient(object):
def __init__(self):
parameters = pika.URLParameters('amqp://djeo4uf8:f4323HekqiVXgt_vlnqPfJnvJruzszbn@sad-groundsel-39.bigwig.lshift.net:10722/fl1sX7CbcDds')
parameters.socket_timeout = 5
self.connection = pika.BlockingConnection(parameters)
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 =loads( b64decode(body) )
def call(self, dict_data):
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=b64encode( dumps(dict_data) ) )
while self.response is None:
self.connection.process_data_events()
self.channel.close()
self.connection.close()
return self.response
所以我打了电话,但我从来没有收到任何东西,因为我的 rpc_queue 总是空着
rpc = RpcClient()
response = rpc.call(payloadObj)
非常感谢!
服务器和客户端中的 Urls 使用不同的端口 10723
和 10722
,要接收消息,它应该是在两个端口上侦听的相同 RabbitMQ 节点或具有 HA 队列的集群节点。
我刚刚在 heroku 中设置了一个 RabbitMQ 插件。在开发我的应用程序以在本地实例上排队和使用消息 运行 后,我将其部署到 Heroku,但尚未成功发送我的消息。
rpc_queue 从来没有收到任何东西,我的网址是正确的,我的 rpc_server 听得很好,但从来没有收到任何东西
server.py
parameters = pika.URLParameters('amqp://djeo4uf8:f4323HekqiVXgt_vlnqPfJnvJruzszbn@sad-groundsel-39.bigwig.lshift.net:10723/fl1sX7CbcDds')
connection = pika.BlockingConnection(parameters)
channel = connection.channel()
channel.queue_declare(queue='rpc_queue')
def on_request(ch, method, props, body):
data = loads( b64decode(body) )
response = getattr(functions, data["command"] )(data["args"])
response = b64encode( dumps(response) )
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()
client.py
class RpcClient(object):
def __init__(self):
parameters = pika.URLParameters('amqp://djeo4uf8:f4323HekqiVXgt_vlnqPfJnvJruzszbn@sad-groundsel-39.bigwig.lshift.net:10722/fl1sX7CbcDds')
parameters.socket_timeout = 5
self.connection = pika.BlockingConnection(parameters)
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 =loads( b64decode(body) )
def call(self, dict_data):
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=b64encode( dumps(dict_data) ) )
while self.response is None:
self.connection.process_data_events()
self.channel.close()
self.connection.close()
return self.response
所以我打了电话,但我从来没有收到任何东西,因为我的 rpc_queue 总是空着
rpc = RpcClient()
response = rpc.call(payloadObj)
非常感谢!
服务器和客户端中的 Urls 使用不同的端口 10723
和 10722
,要接收消息,它应该是在两个端口上侦听的相同 RabbitMQ 节点或具有 HA 队列的集群节点。