如何做基于python的网络聊天室

① 如何用Python编写一个聊天室

python聊天室(python2.7版本)：

暂时先给出两种版本的,tcp+udp

都是分别运行server.py和client.py，就可以进行通讯了。

别外还有websocket版本，这个是有web界面的和基本web服务的，如果需要的话，我会把基本的代码贴一版上来。

TCP版本：

socket-tcp-server.py（服务端）:

#-*-encoding:utf-8-*-
#socket.getaddrinfo(host,port,family=0,socktype=0,proto=0,flags=0)
#根据给定的参数host/port，相应的转换成一个包含用于创建socket对象的五元组，
#参数host为域名，以字符串形式给出代表一个IPV4/IPV6地址或者None.
#参数port如果字符串形式就代表一个服务名，比如“http”"ftp""email"等，或者为数字，或者为None
#参数family为地主族，可以为AF_INET，AF_INET6，AF_UNIX.
#参数socktype可以为SOCK_STREAM(TCP)或者SOCK_DGRAM(UDP)
#参数proto通常为0可以直接忽略
#参数flags为AI_*的组合，比如AI_NUMERICHOST，它会影响函数的返回值
#附注：给参数host,port传递None时建立在C基础，通过传递NULL。
#该函数返回一个五元组(family,socktype,proto,canonname,sockaddr)，同时第五个参数sockaddr也是一个二元组(address,port)
#更多的方法及链接请访问
#Echoserverprogram
fromsocketimport*
importsys
importthreading
fromtimeimportctime
fromtimeimportlocaltime
importtraceback
importtime
importsubprocess
reload(sys)
sys.setdefaultencoding("utf8")


HOST='127.0.0.1'
PORT=8555#设置侦听端口
BUFSIZ=1024

classTcpServer():
def__init__(self):
self.ADDR=(HOST,PORT)
try:
self.sock=socket(AF_INET,SOCK_STREAM)
print'%disopen'%PORT

self.sock.bind(self.ADDR)
self.sock.listen(5)
#设置退出条件
self.STOP_CHAT=False

#所有监听的客户端
self.clients={}
self.thrs={}
self.stops=[]

exceptException,e:
print"%disdown"%PORT
returnFalse

defIsOpen(ip,port):

s=socket(AF_INET,SOCK_STREAM)
try:
s.connect((ip,int(port)))
#s.shutdown(2)
#利用shutdown()函数使socket双向数据传输变为单向数据传输。shutdown()需要一个单独的参数，
#该参数表示s了如何关闭socket。具体为：0表示禁止将来读；1表示禁止将来写；2表示禁止将来读和写。
print'%disopen'%port
returnTrue
except:
print'%disdown'%port
returnFalse

deflisten_client(self):
whilenotself.STOP_CHAT:
print(u'等待接入，侦听端口:%d'%(PORT))
self.tcpClientSock,self.addr=self.sock.accept()
print(u'接受连接，客户端地址：',self.addr)
address=self.addr
#将建立的clientsocket链接放到列表self.clients中
self.clients[address]=self.tcpClientSock
#分别将每个建立的链接放入进程中，接收且分发消息
self.thrs[address]=threading.Thread(target=self.readmsg,args=[address])
self.thrs[address].start()
time.sleep(0.5)defreadmsg(self,address):
#如果地址不存在，则返回False
ifaddressnotinself.clients:
returnFalse
#得到发送消息的clientsocket
client=self.clients[address]
whileTrue:
try:
#获取到消息内容data
data=client.recv(BUFSIZ)
except:
print(e)
self.close_client(address)
break
ifnotdata:
break
#python3使用bytes，所以要进行编码
#s='%s发送给我的信息是:[%s]%s'%(addr[0],ctime(),data.decode('utf8'))
#对日期进行一下格式化
ISOTIMEFORMAT='%Y-%m-%d%X'
stime=time.strftime(ISOTIMEFORMAT,localtime())
s=u'%s发送给我的信息是:%s'%(str(address),data.decode('utf8'))
#将获得的消息分发给链接中的clientsocket
forkinself.clients:
self.clients[k].send(s.encode('utf8'))
self.clients[k].sendall('sendall:'+s.encode('utf8'))
printstr(k)
print([stime],':',data.decode('utf8'))
#如果输入quit(忽略大小写),则程序退出
STOP_CHAT=(data.decode('utf8').upper()=="QUIT")
ifSTOP_CHAT:
print"quit"
self.close_client(address)
print"alreadyquit"
break

defclose_client(self,address):
try:
client=self.clients.pop(address)
self.stops.append(address)
client.close()
forkinself.clients:
self.clients[k].send(str(address)+u"已经离开了")
except:
pass
print(str(address)+u'已经退出')


if__name__=='__main__':
tserver=TcpServer()
tserver.listen_client()

——————————华丽的分割线——————————

socket-tcp-client.py（客户端）：

#-*-encoding:utf-8-*-
fromsocketimport*
importsys
importthreading
importtime
reload(sys)
sys.setdefaultencoding("utf8")


#测试，连接本机
HOST='127.0.0.1'
#设置侦听端口
PORT=8555
BUFSIZ=1024

classTcpClient:

ADDR=(HOST,PORT)
def__init__(self):
self.HOST=HOST
self.PORT=PORT
self.BUFSIZ=BUFSIZ
#创建socket连接
self.client=socket(AF_INET,SOCK_STREAM)
self.client.connect(self.ADDR)
#起一个线程，监听接收的信息
self.trecv=threading.Thread(target=self.recvmsg)
self.trecv.start()

defsendmsg(self):
#循环发送聊天消息，如果socket连接存在则一直循环，发送quit时关闭链接
whileself.client.connect_ex(self.ADDR):
data=raw_input('>:')
ifnotdata:
break
self.client.send(data.encode('utf8'))
print(u'发送信息到%s：%s'%(self.HOST,data))
ifdata.upper()=="QUIT":
self.client.close()
printu"已关闭"
break
defrecvmsg(self):
#接收消息，如果链接一直存在，则持续监听接收消息
try:
whileself.client.connect_ex(self.ADDR):
data=self.client.recv(self.BUFSIZ)
print(u'从%s收到信息：%s'%(self.HOST,data.decode('utf8')))
exceptException,e:
printstr(e)

if__name__=='__main__':
client=TcpClient()
client.sendmsg()

UDP版本：

socket-udp-server.py

#-*-coding:utf8-*-

importsys
importtime
importtraceback
importthreading
reload(sys)
sys.setdefaultencoding('utf-8')

importsocket
importtraceback

HOST="127.0.0.1"
PORT=9555
CHECK_PERIOD=20
CHECK_TIMEOUT=15

classUdpServer(object):
def__init__(self):
self.clients=[]
self.beats={}
self.ADDR=(HOST,PORT)
try:
self.sock=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
self.sock.bind(self.ADDR)#绑定同一个域名下的所有机器
self.beattrs=threading.Thread(target=self.checkheartbeat)
self.beattrs.start()
exceptException,e:
traceback.print_exc()
returnFalse

deflisten_client(self):
whileTrue:
time.sleep(0.5)
print"hohohohohoo"
try:
recvData,address=self.sock.recvfrom(2048)
ifnotrecvData:
self.close_client(address)
break
ifaddressinself.clients:
senddata=u"%s发送给我的信息是:%s"%(str(address),recvData.decode('utf8'))
ifrecvData.upper()=="QUIT":
self.close_client(address)
ifrecvData=="HEARTBEAT":
self.heartbeat(address)
continue
else:
self.clients.append(address)
senddata=u"%s发送给我的信息是:%s"%(str(address),u'进入了聊天室')
forcinself.clients:
try:
self.sock.sendto(senddata,c)
exceptException,e:
printstr(e)
self.close_client(c)
exceptException,e:
#traceback.print_exc()
printstr(e)
pass

defheartbeat(self,address):
self.beats[address]=time.time()

defcheckheartbeat(self):

whileTrue:
print"checkheartbeat"
printself.beats
try:
forcinself.clients:
printtime.time()
printself.beats[c]
ifself.beats[c]+CHECK_TIMEOUT<time.time():
printu"%s心跳超时，连接已经断开"%str(c)
self.close_client(c)
else:
printu"checkp%s,没有断开"%str(c)
exceptException,e:
traceback.print_exc()
printstr(e)
pass
time.sleep(CHECK_PERIOD)

defclose_client(self,address):
try:
ifaddressinself.clients:
self.clients.remove(address)
ifself.beats.has_key(address):
delself.beats[address]
printself.clients
forcinself.clients:
self.sock.sendto(u'%s已经离开了'%str(address),c)
print(str(address)+u'已经退出')
exceptException,e:
printstr(e)
raise

if__name__=="__main__":
udpServer=UdpServer()
udpServer.listen_client()

——————————华丽的分割线——————————
socket-udp-client.py:
#-*-coding:utf8-*-

importsys
importthreading
importtime
reload(sys)
sys.setdefaultencoding('utf-8')

importsocket

HOST="127.0.0.1"
PORT=9555
#BEAT_PORT=43278
BEAT_PERIOD=5


classUdpClient(object):
def__init__(self):
self.clientsock=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
self.HOST=HOST
self.ADDR=(HOST,PORT)
self.clientsock.sendto(u'请求建立链接',self.ADDR)
self.recvtrs=threading.Thread(target=self.recvmsg)
self.recvtrs.start()
self.hearttrs=threading.Thread(target=self.heartbeat)
self.hearttrs.start()

defsendmsg(self):
whileTrue:
data=raw_input(">:")
ifnotdata:
break
self.clientsock.sendto(data.encode('utf-8'),self.ADDR)
ifdata.upper()=='QUIT':
self.clientsock.close()
break

defheartbeat(self):
whileTrue:
self.clientsock.sendto('HEARTBEAT',self.ADDR)
time.sleep(BEAT_PERIOD)

defrecvmsg(self):
whileTrue:
recvData,addr=self.clientsock.recvfrom(1024)
ifnotrecvData:
break
print(u'从%s收到信息：%s'%(self.HOST,recvData.decode('utf8')))if__name__=="__main__":
udpClient=UdpClient()
udpClient.sendmsg()

② 聊天室是什么 如何创建聊天室求大神帮忙指点下！！

一，在网络内搜索到的资料：

聊天室 （网络虚拟谈话空间）

聊天室(chat room)是一个网上空间，为了保证谈话的焦点，聊天室通常有一定的谈话主题。任何一个联入Internet、使用正确的聊天软件，并且渴望谈论的人都可以享受其乐趣。聊天室会话是自然会话在信息时代的延伸。合作原则解释不了聊天室会话的诸多问题,没有其适用性。聊天室有语音聊天室和视频聊天室等分类。

网络聊天室通常直称聊天室，是一种人们可以在线交谈的网络论坛，在同一聊天室的人们通过广播消息进行实时交谈。
聊天室可以建立在即时通讯软件（如MSN Messenger、QQ、Anychat）、P2P软件、万维网（如 Halapo,Meebo ) 等基础上，万维网方式更为普通和种类繁多，交谈的手段不局限于文本，更包括语音、视频。通常聊天室是按照房间或频道为单位的，在同一房间或频道的网人可以实时地广播和阅读公开消息。一般情况下，与其它网络论坛、即时通讯不同的是，聊天室不保存聊天记录。
聊天室基本原理是，抛开CGI和WWW服务器，根据HTML规范，接收到浏览器的请求以后，模仿WWW服务器的响应，将聊天内容发回浏览器。在浏览器看来就像浏览一个巨大的页面一样始终处于页面联接状态， 这就是一个专门的聊天服务器，一个简化了的WWW服务器。
聊天者只需在想要进入的聊天室注册自己的用户名、密码后，登录进入某一个聊天室（大多数网站都有很多的聊天室）。在聊天室里，一般都会列出正在聊天人的名单，并且对新人进入进行提示。聊天者在一个对话框里留言，写下的话会立刻被其他人看到，并收到回应。用户也可以在聊天室内看别人对话，而自己不说话，这种行为一般被称作“潜水”。
由于聊天室里的话语都是立即可见的，所以需要一个管理员来维持秩序。管理员会制定一些基本的规章制度让大家来遵守。比如，当聊天者刚进入聊天室的时候，应该向大家介绍自己；当你向某人说话时，应该明确指明说话对象；举报一些恶意说废话者，他们反复说同样的话，使对方经常滚屏。聊天室的话题涉及方方面面，如，经典电影、爱尔兰历史、警察暴行、精神食粮。有的网站，如Yahoo，提供分专题的聊天室。有的网站，如MSN，可以指导用户创建自己的话题聊天室。

二，在其他网站搜索到的资料：

即网络聊天室，通常直呼聊天室,是一种多人可以同时在线交谈的的网络论坛，在同一聊天室的人们通过广播消息、文字、语音、视频等进行实时交谈。

聊天室可以建立在即时通讯软件（如MSN Messenger、QQ）、P2P软件、万维网等基础上，万维网方式更为普通和种类繁多，交谈的手段不局限于文本，更包括语音、视频。通常聊天室是按照房间或频道为单位的，由一个或者多个管理员管理，在同一房间或频道的网人可以实时地广播和阅读公开消息。一般情况下，与其它网络论坛、即时通讯不同的是，聊天室不保存聊天记录。

③ 怎么建立一个网络聊天室

自己建设个吧只要有自己的空间 和域名找到源程序 就行了这个是仿照 QQ群的 网页源码http://down.cnzz.cn/ShowPic/48735.aspx

④ 如何用Python编写一个聊天室

一、课程介绍

1.简介

本次项目课是实现简单聊天室程序的服务器端和客户端。

2.知识点

服务器端涉及到asyncore、asynchat和socket这几个模块，客户端用到了telnetlib、wx、time和thread这几个模块。

3.所需环境

本次课中编写客户端需要用到wxPython，它是一个GUI工具包，请先使用下面的命令安装：

$ sudo apt-get install python-wxtools

密码为shiyanlou

4.项目效果截图

登录窗口

二、项目实战（服务器端）

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(' ')
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 ' % 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. ')
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. ')

def do_say(self, session, line):
'客户端发送消息'
self.broadcast(session.name + ': ' + line + ' ')

def do_look(self, session, line):
'查看在线用户'
session.push('Online Users: ')
for other in self.sessions:
session.push(other.name + ' ')

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 ' % 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. ')
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. ')

def do_say(self, session, line):
'客户端发送消息'
self.broadcast(session.name + ': ' + line + ' ')

def do_look(self, session, line):
'查看在线用户'
session.push('Online Users: ')
for other in self.sessions:
session.push(other.name + ' ')

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(' ')
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

三、项目实战（客户端）

完成了服务器端后，就需要实现客户端了，这里客户端连接服务器使用了telnetlib模块。

1.登录窗口

这里的图形界面包选择了wxPython，前面有安装说明，登录窗口通过继承wx.Frame类来实现，代码如下：

class LoginFrame(wx.Frame):
"""
登录窗口

⑤ 怎么用python做一个聊天室不带注释，谢谢！

问题太大了兄弟，你怎么不说怎么做个淘宝京东呢。想要做聊天室，就要了解聊天室需要的技术，建议你看下python socket编程相关，一步一步来。比如先做一个无界面一问一答的双人聊天室，然后做实时问答版的，在做多人实时聊天室版，再加上界面不就ok了，之后人多了系统扛不住了，在考虑如何提高系统性能。饭是一口一口吃，路是一步一步走。

⑥ python怎么连接websocket

不知道是不是要server和client。

给一个例子，基于py27的聊天室，有server，同时client是用python模拟的，如果你想用js写，可以自己写一个

使用前先：

pip install websocket-client

然后运行server、client就可以了

websocket_server.py（服务端）

#-*-encoding:utf-8-*-

importsys
sys.path.append("..")
fromsocketimport*
importjson,time,threading

reload(sys)
sys.setdefaultencoding("utf8")

config={
'HOST':'127.0.0.1',
'PORT':10010,
'LISTEN_CLIENT':50,
'KEY':'',
'SIZE':2048,
'TIME_OUT':10000,
'HEART_TIME':5,
'MAGIC_STRING':'258EAFA5-E914-47DA-95CA-C5AB0DC85B11',
'HANDSHAKE_STRING':"HTTP/1.1101SwitchingProtocols
"
"Upgrade:websocket
"
"Connection:Upgrade
"
"Sec-WebSocket-Accept:{1}
"
"WebSocket-Location:ws://{2}/chat
"
"WebSocket-Protocol:chat

"
}


classServer():
"""
服务端基类
"""
def__init__(self):
self.sock=socket(AF_INET,SOCK_STREAM)
self.sock.bind((config['HOST'],config['PORT']))#监听端口
self.sock.listen(config['LISTEN_CLIENT'])#监听客户端数量

#所有监听的客户端
self.clients={}
self.thrs={}
self.users={}
self.stops=[]
self.onlineusers=[]

#监听客户端连接
deflisten_client(self):
while1:
#循环监听
tcpClientSock,addr=self.sock.accept()
address=addr[0]+':'+str(addr[1])#ip:port
#握手
topInfo=tcpClientSock.recv(1024)
headers={}
ifnottopInfo:
self.onlineusers.remove(self.users[address])
tcpClientSock.close()
continue

header,data=topInfo.split('

',1)

try:
getInfo=header.split('
')[0].split('')[1].split('/')[1:]
ifgetInfo[0]=='name':
self.users[address]=str(getInfo[1])
self.onlineusers.append(self.users[address])
else:
self.users[address]=u'匿名用户'

except:
self.users[address]=u'匿名用户'

print"thisisself.users[address]:"
printself.users[address]

forlineinheader.split('
')[1:]:
key,val=line.split(':',1)
headers[key]=val

if'Sec-WebSocket-Key'notinheaders:
self.onlineusers.remove(self.users[address])
tcpClientSock.close()
continue


importhashlib,base64
sec_key=headers['Sec-WebSocket-Key']
res_key=base64.b64encode(hashlib.sha1(sec_key+config['MAGIC_STRING']).digest())
str_handshake=config['HANDSHAKE_STRING'].replace('{1}',res_key).replace('{2}',config['HOST']+':'+str(config['PORT']))

tcpClientSock.send(str_handshake)

#握手成功分配线程进行监听
print(address+u'进来了')

self.clients[address]=tcpClientSock
self.thrs[address]=threading.Thread(target=self.readMsg,args=[address])
self.thrs[address].start()
time.sleep(0.5)

defreadMsg(self,address):
ifaddressnotinself.clients:
returnFalse
client=self.clients[address]

importselect
time_out=0
while1:
ifaddressinself.stops:
self.close_client(address)
print(address+u'已经离开了系统！')
break

#检测超时
iftime_out>=config['TIME_OUT']:
self.close_client(address)
break

time_out+=5

infds,outfds,errfds=select.select([client,],[],[],5)
iflen(infds)==0:
continue

time_out=0
try:
info=client.recv(1024)
except:
self.close_client(address)
break

ifnotinfo:
continue

ifinfo=='quit':
self.close_client(address)
break
code_len=ord(info[1])&127
ifcode_len==126:
masks=info[4:8]
data=info[8:]
elifcode_len==127:
masks=info[10:14]
data=info[14:]
else:
masks=info[2:6]
data=info[6:]
i=0
raw_str=""
fordindata:
#print(masks,masks[i%4])
raw_str+=chr(ord(d)^ord(masks[i%4]))
i+=1

print"thisisraw_stryesthisisraw_str"
printrepr(raw_str)

#获取到输入的数据向所有的客户端发送
#开启线程记录

ifraw_str:
t1=threading.Thread(target=self.send_data,args=[raw_str,address])
t1.start()

time.sleep(0.5)defonlineuser(self):
fromurllibimportunquote
username=[]
foriinself.onlineusers:
i=unquote(i).encode('utf8')
username.append(str(i))
returnusername


defsend_data(self,data,address):
importstruct
fromurllibimportunquote
try:
username=unquote(self.users[address])
except:
username=u'匿名用户'

'''封装数据'''
reply={}
ifdata:
data=data.split("}")[0]+"}"
data=json.loads(data);
'''如果有人加入的话，消息封装如下：'''
ifdata["type"]=="JOIN":
reply["type"]="JOIN"
reply["data"]=data["username"]
reply["user_from"]=data["username"]
reply["user"]=self.onlineuser()
'''如果有人发消息，判断是发送给全部还是个人'''

elifdata["type"]=="POST":
reply["type"]="POST"
ifdata["sendto"]=="ALL":
reply["data"]="["+data['username']+"]:"+data["content"]
else:
reply["data"]=u"["+data['username']+"]悄悄对["+data["sendto"]+"]说:"+data["content"]
reply["user_from"]=data["username"]
reply["user"]=self.onlineuser()
reply["sendto"]=data["sendto"]

'''如果是退出的消息，封装如下'''
elifdata["type"]=="QUIT":
self.close_client(address)
reply["type"]="QUIT"
reply["user_from"]=data["username"]
reply["user"]=self.onlineuser()

reply=json.mps(reply)
else:
returnFalse

token="x81"
length=len(reply)
iflength<126:
token+=struct.pack("B",length)
eliflength<=0xFFFF:
token+=struct.pack("!BH",126,length)
else:
token+=struct.pack("!BQ",127,length)

#struct为Python中处理二进制数的模块，二进制流为C，或网络流的形式。
alldata='%s%s'%(token,reply)
try:
#判断消息如果是私聊的，找出sendto和sendfrom进行单发
ifdata["type"]=="POST":
ifdata["sendto"]!="ALL":

forkey,valinself.users.iteritems():
printkey,unquote(val)
val=unquote(val)
ifval==data["sendto"]orval==data["username"]:
printkey
self.clients[key].send(alldata)
else:
forkey,valinself.clients.iteritems():
client=val
try:
client.send(alldata)
except:
self.close_client(key)
else:
forkey,valinself.clients.iteritems():
client=val
try:
client.send(alldata)
except:
self.close_client(key)
except:
pass


defclose_client(self,address):
try:
client=self.clients.pop(address)
self.stops.append(address)
self.onlineusers.remove(self.users[address])
client.close()
delself.users[address]
except:
pass

print(address+u'已经退出')if__name__=='__main__':
s=Server()
s.listen_client()websocket_client.py(客户端)
#-*-encoding:utf-8-*-

importsys
sys.path.append("..")
fromsocketimport*
importjson,time,threading
fromwebsocketimportcreate_connection
reload(sys)
sys.setdefaultencoding("utf8")

#config={
#'HOST':'127.0.0.1',
#'PORT':10010
#}
#pipinstallwebsocket-client

classClient():
def__init__(self):
#调用create_connection方法，建立一个websocket链接
self.ws=create_connection("ws://127.0.0.1:10010/name/johanna")
#建一个线程，监听服务器发送给客户端的数据
self.trecv=threading.Thread(target=self.recv)
self.trecv.start()
#建立链接后，给聊天室大家群发一个加入消息
msg={
"type":"JOIN",
"username":"johanna",
"content":"HelloEvery,anewguycomein"
}
msg=json.mps(msg)
self.ws.send(msg)

#发送方法，聊天输入语句时调用，此处默认为群聊ALL
defsend(self,content):
msg={
"type":"POST",
"username":"johanna",
"sendto":"ALL",
"content":content

}
msg=json.mps(msg)
self.ws.send(msg)

#接收服务端发送给客户的数据，只要ws处于连接状态，则一直接收数据
defrecv(self):
try:
whileself.ws.connected:
result=self.ws.recv()
print"receivedmsg:"+str(result)
exceptException,e:
pass


#关闭时，发送QUIT方法，并告诉大家，我要走了
defclose(self):
msg={
"type":"QUIT",
"username":"johanna",
"content":"byebye,everyone"
}
msg=json.mps(msg)
self.ws.send(msg)


if__name__=='__main__':

c=Client()
#当输入聊天语句非exit时，则持续聊天状态，如果exit，则关闭链接
whileTrue:
content=raw_input("pleaseinput(inputexittoexit):")
ifcontent=="exit":
c.close()
break
else:
c.send(content)
time.sleep(1)

⑦ python局域网聊天室怎么编写表情代码，用什么方式打开，需要什么插件吗

要VB我给你代码，Python不会

⑧ 如何用Python编写一个聊天室

#!/usr/bin/python
#encoding:utf-8

fromasyncoreimportdispatcher
fromasynchatimportasync_chat
importsocket,asyncore

PORT=6666#端口

classEndSession(Exception):
"""
自定义会话结束时的异常
"""
pass

classCommandHandler:
"""
命令处理类
"""

defunknown(self,session,cmd):
'响应未知命令'
session.push('Unknowncommand:%sn'%cmd)

defhandle(self,session,line):
'命令处理'
ifnotline.strip():
return
parts=line.split('',1)
cmd=parts[0]
try:
line=parts[1].strip()
exceptIndexError:
line=''
meth=getattr(self,'do_'+cmd,None)
try:
meth(session,line)
exceptTypeError:
self.unknown(session,cmd)

classRoom(CommandHandler):
"""
包含多个用户的环境，负责基本的命令处理和广播
"""

def__init__(self,server):
self.server=server
self.sessions=[]

defadd(self,session):
'一个用户进入房间'
self.sessions.append(session)

defremove(self,session):
'一个用户离开房间'
self.sessions.remove(session)

defbroadcast(self,line):
'向所有的用户发送指定消息'
forsessioninself.sessions:
session.push(line)

defdo_logout(self,session,line):
'退出房间'
raiseEndSession

classLoginRoom(Room):
"""
刚登录的用户的房间
"""

defadd(self,session):
'用户连接成功的回应'
Room.add(self,session)
session.push('ConnectSuccess')

defdo_login(self,session,line):
'登录命令处理'
name=line.strip()
ifnotname:
session.push('UserNameEmpty')
elifnameinself.server.users:
session.push('UserNameExist')
else:
session.name=name
session.enter(self.server.main_room)

classChatRoom(Room):
"""
聊天用的房间
"""

defadd(self,session):
'广播新用户进入'
session.push('LoginSuccess')
self.broadcast(session.name+'hasenteredtheroom.n')
self.server.users[session.name]=session
Room.add(self,session)

defremove(self,session):
'广播用户离开'
Room.remove(self,session)
self.broadcast(session.name+'haslefttheroom.n')

defdo_say(self,session,line):
'客户端发送消息'
self.broadcast(session.name+':'+line+'n')

defdo_look(self,session,line):
'查看在线用户'
session.push('OnlineUsers:n')
forotherinself.sessions:
session.push(other.name+'n')

classLogoutRoom(Room):
"""
用户退出时的房间
"""

defadd(self,session):
'从服务器中移除'
try:
delself.server.users[session.name]
exceptKeyError:
pass

classChatSession(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))

defenter(self,room):
'从当前房间移除自身，然后添加到指定房间'
try:
cur=self.room
exceptAttributeError:
pass
else:
cur.remove(self)
self.room=room
room.add(self)

defcollect_incoming_data(self,data):
'接受客户端的数据'
self.data.append(data)

deffound_terminator(self):
'当客户端的一条数据结束时的处理'
line=''.join(self.data)
self.data=[]
try:
self.room.handle(self,line)
exceptEndSession:
self.handle_close()

defhandle_close(self):
async_chat.handle_close(self)
self.enter(LogoutRoom(self.server))

classChatServer(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)

defhandle_accept(self):
conn,addr=self.accept()
ChatSession(self,conn)

if__name__=='__main__':
s=ChatServer(PORT)
try:
asyncore.loop()
exceptKeyboardInterrupt:
print

⑨ 用python制作聊天室服务器源代码写好了不知如何让运行

Python是一种即译式的，互动的，...或新建一个界面让数据在互不兼容的系统中流动。...Zope是一个开放源代码的Web应用服务器，采用Python语言开发，使用它您可

⑩ 我想要做一个网络聊天室，不知道怎么开始做

1.首先你要进一步明确你要做什么？
网络聊天室，是网页聊天？电脑软件聊天？移动app聊天？
2.然后你要明白你可以做到什么？
你会编程吗？java，php，C++，C#，你会？那就可以开始设计程序的思路了。你不会？你就可以网上找源码学习自己部署源码项目了。
3.进一步你要知道你怎么可以做好。
服务端环境怎么搭建，服务器用什么系统，源码是不是有bug和漏洞，搭建好了客户端怎么连接，运行起来了怎么保证稳定性。
4.什么？你有钱？而且很多。
差不多几十万可以直接让别人帮你搞定，还有余钱招人运维。猪八戒或者直接线下联系软件公司就好。
5.什么？你没钱？
那么老老实实参考上述三条，让你或者你的团队自学搞定。不会编程也得会部署已经有的源码，不会服务器就赶紧了解就学，网上的聊天程序一大堆，安装说明文档，和各种知识也很多，基本上看教程照着来就行，如果你这都搞不定？
【那就没办法了】