python实现的使用telnet登陆聊天室实例

本文实例讲述了python实现的使用telnet登陆聊天室。分享给大家供大家参考。具体如下：

前久在家学习python的时候写的一个简单的聊天室，可以使用telnet来登陆。

遗憾的是现在对中文的支持很差，英文聊天倒是没什么问题了。

功能很简单的，应该没有你想象的那么强大，但是你如果有兴趣的话可以试试的。

另外，让我惊奇的是它可以在android的平板上运行sl4a的python解释器上运行（需要稍微改几句代码，貌似是编码的那个地方，我记不清了）。

现在这个是可以在pc上跑起来的。

废话不多，直接放代码了，就一个py文件而已，而且注释是乱七八糟的，编码风格也不好（好神似我在用类c语言的习惯）。

# filename: chatroomserver.py
import threading
import datetime
import socket
# a simple log function
def log(lg):
print(lg)
# chat room server listen thread class, this class is use for listening client login
# when a client request to connect server, this class will start a connect thread
class serverlistenthread(threading.thread):
def __init__(self, hostname, port, accept):
threading.thread.__init__(self)
self.hostname = hostname
self.port = port
self.accept = accept
self.sock = socket.socket(socket.af_inet, socket.sock_stream)
self.sock.setsockopt(socket.sol_socket, socket.so_reuseaddr, 1)
self.sock.bind((hostname, port))
self.sock.listen(0)
log(‘serverip:%s serverport:%s waiting for client…’%self.sock.getsockname())
def run(self):
clientid = 1
while true:
client, cltadd = self.sock.accept()
log(‘a request from %(‘%d address:’%clientid , cltadd))
if self.accept(clientid, client):
clientid = clientid + 1
# connect thread class, this class is use for connecting with client and receiving client’s message
class serverconnectthread(threading.thread):
def __init__(self, clientid, client, encoding, receive, disconnect):
threading.thread.__init__(self)
self.client = client
self.clientid = clientid
self.encoding = encoding
self.receive = receive
self.disconnect = disconnect
self.clientname = none
self.inputs = self.client.makefile(‘rb’, 0)
self.outputs = self.client.makefile(‘wb’, 0)
def run(self):
self.sendstring(‘input your name:’)
while true:
string = self.readline()
if string:
string = string.lstrip()
if len(string)>0:
self.receive(self, string)
else:
self.inputs.close()
self.outputs.close()
break
if self.clientname:
self.disconnect(self)
def sendstring(self, string):
self.sendbytes(bytes(string, self.encoding))
def sendbytes(self, bts):
self.outputs.write(bts)
def readline(self):
rec = self.inputs.readline()
if rec:
string = bytes.decode(rec, self.encoding)
if len(string)>2:
string = string[0:-2]
else:
string = ‘ ‘
else:
string = false
return string
# chat room server class, this class is constitute of a listen thread and many connect thread
class chatroomserver:
def __init__(self, ip=’0.0.0.0′, port=9113, encoding=’utf-8’):
self.hostname = ip
self.encoding = encoding
self.port = port
self.clients = {}
self.clientnames = {}
def whenconnect(self, clientid, client):
log(‘a connect with %(‘%d address:’%clientid , client.getpeername()))
connect = serverconnectthread(clientid, client, self.encoding, self.whenreceive, self.whenexit)
connect.start()
return true
def whenreceive(self, client, string):
log(‘frome %d, receive:%s (%d)’%(client.clientid, string, len(string)))
if client.clientname:
if string[0]==’.’:
self.handlecmd(client, string[1:])
else:
now = datetime.datetime.now()
sendstring = ‘%s %s\r\n %s\r\n’%(now, client.clientname, string)
self.sendtoall(sendstring, client)
else:
if self.clientnames.__contains__(string):
client.sendstring(‘%s is exited!!!\r\n’%string)
else:
client.clientname = string
client.sendstring(‘hell, %s!!!\r\n’%client.clientname)
self.addclient(client)
return true
def whenexit(self, client):
self.delclient(client)
return true
def handlecmd(self, client, cmd):
log(‘cmd: %s’%cmd)
if cmd==’user’:
client.sendstring(‘user list(%d):\r\n’%len(self.clients))
for i in self.clients:
clt = self.clients[i]
client.sendstring(‘ %d\t%s\r\n’%(clt.clientid, clt.clientname))
else:
client.sendstring(‘unknow command: %s:\r\n’%cmd)
def start(self):
serverlisten = serverlistenthread(self.hostname, self.port, self.whenconnect)
serverlisten.start()
def sendtoall(self, string, notfor):
sends = bytes(string, self.encoding)
for i in self.clients:
if not(notfor and notfor.clientid==i):
self.clients[i].sendbytes(sends)
def addclient(self, client):
self.sendtoall(‘%s logined!!!\r\n’%client.clientname, client)
self.clients[client.clientid] = client
self.clientnames[client.clientname] = client.clientid
def delclient(self, client):
self.sendtoall(‘%s logouted!!!\r\n’%client.clientname, client)
del self.clients[client.clientid]
del self.clientnames[client.clientname]
# start a chat room server
chatroomserver().start()