对等端重置Python连接

Question

我正在尝试让一个简单的主机/客户端传输工作。我遵循了一个教程，服务器正常运行，但当客户端尝试连接时，它返回“由对等端重置连接”我真的不知道错误在哪里。

class genSocket:

def __init__(self, sock=None):
    if sock is None:
        self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    else:
        self.sock = sock

def bind(self, ip, port):
    self.sock.bind((ip, port))

def listen(self, maxcon):
    self.sock.listen(maxcon)
    while True:
        self.sock.accept()

def accept(self):
    self.sock.accept()
    while True:
        print (self.recieve())

def connect(self, host, port):
    self.sock.connect((host, port))

def send(self, msg, type):
    totalsent = 0
    prefix = str(type) + str(len(msg)).rjust(5, '0')
    print prefix
    while totalsent < 6:
        sent = self.sock.send(prefix)
        if sent == 0:
            raise RuntimeError("Connection broken!")

    print "sent prefix"

    totalsent = 0
    while totalsent < len(msg):
        sent = self.sock.send(msg[totalsent:])
        if sent == 0:
            raise RuntimeError("Connection broken!")
        totalsent = + sent

def recieve(self):
    bytes_recd = 0
    while bytes_recd < 6:
        prefix = self.sock.recv(6)
        if prefix == '':
            raise RuntimeError("Connection broken!")
        prefix.append(prefix)
        bytes_recd = + len(prefix)

    print "recieved prefix"

    chunks = []
    msglen = prefix[1:]
    bytes_recd = 0
    while bytes_recd < msglen:
        chunk = self.sock.recv(min(msglen - bytes_recd, 2048))
        if chunk == '':
            raise RuntimeError("Connection broken!")
        chunks.append(chunk)
        bytes_recd = + len(chunk)
    return ''.join(chunks)

Answer 1

newsock, clientaddr = oldsock.accept()
while True:
    print newsock.recv(100), "from", clientaddr[0], "on port", clientaddr[1]

当操作系统在监听端口上接收到连接时，操作系统会将端口切换到新的空闲端口。通过这种方式，您可以在处理刚到达的连接时继续侦听端口以获取新连接。插座accept（）将等待连接到来，然后它将返回一个绑定到新端口的新套接字和一个元组（address，port），其中address是客户端的IP，port是OS内部提供的新端口。因此，如果您想取消accept（）方法与receive（）的关联，则必须将新套接字保存在某个属性中。或者像garph0说的那样把它作为一个论点来传递。

据我记忆所及，当客户端断开连接时，recv（）将抛出一个错误。然后你打电话给纽斯托克。close（），或者在希望关闭客户机鼻子上的门时调用它。然后你平静地继续等待新的。

Answer 2

socket。accept（）将返回发送和接收所需的新套接字对象。看看这些文件。

例如。：

def accept(self):
    conn, addr = self.sock.accept()
    while True:
        print (self.recieve(conn))

并更改self.recieve（）以使用新套接字。

此外，此实现在为第一个客户端提供服务时不会接受（）任何新客户端，但是可以为listen（）调用指定大于零的maxcon值。

这将使任何新客户机（最多maxconvalue）成功连接，然后排队等待服务，但是这个实现看起来好像在客户机停止连接时就要退出（虽然我没有仔细检查：），所以最好给listen（）一个零积压值。