Python網(wǎng)絡(luò)編程之socketserver實現(xiàn)多并發(fā)

利用socketserver實現(xiàn)多并發(fā)，socketserver內(nèi)部會調(diào)用socket模塊進行功能上的實現(xiàn)

client.py客戶端腳本文件內(nèi)容

1. #!/usr/bin/env python

2. # _*_ coding:utf-8 _*_

4. import socket

6. # 創(chuàng)建一個socket對象

7. obj = socket.socket()

9. # 制定服務(wù)端的IP地址和端口

10. obj.connect(('127.0.0.1', 999, ))

12. # 阻塞，等待服務(wù)端發(fā)送內(nèi)容，接受服務(wù)端發(fā)送過來的內(nèi)容，最大接受1024字節(jié)

13. ret_bytes = obj.recv(1024)

15. # 因為服務(wù)端發(fā)送過來的是字節(jié)，所以我們需要把字節(jié)轉(zhuǎn)換為字符串進行輸出

16. ret_str = str(ret_bytes, encoding="utf-8")

18. # 輸出內(nèi)容

19. print(ret_str)

21. while True:

22.    # 當(dāng)進入連接的時候，提示讓用戶輸入內(nèi)容

23.    inp = input("Client請輸入要發(fā)送的內(nèi)容>>> ")

24.    # 如果輸出q則退出

25.    if inp == "q":

26.        # 把q發(fā)送給服務(wù)端

27.        obj.sendall(bytes(inp, encoding="utf-8"))

28.        # 退出當(dāng)前while

29.        break

30.    else:

31.        # 否則就把用戶輸入的內(nèi)容發(fā)送給用戶

32.        obj.sendall(bytes(inp, encoding="utf-8"))

33.        # 等待服務(wù)端回答

34.        print("正在等待Server輸入內(nèi)容......")

35.        # 獲取服務(wù)端發(fā)送過來的結(jié)果

36.        ret = str(obj.recv(1024), encoding="utf-8")

37.        # 輸出結(jié)果

38.        print(ret)

40. # 連接完成之后關(guān)閉鏈接

41. obj.close()

server.py服務(wù)端腳本文件內(nèi)容

1. #!/usr/bin/env python

2. # _*_ coding:utf-8 _*_

4. import socketserver

6. class MyServer(socketserver.BaseRequestHandler):

8.    def handle(self):

10.        conn = self.request

12.        conn.sendall(bytes("你好，歡迎登陸！", encoding="utf-8"))

14.        while True:

15.            # 輸出等待客戶端發(fā)送內(nèi)容

16.            print("正在等待Client輸入內(nèi)容......")

17.            # 接收客戶端發(fā)送過來的內(nèi)容

18.            ret_bytes = conn.recv(1024)

19.            # 轉(zhuǎn)換成字符串類型

20.            ret_str = str(ret_bytes, encoding="utf-8")

21.            # 輸出用戶發(fā)送過來的內(nèi)容

22.            print(ret_str)

24.            # 如果用戶輸入的是q

25.            if ret_str == "q":

26.                # 則退出循環(huán)，等待下個用戶輸入

27.                break

28.            # 給客戶端發(fā)送內(nèi)容

29.            inp = input("Service請輸入要發(fā)送的內(nèi)容>>> ")

30.            conn.sendall(bytes(inp, encoding="utf-8"))

32. if __name__ == "__main__":

33.    server = socketserver.ThreadingTCPServer(('127.0.0.1', 999, ), MyServer)

34.    server.serve_forever()

效果圖

同時打開多個客戶端，服務(wù)端也不會出現(xiàn)錯誤

本文出自 “一盞燭光” 博客，謝絕轉(zhuǎn)載！