Клиентский сокет не получает данные правильно

Я пытался найти ответ, но не могу найти тот, который отвечает на мою конкретную проблему.

Возможно, я не знаю, как правильно сформулировать проблему.

Кажется, я точно определил, что это такое, но дело в том, что я просто не знаю, как это исправить.

РЕДАКТИРОВАТЬ: я пытался использовать двух клиентов на одном сокете TCP. Не могу этого сделать. Мне придется думать о другом пути. Думаю, решено.

Так что у меня есть

1: два клиента

2: один сервер

Цель заключается в следующем: Заставить сервер распространять новые имена пользователей для всех клиентов по мере их подключения.

Вот что происходит, когда я запускаю программу:

Сервер: определите хост и порт, инициализируйте его. Проверить

Клиент 1: подключается к серверу. Проверить

Клиент 1: после подключения отправляет строку на сервер. Проверить

Сервер: получает строку, проверяет, находится ли строка в списке. Если да: пройти, если нет, отправить всем новую строку. Проверить

Клиент 1: [Ожидает получения данных] Получает данные, проверяет, соответствует ли полученная строка той, которую он отправил. Если это так, напечатайте («Это один из наших!»), В противном случае сделайте новую строку = для имени пользователя клиента 2. Проверить

Клиент 2: подключается к серверу: Проверить

Сервер: [Если он получает строку, печатает ее.] (Работает) Проверяет, есть ли новая строка в списке. [Это не так] Итак, новое имя пользователя отправляется всем, а затем печатается ("Отправлено всем") Проверить

Но когда клиент 2 получает строку, он печатает ее. Однако клиент 1 никогда не получает строку.

И при запуске клиента 1 в IDLE я заметил, что что-то пошло не так, поскольку клиент 1 пытался получить данные. (Цикл while, в котором data = s.recv начал выполняться очень быстро, вместо ожидания)

Я поспрашивал в чате, но, кажется, сейчас никого нет. Я пытался найти это, но я действительно не могу найти ответ. Я подозреваю, что когда мой сервер отправляет запрос на "подключение" во второй раз, он каким-то образом переопределяет исходное клиентское подключение.

Вот мой код сервера:

from socket import *
import threading
import os
import csv

Username_List = []

host = input("Host: ")
port = input("Port: ")

ss = socket(AF_INET,SOCK_STREAM)
ss.bind((host,int(port)))
ss.listen(2)




while True:
    try:
        connection,address = ss.accept()
        data = connection.recv(1024)
        if data:
            translated_data = data.decode()
            print(translated_data)

            if translated_data in Username_List:
                pass
            else:
                Username_List.append(translated_data)
                connection.sendall(translated_data.encode())
                print("Sent new username to everyone")
    except IOError:
        connection.close()
        print("An exception with a connected user occured")
        break

А вот код моего клиента: [Единственная разница между клиентом 1 и клиентом 2 заключается в том, что я изменил переменную имени пользователя]

# Sample Username Client Service Handler.
from socket import *
import threading
import os
import csv

Username = ("Owatch")
host = input("Host: ")
port = input("Port: ")
try:

    ss = socket(AF_INET,SOCK_STREAM)
    ss.connect((host,int(port)))
except IOError:
    print("Aw no man")

ss.send(Username.encode())

while True:
    try:
        print("Waiting to Recieve Data")
        data = ss.recv(1024)
        if data:
            translated_data = data.decode()
            print(translated_data)
            if translated_data == Username:
                print("It's one of ours!")

            else:
                Client_Username = translated_data
                print (Client_Username)


    except Exception as e:
        print (vars(e))

Если бы вы могли помочь, пожалуйста, я был бы признателен.

Если вам известен ответ на мой вопрос, который уже был задан, сообщите мне, и я удалю это сообщение, чтобы не нарушать правила. Спасибо!


person Micrified    schedule 11.05.2013    source источник
comment
* Я только что заметил ошибку в своей логике. Если пользователь подключается после другого. Он не получит имя пользователя первого пользователя. А вот первый коннектор(?) будет. Что-то я должен исправить позже ..   -  person Micrified    schedule 11.05.2013
comment
Я считаю, что мой сервер не может обрабатывать двух клиентов на одном сокете.   -  person Micrified    schedule 12.05.2013
comment
В TCP не бывает двух клиентов на одном сокете.   -  person user207421    schedule 12.05.2013
comment
Поэтому мне понадобятся два сокета, работающие одновременно в разных потоках. Или мне нужно будет создать еще один, как только кто-то подключится. Но я тоже не знаю, как это сделать.   -  person Micrified    schedule 12.05.2013
comment
Да, одно соединение, одна розетка. Вам, вероятно, понравится node.js. Копание в Google дало мне следующее: stackoverflow.com/questions/3670127/   -  person Michel Feldheim    schedule 12.05.2013
comment
@MichelFeldheim Любопытно. Я гуглил, прежде чем заметил ваш ответ, и до сих пор не нашел этого. Только посты об использовании Twisted и т.д. Спасибо большое   -  person Micrified    schedule 12.05.2013


Ответы (1)


Именно тогда я начал с того, что вы затем изменили, пока это не сработало. Я создал клиентский класс, который запускает поток с каждым соединением и добавляет его в список потоков (пожалуйста, если я делаю что-то ужасно неправильно, умнее люди поправляют меня), поток запускается, получает некоторые проверки данных, если он находится в списке имен пользователей, если он не отправляет сообщение всем клиентам в списке потоков с этим именем, тогда поток просто успокаивается. Во всяком случае, к коду.

СЕРВЕР!!!

import csv

class client(threading.Thread):
    Username_List = []
    def __init__(self, conn):
        super(client, self).__init__()
        self.conn = conn

    def run(self):
        print "Client thread started"
        data = self.conn.recv(1024)
        print "Received: {0}".format(data)
        if data in client.Username_List:
            self.send_msg("Welcome Back!")
        else:
            for cnt in threadz:
                cnt.send_msg(data)
            print("Sent new username to everyone")
            client.Username_List.append(data)
        while True:
            # dont need nothing now
            pass

    def send_msg(self,msg):
        self.conn.send(msg)

host = input("Host: ")
port = input("Port: ")

ss = socket() #AF_INET,SOCK_STREAM)
ss.bind((host,int(port)))
print "Server Opening on port: {0}".format(port)
ss.listen(2)
threadz = []
print "Begining Wait for connections"

while True:      
    try:
        connection, address = ss.accept()
        print "Got ONE!"
        c = client(connection)
        print "Recevied connection from:{0} On port:{1}".format(address[0],address[1])
        c.start()
        threadz.append(c)
        print "Client appended to threadz, currently {0} threadz active".format(len(threadz))

    except IOError,KeyboardInterrupt:
        connection.close()
        print("An exception with a connected user occured")
        break

Клиент:

# Sample Username Client Service Handler.
from socket import *
import threading
import os
import csv

Username = ("ShyGuy")
host = input("Host: ")
port = input("Port: ")
try:
    ss = socket() #AF_INET,SOCK_STREAM)
    ss.connect((host,int(port))) #I was using ("localhost",1234) for testing
    ss.send(Username)
except IOError:
    print("Aw no man")


print("Waiting to Recieve Data")
while True:
    try:
        data = ss.recv(1024)
        if data:
            translated_data = data.decode()
            print(translated_data)
            if translated_data == Username:
                print"Name: {0} has been registered on server!".format(translated_data)
            else:
                Client_Username = translated_data
                print "New client name received: {0}".format(Client_Username)


    except Exception as e:
        print (vars(e))

Это работает на python 2.7 с двумя клиентами локально. Необходимо использовать семафор, чтобы остановить печать потоков одновременно с печатью основного цикла сервера: http://en.wikipedia.org/wiki/Semaphore_(programming)

Этот код не делает ничего изящного при отключении клиента, но как только вы научитесь работать с исключениями, которые возникают, когда это происходит, я уверен, что вы узнаете больше.

person Noelkd    schedule 12.05.2013
comment
Извините, получил ваше сообщение в чате. Случилось так, что я получил это, пока работал над другим решением. Поэтому я решил добавить его в закладки и вернуться к нему позже. (На самом деле хотел решить это сам) В конце концов я завязал на работе, и когда я вернулся сейчас, я вижу ваше сообщение. Так жаль. Я обязательно отложу всю работу, когда доберусь до этого, и снова сообщу вам. ЕДИНСТВЕННОЕ, что меня беспокоило, это то, что кто-то сказал мне, что открывать новые темы для клиентов — плохая практика. Но учитывая, что я все равно это делал. Это не имеет значения. Спасибо большое. Комментарий скоро! - person Micrified; 13.05.2013
comment
Сладкий, я не хотел преследовать тебя в чате, просто если ты хочешь что-то выяснить, я готов помочь! - person Noelkd; 13.05.2013