Skip to main content
adicionou 2197 caracteres ao conteúdo
Fonte Link
sergiopereira
  • 2,9mil
  • 13
  • 12

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 $

Uma outra maneira é utilizar o módulo multiprocessing do próprio Python. Aqui vai um exemplo não-testado, apenas para dar uma idéia por onde começar:

from multiprocessing.connection import Listener
import threading
 
def inicia_servidor():
    servidor = Listener(('localhost', 12345), authkey='senha')
    try:
        # esperar conexão
        cnx = servidor.accept()
        while True:
            mensagem = conx.recv()
            if mensagem['tipo'] == 'comando':
                reposta = processa_comando(mensagem['comando'])
                cons.send(resposta)
            elif mensagem['tipo'] == 'exit':
                cnx.close()
                break
    except Exception as err:
        print 'Erro', err
    finally:
        servidor.close()

# o servidor executa em uma thread separada para não 
# bloquear o programa principal
t = threading.Thread(target=inicia_servidor)
t.start()
t.join()
from multiprocessing.connection import Client

try:
    cliente = Client(('localhost', 12345), authkey='senha')
    while True:
        # fica em loop até um CTRL+C
        texto = aguarda_proximo_commando()
        cnx.send({'tipo': 'comando', 'comando': texto})
except KeyboardInterrupt:
    if cnx:
        cnx.send({'tipo': 'exit'})
        cnx.close()
except Exception:
    if cnx:
        cnx.close()
    print 'Erro', err
finally:
    cliente.close()

Uma outra maneira é utilizar o módulo multiprocessing do próprio Python. Aqui vai um exemplo testado, 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 conexao
            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 = cnx.recv()
                if mensagem['tipo'] == 'comando':
                    resposta = processa_comando(mensagem['comando'])
                    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 nao
# bloquear o programa principal
t = threading.Thread(target=inicia_servidor)
t.start()

# simulacao para mostrar que o servidor continua a
# trabalhar enquanto aguarda comandos
while True:
    print 'Servidor trabalhando...'
    time.sleep(5)
from multiprocessing.connection import Client

def aguarda_proximo_commando():
    commando = raw_input()
    return commando

cliente = Client(('localhost', 12345), authkey='senha')
try:
    while True:
        # fica em loop ate um CTRL+C
        print 'server>',
        texto = aguarda_proximo_commando()
        cliente.send({'tipo': 'comando', 'comando': texto})
        resposta = cliente.recv()
        print '  =>', resposta
except KeyboardInterrupt:
    cliente.send({'tipo': 'exit'})
except Exception as err:
    print 'Erro', err
finally:
    cliente.close()

Exemplo de execução do cliente:

~/teste $ python client.py 
server> ola
  => {'status': 'OK', 'commando': 'ola'}
server> tudo bem
  => {'status': 'OK', 'commando': 'tudo bem'}
server> ^C
~/teste $ python client.py 
server> ola de novo
  => {'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.py 
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", line 46, in <module>
    time.sleep(5)
KeyboardInterrupt
^C^CTerminated: 15
~/teste $
Fonte Link
sergiopereira
  • 2,9mil
  • 13
  • 12

Você precisa procurar por uma solução de comunicação inter-processos.

Uma maneira popular que funciona de maneira similar em várias plataformas e linguagens de programação é criar um servidor de filas (MQ). Um desses é ZeroMQ e você pode ver alguns exemplos aqui.

Uma outra maneira é utilizar o módulo multiprocessing do próprio Python. Aqui vai um exemplo não-testado, apenas para dar uma idéia por onde começar:

No seu daemon, inicie o servidor que espera conexões do cliente (console)

from multiprocessing.connection import Listener
import threading
 
def inicia_servidor():
    servidor = Listener(('localhost', 12345), authkey='senha')
    try:
        # esperar conexão
        cnx = servidor.accept()
        while True:
            mensagem = conx.recv()
            if mensagem['tipo'] == 'comando':
                reposta = processa_comando(mensagem['comando'])
                cons.send(resposta)
            elif mensagem['tipo'] == 'exit':
                cnx.close()
                break
    except Exception as err:
        print 'Erro', err
    finally:
        servidor.close()

# o servidor executa em uma thread separada para não 
# bloquear o programa principal
t = threading.Thread(target=inicia_servidor)
t.start()
t.join()

No seu cliente (console) connecte-se ao daemon

from multiprocessing.connection import Client

try:
    cliente = Client(('localhost', 12345), authkey='senha')
    while True:
        # fica em loop até um CTRL+C
        texto = aguarda_proximo_commando()
        cnx.send({'tipo': 'comando', 'comando': texto})
except KeyboardInterrupt:
    if cnx:
        cnx.send({'tipo': 'exit'})
        cnx.close()
except Exception:
    if cnx:
        cnx.close()
    print 'Erro', err
finally:
    cliente.close()