1.æå¡å¨ç±»
é¦å
éè¦ä¸ä¸ªè天æå¡å¨ï¼è¿é继æ¿asyncoreçdispatcherç±»æ¥å®ç°ï¼ä»£ç å¦ä¸
class ChatServer(dispatcher):
"""
è天æå¡å¨
"""
def __init__(self, port):
dispatcher.__init__(self)
self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
self.set_reuse_addr()
self.bind(('', port))
self.listen(5)
self.users = {}
self.main_room = ChatRoom(self)
def handle_accept(self):
conn, addr = self.accept()
ChatSession(self, conn)
2.ä¼è¯ç±»
æäºæå¡å¨ç±»è¿éè¦è½ç»´æ¤æ¯ä¸ªç¨æ·çè¿æ¥ä¼è¯ï¼è¿é继æ¿asynchatçasync_chatç±»æ¥å®ç°ï¼ä»£ç å¦ä¸ï¼
class ChatSession(async_chat):
"""
è´è´£ååç¨æ·éä¿¡
"""
def __init__(self, server, sock):
async_chat.__init__(self, sock)
self.server = server
self.set_terminator('\n')
self.data = []
self.name = None
self.enter(LoginRoom(server))
def enter(self, room):
'ä»å½åæ¿é´ç§»é¤èªèº«ï¼ç¶åæ·»å å°æå®æ¿é´'
try:
cur = self.room
except AttributeError:
pass
else:
cur.remove(self)
self.room = room
room.add(self)
def collect_incoming_data(self, data):
'æ¥å客æ·ç«¯çæ°æ®'
self.data.append(data)
def found_terminator(self):
'å½å®¢æ·ç«¯çä¸æ¡æ°æ®ç»ææ¶çå¤ç'
line = ''.join(self.data)
self.data = []
try:
self.room.handle(self, line)
except EndSession:
self.handle_close()
def handle_close(self):
async_chat.handle_close(self)
self.enter(LogoutRoom(self.server))
3.å½ä»¤è§£éå¨
ç°å¨å°±éè¦ä¸ä¸ªå½ä»¤è§£éå¨è½å¤è§£éç¨æ·çå½ä»¤ï¼ä¾å¦ç»å½ãæ¥è¯¢å¨çº¿ç¨æ·ååæ¶æ¯çï¼ä»£ç å¦ä¸ï¼
class CommandHandler:
"""
å½ä»¤å¤çç±»
"""
def unknown(self, session, cmd):
'ååºæªç¥å½ä»¤'
session.push('Unknown command: %s\n' % cmd)
def handle(self, session, line):
'å½ä»¤å¤ç'
if not line.strip():
return
parts = line.split(' ', 1)
cmd = parts[0]
try:
line = parts[1].strip()
except IndexError:
line = ''
meth = getattr(self, 'do_' + cmd, None)
try:
meth(session, line)
except TypeError:
self.unknown(session, cmd)
4.æ¿é´
æ¥ä¸æ¥å°±éè¦å®ç°è天室çæ¿é´äºï¼è¿éæ们å®ä¹äºä¸ç§æ¿é´ï¼åå«æ¯ç¨æ·åç»å½æ¶çæ¿é´ãè天çæ¿é´åéåºç»å½çæ¿é´ï¼è¿ä¸ç§æ¿é´é½æä¸ä¸ªå
Œ
±çç¶ç±»ï¼ä»£ç å¦ä¸ï¼
class Room(CommandHandler):
"""
å
å«å¤ä¸ªç¨æ·çç¯å¢ï¼è´è´£åºæ¬çå½ä»¤å¤çå广æ
"""
def __init__(self, server):
self.server = server
self.sessions = []
def add(self, session):
'ä¸ä¸ªç¨æ·è¿å
¥æ¿é´'
self.sessions.append(session)
def remove(self, session):
'ä¸ä¸ªç¨æ·ç¦»å¼æ¿é´'
self.sessions.remove(session)
def broadcast(self, line):
'åææçç¨æ·åéæå®æ¶æ¯'
for session in self.sessions:
session.push(line)
def do_logout(self, session, line):
'éåºæ¿é´'
raise EndSession
class LoginRoom(Room):
"""
åç»å½çç¨æ·çæ¿é´
"""
def add(self, session):
'ç¨æ·è¿æ¥æåçååº'
Room.add(self, session)
session.push('Connect Success')
def do_login(self, session, line):
'ç»å½å½ä»¤å¤ç'
name = line.strip()
if not name:
session.push('UserName Empty')
elif name in self.server.users:
session.push('UserName Exist')
else:
session.name = name
session.enter(self.server.main_room)
class ChatRoom(Room):
"""
è天ç¨çæ¿é´
"""
def add(self, session):
'广ææ°ç¨æ·è¿å
¥'
session.push('Login Success')
self.broadcast(session.name + ' has entered the room.\n')
self.server.users[session.name] = session
Room.add(self, session)
def remove(self, session):
'广æç¨æ·ç¦»å¼'
Room.remove(self, session)
self.broadcast(session.name + ' has left the room.\n')
def do_say(self, session, line):
'客æ·ç«¯åéæ¶æ¯'
self.broadcast(session.name + ': ' + line + '\n')
def do_look(self, session, line):
'æ¥çå¨çº¿ç¨æ·'
session.push('Online Users:\n')
for other in self.sessions:
session.push(other.name + '\n')
class LogoutRoom(Room):
"""
ç¨æ·éåºæ¶çæ¿é´
"""
def add(self, session):
'ä»æå¡å¨ä¸ç§»é¤'
try:
del self.server.users[session.name]
except KeyError:
pass
5.æå¡å¨ç«¯å®æ´ä»£ç
#!/usr/bin/python
# encoding: utf-8
from asyncore import dispatcher
from asynchat import async_chat
import socket, asyncore
PORT = 6666 #端å£
class EndSession(Exception):
"""
èªå®ä¹ä¼è¯ç»ææ¶çå¼å¸¸
"""
pass
class CommandHandler:
"""
å½ä»¤å¤çç±»
"""
def unknown(self, session, cmd):
'ååºæªç¥å½ä»¤'
session.push('Unknown command: %s\n' % cmd)
def handle(self, session, line):
'å½ä»¤å¤ç'
if not line.strip():
return
parts = line.split(' ', 1)
cmd = parts[0]
try:
line = parts[1].strip()
except IndexError:
line = ''
meth = getattr(self, 'do_' + cmd, None)
try:
meth(session, line)
except TypeError:
self.unknown(session, cmd)
class Room(CommandHandler):
"""
å
å«å¤ä¸ªç¨æ·çç¯å¢ï¼è´è´£åºæ¬çå½ä»¤å¤çå广æ
"""
def __init__(self, server):
self.server = server
self.sessions = []
def add(self, session):
'ä¸ä¸ªç¨æ·è¿å
¥æ¿é´'
self.sessions.append(session)
def remove(self, session):
'ä¸ä¸ªç¨æ·ç¦»å¼æ¿é´'
self.sessions.remove(session)
def broadcast(self, line):
'åææçç¨æ·åéæå®æ¶æ¯'
for session in self.sessions:
session.push(line)
def do_logout(self, session, line):
'éåºæ¿é´'
raise EndSession
class LoginRoom(Room):
"""
åç»å½çç¨æ·çæ¿é´
"""
def add(self, session):
'ç¨æ·è¿æ¥æåçååº'
Room.add(self, session)
session.push('Connect Success')
def do_login(self, session, line):
'ç»å½å½ä»¤å¤ç'
name = line.strip()
if not name:
session.push('UserName Empty')
elif name in self.server.users:
session.push('UserName Exist')
else:
session.name = name
session.enter(self.server.main_room)
class ChatRoom(Room):
"""
è天ç¨çæ¿é´
"""
def add(self, session):
'广ææ°ç¨æ·è¿å
¥'
session.push('Login Success')
self.broadcast(session.name + ' has entered the room.\n')
self.server.users[session.name] = session
Room.add(self, session)
def remove(self, session):
'广æç¨æ·ç¦»å¼'
Room.remove(self, session)
self.broadcast(session.name + ' has left the room.\n')
def do_say(self, session, line):
'客æ·ç«¯åéæ¶æ¯'
self.broadcast(session.name + ': ' + line + '\n')
def do_look(self, session, line):
'æ¥çå¨çº¿ç¨æ·'
session.push('Online Users:\n')
for other in self.sessions:
session.push(other.name + '\n')
class LogoutRoom(Room):
"""
ç¨æ·éåºæ¶çæ¿é´
"""
def add(self, session):
'ä»æå¡å¨ä¸ç§»é¤'
try:
del self.server.users[session.name]
except KeyError:
pass
class ChatSession(async_chat):
"""
è´è´£ååç¨æ·éä¿¡
"""
def __init__(self, server, sock):
async_chat.__init__(self, sock)
self.server = server
self.set_terminator('\n')
self.data = []
self.name = None
self.enter(LoginRoom(server))
def enter(self, room):
'ä»å½åæ¿é´ç§»é¤èªèº«ï¼ç¶åæ·»å å°æå®æ¿é´'
try:
cur = self.room
except AttributeError:
pass
else:
cur.remove(self)
self.room = room
room.add(self)
def collect_incoming_data(self, data):
'æ¥å客æ·ç«¯çæ°æ®'
self.data.append(data)
def found_terminator(self):
'å½å®¢æ·ç«¯çä¸æ¡æ°æ®ç»ææ¶çå¤ç'
line = ''.join(self.data)
self.data = []
try:
self.room.handle(self, line)
except EndSession:
self.handle_close()
def handle_close(self):
async_chat.handle_close(self)
self.enter(LogoutRoom(self.server))
class ChatServer(dispatcher):
"""
è天æå¡å¨
"""
def __init__(self, port):
dispatcher.__init__(self)
self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
self.set_reuse_addr()
self.bind(('', port))
self.listen(5)
self.users = {}
self.main_room = ChatRoom(self)
def handle_accept(self):
conn, addr = self.accept()
ChatSession(self, conn)
if __name__ == '__main__':
s = ChatServer(PORT)
try:
asyncore.loop()
except KeyboardInterrupt:
print
温馨提示:答案为网友推荐,仅供参考