python基于C/S模式实现聊天室功能

最简单的模式，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()

运行结果：

来源：https://blog.csdn.net/whoami021/article/details/21285421