Sugiro que para tranferência de estruturas de dados uses json
ou pickle, embora com json a serialização possa ser mais rápida.
Dito isto, esta pergunta sem querer torna-se um pouco nabragente/desafiante.
A descrição do próprio erro fala no problema, ou seja, precisas de mandar bytes e não um tuple, e como não podes converter um tuple
em bytes diretamente mas pode fazê-lo com strings, podes enviar um json (embora neste caso se torne mais trabalhoso e por isso não vou fazer isso, explico em baixo a razão).
No entanto ainda temos um problema, não podes enviar os bytes do ficheiro no json porque ocorrem problemas com a serialização (lista dos tipos de dados que json entende), terias de enviar duas mensagens em separado, uma com a informação adjacente (nome, tamanho do ficheiro etc.., em forma de um dict por exemplo) e outra com os bytes que o compõem, e MUITO IMPORTANTE, terias de enviar uma flag (byte nulo por ex, b'\x00'
) no final da primeira para indicar que esta chegou ao fim e que o servidor pode então começar a receber os dados binários do ficheiro.
Esta flag tem de existir porque TCP é um streaming protocol não há garantia alguma que o método recv
(da lado servidor neste caso) recebeu exatamente o json com a informação antes, pode conter apenas uma parte do json ou pode incluir alguma da informação binária do ficheiro à mistura.
Aqui coloco um exemplo básico de upoload de ficheiros para o servidor com pickle, onde podemos converter uma estrutura de dados (objetos, dicionários, tuples, etc...) em um byte stream, assim, com pickle, podemos enviar logo os dados necessários "de uma só vez", por isso neste caso facilita bastante:
Cliente:
import socket, pickle
f = input('escreva o nome do ficheiro')
f_bin = open(f, 'rb').read()
info = {'name': f, 'file': f_bin, 'opcao': 1} # ajustar opcao para adequar ao teu codigo
with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
s.connect(('', 9005))
s.sendall(pickle.dumps(info))
Servidor:
import socket, threading, pickle, time
def run(conn):
info_bin = b''
st = time.time()
while True:
c = conn.recv(2048)
if not c:
break
info_bin += c
if time.time() - st >= 2: # opcional, informacao sobre o total ja carregado
print('bytes downloaded:', len(info_bin))
st = time.time()
info = pickle.loads(info_bin)
if info['file']:
dest = 'files/{}'.format(info['name'])
with open(dest, 'wb') as f:
f.write(info['file'])
print('success on receiving and saving {} for {}'.format(info['name'], conn.getpeername()))
conn.close()
host, port = ('', 9005)
with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
sock.bind((host, port))
sock.listen(5)
while True:
conn, addr = sock.accept()
print('conn', addr)
threading.Thread(target=run, args=(conn,)).start()
Não testei com multiplos clientes mas em príncipio também funcionará.
Deves ter de ajustar a tua conecção e o sítio onde o servidor escreverá o ficheiro
socket_object
? Utiliza o pacotesocket
nativo do Python?socket_object = socket(AF_INET, SOCK_STREAM)
socket_object.sendall(str.encode(json.dumps(tupla)))
, ou algo semelhante.NameError: name 'json' is not defined
, estou trabalhando com os terminais do ubuntu e com o python3 padrão deleimport json