Tengo el siguiente esquema que figura en la imagen, tengo un cliente que debe pasar por este "proxy" ya que el desarrollo del cliente no soporta conexion TLS/SSL para los sockets. esto funciona bien.
El problema es que funciona 1 response para 1 request
El cliente envia un request recibe un response, automaticamente este "proxy" se bloquea esperando otro request.
Yo necesito que se quede escuchando posibles responses sin que antes exista un request de parte del cliente.
No se si sea necesario el uso de Threads o Si con el No-blocking sera suficiente
import socket
import ssl
host_servidor = "xxx.xxx.xxx.xxx"
port_servidor = 5555
host_local = '127.0.0.1'
port_local = 4444
with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
sock.bind((host_local,port_local))
sock.listen(2)
print('[*] Socket abierto en {} {}'.format(host_local, port_local))
conn,addr = sock.accept()
with conn:
print("[*] Conexion establecida")
while True:
request = conn.recv(1024)
if not request:
print('[*] Cerrando conexion con cliente ')
break
else:
print('[*] Datos recibidos desde cliente: {}'.format(request.decode()))
if(not sock_servidor):
context = ssl.create_default_context()
ssock = socket.create_connection((host_servidor, port_servidor))
sock_servidor = context.wrap_socket(ssock, server_hostname=host_servidor)
print(sock_servidor.version())
sock_servidor.sendall(request)
response = sock_servidor.recv(1024)
if not response:
break
print('[*] Datos recibidos desde servidor:',response.decode())
if not response:
print('[-] No se recibio informacion de servidor:')
sock_servidor.close()
break
else:
conn.send(response)
recv()
en uno de ellos se te bloqueará hasta recibir datos por él, impidiéndote entonces "enterarte" de cuándo llegan datos por el otro. La solución para esto es usar un multiplexor de E/S como select(), o su interfaz de más alto nivel selectors, que te permite por así decir "esperar datos en varios sockets a la vez".