Uma outra maneira é utilizar o módulo multiprocessing do próprio Python. Aqui vai um exemplo não-testadotestado, apenas para dar uma idéia por onde começar:
from multiprocessing.connection import Listener
import threading
import time
def processa_comando(comando):
print 'Recebi o comando:', comando
return {'status': 'OK', 'commando': comando}
def inicia_servidor():
servidor = Listener(('localhost', 12345), authkey='senha')
try:
while True:
# esperar conexãoconexao
cnx = servidor.accept()
# o codigo a seguir, em uma implementacao real,
# poderia ser movido para uma thread nova (uma
# para cada cliente conectado)
print 'Client connected.'
while True:
# esperar comandos do cliente
mensagem = conxcnx.recv()
if mensagem['tipo'] == 'comando':
reposta resposta = processa_comando(mensagem['comando'])
cons cnx.send(resposta)
elif mensagem['tipo'] == 'exit':
print 'Client left.'
cnx.close()
break
except Exception as err:
print 'Erro', err
finally:
servidor.close()
# o servidor executa em uma thread separada para não nao
# bloquear o programa principal
t = threading.Thread(target=inicia_servidor)
t.start()
t
# simulacao para mostrar que o servidor continua a
# trabalhar enquanto aguarda comandos
while True:
print 'Servidor trabalhando.join..'
time.sleep(5)
from multiprocessing.connection import Client
trydef aguarda_proximo_commando():
commando = raw_input()
return commando
cliente = Client(('localhost', 12345), authkey='senha')
try:
while True:
# fica em loop atéate um CTRL+C
print 'server>',
texto = aguarda_proximo_commando()
cnxcliente.send({'tipo': 'comando', 'comando': texto})
except KeyboardInterrupt:
if cnx: resposta = cliente.recv()
cnxprint ' =>', resposta
except KeyboardInterrupt:
cliente.send({'tipo': 'exit'})
except Exception as err:
print 'Erro', err
finally:
cnx cliente.close()
except
Exemplo de execução do cliente:
~/teste Exception$ python client.py
server> ola
=> {'status': 'OK', 'commando': 'ola'}
server> tudo bem
if=> cnx{'status': 'OK', 'commando': 'tudo bem'}
server> ^C
~/teste $ python client.py
server> ola de cnxnovo
=> {'status': 'OK', 'commando': 'ola de novo'}
server> ja vou
=> {'status': 'OK', 'commando': 'ja vou'}
server> ^C
~/teste $
Resultado do exemplo no servidor:
~/teste $ python server.closepy
Servidor trabalhando...
Servidor trabalhando...
Client connected.
Recebi o comando: ola
Servidor trabalhando...
Recebi o comando: tudo bem
Servidor trabalhando...
Client left.
Servidor trabalhando...
Client connected.
Servidor trabalhando...
Servidor trabalhando...
Recebi o comando: ola de novo
Servidor trabalhando...
Servidor trabalhando...
Recebi o comando: ja vou
Servidor trabalhando...
Client left.
Servidor trabalhando...
^CTraceback (most recent call last):
File "server.py", printline 'Erro'46, err
finally:in <module>
clientetime.closesleep(5)
KeyboardInterrupt
^C^CTerminated: 15
~/teste $