Python中的进程间通信

作者: 你瞎啊！撞我心了
发布时间: 2024-10-18 05:20:42 (2天前)
转自：

5 条回复

0#
回复此人
AsuRa | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 查看一个名为RabbitMQ的跨平台库/服务器。对于双进程通信可能太重，但如果您需要多进程或多代码库通信（使用各种不同的方式，例如一对多，队列等），这是一个不错的选择。 </p> <P> 要求： </p> <pre> <code> $ pip install pika $ pip install bson # for sending binary content $ sudo apt-get rabbitmq-server # ubuntu, see rabbitmq installation instructions for other platforms </code> </pre> <P> 发布者（发送数据）： </p> <pre> <code> import pika, time, bson, os connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel = connection.channel() channel.exchange_declare(exchange='logs', type='fanout') i = 0 while True: data = {'msg': 'Hello %s' % i, b'data': os.urandom(2), 'some': bytes(bytearray(b'\x00\x0F\x98\x24'))} channel.basic_publish(exchange='logs', routing_key='', body=bson.dumps(data)) print("Sent", data) i = i + 1 time.sleep(1) connection.close() </code> </pre> <P> 订阅者（接收数据，可以是多个）： </p> <pre> <code> import pika, bson connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost')) channel = connection.channel() channel.exchange_declare(exchange='logs', type='fanout') result = channel.queue_declare(exclusive=True) queue_name = result.method.queue channel.queue_bind(exchange='logs', queue=queue_name) def callback(ch, method, properties, body): data = bson.loads(body) print("Received", data) channel.basic_consume(callback, queue=queue_name, no_ack=True) channel.start_consuming() </code> </pre> <P> 基于的例子 <a href="https://www.rabbitmq.com/tutorials/tutorial-two-python.html" rel="nofollow"> https://www.rabbitmq.com/tutorials/tutorial-two-python.html </A> </p> </DIV>

编辑
1#
回复此人
12345 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 我会使用套接字，但使用Twisted为您提供一些抽象，并使事情变得简单。 <a href="http://twistedmatrix.com/documents/current/core/examples/#auto0" rel="nofollow"> 他们的简单回声客户端/服务器示例 </A> 是一个很好的起点。 </p> <P> 您只需要组合文件并实例化并运行客户端或服务器，具体取决于传递的参数。 </p> </DIV>

编辑
2#
回复此人
哦哦了 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 我会用套接字;本地通信得到了极大的优化，因此您不应该遇到性能问题，并且如果需要，您可以将应用程序分发到不同的物理节点。 </p> <P> 关于“低级”方法，你是对的。但您可以根据需要始终使用更高级别的包装器。 <a href="http://docs.python.org/library/xmlrpclib.html" rel="nofollow"> XMLRPC </A> 可能是一个很好的候选人，但对于你正在尝试执行的任务来说，这可能是过度的。 </p> <P> <a href="http://twistedmatrix.com/trac/" rel="nofollow"> 扭曲 </A> 提供了一些很好的协议简单实现，例如 <a href="http://twistedmatrix.com/documents/8.2.0/api/twisted.protocols.basic.LineReceiver.html" rel="nofollow"> LineReceiver </A> （对于简单的基于行的消息）或更优雅的AMP（顺便说一下， <a href="http://amp-protocol.net/" rel="nofollow"> 标准化并以不同语言实施 </A> ）。 </p> </DIV>

编辑
3#
回复此人
爱我真好 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 根据我的经验， <a href="http://rpyc.readthedocs.org/en/latest/"> <code> rpyc </code> </A> 是迄今为止最简单，最优雅的方式。 </p> <P> （我知道这是一个老问题，但我偶然发现它......） </p> </DIV>

编辑

登录后才能参与评论