Python socket C/S结构的聊天室应用实现
2014-11-30 00:00
911 查看
Python socket C/S结构的聊天室应用
服务端:
#!/usr/bin/env python
#coding:utf8
import socket,select
def broadcast_data (sock,message):
for socket in conn_list:
if socket != server_socket and socket != sock :
try :
socket.send(message)
except :
socket.close()
conn_list.remove(socket)
if __name__ == "__main__":
conn_list = []
recv_buffer = 4096
PORT = 9999
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) #端口重用,可选
server_socket.bind(('', PORT))
server_socket.listen(99)
conn_list.append(server_socket)
print "Chat server started on port " + str(PORT)
while 1:
read_sockets,write_sockets,error_sockets = select.select(conn_list,[],[])
for sock in read_sockets:
#新建连接
if sock == server_socket:
sockfd, addr = server_socket.accept()
conn_list.append(sockfd)
print "Client (%s, %s) connected" % addr
broadcast_data(sockfd, "[%s:%s] entered room\n" % addr)
#进入聊天室
else:
try:
data = sock.recv(recv_buffer)
if data:
broadcast_data(sock, "\r" + '<' + str(sock.getpeername()) + '> ' + data)
except:
broadcast_data(sock, "Client (%s, %s) is offline" % addr)
print "Client (%s, %s) is offline" % addr
sock.close()
conn_list.remove(sock)
continue
server_socket.close()
客户端:
#!/usr/bin/env python
#coding:utf8
import socket,select,string,sys
def prompt() :
sys.stdout.write('<You> ')
sys.stdout.flush()
if __name__ == "__main__":
if(len(sys.argv) < 3) :
print 'Usage : python chat_client.py hostname port'
sys.exit()
HOST = sys.argv[1]
PORT = int(sys.argv[2])
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.settimeout(2)
try :
s.connect((HOST, PORT))
except :
print 'Unable to connect'
sys.exit()
print 'Connected to remote host. Start sending messages'
prompt()
while 1:
socket_list = [sys.stdin, s]
read_sockets, write_sockets, error_sockets = select.select(socket_list , [], [])
for sock in read_sockets:
if sock == s:
data = sock.recv(4096)
if not data :
print '\nDisconnected from chat server'
sys.exit()
else :
sys.stdout.write(data)
prompt()
else :
msg = sys.stdin.readline()
s.send(msg)
prompt()
服务端:
#!/usr/bin/env python
#coding:utf8
import socket,select
def broadcast_data (sock,message):
for socket in conn_list:
if socket != server_socket and socket != sock :
try :
socket.send(message)
except :
socket.close()
conn_list.remove(socket)
if __name__ == "__main__":
conn_list = []
recv_buffer = 4096
PORT = 9999
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) #端口重用,可选
server_socket.bind(('', PORT))
server_socket.listen(99)
conn_list.append(server_socket)
print "Chat server started on port " + str(PORT)
while 1:
read_sockets,write_sockets,error_sockets = select.select(conn_list,[],[])
for sock in read_sockets:
#新建连接
if sock == server_socket:
sockfd, addr = server_socket.accept()
conn_list.append(sockfd)
print "Client (%s, %s) connected" % addr
broadcast_data(sockfd, "[%s:%s] entered room\n" % addr)
#进入聊天室
else:
try:
data = sock.recv(recv_buffer)
if data:
broadcast_data(sock, "\r" + '<' + str(sock.getpeername()) + '> ' + data)
except:
broadcast_data(sock, "Client (%s, %s) is offline" % addr)
print "Client (%s, %s) is offline" % addr
sock.close()
conn_list.remove(sock)
continue
server_socket.close()
客户端:
#!/usr/bin/env python
#coding:utf8
import socket,select,string,sys
def prompt() :
sys.stdout.write('<You> ')
sys.stdout.flush()
if __name__ == "__main__":
if(len(sys.argv) < 3) :
print 'Usage : python chat_client.py hostname port'
sys.exit()
HOST = sys.argv[1]
PORT = int(sys.argv[2])
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.settimeout(2)
try :
s.connect((HOST, PORT))
except :
print 'Unable to connect'
sys.exit()
print 'Connected to remote host. Start sending messages'
prompt()
while 1:
socket_list = [sys.stdin, s]
read_sockets, write_sockets, error_sockets = select.select(socket_list , [], [])
for sock in read_sockets:
if sock == s:
data = sock.recv(4096)
if not data :
print '\nDisconnected from chat server'
sys.exit()
else :
sys.stdout.write(data)
prompt()
else :
msg = sys.stdin.readline()
s.send(msg)
prompt()
相关文章推荐
- Python socket C/S结构的聊天室应用实现
- Python socket实现简单聊天室
- Python Socket实现简单的聊天室
- 命令行界面的C/S聊天室应用 (Socket多线程实现)
- 命令行界面的C/S聊天室应用 (Socket多线程实现)
- python应用系列教程——python使用SocketServer实现网络服务器,socket实现客户端
- 使用socket.io+redis来实现基本的聊天室应用场景
- 使用socket.io+redis来实现基本的聊天室应用场景
- Python socket实现简单聊天室
- Python基于Socket实现简单聊天室
- 用Python socket实现一个简单的http服务器(post 与get 的区别)、CGIHTTPServer 简单应用
- Python应用-[用Python实现一个socket echo程序 && tcp socket的几个关闭状态]
- python socket 初学 串行双向聊天室的简单实现
- 基于Socket的聊天室实现原理
- C# Socket通信应用实现 基本流程
- Python中socket和多线程的应用
- Python网络编程Socket应用实例
- 求助:J2ME:用socket实现聊天室时,发送消息的内容不能正常显示
- Socket实现手机聊天室
- python实现socket通讯(UDP)