Twisted中启动子进程及进程间通信方式

1.main.py

#!/bin/env python
#-*-coding:utf-8-*-

import sys
from twisted.python import log
log.startLogging(sys.stdout)

from twisted.internet import protocol, reactor

class SubProcessProtocol(protocol.ProcessProtocol):
    def __init__(self):
        self.input = 97

    def connectionMade(self):
        log.msg('Connection Made.')
        self.send()

    def send(self):
        self.transport.write(chr(self.input) + "\n")
        log.msg('Sent:', chr(self.input))
        self.input += 1

    def outReceived(self, data):
        log.msg('Received:', data)
        reactor.callLater(.1, self.send)

    def errReceived(self, data):
        log.msg('Error:', data)

    def inConnectionLost(self):
        log.msg('Error: inConnectionLost')

    def outConnectionLost(self):
        log.msg('Error: inConnectionLost')

    def errConnectionLost(self):
        log.msg('Error: errConnectionLost')

    def proces***ited(self, reason):
        log.msg('Process exit status:',reason.value.exitCode )

    def processEnded(self, reason):
        log.msg('Process end status:',reason.value.exitCode )
        if reactor.running:
            reactor.stop()

def main():
    p = SubProcessProtocol()
    reactor.spawnProcess(p, 'sub.py', ['sub.py'], {})
    reactor.run()

if __name__ == "__main__":
    main()

2. sub.py:

#!/bin/env python
#-*-coding:utf-8-*-

import sys, os
sys.stdout = os.fdopen(sys.stdout.fileno(), 'w', 1)


def main():
    running = True

    while running:
        input = sys.stdin.readline().rstrip('\n')
        if input == 'q':
            running = False
        print "You said:%s" % input

if __name__ == "__main__":
    main()
    sys.exit(2)

文章来自：http://www.cnitblog.com/donne/archive/2011/11/16/76327.html