先启动客户端也可以
服务端:
import socketimport time#服务端HOST = ''PORT = 8888ADDR = (HOST, PORT)BUFFSIZE = 102400MAX_LISTEN = 5s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)s.bind(ADDR)s.listen(MAX_LISTEN)print('等待用户接入中..')clientsocket, addr = s.accept()while True:try:recv_data = clientsocket.recv(BUFFSIZE).decode('gbk')if recv_data:print('来自客户端的消息%s'%recv_data)except Exception as message:print('客户端断开连接%s'%message)print('等待用户重新接入中..')clientsocket, addr = s.accept()
客户端:
# 导入socket库import socketimport threadingimport time#客户端def connect():while True:server2 = ("127.0.0.1", 8888)global socket_client2socket_client2 = socket.socket(socket.AF_INET, socket.SOCK_STREAM)try:socket_client2.connect(server2)except Exception as message:print('连接服务器报错%s'%message)time.sleep(1)continueelse:print('连接服务器成功')breakdef send_to_server(msg):socket_client2.send(msg.encode("gbk"))print('发送给服务器的消息:%s'%msg)def main():for i in range(999):if i%2 == 0:try:send_to_server(str(i))time.sleep(1)except Exception as message:print('消息发送失败%s'%message)time.sleep(2)connect()connect()main()