0

Не могу понять, почему не записывается файл на стороне сервера при приеме бинарной информации от клиента? В чем может быть проблема?

# SERVER 
import socketserver as ss

HOST, PORT = "127.0.0.1", 50007
class superTCPUnlimitedServer(ss.BaseRequestHandler):

    def setup(self):
        pass

    def handle(self):
        # self.request is the TCP socket connected to the client
        print("Server connected by ", self.client_address[0])

        with open('input.tst', 'ab') as f:
            self.data = self.request.recv(1024).strip()  
            while self.data:
                print("Начало приема файла")
                f.write(self.data)
                self.data = self.request.recv(1024).strip() 
        print("Файл закрыт")    
        print("{} wrote:".format(self.client_address[0]))
        print("Файл получен")
        # just send back the same data, but upper-cased
        self.request.sendall(bytes("файл получен", "utf-8"))

    def finish(self):
        pass    

with ss.ThreadingTCPServer((HOST, PORT), superTCPUnlimitedServer) as server:
    server.serve_forever() # server.shutdown() останавливает цикл serve_forever()
# CLIENT
import socket
import threading


HOST, PORT = "127.0.0.1", 50007
data = "Hello super server"
    
# Create a socket (SOCK_STREAM means a TCP socket)
with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
    # Connect to server and send data
    sock.connect((HOST, PORT))
    with open("001055.test", "rb") as file:
        sock.send(file.read())  
    
    # Receive data from the server and shut down
    received = str(sock.recv(1024), "utf-8")
    print("Sent:     {}".format(data))
    print("Received: {}".format(received))
8
  • 1
    А что у вас в файле "001055.test"? Может он пустой? )
    – CrazyElf
    23 ноя 2020 в 17:09
  • В том то и дело что не пустой. Размер файла 1271 байт. В нем бинарная информация 23 ноя 2020 в 17:16
  • 3
    Тогда вопрос - зачем вы делаете .strip(), если там бинарная информация?
    – CrazyElf
    23 ноя 2020 в 17:33
  • Использование .strip() взял из примера socketserver.TCPServer в документации к модулю socketserver. Ссылка docs.python.org/3.8/library/socketserver.html 24 ноя 2020 в 5:02
  • Ну там видимо текстовый файл обрабатывается. Как strip() на байты подействует мне сложно сказать. Может и никак, а может обрежет что-то лишнее.
    – CrazyElf
    24 ноя 2020 в 8:06

1 ответ 1

0

Ключевая строка:

self.data = self.request.recv(1024).strip() 

В данном случае, при очередной итерации цикла while, когда все байты уже приняты, self.request.recv(1024) бесконечно ожидает новую порцию данных. Было принято решение добавить атрибут CHUNK класса SuperTCPUnlimitedServer и в цикле while сравнивать длину CHUNK с размером принятых данных. Если очередная порция данных меньше атрибута CHUNK, это говорит о том что поступила последняя порция данных. Решение не оптимальное. Проблемы возникнут если вдруг размер получаемого файла кратен значению CHUNK.

Итоговый код:

import socketserver as ss

HOST, PORT = "127.0.0.1", 50007



class SuperTCPUnlimitedServer(ss.BaseRequestHandler):
    CHUNK = 1024
    def setup(self):
        pass

    def handle(self):

        # self.request is the TCP socket connected to the client
        print("Server connected by ", self.client_address[0])
        with open('input.ff', 'ab') as f:
            self.data = self.request.recv(self.CHUNK)
            while 1:
                if len(self.data) < self.CHUNK:
                    f.write(self.data)
                    break
                f.write(self.data)
                self.data = self.request.recv(self.CHUNK)
        print("Файл закрыт")
        print("{} wrote:".format(self.client_address[0]))
        print("Файл получен")
        # just send back the same data, but upper-cased
        self.request.sendall(bytes("файл получен", "utf-8"))

    def finish(self):
        pass

with ss.ThreadingTCPServer((HOST, PORT), SuperTCPUnlimitedServer) as server:
    server.serve_forever()  

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.