python socket 聊天室，pythonsocket,__author__ =

python socket 聊天室，pythonsocket,__author__ =

__author__ = '’import socketimport selectHOST = ""PORT = 9008BACKLOG = 100BUFF = 1024ADDR = (HOST, PORT)CONNECT_MAP = {}def broadcast_msg(_srv_sock, my_sock, msg):    for _file_no, _sock in CONNECT_MAP.iteritems():        if _sock != _srv_sock and _sock != my_sock:            try:                _sock.send(msg)            except socket.error:                passdef chat_server():    srv_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)    srv_sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)    srv_sock.bind(ADDR)    srv_sock.listen(BACKLOG)    _epoll = select.epoll()    _epoll.register(srv_sock.fileno(), select.EPOLLIN)    print "Start chat server on port %d" % PORT    while True:        events = _epoll.poll(timeout=0.5)        for _file_no, event in events:            if _file_no == srv_sock.fileno():                _cli_sock, _addr = srv_sock.accept()                _cli_sock.setblocking(0)                print "Client (%s, %s) connected" % _addr                broadcast_msg(srv_sock, _cli_sock, "[%s:%s] entered root\n\r" % _addr)                _epoll.register(_cli_sock.fileno(), select.EPOLLIN)                CONNECT_MAP[_cli_sock.fileno()] = _cli_sock            elif event &amp; select.EPOLLIN:                try:                    _sock = CONNECT_MAP[_file_no]                    _data = _sock.recv(BUFF)                    if _data:                        _msg = "<" + str(_sock.getpeername()) + ">" + _data + '\n\r'                        broadcast_msg(srv_sock, _sock, _msg)                except:                    CONNECT_MAP[_file_no].close()                    CONNECT_MAP.pop(_file_no)                    _epoll.unregister(_file_no)            elif event &amp; select.EPOLLHUP:                CONNECT_MAP[_file_no].close()                CONNECT_MAP.pop(_file_no)                _epoll.unregister(_file_no)if __name__ == "__main__":    chat_server()