python进程间查询/控制

Question

我有一个基于Python的服务守护进程，它正在执行大量的多路复用IO（选择）。

我想从另一个脚本（也是Python）查询该服务守护进程的状态/信息和/或控制处理（例如暂停它、关闭它、更改一些参数等）。

使用 python 发送控制消息（“从现在开始，你像这样处理！”）和查询处理数据（“结果是什么？”）的最佳方法是什么？

我在某处读到命名管道可能有效，但不太了解命名管道，尤其是在 python 中 - 以及是否有更好的替代方案。

后台服务守护进程和前端都将由我编程，因此所有选项都是开放的:)

我使用的是 Linux。

Answer 1

管道和命名管道是不同进程之间通信的良好解决方案。
管道的工作方式类似于共享内存缓冲区，但有一个在两端各模拟一个简单文件的接口。一个进程在管道的一端写入数据，另一个进程在另一端读取该数据。

命名管道与上面类似，不同之处在于该管道实际上与计算机中的真实文件关联。

更多详细信息，

• 访问http://www.softpanorama.org/Scripting/pipes.shtml

请 Python，命名管道文件是使用 os.mkfifo 调用创建的

x = os.mkfifo(filename)

在子级和父级中打开此管道作为文件

out = os.open(filename, os.O_WRONLY)
in = open(filename, 'r')

要写入

os.write(out, 'xxxx')

要读取

lines = in.readline( )

编辑：添加来自 SO

• 在 Python 中创建临时 FIFO（命名管道）？
• https://stackoverflow.com/search?q=python+named+pipes

您可能想阅读有关“IPC 和 Python”的更多信息

• http://www.freenetpages.co.uk/hp/alan.gauld/tutipc.htm

Answer 2

进行 IPC 的最佳方法是使用 python 中的消息队列作为以下

服务器进程 server.py （在运行 client.py 和 interact.py 之前运行此进程）

from multiprocessing.managers import BaseManager
import Queue
queue1 = Queue.Queue()
queue2 = Queue.Queue()
class QueueManager(BaseManager): pass
QueueManager.register('get_queue1', callable=lambda:queue1)
QueueManager.register('get_queue2', callable=lambda:queue2)
m = QueueManager(address=('', 50000), authkey='abracadabra')
s = m.get_server()
s.serve_forever()

用于 I/O 的交互参与者 interact.py

from multiprocessing.managers import BaseManager
import threading
import sys
class QueueManager(BaseManager): pass
QueueManager.register('get_queue1')
QueueManager.register('get_queue2')
m = QueueManager(address=('localhost', 50000),authkey='abracadabra')
m.connect()
queue1 = m.get_queue1()
queue2 = m.get_queue2()

def read():
    while True:
        sys.stdout.write(queue2.get())

def write():
    while True:
        queue1.put(sys.stdin.readline())
threads = []

threadr = threading.Thread(target=read)
threadr.start()
threads.append(threadr)

threadw = threading.Thread(target=write)
threadw.start()
threads.append(threadw)

for thread in threads:
    thread.join()

客户端程序 Client。 py

from multiprocessing.managers import BaseManager
import sys
import string
import os

class QueueManager(BaseManager): pass
QueueManager.register('get_queue1')
QueueManager.register('get_queue2')
m = QueueManager(address=('localhost', 50000), authkey='abracadabra')
m.connect()
queue1 = m.get_queue1()
queue2 = m.get_queue2()


class RedirectOutput:
    def __init__(self, stdout):
        self.stdout = stdout
    def write(self, s):
        queue2.put(s)

class RedirectInput:
    def __init__(self, stdin):
        self.stdin = stdin
    def readline(self):
        return queue1.get()

# redirect standard output

sys.stdout = RedirectOutput(sys.stdout)

sys.stdin = RedirectInput(sys.stdin)

# The test program which will take input and produce output 
Text=raw_input("Enter Text:")
print "you have entered:",Text
def x():
    while True:
        x= raw_input("Enter 'exit' to end and some thing else to continue")
        print x
        if 'exit' in x:
            break
x()

这可用于在网络中或同一台机器上的两个进程之间进行通信
请记住，除非您手动终止交互参与者和服务器进程，否则它不会终止。