[Sin resolver]-[Python]Problema con sockets

[Arnau27]

 Bueno, empezé a conocer los sockets y lo primero que intenté hacer fue un socket cliente servidor en el que el cliente enviara strings y el servidor las pintara. Me costó lo suyo ya que parece que sino todos, la mayoria de la gente en internet usa python 2.7, y se ve que a partir de la 3.0 hay que passar strings a bytes para poder enviarlo puesto que no se pueden mezclar bytes y strings.

Despues de esto pense en hacer un chat ya que estaba jugando con strings y sockets...Bueno pues como siempre debe haber cliente y servidor, apliqué los pocos conceptos que tengo y hice 2 scripts que fueran cliente y servidor a la vez para asi establecer 2 sockets y hacer el chat. Pero como un programa no puede ser cliente y servidor a la vez planteo esta situación:

Con una estructura de 1 servidor y muchos clientes, los clientes envian bytes al servidor y el servidor envia estos bytes a un cliente. Como, usando python y solo con el modulo socket, puedo hacer esto?
En caso de que la estructura que he planteado no sea como deberia ser corrijanme porfavor.

He leido que la gente usa threads pero quiero hacerlo solo con el modulo socket...

Gracias

[oxydec]

¿Podrias poner el codigo que has hecho del cliente y servidor para poder ayudarte mejor?

A nivel abstracto creo que lo que quieres hacer se haria del siguiente modo:

- El servidor tiene un socket escuchando conexiones entrantes
- El servidor ejecuta un bucle, a cada iteracion:
- Mira si le entra una conexion por el socket a la escucha.
- Cuando le llega una conexion de un cliente crea un nuevo socket unico para ese cliente y lo añade a una lista de clientes.
- Recorre la lista de clientes a ver si alguno ha enviado algo.
- Si ha enviado algo le manda el mensaje recibido a los demas clientes de la lista.

Esto es con un solo hilo como has pedido, si lo haces con threads en vez de una lista sockets para cada cliente/conexion tendrias un hilo para cada cliente/conexion.

[Arnau27]

¿Podrias poner el codigo que has hecho del cliente y servidor para poder ayudarte mejor?

A nivel abstracto creo que lo que quieres hacer se haria del siguiente modo:

- El servidor tiene un socket escuchando conexiones entrantes
- El servidor ejecuta un bucle, a cada iteracion:
- Mira si le entra una conexion por el socket a la escucha.
- Cuando le llega una conexion de un cliente crea un nuevo socket unico para ese cliente y lo añade a una lista de clientes.
- Recorre la lista de clientes a ver si alguno ha enviado algo.
- Si ha enviado algo le manda el mensaje recibido a los demas clientes de la lista.

Esto es con un solo hilo como has pedido, si lo haces con threads en vez de una lista sockets para cada cliente/conexion tendrias un hilo para cada cliente/conexion.

Aqui tienes el codigo, he echo más pero el unico que me ha funcionado es el mas simple.

Código (python) [Seleccionar] Expandir

#Cliente
import socket
s=socket.socket()
try:
s.connect(("localhost", 9999))
except socket.error:
print("Socket error")

while True:
inp=input(" >>  ")
encode=str.encode(inp)
if inp=="quit":
s.close()
quit()
print("bye")
else:
s.send(encode)

Código (python) [Seleccionar] Expandir

#Servidor
import socket 
     
s=socket.socket() 
s.bind(("localhost", 9999)) 
s.listen(3) 
print("Waiting...")
sc, addr=s.accept() 
print("Socket established")   
while True:
r=sc.recv(1024)
dc=bytes.decode(r)
print(" -  ", dc)
if r=="quit":
sc.close()
s.close()
quit()
Me has entendido a la perfección, gracias.

[oxydec]

He estado investigando un poco porque me parece interesante el tema, y veo que hacerlo sin threads es complicado, el problema es que la funcion socket.accept() bloquea la ejecucion en ese punto hasta que recibe una conexion, normalmente lo que se hace es que en el hilo de ejecucion principal tienes un bucle infinito haciendo accepts y abriendo un nuevo thread cuando llega una conexion, o tal vez se pueda hacer con solo 2 threads, uno para los accepts y otro gestionando las conexiones abiertas.

Ahora bien si quieres hacerlo con un unico hilo hay una solucion que es usar el modulo select, concretmente la funcion select.select(), que lo que hace es como observar un conjunto de datos y lanzar "eventos" cuando alguno de los datos es modificado: aqui hablan del tema http://stackoverflow.com/questions/5308080/python-socket-accept-nonblocking
y aqui tienes la documentacion http://docs.python.org/library/select.html#select.select

Si descubro algo mas ya te informo.

Saludos.

[Arnau27]

He estado investigando un poco porque me parece interesante el tema, y veo que hacerlo sin threads es complicado, el problema es que la funcion socket.accept() bloquea la ejecucion en ese punto hasta que recibe una conexion, normalmente lo que se hace es que en el hilo de ejecucion principal tienes un bucle infinito haciendo accepts y abriendo un nuevo thread cuando llega una conexion, o tal vez se pueda hacer con solo 2 threads, uno para los accepts y otro gestionando las conexiones abiertas.

Ahora bien si quieres hacerlo con un unico hilo hay una solucion que es usar el modulo select, concretmente la funcion select.select(), que lo que hace es como observar un conjunto de datos y lanzar "eventos" cuando alguno de los datos es modificado: aqui hablan del tema http://stackoverflow.com/questions/5308080/python-socket-accept-nonblocking
y aqui tienes la documentacion http://docs.python.org/library/select.html#select.select

Si descubro algo mas ya te informo.

Saludos.

Muchas gracias, pero al probar el ejemplo de stackoverflow no entiendo por que me da error, no consigo entender por que. Te dejo el cliente y servidor y más abajo el problema :S.

Servidor

Código (python) [Seleccionar] Expandir

import socket, select

s=socket.socket()  
s.bind(("localhost", 9999))  
s.listen(3)  
input=[s]
print("0")
while True:
inp, out, exc=select.select(input,[] ,[])
for x in inp:
if x is s:
print("1")
c, addr=s.accept()
input.append(c)
else:
data=s.recv(1024)
if data:
dc=bytes.decode(data)
print(s.getpeername(), " -  ", dc)
x.send(data)
else:
s.close()
Cliente

Código (python) [Seleccionar] Expandir

import socket
s=socket.socket()
try:
s.connect(("localhost", 9999))
except socket.error:
print("Socket error")

while True:
data=input(" >>  ")
encode=str.encode(data)
if data=="quit":
s.close()
quit()
print("bye")
elif data=="get*":
inp=s.recv(1024)
dc=bytes.decode(inp)
print(dc)
else:
s.send(encode)

Bueno resulta que al enviar alguna cosa desde el cliente, el servidor salta diciendo que no hay un socket establezido, que no esta conectado. He comprobado, como puedes ver en el script del servidor, que el programa pasa por aceptar la conexion asi que no entiendo el problema. Espero que alguien pueda ayudar, gracias.