通過socket實現(xiàn)局域網(wǎng)內(nèi)的聊天工具。
service.py文件如下：
#!/usr/bin/env python
# _*_ coding:utf-8 _*_
import socket
# 創(chuàng)建一個socket對象
sk = socket.socket()
# 綁定允許連接的IP地址和端口
sk.bind(('127.0.0.1', 6053, ))
# 服務(wù)端允許起來之后，限制客戶端連接的數(shù)量，如果超過五個連接脚作，第六個連接來的時候直接斷開第六個惩阶。
sk.listen(5)
while True:
# 會一直阻塞，等待接收客戶端的請求部翘，如果有客戶端連接會獲取兩個值，conn=創(chuàng)建的連接响委，address=客戶端的IP和端口
conn, address = sk.accept()
# 當(dāng)用戶連接過來的時候就給用戶發(fā)送一條信息新思，在Python3里面需要把發(fā)送的內(nèi)容轉(zhuǎn)換為字節(jié)
conn.sendall(bytes("你好，歡迎登陸赘风！", encoding="utf-8"))
while True:
# 輸出等待客戶端發(fā)送內(nèi)容
print("正在等待Client輸入內(nèi)容......")
# 接收客戶端發(fā)送過來的內(nèi)容
ret_bytes = conn.recv(1024)
# 轉(zhuǎn)換成字符串類型
ret_str = str(ret_bytes, encoding="utf-8")
# 輸出用戶發(fā)送過來的內(nèi)容
print(ret_str)
# 如果用戶輸入的是q
if ret_str == "q":
# 則退出循環(huán)夹囚，等待下個用戶輸入
break
# 給客戶端發(fā)送內(nèi)容
inp = input("Service請輸入要發(fā)送的內(nèi)容>>> ")
conn.sendall(bytes(inp, encoding="utf-8"))
client.py文件內(nèi)容如下：
#!/usr/bin/env python
# _*_ coding:utf-8 _*_
import socket
# 創(chuàng)建一個socket對象
obj = socket.socket()
# 制定服務(wù)端的IP地址和端口
obj.connect(('127.0.0.1', 6053, ))
# 阻塞，等待服務(wù)端發(fā)送內(nèi)容邀窃，接受服務(wù)端發(fā)送過來的內(nèi)容荸哟，最大接受1024字節(jié)
ret_bytes = obj.recv(1024)
# 因為服務(wù)端發(fā)送過來的是字節(jié)，所以我們需要把字節(jié)轉(zhuǎn)換為字符串進行輸出
ret_str = str(ret_bytes, encoding="utf-8")
# 輸出內(nèi)容
print(ret_str)
while True:
# 當(dāng)進入連接的時候，提示讓用戶輸入內(nèi)容
inp = input("Client請輸入要發(fā)送的內(nèi)容>>> ")
# 如果輸出q則退出
if inp == "q":
# 把q發(fā)送給服務(wù)端
obj.sendall(bytes(inp, encoding="utf-8"))
# 退出當(dāng)前while
break
else:
# 否則就把用戶輸入的內(nèi)容發(fā)送給用戶
obj.sendall(bytes(inp, encoding="utf-8"))
# 等待服務(wù)端回答
print("正在等待Server輸入內(nèi)容......")
# 獲取服務(wù)端發(fā)送過來的結(jié)果
ret = str(obj.recv(1024), encoding="utf-8")
# 輸出結(jié)果
print(ret)
# 連接完成之后關(guān)閉鏈接
obj.close()
