Как создать условную двунаправленную передачу файлов Client Server с использованием Python - PullRequest
Новая
       16

Как создать условную двунаправленную передачу файлов Client Server с использованием Python

1 голос
/ 24 апреля 2019

Я пытаюсь создать простой сервер, который

а) отправляет файл, как только клиент подключается, б) получает файл позже, когда файл редактируется

, и клиент, который получаетфайл автоматически при подключении и последующей отправке отредактированного файла

Так что для клиента часть, которая получает первую часть, работает нормально, но как отправить файл обратно, если условие выполнено 

TCP_IP = 'localhost'
TCP_PORT = 9001
BUFFER_SIZE = 1024

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((TCP_IP, TCP_PORT))
with open('received_file', 'wb') as f:
    print( 'file opened')
    while True:
        #print('receiving data...')
        data = s.recv(BUFFER_SIZE)
        print('data=%s', (data))
        if not data:
            f.close()
            print( 'file close()')
            break
        # write data to a file
        f.write(data)
s.close()
print('Successfully get the file')

if time.sleep(3):
    s.connect((TCP_IP, TCP_PORT))    
    with open('answer.txt', 'rb') as f:
        print( 'file opened')
        while True:
            #print('receiving data...')
            data = s.send(BUFFER_SIZE)
            print('data=%s', (data))
            print('Successfully send the file')
    s.close()

print('connection closed')

Сервер 

TCP_IP = "0.0.0.0"
TCP_PORT = 9001
BUFFER_SIZE = 1024

class ClientThread(Thread):

    def __init__(self,ip,port,sock):
        Thread.__init__(self)
        self.ip = ip
        self.port = port
        self.sock = sock
        print( " New thread started for "+ip+":"+str(port))

    def run(self):
        filename='filetosend.csv'
        f = open(filename,'rb')
        while True:
            l = f.read(BUFFER_SIZE)
            while (l):
                self.sock.send(l)
                #print('Sent ',repr(l))
                l = f.read(BUFFER_SIZE)
            if not l:
                f.close()
                self.sock.close()
                break

tcpsock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
tcpsock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
tcpsock.bind((TCP_IP, TCP_PORT))
threads = []

while True:
    tcpsock.listen(5)
    print("Waiting for incoming connections...")
    (conn, (ip,port)) = tcpsock.accept()
    print( 'Got connection from ', (ip,port))
    newthread = ClientThread(ip,port,conn)
    newthread.start()
    threads.append(newthread)

for t in threads:
    t.join()

Где и что я должен разместить для прослушивания файла, отправленного клиентом?

Является ли отправляющая частьклиента верный?

...