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

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

2021-05-13 00:58whoami021 Python

这篇文章主要为大家详细介绍了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()