python基于C/S模式实现聊天室功能
时间：2020-11-08 12:31:50 | 栏目：Python代码 | 点击：次
最简单的模式，C/S模式实现聊天室
从半双工开始，何谓半双工？半双工即是说双方可以互发消息，但一次只能一个用户发送。
只要稍微会点socket编程的人都会觉得很简单，所以过过场，直接上代码。
服务器端代码：
from socket import *
from time import ctime
HOST = ''
PORT = 4568
BUFSIZE = 1024
ADDR = (HOST,PORT)
tcpSerSocket = socket(AF_INET, SOCK_STREAM)
tcpSerSocket.bind(ADDR)
tcpSerSocket.listen(5)
while True:
print('waitint for connection...')
tcpCliSocket, addr = tcpSerSocket.accept()
print('connecting from: ', addr)
while True:
data = tcpCliSocket.recv(BUFSIZE)
if not data:
break
print data
msg = raw_input('>')
tcpCliSocket.send('[%s] %s' % (ctime(), msg))
tcpCliSocket.close()
tcpSerSocket.close()
客户端代码：
from socket import *
HOST = 'localhost'
PORT = 4568
BUFSIZE = 1024
ADDR = (HOST, PORT)
tcpCliSocket = socket(AF_INET, SOCK_STREAM)
tcpCliSocket.connect(ADDR)
while True:
data = raw_input('>>')
if not data:
break
tcpCliSocket.send(data)
data = tcpCliSocket.recv(BUFSIZE)
if not data:
break
print data
tcpCliSocket.close()
运行结果我就不截图了，如果还不会的就复制下来运行一遍。
上面只是最简单的入门，一点都不好使，问题多着。
下面看怎么实现全双工。全双工就是双方可任意给对方发送消息。
全双工明显要用到多线程。我们在主线程之外创建两个子线程，一个负责接收消息，另一个负责接受用户输入并发送消息。
服务器端代码：
#coding: utf-8
from socket import *
from time import ctime
import threading
from sys import stdout
HOST = ''
PORT = 21567
BUFSIZE = 1024
ADDR = (HOST, PORT)
def Send(sck):
while True:
data = raw_input('>')
sck.send(data)
def Deal(sck, addr):
while True:
data = sck.recv(BUFSIZE)
if data == "quit":
sck.close()
break
str = '\nfrom' + addr[0] + ':' + data + '\n>'
stdout.write(str)
chatSerSock = socket(AF_INET, SOCK_STREAM)
chatSerSock.bind(ADDR)
chatSerSock.listen(5)
threads = []
while True:
print 'waiting for connection...'
chatCliSock, addr = chatSerSock.accept()
print "...connected from: ", addr
t = threading.Thread(target=Deal, args=(chatCliSock, addr))
threads.append(t)
t = threading.Thread(target=Send, args=(chatCliSock,))
threads.append(t)
for i in range(len(threads)):
threads[i].start()
threads[0].join()
chatCliSock.close()
chatSerSock.close()
客户端代码：
#coding: utf8
from socket import *
from time import ctime
import threading
from sys import stdout
def Send(sck, test):
while True:
data = raw_input('>')
sck.send(data)
if data == "quit":
break
def Recieve(sck, test):
while True:
data = sck.recv(BUFSIZ)
if data == "quit":
sck.close()
break
str = "\nfrom server:" + data + "\n>"
stdout.write(str)
HOST = 'localhost'
PORT= 21567
BUFSIZ = 1024
ADDR = (HOST, PORT)
threads = []
if __name__ == "__main__":
chatCliSock = socket(AF_INET, SOCK_STREAM)
chatCliSock.connect(ADDR)
t = threading.Thread(target=Send, args = (chatCliSock, None))
threads.append(t)
t = threading.Thread(target=Recieve, args = (chatCliSock, None))
threads.append(t)
for i in range(len(threads)):
threads[i].start()
threads[0].join()
chatCliSock.close()
运行结果：
