使用python套接字时不发生循环

Question

我在树莓派上使用服务器代码，在笔记本电脑上使用客户端代码。我还关闭了电脑上的防火墙。连接到服务器后，我设法从客户端运行一次循环，关键字&;data&;当我输入另一个命令时，它就跳出了循环。如果我键入Quit，它说它已经使用了一个OS error98地址。我能知道如何保持这个循环吗?下面是我的client.py和server.py代码。

Server.py代码:

import socket
import numpy as np
import encodings
HOST = '192.168.1.65'  
PORT = 65432        # Port to listen on (non-privileged ports are > 1023)
def random_data():          # ANY DATA YOU WANT TO SEND WRITE YOUR SENSOR CODE HERE
x1 = np.random.randint(0, 55, None)         # Dummy temperature
y1 = np.random.randint(0, 45, None)         # Dummy humidigy
my_sensor = "{},{}".format(x1,y1)
return my_sensor                            # return data seperated by comma
def my_server():
with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
print("Server Started waiting for client to connect ")
s.bind((HOST, PORT))
s.listen(5)
conn, addr = s.accept()
with conn:
print('Connected by', addr)
while True:
data = conn.recv(1024).decode('utf-8')
if str(data) == "Data":
print("Ok Sending data ")
my_data = random_data()
x_encoded_data = my_data.encode('utf-8')
conn.sendall(x_encoded_data)
elif  str(data) == "Quit":
print("shutting down server ")
break
else:
pass

if __name__ == '__main__':
while 1:
my_server()

Client.py代码:

import socket
import threading
import time

HOST = '192.168.1.65'  # The server's hostname or IP address
PORT = 65432       # The port used by the server

def process_data_from_server(x):
x1, y1 = x.split(",")
return x1,y1
def my_client():
threading.Timer(11, my_client).start()
with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
s.connect((HOST, PORT))
my = input("Enter command ")
my_inp = my.encode('utf-8')
s.sendall(my_inp)
data = s.recv(1024).decode('utf-8')
x_temperature,y_humidity = process_data_from_server(data)
print("Temperature {}".format(x_temperature))
print("Humidity {}".format(y_humidity))
s.close()
time.sleep(5)

if __name__ == "__main__":
while 1:
my_client()

Answer 1

address already used

你需要使用socket.setsockopt设置socket.SO_REUSEADDR在我认为客户端和服务器。py

def my_server():

# with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
print("Server Started waiting for client to connect ")
s.bind((HOST, PORT))
s.listen(5)
conn, addr = s.accept()

with conn:
print('Connected by', addr)
while True:

data = conn.recv(1024).decode('utf-8')
if str(data) == "Data":
...