客户端套接字未正确接收数据

Question

我已尝试寻找答案，但似乎找不到能回答我的具体问题的答案。

也许我不知道如何正确地表达这个问题。

我想我已经确定了它是什么，但问题是我只是不知道如何解决它。

编辑：我试图在一个 TCP 套接字上使用两个客户端。不能那样做。我得想别的办法了。解决了，我猜。

所以我得到的是

1：两个客户

2：一台服务器

目标是这样的： 让服务器在连接时将新用户名分发给所有客户端。

这是我运行程序时发生的情况：

Server：定义主机，端口，初始化。 检查

客户端 1：连接到服务器。 检查

客户端 1：连接后，向服务器发送一个字符串。 检查

Server：接收一个字符串，检查该字符串是否在创建的列表中。如果是：通过，如果不是，将新字符串发送给每个人。 检查

客户端 1：[正在等待接收数据] 接收数据，检查接收到的字符串是否与发送的字符串匹配。如果是，则打印（“这是我们的一个！”），否则，将新字符串 = 设置为客户端 2 用户名。 检查

客户端 2： 连接到服务器：检查

服务器：[如果它接收到一个字符串，打印它。]（有效）检查新字符串是否在列表中。 [不是] 所以它将新用户名发送给所有人，然后打印 ("Sent to everyone") Check

但是，当客户端 2 收到字符串时，它会打印它。但是，客户端 1 从不接收字符串。

当在 IDLE 中运行客户端 1 时，我注意到客户端 1 尝试接收数据时出现了问题。 （data = s.recv 的 while 循环开始快速循环，而不是等待）

我在聊天中四处打听过，但现在似乎没有人在附近。我试过查找这个，但我真的找不到答案。 我怀疑正在发生的事情是，当我的服务器第二次发送到“连接”时，它会以某种方式覆盖原始客户端连接。

这是我的服务器代码：

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))

如果您能帮忙，我将不胜感激。

如果您知道我已经提出的问题的答案，请告诉我，我将删除此帖子以避免违反规则。谢谢！

Answer 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)

这段代码在客户端断开连接时没有做任何优雅的事情，但是一旦你可以处理发生这种情况时引发的异常，我相信你会学到更多。