东莞公司网站做优化,app下载安卓软件,小程序token,中国建筑网官网防水证书查询目前是使用C嵌入式的python函数 python函数是阻塞式的接收服务器消息 直到退出监听才会有返回值 监听中收到消息会调用python的一个回调函数#xff0c;可以获取到收到的消息 所以要怎么样来返回消息给C EDIT: 代码如下callback打印可以打印正确数据#xff0c;问题是 这里用…目前是使用C嵌入式的python函数 python函数是阻塞式的接收服务器消息 直到退出监听才会有返回值 监听中收到消息会调用python的一个回调函数可以获取到收到的消息 所以要怎么样来返回消息给C EDIT: 代码如下callback打印可以打印正确数据问题是 这里用pika库写的rabbitMQ 的client就是为了不用 rabbitMQ的C库 现在有一种考虑就是再用C写一个python可以调的module 然后在回调函数里面调就是感觉有点丑陋。 #!/usr/bin/env python import pika import sys message def callback(ch, method, properties, body): message body print(method.routing_key) return message def consume(): connection pika.BlockingConnection(pika.ConnectionParameters(hostlocalhost)) channel connection.channel() result channel.queue_declare(exclusiveTrue) queue_name result.method.queue channel.queue_bind(exchangenormalEx, routing_keyremote, queuequeue_name) print( [*] Waiting for logs. To exit press CTRLC) channel.basic_consume(callback, queuequeue_name, no_ackTrue) channel.start_consuming()