Python網絡程式設計之基于socket實作聊天機器人

通過socket實作區域網路内的聊天工具。

service.py檔案如下：

1. #!/usr/bin/env python

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

4. import socket

6. # 建立一個socket對象

7. sk = socket.socket()

9. # 綁定允許連接配接的IP位址和端口

10. sk.bind(('127.0.0.1', 6053, ))

12. # 服務端允許起來之後，限制用戶端連接配接的數量，如果超過五個連接配接，第六個連接配接來的時候直接斷開第六個。

13. sk.listen(5)

15. while True:

16.    # 會一直阻塞，等待接收用戶端的請求，如果有用戶端連接配接會擷取兩個值，conn=建立的連接配接，address=用戶端的IP和端口

17.    conn, address = sk.accept()

19.    # 當使用者連接配接過來的時候就給使用者發送一條資訊，在Python3裡面需要把發送的内容轉換為位元組

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

22.    while True:

23.        # 輸出等待用戶端發送内容

24.        print("正在等待Client輸入内容......")

25.        # 接收用戶端發送過來的内容

26.        ret_bytes = conn.recv(1024)

27.        # 轉換成字元串類型

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

29.        # 輸出使用者發送過來的内容

30.        print(ret_str)

32.        # 如果使用者輸入的是q

33.        if ret_str == "q":

34.            # 則退出循環，等待下個使用者輸入

35.            break

36.        # 給用戶端發送内容

37.        inp = input("Service請輸入要發送的内容>>> ")

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

client.py檔案内容如下：

1. #!/usr/bin/env python

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

4. import socket

6. # 建立一個socket對象

7. obj = socket.socket()

9. # 制定服務端的IP位址和端口

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

12. # 阻塞，等待服務端發送内容，接受服務端發送過來的内容，最大接受1024位元組

13. ret_bytes = obj.recv(1024)

15. # 因為服務端發送過來的是位元組，是以我們需要把位元組轉換為字元串進行輸出

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

18. # 輸出内容

19. print(ret_str)

21. while True:

22.    # 當進入連接配接的時候，提示讓使用者輸入内容

23.    inp = input("Client請輸入要發送的内容>>> ")

24.    # 如果輸出q則退出

25.    if inp == "q":

26.        # 把q發送給服務端

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

28.        # 退出目前while

29.        break

30.    else:

31.        # 否則就把使用者輸入的内容發送給使用者

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

33.        # 等待服務端回答

34.        print("正在等待Server輸入内容......")

35.        # 擷取服務端發送過來的結果

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

37.        # 輸出結果

38.        print(ret)

40. # 連接配接完成之後關閉連結

41. obj.close()

執行結果