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

import asyncore
import socket
class EchoHandler(asyncore.dispatcher_with_send):
    def handle_read(self):
        data = self.recv(8192)
        if data:
            print 'Received data = ', data
            self.send(data)
    def handle_error(self):
        print 'Error'
    def handle_close(self):
        print 'Client disconnected normal'
class EchoServer(asyncore.dispatcher):
    def __init__(self, host, port):
        asyncore.dispatcher.__init__(self)
        self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
        self.set_reuse_addr()
        self.bind((host, port))
        self.listen(5)
    def handle_accept(self):
        pair = self.accept()
        if pair is not None:
            sock, addr = pair
            print 'Incoming connection from %s' % repr(addr)
            handler = EchoHandler(sock)
server = EchoServer('localhost', 8080)
asyncore.loop()

import asyncore
import socket
import time
from collections import defaultdict
class TimeoutController(object):
    TICK = 10.0
    TIMEOUT = 30.0
    def __init__(self):
        self.connections = defaultdict(float)
    def loop(self):
        while True:
            asyncore.loop(self.TICK, count=1)
            self.check_connections()
    def check_connections(self):
        now = time.time()
        for conn_id, (connection, last) in self.connections.items():
            if now - last > self.TIMEOUT:
                print 'Close client by timeout'
                del self.connections[conn_id]
                connection.close()
    def checkin(self, connection):
        self.connections[id(connection)] = (connection, time.time())
class EchoHandler(asyncore.dispatcher_with_send):
    def __init__(self, controller, sock=None, map=None):
        self.controller = controller
        controller.checkin(self)
        asyncore.dispatcher_with_send.__init__(self, sock, map)
    def handle_read(self):
        data = self.recv(8192)
        self.controller.checkin(self)
        if data:
            print 'Received data = ', data
            self.send(data)
    def handle_error(self):
        print 'Error'
    def handle_close(self):
        print 'Client disconnected normal'
        self.close()
        
        
class EchoServer(asyncore.dispatcher):
    def __init__(self, host, port, controller):
        asyncore.dispatcher.__init__(self)
        self.controller = controller
        self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
        self.set_reuse_addr()
        self.bind((host, port))
        self.listen(5)
    def handle_accept(self):
        pair = self.accept()
        if pair is not None:
            sock, addr = pair
            print 'Incoming connection from %s' % repr(addr)
            EchoHandler(self.controller, sock)
controller = TimeoutController()
server = EchoServer('localhost', 8080, controller)
controller.loop()

def checkout(self, connection):
   del self.connections[id(connection)]