Twisted - как создать многопротокольный процесс и отправлять данные между протоколами

Вот пример кода для чтения из нескольких подключений к порту 9001 и записи в подключение через порт 9000. Вам потребуется несколько реализаций «PutLine», одна для XMPP, IRC, MSN и т. Д.

Я использовал глобал для хранения выходного соединения PutLine, но вы хотели бы создать более сложный объект Factory, который бы справился с этим.

#!/usr/bin/env python

from twisted.internet.protocol import Protocol, Factory
from twisted.internet.endpoints import clientFromString, serverFromString
from twisted.protocols.basic import LineReceiver
from twisted.internet import reactor

queue = []
putter = None

class GetLine(LineReceiver):
    delimiter = '\n'

    def lineReceived(self, line):
        queue.append(line)
        putter.have_data()
        self.sendLine(line)

class PutLine(LineReceiver):
    def __init__(self):
        global putter
        putter = self
        print 'putline init called %s' % str(self)

    def have_data(self):
        line = queue.pop()
        self.sendLine(line)


def main():
    f = Factory()
    f.protocol = PutLine
    endpoint = clientFromString(reactor, "tcp:host=localhost:port=9000")
    endpoint.connect(f)
    f = Factory()
    f.protocol = GetLine
    endpoint2 = serverFromString(reactor, "tcp:port=9001")
    endpoint2.listen(f)
    reactor.run()

if __name__ == '__main__':
    main()

Тестирование:

nc -l  9000
python test.py
nc 9001

Данные, введенные из любого числа nc 9001 (или netcat 9001), появятся на nc -l 9000.

Ответ на этот вопрос можно найти в FAQ.

http://twistedmatrix.com/trac/wiki/FrequentAskedQuestionsput#HowdoImakeinput

См. doc/core/examples/chatserver.py. Там они добавили хуки к методам Protocol connectionMade и connectionLost для поддержки списка подключенных клиентов, а затем он перебирает их всех, когда приходит сообщение для передачи.