Estoy haciendo un cliente y un servidor con sockets.
El cliente envía una opción (1,2,3) y el servidor le retorna el resultado. En la opción 1 envío un comando (ipconfig) y me devuelve el resultado, pero después para volver a ejecutar otro comando he de volver a pulsar 1, y seguidamente el nuevo comando.
¿Como puedo hacer para que cuando pulso la opción 1 me permita enviar comando y recibir el resultado infinitas veces, sin salirse al menu principal como hace ahora?
Servidor principal.
# -*- coding: utf-8 -*-
import logging
from lib.thread_server import Thread_server
from app_settings import settings
logger = logging.getLogger(settings.LOGGING['logger_name'])
import socket
''' Metodo main '''
def main():
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind(("127.0.0.1", 9999))
s.listen(2)
while True:
sc, addr = s.accept()
t_server = Thread_server('Thread_server',sc)
t_server.start()
s.close()
''' Inicio de la app '''
if __name__ == "__main__":
main()
Hilo servidor.
# -*- coding: utf-8 -*-
import logging
import threading
import time
# Import configuration file:
from app_settings import settings
# Instance logger:
logger = logging.getLogger(settings.LOGGING['logger_name'])
import os
import subprocess
from lib.thread_1 import Thread_1
class Thread_server(threading.Thread):
def __init__(self, name, sc):
threading.Thread.__init__(self)
self.name = name
self.sc = sc
def run(self):
while True:
message_recived = self.sc.recv(1024)
# Condiciones.
if message_recived == "1":
while True:
# recivo.
mensaje1 = self.sc.recv(1024)
print(mensaje1)
# envio.
self.sc.send('correcto')
elif message_recived == "2":
print('opcion 2')
elif message_recived == "3":
break
else:
self.sc.send('Opcion no valida.')
self.sc.close()
Cliente.
# -*- coding: utf-8 -*-
import logging
from app_settings import settings
logger = logging.getLogger(settings.LOGGING['logger_name'])
from lib.thread_1 import Thread_1
import socket
import os
import time
import sys
def main():
PORT = 9999
SERVER = "127.0.0.1"
SERVER_STATUS = "STOP"
TIME_WAIT_CONECTING = 1
while True:
try:
# Si el servidor esta encendido.
s = socket.socket()
s.connect((SERVER, PORT))
SERVER_STATUS = "START"
os.system('cls')
# Salgo del bucle y doy paso al menu de opciones.
break
except Exception:
os.system('cls')
print('CONECTING SERVER')
SERVER_STATUS = "STOP"
while True:
print('====== SERVER OPTIONS ======')
print('- PRESS 1 - Enter comand. ')
print('- PRESS 2 - ')
print('- PRESS 3 - EXIT.')
print('============================')
# Instanciamos una entrada de datos para que el cliente pueda enviar mensajes.
mensaje_menu = raw_input("SEND SERVER >> ")
if mensaje_menu =="1":
while True:
mensaje_servidor = raw_input("SEND COMAND >> ")
# Envio comando.
s.send(mensaje_servidor)
mensaje_recivido = s.recv(1024)
print("SERVER RESPONSE >> " + mensaje_recivido)
if mensaje_menu =="2":
mensaje_servidor = raw_input("SEND COMAND >> ")
# Envio comando.
s.send(mensaje_servidor)
if mensaje_menu == "3":
break
os.system('cls')
s.close()
if __name__ == "__main__":
main()
if message_recived == "1":
tienes unwhile True:
del que nunca sales.