代码拉取完成,页面将自动刷新
import socket
import time
class Client:
def __init__(self, server, port):
# 创建socket
# 指定IPv4协议(AF_INET),IPv6协议请使用AF_INET6
# 指定使用TCP协议(SOCK_STREAM),UDP协议请使用SOCK_DGRAM
self.s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 连接服务器
self.s.connect((server, port))
# 以下是在终端中使用的方法
def receive_msg(self):
data = self.s.recv(1024).decode('utf-8') # 每次接收1KB
if data == 'exit':
return 'exit'
if data:
print("\n【人工智障聊天机器人】" + " " + time.strftime('%Y-%m-%d %H:%M:%S', time.localtime()))
print(data)
return True
return False
def send_msg(self):
print('\n请输入对话: ', end='')
message = input()
self.s.sendall(message.encode('utf-8'))
def chat(self):
data = self.s.recv(1024).decode('utf-8') # 每次接收1KB
print(data)
self.send_msg()
while True:
rec = self.receive_msg()
if rec == 'exit':
self.s.close()
print('聊天服务器断开连接')
break
if rec:
self.send_msg()
# 以下是为 Qt5 图形界面新增的方法
# 判断socket连接是否关闭
def isClose(self):
try:
test = self.s.recv(1024).decode('utf-8')
if not test:
return True
except OSError:
return True
return False
# 关闭与服务器的连接
def closeSocket(self):
self.s.sendall('exit'.encode('utf-8'))
while True:
rec = self.receive_msg()
if rec == 'exit':
self.s.close()
print('与聊天服务器断开连接')
break
# 强制关闭Socket
def force_close(self):
try:
self.s.sendall('force_exit'.encode('utf-8'))
print('断开连接')
except OSError:
print('当前没有连接服务器')
self.s.close()
# 在Qt5界面中发送消息
def send_msg_gui(self, message):
try:
self.s.sendall(message.encode('utf-8'))
print('消息', '\"' + message + '\"', '已发送')
except OSError:
print('与服务器意外断开连接')
# 在Qt5界面中接收服务器发来的回复
# 异步接收消息方法, 默认不启用
# def rec_msg_gui(self):
# while True:
# try:
# res = self.s.recv(1024).decode('utf-8')
# if res == 'exit':
# self.s.close()
# return 'exit'
# if not res:
# return '与服务器意外断开连接'
# else:
# return res
# except OSError:
# return '与服务器意外断开连接'
# 在Qt5界面中接收服务器发来的回复
# 配合QThread多线程对象使用的同步方法
def rec_msg_thread(self) -> str:
try:
res = self.s.recv(1024).decode('utf-8')
if res == 'exit':
self.s.close()
return '与服务器断开连接'
if not res:
return '与服务器意外断开连接'
elif res:
return res
except OSError:
return '与服务器意外断开连接'
if __name__ == '__main__':
client = Client(server='127.0.0.1', port=8000)
client.chat()
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。