Este programa tem diversos erros de uso de sockets.
1) Em TCP, envia-se e recebe-se bytes, não mensagens completas. Não existe garantia que um send() vá enviar toda a string fornecida, nem que recv() vá receber uma mensagem completa, muito menos o total de bytes especificado, que é apenas um máximo.
2) É preciso observar o valor de retorno de send() para ver quantos bytes foram efetivamente enviados; se não foram todos, é preciso chamar send() novamente para enviar o resto, geralmente se faz isso num loop.
3) O mesmo vale para recv(), mas no caso de mensagens de tamanho variável, você precisa decidir como vai detectar o "fim da mensagem" - se é uma quebra de linha, ou um número X de bytes, ou outro critério. Não existe o equivalente do radioamador dizendo "over" ou "câmbio" :)
4) Tanto em send() quanto em recv() é preciso testar se enviou ou recebeu zero bytes. Isto significa que a conexão foi fechada. No caso de send(), um retorno menor que zero significa erro, que geralmente acontece ao tentar usar uma conexão já fechada. (No recv() do server você já está fazendo esta checagem.)
5) Isto não é um erro, é uma técnica: para um servidor atender diversos clientes, é preciso lançar mão ou de threads (uma thread tomando conta de cada socket de conexão) ou de programação assíncrona (usando select()).
Cliente melhorado (não está perfeito, mas atenderá múltiplos clientes ao mesmo tempo, que é o que você deseja):
from socket import *
import time
serverHost = 'localhost'
serverPort = 50007
# Adotei o caractere \n como fim de mensagem
mensagem = [b'Ola mundo da internet!\n', b'bla\n', b'ble\n']
sockobj = socket(AF_INET, SOCK_STREAM)
sockobj.connect((serverHost, serverPort))
for linha in mensagem:
time.sleep(1)
while linha:
enviado = sockobj.send(linha)
if enviado == 0:
print("Servidor fechou")
break
# corta parte da linha ja enviada
linha = linha[enviado:]
data = b''
# Adotei o caractere \n como fim de mensagem
while b'\n' not in data:
newdata = sockobj.recv(1024)
if not newdata:
print('Servidor fechou conexao')
break
data += newdata
print('Cliente recebeu:', data)
sockobj.close()
Servidor melhorado:
from socket import *
import time
import threading
def cuida_cliente(conexao, endereco):
print('Server conectado a', endereco)
aberto = True
while aberto:
data = b''
while b'\n' not in data:
newdata = conexao.recv(1024)
if not newdata:
print("Cliente fechou")
data = b''
aberto = False
break
data += newdata
if not data:
break
msg = b'Eco=>' + data + b'\n'
while msg:
enviado = conexao.send(msg)
if enviado <= 0:
print("Cliente fechou")
aberto = False
break
msg = msg[enviado:]
conexao.close()
return
meuHost = ''
minhaPort = 50007
sockobj = socket(AF_INET, SOCK_STREAM)
sockobj.bind((meuHost, minhaPort))
sockobj.listen(5)
while True:
conexao, endereco = sockobj.accept()
t = threading.Thread(target=cuida_cliente, args=(conexao, endereco))
t.start()
Por completeza, vou incluir uma segunda versão do servidor, baseada em select(), que não precisa de threads e funciona de forma completamente assíncrona. Note que ela é bem mais complexa, mas é considerada muito melhor.
from socket import *
import time
import select
# Estrutura que representa um cliente: [socket, buffer recv, buffer send]
clientes = []
# Retorna índice de "clientes" cujo socket seja igual ao passado
def acha_cliente(socket):
for i, cliente in enumerate(clientes):
if socket is cliente[0]:
return i
return -1
# Cria um cliente novo
def abre_cliente(conexao, endereco):
print('Server conectado a', endereco)
clientes.append([conexao, b'', b''])
# Fecha e exclui cliente com erro
def erro_cliente(socket):
i = acha_cliente(socket)
if i >= 0:
clientes[i][0].close()
del clientes[i]
return
def recv_cliente(socket):
i = acha_cliente(socket)
if i < 0:
socket.close()
return
newdata = socket.recv(1024)
if not newdata:
print("Cliente fechou")
clientes[i][0].close()
del clientes[i]
return
clientes[i][1] += newdata
if b'\n' in clientes[i][1]:
# Recebeu msg completa do cliente
# Coloca mensagem para envio no buffer de transmissão
clientes[i][2] = b'Eco=>' + clientes[i][1] + b'\n'
# Limpa buffer de recepcão
clientes[i][1] = b''
def send_cliente(socket):
i = acha_cliente(socket)
if i < 0:
socket.close()
return
# Tenta enviar todo o buffer de transmissão
enviado = socket.send(clientes[i][2])
if enviado <= 0:
print("Cliente fechou")
clientes[i][0].close()
del clientes[i]
return
# Remove parte já enviada do buffer
clientes[i][2] = clientes[i][2][enviado:]
meuHost = ''
minhaPort = 50007
sockobj = socket(AF_INET, SOCK_STREAM)
sockobj.bind((meuHost, minhaPort))
sockobj.listen(5)
while True:
ler = [sockobj]
gravar = []
erro = [sockobj]
for cliente in clientes:
# Todo cliente pode enviar dados quando quiser
ler.append(cliente[0])
erro.append(cliente[0])
if cliente[2]:
# Dados pendentes para envio ao cliente
gravar.append(cliente[0])
ler, gravar, erro = select.select(ler, gravar, erro, 10)
if not ler and not gravar and not erro:
print("Timeout")
continue
# Despacha erros
for socket in erro:
erro_cliente(socket)
# Despacha leituras
for socket in ler:
if socket is sockobj:
# Socket principal do servidor
conexao, endereco = sockobj.accept()
abre_cliente(conexao, endereco)
else:
recv_cliente(socket)
# Despacha gravações
for socket in gravar:
send_cliente(socket)