Python-сообщество

class MyRequestHandler(http.Request):
    def process(self):
        #здесь отдаем пакеты клиенту
class MyHttp(http.HTTPChannel):
    requestFactory = MyRequestHandler
class MyHttpFactory(http.HTTPFactory):
    protocol = MyHttp
reactor.listenTCP(8080, MyHttpFactory())
class MulticastServerUDP(DatagramProtocol):
    def startProtocol(self):
        self.transport.joinGroup('229.254.1.11')
    def datagramReceived(self, data, address):
        # здесь получаем пакеты
reactor.listenMulticast(9000, MulticastServerUDP())
reactor.run()

class MyRequestHandler(http.Request):
    def out(self, data):
        #этот callback вызывается на каждую datagramReceived, в нем же в deffered добавляем снова себя
        self.write(data)
        if self.transport.connected:
            d = defer.Deferred()
            d.addCallback(self.out)
            self.mserver.deferreds.append(d)
        else:
            self.finish()
    def process(self):
        #соединение установлено, создаем первый callback
        d = defer.Deferred()
        d.addCallback(self.out)
        self.mserver.deferreds.append(d)
 
class MyHttp(http.HTTPChannel):
    requestFactory = MyRequestHandler
 
class MyHttpFactory(http.HTTPFactory):
    protocol = MyHttp
  
class MulticastServerUDP(DatagramProtocol):
    def __init__(self):
        #deffereds - это список объектов Deffered, в каждый из которых добавляются колбэки при подключении новых клиентов по http
        self.deffereds = []
    def startProtocol(self):
        self.transport.joinGroup('229.254.1.11')
 
    def datagramReceived(self, data, address):
        # получаем пакет и посылаем его по всем затребовавшим callback'ам
        deferreds = copy(self.deferreds)
        self.deferreds = []
        for d in deferreds:
            d.callback(data)
mcast = MulticastServerUDP()
reactor.listenMulticast(9000, mcast)
mhttp = MyHttpFactory()
mhttp.mserver = mcast
reactor.listenTCP(8080, mhttp)
reactor.run()

class MyRequestHandler(http.Request):
    def process(self):
        #добавляем себя в список к MulticastServerUDP
        self.transport.protocol.factory.mserver.outputs.append(self)
 
class MyHttp(http.HTTPChannel):
    requestFactory = MyRequestHandler
 
class MyHttpFactory(http.HTTPFactory):
    protocol = MyHttp
  
class MulticastServerUDP(DatagramProtocol):
    def __init__(self):
        #outputs - список экземпляров http.Request, в которые нужно писать получаемые данные
        self.outputs = []
 
    def startProtocol(self):
        self.transport.joinGroup('229.254.1.11')
 
    def datagramReceived(self, data, address):
        # получаем пакет и посылаем его по всем затребовавшим
        for out in outputs:
            out.write(data)
 
mcast = MulticastServerUDP()
reactor.listenMulticast(9000, mcast)
 
mhttp = MyHttpFactory()
mhttp.mserver = mcast
reactor.listenTCP(8080, mhttp)
 
reactor.run()

class MyRequestHandler(http.Request):
    def connectionLost(self, reason):
       self.transport.protocol.factory.mserver. outputs.remove(self)