Chat sencillo TCP

[roberkas98]

Bueno la cosa es que quiero crear un chat para ver como van los sockets y demás, la cosa es que si no escribo nada y lo envio se corta la comunicacion.Lo he intentado solucionar pero no he conseguido nada.
Aqui dejo los codigos:

CLIENTE

Código Python:

#!/usr/bin/env python
 
import socket
 
# creamos el socket
clientsocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# ahora acemos que se conecte con el servidor
clientsocket.connect(('localhost',8000))
 
# este bucle hace que mientras este conectado  haga lo que pone en el interior
while 1:
        data = raw_input('>') #funcion que hace que podamos escribir para mandarlo posteriormente
        if data != " ":  # si no ai datos no lo envia
            clientsocket.send(data)# enviamos los datos que hemos escrito
        else:
              print "No has escrito nada"
        newdata = clientsocket.recv(1024) # recibimos los datos que envie el servidor
        print 'servidor: %s' % newdata # y con esto lo escribimos en pantalla
clientsocket.close() # cerramos el socket
 

SERVIDOR

Código Python:

#!/usr/bin/env python
 
import socket
 
# creamos el socket
serversocket    =   socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# usamos esta funcion para mantener en eschucha el puerto que queramos este caso 8000
serversocket.bind(('localhost', 8000))
# mantenemos en escucha el servidor
serversocket.listen(1)
# aceptamos la conexion
clientsocket, clientaddress = serversocket.accept()
print 'Conexion desde: ', clientaddress # escribimos la ip del cliente
# mientras estamos conectados hace lo que este dentro del bucle
while 1:
        data = clientsocket.recv(1024) # recibimos datos del cliente
        print 'cliente %s' % data # ponemos en pantalla lo que nos a dicho el cliente
        newdata = raw_input('>') # escribimos lo que queramos enviar
        if  newdata != " ":  # si no hay datos no lo enviamos
          clientsocket.send(newdata) # enviamos lo que hemos escrito                
clientsocket.close() # cerramos el socket
 

[razpeitia]

Ok, no se cual sea el problema.

Pero si quieres hacer un chat de sockets robusto pero sencillo. Puedes usar select.

server.py

Código Python:

import select
import socket
import sys
import Queue
 
# Create a TCP/IP socket
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.setblocking(0)
 
# Bind the socket to the port
server_address = ('localhost', 10000)
print >>sys.stderr, 'starting up on %s port %s' % server_address
server.bind(server_address)
 
# Listen for incoming connections
server.listen(5)
 
# Sockets from which we expect to read
inputs = [ server ]
 
# Sockets to which we expect to write
outputs = [ ]
 
# Outgoing message queues (socket:Queue)
message_queues = {}
 
while inputs:
    # Wait for at least one of the sockets to be ready for processing
    print >>sys.stderr, '\nwaiting for the next event'
    readable, writable, exceptional = select.select(inputs, outputs, inputs)
    
    # Handle inputs
    for s in readable:
        if s is server:
            # A "readable" server socket is ready to accept a connection
            connection, client_address = s.accept()
            print >>sys.stderr, 'new connection from', client_address
            connection.setblocking(0)
            inputs.append(connection)
 
            # Give the connection a queue for data we want to send
            message_queues[connection] = Queue.Queue()
        else:
            data = s.recv(1024)
            if data:
                # A readable client socket has data
                print >>sys.stderr, 'received "%s" from %s' % (data, s.getpeername())
                message_queues[s].put(data)
                # Add output channel for response
                if s not in outputs:
                    outputs.append(s)
            else:
                # Interpret empty result as closed connection
                print >>sys.stderr, 'closing', client_address, 'after reading no data'
                # Stop listening for input on the connection
                if s in outputs:
                    outputs.remove(s)
                inputs.remove(s)
                s.close()
 
                # Remove message queue
                del message_queues[s]
    # Handle outputs
    for s in writable:
        try:
            next_msg = message_queues[s].get_nowait()
        except Queue.Empty:
            # No messages waiting so stop checking for writability.
            print >>sys.stderr, 'output queue for', s.getpeername(), 'is empty'
            outputs.remove(s)
        else:
            print >>sys.stderr, 'sending "%s" to %s' % (next_msg, s.getpeername())
            s.send(next_msg)
    # Handle "exceptional conditions"
    for s in exceptional:
        print >>sys.stderr, 'handling exceptional condition for', s.getpeername()
        # Stop listening for input on the connection
        inputs.remove(s)
        if s in outputs:
            outputs.remove(s)
        s.close()
 
        # Remove message queue
        del message_queues[s]
 

client.py

Código Python:

import socket
import sys
 
messages = [ 'This is the message. ',
             'It will be sent ',
             'in parts.',
             ]
server_address = ('localhost', 10000)
 
# Create a TCP/IP socket
socks = [ socket.socket(socket.AF_INET, socket.SOCK_STREAM),
          socket.socket(socket.AF_INET, socket.SOCK_STREAM),
          ]
 
# Connect the socket to the port where the server is listening
print >>sys.stderr, 'connecting to %s port %s' % server_address
for s in socks:
    s.connect(server_address)
 
for message in messages:
    # Send messages on both sockets
    for s in socks:
        print >>sys.stderr, '%s: sending "%s"' % (s.getsockname(), message)
        s.send(message)
 
    # Read responses on both sockets
    for s in socks:
        data = s.recv(1024)
        print >>sys.stderr, '%s: received "%s"' % (s.getsockname(), data)
        if not data:
            print >>sys.stderr, 'closing socket', s.getsockname()
            s.close()
 

Supongo que puedes modificar esto para que funcione como un chat.

[roberkas98]

Muchas Gracias,enseguida me pongo a ello!

[carbon]

Probaste...

Código Python:

if not data:
 

En lugar de...

Código Python:

if data != " ":
 

Ya que no es lo mismo. En el primero verificas que la cadena está vacía, en el segundo verificas que la cadena no sea un espacio.

Espero que te sirva!

[roberkas98]

Iniciado por carbon

Probaste...

Código Python:

if not data:
 

En lugar de...

Código Python:

if data != " ":
 

Ya que no es lo mismo. En el primero verificas que la cadena está vacía, en el segundo verificas que la cadena no sea un espacio.

Espero que te sirva!

Gracias me ha servido!No soluciona lo del que se desconecte pero has mejorado el codigo.

[carbon]

Bueno probé el código y el problema es que si el usuario no ingresa nada en el cliente, no vovlés a preguntar, entonces se queda esperando una respuesta a un mensaje que nunca fué enviado. Así que deberías reemplazar esto:

Código Python:

if data != " ":  # si no ai datos no lo envia
    clientsocket.send(data)# enviamos los datos que hemos escrito
else:
      print "No has escrito nada"
 

Por esto:

Código Python:

if data:  # si no ai datos no lo envia
    clientsocket.send(data)# enviamos los datos que hemos escrito
else:
    print "No has escrito nada, vuelve a intentarlo."
    continue # Vuelve a comenzar el bucle
 

Por cierto tenes como medio una ensalada de espacios en el código, a veces haces indentaciones de 8 espacios y a veces de 2, selecciona un patrón y seguilo en todo el código, aunque lo más común es usar 4 espacios.

Espero que te sirva!

[roberkas98]

Muchas Gracias!Me ha servido de mucho!Una duda,se podria poner de alguna manera lo de recibir los datos

newdata = clientsocket.recv(1024)

en segunda plano,no se si me explico.
Un saludo

[razpeitia]

Puedes usar threads. O como recomendé select para envio y recepción de datos.

Pero como raw_input bloquea el programa puedes usar un thread para leer desde el teclado (raw_input) y otro para envio/recepcion de datos del socket e imprimir esos datos.

[roberkas98]

Gracias!Ahora me informo!

[roberkas98]

He empezado con los threads,(ya se que "thread" es basto y simple pero era mucho mas simple que threading).
El error que me arroja sera tonto pero mis conocimientos son muy limitados.Solo he modificado la parte del cliente y todavia no me he puesto con el "select".
Codigo:

Código Python:

#!/usr/bin/env python
import thread
import socket
 
# creamos el socket
clientsocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# ahora acemos que se conecte con el servidor
clientsocket.connect(('localhost',8000))
def escribir_texto():
         data = raw_input('>') #funcion que hace que podamos escribir para mandarlo posteriormente
# este bucle hace que mientras este conectado  haga lo que pone en el interior
while True:
    thread.start_new_thread(escribir_texto, ())
    if data:  # si no hay datos, no lo envia
        clientsocket.send(data)# enviamos los datos que hemos escrito
    else:
        print "No has escrito nada, vuelve a intentarlo."
        continue # Vuelve a comenzar el bucle
    newdata = clientsocket.recv(1024) # recibimos los datos que envie el servidor
    print 'servidor: %s' % newdata # y con esto lo escribimos en pantalla
clientsocket.close() # cerramos el socket
 

Error:

Traceback (most recent call last):

Un Saludo

[Carlangueitor]

No estás mostrando el error. Pegalo completo.

[razpeitia]

Usando solo select y sockets.

Código Python:

import select
import socket
import sys
import re
 
 
CONNECTION_LIMIT = 10
HOST, PORT = 'localhost', 8080
 
# Create a TCP/IP socket
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.setblocking(0)
 
# Bind the socket to the port
server_address = (HOST, PORT)
print >>sys.stderr, 'starting up on %s port %s' % server_address
server.bind(server_address)
 
# Listen for incoming connections
server.listen(10)
 
# Sockets from which we expect to read
inputs = [ server ]
 
# Sockets to which we expect to write
outputs = [ ]
 
# User list
users = {}
 
def broadcast(sockets, message):
    for s in sockets:
        s.send(message)
 
while True:
    readable, writable, exceptional = select.select(inputs, outputs, inputs)
    
    # Handle inputs
    for s in readable:
        if s is server:
            # A "readable" server socket is ready to accept a connection
            connection, client_address = s.accept()
            connection.setblocking(0)
 
            inputs.append(connection)
            outputs.append(connection)
 
            users[connection] = "nameless"
            username = users[connection]
            broadcast(outputs, '%s has enter' % username)
        else:
            data = s.recv(1024)
            if data:
                # A readable client socket has data
                data = data.strip()
                m = re.match(r'^/nick (\w+)$', data, re.I)
                if m:
                    old_username = users[s]
                    users[s] = m.group(1)
                    data = '%s is now %s' % (old_username, users[s])
                else:
                    data = "%s > %s" % (users[s], data)
                broadcast(outputs, data)
            else:
                # Stop listening for input on the connection
                username = users[s]
                outputs.remove(s)
                inputs.remove(s)
                s.close()
                broadcast(outputs, '%s has left' % username)
        
 
    # Handle "exceptional conditions"
    for s in exceptional:
        # Stop listening for input on the connection
        inputs.remove(s)
        outputs.remove(s)
        s.close()
 

Código Python:

# client.py
import socket
import sys
import select
import Queue
 
HOST, PORT = 'localhost', 8080
server_address = (HOST, PORT)
 
# Create a TCP/IP socket
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
 
# Connect the socket to the port where the server is listening
print >>sys.stderr, 'connecting to %s port %s' % server_address
sock.connect(server_address)
 
 
inputs = [sys.stdin, sock]
outputs = [sock]
queue = Queue.Queue()
 
while True:
    readable, writable, exceptional = select.select(inputs, outputs, inputs)
 
    for r in readable:
        if r is sys.stdin:
            message = sys.stdin.readline()
            queue.put(message)
        elif r is sock:
            data = sock.recv(1024)
            if not data:
                sock.close()
                print "Connection closed"
                sys.exit(0)
            else:
                print data
            
    for w in writable:
        if w is sock:
            try:
                next_msg = queue.get_nowait()
                sock.send(next_msg)
            except Queue.Empty:
                pass
 
    for ex in exceptional:
        if ex is sock:
            sock.close()
 

PD: Esto no funcionara en windows. El servidor si, pero el cliente no.

[roberkas98]

Iniciado por Carlangueitor

No estás mostrando el error. Pegalo completo.

Es eso lo que me arroja por pantalla.Yo tan solo lo he pegado.

Un saludo

[roberkas98]

Iniciado por razpeitia

Usando solo select y sockets.

Código Python:

import select
import socket
import sys
import re
 
 
CONNECTION_LIMIT = 10
HOST, PORT = 'localhost', 8080
 
# Create a TCP/IP socket
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.setblocking(0)
 
# Bind the socket to the port
server_address = (HOST, PORT)
print >>sys.stderr, 'starting up on %s port %s' % server_address
server.bind(server_address)
 
# Listen for incoming connections
server.listen(10)
 
# Sockets from which we expect to read
inputs = [ server ]
 
# Sockets to which we expect to write
outputs = [ ]
 
# User list
users = {}
 
def broadcast(sockets, message):
    for s in sockets:
        s.send(message)
 
while True:
    readable, writable, exceptional = select.select(inputs, outputs, inputs)
    
    # Handle inputs
    for s in readable:
        if s is server:
            # A "readable" server socket is ready to accept a connection
            connection, client_address = s.accept()
            connection.setblocking(0)
 
            inputs.append(connection)
            outputs.append(connection)
 
            users[connection] = "nameless"
            username = users[connection]
            broadcast(outputs, '%s has enter' % username)
        else:
            data = s.recv(1024)
            if data:
                # A readable client socket has data
                data = data.strip()
                m = re.match(r'^/nick (\w+)$', data, re.I)
                if m:
                    old_username = users[s]
                    users[s] = m.group(1)
                    data = '%s is now %s' % (old_username, users[s])
                else:
                    data = "%s > %s" % (users[s], data)
                broadcast(outputs, data)
            else:
                # Stop listening for input on the connection
                username = users[s]
                outputs.remove(s)
                inputs.remove(s)
                s.close()
                broadcast(outputs, '%s has left' % username)
        
 
    # Handle "exceptional conditions"
    for s in exceptional:
        # Stop listening for input on the connection
        inputs.remove(s)
        outputs.remove(s)
        s.close()
 

Código Python:

# client.py
import socket
import sys
import select
import Queue
 
HOST, PORT = 'localhost', 8080
server_address = (HOST, PORT)
 
# Create a TCP/IP socket
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
 
# Connect the socket to the port where the server is listening
print >>sys.stderr, 'connecting to %s port %s' % server_address
sock.connect(server_address)
 
 
inputs = [sys.stdin, sock]
outputs = [sock]
queue = Queue.Queue()
 
while True:
    readable, writable, exceptional = select.select(inputs, outputs, inputs)
 
    for r in readable:
        if r is sys.stdin:
            message = sys.stdin.readline()
            queue.put(message)
        elif r is sock:
            data = sock.recv(1024)
            if not data:
                sock.close()
                print "Connection closed"
                sys.exit(0)
            else:
                print data
            
    for w in writable:
        if w is sock:
            try:
                next_msg = queue.get_nowait()
                sock.send(next_msg)
            except Queue.Empty:
                pass
 
    for ex in exceptional:
        if ex is sock:
            sock.close()
 

PD: Esto no funcionara en windows. El servidor si, pero el cliente no.

Por que no funcionaria el cliente?

Un saludo