客服端發(fā)送功能請(qǐng)求,服務(wù)器通過(guò)接收的到請(qǐng)求,發(fā)送個(gè)客服端需要的文字或圖片
服務(wù)器
"""__ author__= 小孩子 """
from socket import *
from os import listdir
from threading import *
class ServerThread(Thread):
def __init__(self, connect, address):
super().__init__()
self.connect = connect
self.address = address
def run(self) ->None:
self.func()
def func(self):
# 接受消息
client_data = self.connect.recv(1024).decode()
print('Client,{}:'.format(self.address[1]), client_data)
if client_data == 'img':
self.img_server()
elif client_data == 'text':
self.text_server()
else:
self.connect.close()
return
def img_server(self):
list_img = str(listdir('../image'))
while True:
self.connect.send(list_img.encode())
# 接受客戶端發(fā)送的文件名
client_file = self.connect.recv(1024)
if client_file == 'exit':
connect.close()
break
if client_file.decode() in list_img:
with open('../image/' + client_file.decode(), 'rb') as file:
image = file.read()
self.connect.send(client_file)
# 發(fā)送圖片
self.connect.send(image)
else:
self.connect.send('False'.encode())
self.func()
def text_server(self):
while True:
self.connect.send(input('Server:').encode())
client_data = self.connect.recv(1024).decode()
print('Client,{}:'.format(self.address[1]), client_data)
if client_data == 'exit':
self.connect.close()
def servers():
server = socket()
# 綁定ip地址和端口
server.bind(('10.7.181.121', 8070))
# 設(shè)置最大連接數(shù)量
server.listen(87)
while True:
print('監(jiān)聽(tīng)中.....')
connect, address = server.accept()
t1 = ServerThread(connect, address)
print(current_thread())
t1.start()
if __name__ == '__main__':
servers()
客戶端
"""__ author__= 小孩子 """
from socket import *
class Clients:
def __init__(self):
self.client = socket()
# 發(fā)送請(qǐng)求
self.client.connect(('10.7.181.121', 8070))
def text(self, func: str):
# 告訴服務(wù)器,你需要什么
self.client.send(func.encode())
while True:
# 接收消息
server_date = self.client.recv(1024)
print('Server:', server_date.decode())
client_data = input('Client:')
# 發(fā)送消息
self.client.send(client_data.encode())
if client_data == 'exit':
self.client.close()
break
def image(self, func: str):
# 告訴服務(wù)器,你需要什么
self.client.send(func.encode())
while True:
# 接收?qǐng)D片列表
server_date = self.client.recv(1024)
print('Server:', server_date.decode())
client_data = input('Client請(qǐng)輸入圖片名字:')
# 發(fā)送圖片名字給服務(wù)器
self.client.send(client_data.encode())
# 接收文件名
file_name = self.client.recv(1024).decode()
if file_name != 'False':
while True:
# 接收消息
server_date = self.client.recv(1024)
with open(file_name, 'ab') as file:
file.write(server_date)
if len(server_date) < 1024:
print('下載文件成功!')
break
else:
print('沒(méi)有這個(gè)文件')
self.inter()
def inter(self):
with open('../files/menu.txt', 'r', encoding='utf-8') as file:
inters = file.read()
print(inters)
function = input('請(qǐng)選擇功能:')
while True:
if function == 'text':
self.text(function)
elif function == 'img':
self.image(function)
else:
self.client.close()
break
def main():
clients = Clients()
clients.inter()
if __name__ == '__main__':
main()