Я делаю код, который сервер отправляет клиенту от 1 до 256 кбайт. Клиент получает сообщение и должен вернуть его серверу. Процесс необходимо повторить 1000 раз. Сообщение читается из файла. Сервер отправляет, а клиент забирает и отправляет обратно, но в определенный момент он останавливается. Я хотел бы знать, что не так с моим кодом.
Сервер:
import socket
hostA = '127.0.0.1'
portA = 50031
udp = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
udp.bind((hostA, portA))
dest = ('127.0.0.1',50008)
arquivo = 'texto.txt'
arq = open(arquivo , 'r')
arq = arq.read()
for i in range(0, 9):
dado = arq[0:(1024 * (2**i))]
for j in range(0, 1000):
for k in range(0, (len(dado) / 1024)):
x = dado[k:k+1024]
udp.sendto(x, dest)
for k in range(0, (len(dado) / 1024)):
msg, cliente = udp.recvfrom(1024)
udp.close()
Клиент:
import socket
hostB = '127.0.0.1'
portB = 50008
udp = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
udp.bind((hostB, portB))
orig = ('127.0.0.1',50031)
dado = ""
for i in range(0, 9):
for j in range(0, 1000):
for l in range(0, ((1024 * (2**i))/1024)):
msg, cliente = udp.recvfrom(1024)
dado += msg
for k in range(0, ((1024 * (2**i))/1024)):
x = dado[k:k+1024]
udp.sendto(x, orig)
udp.close()
Ваш вопрос касается «сокетов TCP», но вы не используете TCP.
udp = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
udp.bind((hostA, portA))
Вы используете UDP. В отличие от TCP, UDP не обнаруживает потерянные пакеты, а также не передает или переупорядочивает данные.
Ваш протокол не допускает потери пакетов. Если один пакет от сервера к клиенту или от клиента к серверу потерян, каждая сторона будет ждать друг друга бесконечно.
У тебя тоже есть другие проблемы. Представьте, что две датаграммы, отправленные клиентом, получены сервером в неправильном порядке. Данные будут повреждены.
Если вы хотите разрабатывать поверх UDP, а не TCP, вы должны реализовать все, что TCP предоставляет вам, что вам нужно. Если вам нужно обнаружение и повторная передача потерянных датаграмм, вам необходимо реализовать это самостоятельно или использовать TCP. То же самое для стимуляции передачи, обработки неупорядоченного приема и т. д.
Можете ли вы рассказать нам о конкретных ошибках или проблемах, с которыми вы сталкиваетесь в своем коде?