Répéter/Continu python serveur et le client

J'aimerais mettre en place un système où j'ai un python client et le serveur en permanence l'envoi /la réception de données. Tous les exemples de code que j'ai trouvé montrer comment envoyer un même message à un socket, mais pas la manière de continuellement être mis en place pour l'envoi/la réception de données.

Droit maintenant, mon code est:

client.py

import socket
import time

while True:
    try:
        client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        client_socket.connect(("192.168.0.250", 10220))
        data = "GET\nSONAR\n\n"
        print 'send to server: ' + data
        client_socket.send(data)
        client_socket.close()
    except Exception as msg:
        print msg

Je voudrais le code pour être en mesure d'envoyer des commandes à plusieurs reprises d'une minute, mais pour l'instant il ne semble pas systématiquement envoyer des messages, et je ne suis pas sûr pourquoi. Pourquoi n'est-ce pas le contrôle continu?

server.py

import socket

host = '192.168.0.100'
port = 8220
address = (host, port)

server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.bind((address))
server_socket.listen(5)

while True:
    try:
        print "Listening for client . . ."
        conn, address = server_socket.accept()
        print "Connected to client at ", address
        #pick a large output buffer size because i dont necessarily know how big the incoming packet is                                                                                              
        output = conn.recv(2048);
        if output:
            print "Message received from client:"
            print output

        #conn.send("This is a response from the server.")                                                                                                                                            
        conn.close()
        #print "Test message sent and connection closed."

Cela fonctionne très bien sur le premier essai, mais je ne peux pas avoir le serveur automatiquement écouter à nouveau pour le prochain message -- il bloque toujours sur "l'Écoute du client . . .".

Toutes les pensées?

merci!

OriginalL'auteur nathan lachenmyer | 2014-04-24

  1. 10

    Cela fonctionne très bien pour moi, bien que j'ai eu à régler le port client.py pour correspondre à celui de server.py. J'ai également eu à ajouter une exception à traiter KeyboardInterrupt dans server.py il y aurait donc un moyen de quitter le programme.

    L'écoute du client . . .
    Connecté au client au ('127.0.0.1', 53944)
    Message reçu du client:
    OBTENEZ de l'
    SONAR

    L'écoute du client . . .
    Connecté au client au ('127.0.0.1', 53945)
    Message reçu du client:
    OBTENEZ de l'
    SONAR

    EDIT:

    J'ai pris un coup à l'amélioration de l'architecture. J'ai créer une connexion et l'utiliser pour passer plusieurs messages, faire une pause entre chacun d'attente du client pour le serveur d'envoyer un accusé de réception.

    client.py:

    import socket
import time

client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client_socket.connect(("localhost", 8220))

for index in xrange(5):
    data = "GET\nSONAR%d\n\n" % index
    print 'send to server: ' + data
    client_socket.send(data)
    while client_socket.recv(2048) != "ack":
        print "waiting for ack"
    print "ack received!"

#send disconnect message                                                                                                                           
dmsg = "disconnect"
print "Disconnecting"
client_socket.send(dmsg)

client_socket.close()

    server.py:

    import socket
import sys

host = 'localhost'
port = 8220
address = (host, port)

server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.bind(address)
server_socket.listen(5)

print "Listening for client . . ."
conn, address = server_socket.accept()
print "Connected to client at ", address
#pick a large output buffer size because i dont necessarily know how big the incoming packet is                                                    
while True:
    output = conn.recv(2048);
    if output.strip() == "disconnect":
        conn.close()
        sys.exit("Received disconnect message.  Shutting down.")
        conn.send("dack")
    elif output:
        print "Message received from client:"
        print output
        conn.send("ack")
    Cela faisait partie d'un plus gros projet sur lequel je travaille, mais il semble que ce n'était pas le problème... le problème doit être ailleurs!
    Voir mon edit pour ce que je pense est un mouvement vers une meilleure architecture client/serveur.
    Intéressant, bon d'apprendre à partir de cet exemple! Quelle est la meilleure pratique pour quand je dois envoyer plusieurs messages sur un seul socket rapport à quand je dois fermer/rouvrir le support pour les messages consécutifs? Aussi, votre boolean "connecté" dans le client n'est jamais utilisé.

    OriginalL'auteur Chris

  2. -3

    vous feriez mieux d'ouvrir les deux boucles while avec bloc try et le Serveur de Socket alors u peut obtenir en continu des messages entre le client et vice-versa.

    OriginalL'auteur madhu