那些遇到过的问题

另一个'由同行重置连接'错误

smb*_*let 7 python

我正在使用套接字模块在python中创建一个服务器/客户端应用程序,无论出于什么原因,我的服务器都会不断结束连接.奇怪的是,这在Windows中可以完美运行,但不适用于Linux.我到处寻找一个可能的解决方案,但没有一个工作.下面是利用该错误的代码的清理版本,但成功率更高.通常它永远不会起作用.希望这仍然是足够的信息.谢谢!

服务器:

import logging
import socket
import threading
import time

def getData():
    HOST = "localhost"
    PORT = 5454

    while True:
        s = socket.socket( socket.AF_INET, socket.SOCK_STREAM )
        s.setsockopt( socket.SOL_SOCKET, socket.SO_REUSEADDR, 1 ) #because linux doesn't like reusing addresses by default

        s.bind( ( HOST, PORT ) )
        logging.debug( "Server listens" )
        s.listen( 5 )
        conn, addr = s.accept()
        logging.debug( "Client connects" )
        print "Connected by,", addr

        dataRequest = conn.recv( 1024 )
        logging.debug( "Server received message" )

        time.sleep( .01 ) #usually won't have to sample this fast

        data = """Here is some data that is approximately the length 
of the data that I am sending in my real server. It is a string that
doesn't contain any unordinary characters except for maybe a tab."""

        if not timeThread.isAlive(): #lets client know test is over
            data = "\t".join( [ data, "Terminate" ] )
            conn.send( data )
            s.close()
            print "Finished"
            print "Press Ctrl-C to quit"
            break
        else:
            logging.debug( "Server sends data back to client" )
            conn.send( data )

        logging.debug( "Server closes socket" )
        s.close()

def timer( t ):
    start = time.time()
    while ( time.time() - start ) < t:
        time.sleep( .4 )
        #sets flag for another thread not here

def main():
    global timeThread

    logging.basicConfig( filename="test.log", level=logging.DEBUG )

    #time script runs for
    t = 10 #usually much longer (hours)

    timeThread = threading.Thread( target=timer, args=( t, ) )
    dataThread = threading.Thread( target=getData, args=() )
    timeThread.start()
    dataThread.start()

    #just for testing so I can quit threads when sockets break
    while True:
        time.sleep( .1 )

    timeThread.join()
    dataThread.join()

if __name__ == "__main__":
    main()
Run Code Online (Sandbox Code Playgroud)

客户:

import logging
import socket

def getData():
    dataList = []
    termStr = "Terminate"

    data = sendDataRequest()
    while termStr not in data:
        dataList.append( data )
        data = sendDataRequest()
    dataList.append( data[ :-len( termStr )-1 ] )

def sendDataRequest():
    HOST = "localhost"
    PORT = 5454

    s = socket.socket( socket.AF_INET, socket.SOCK_STREAM )

    while True:
        try:
            s.connect( ( HOST, PORT ) )
            break
        except socket.error:
            print "Connecting to server..."

    logging.debug( "Client sending message" )
    s.send( "Hey buddy, I need some data" ) #approximate length

    try:
        logging.debug( "Client starts reading from socket" )
        data = s.recv( 1024 )
        logging.debug( "Client done reading" )
    except socket.error, e:
        logging.debug( "Client throws error: %s", e )

    print data

    logging.debug( "Client closes socket" )
    s.close()

    return data

def main():
    logging.basicConfig( filename="test.log", level=logging.DEBUG )
    getData()

if __name__ == "__main__":
    main()
Run Code Online (Sandbox Code Playgroud)

编辑:添加回溯

Traceback (most recent call last):
    File "client.py", line 39, in <moduel>
        main()
    File "client.py", line 36, in main
        getData()
    File "client.py", line 10, in getData
        data = sendDataRequest()
    File "client.py", line 28, in sendDataRequest
        data = s.recv( 1024 )
socket.error: [Errno 104] Connection reset by peer
Run Code Online (Sandbox Code Playgroud)

编辑:添加调试

DEBUG:root:Server listens
DEBUG:root:Client sending message
DEBUG:root:Client connects
DEBUG:root:Client starts reading from socket
DEBUG:root:Server received message
DEBUG:root:Server sends data back to client
DEBUG:root:Server closes socket
DEBUG:root:Client done reading
DEBUG:root:Server listens
DEBUG:root:Client sending message
DEBUG:root:Client connects
DEBUG:root:Client starts reading from socket
DEBUG:root:Server received message
DEBUG:root:Server sends data back to client
DEBUG:root:Client done reading
DEBUG:root:Client sending message
DEBUG:root:Client starts reading from socket
DEBUG:root:Server closes socket
DEBUG:root:Client throws error: [Errno 104] Connection reset by peer
DEBUG:root:Server listens
Run Code Online (Sandbox Code Playgroud)

汤姆的理论似乎是正确的.我会试着弄清楚如何更好地关闭连接.

这没有解决,但接受的答案似乎指出了问题.

编辑:我尝试使用Tom的getData()函数,看起来服务器仍然很快关闭连接.应该是可重复的,因为我无法在Windows中使用它.

服务器输出/回溯:

Connected by, ('127.0.0.1', 51953)
Exception in thread Thread-2:
Traceback (most recent call last):
    File "/usr/lib64/python2.6/threading.py", line 532, in __bootstrap_inner
        self.run()
    File "/usr/lib64/python2.6/threading.py", line 484, in run
        self.__target(*self.__args, **self.__kwargs)
    File "server.py", line 15, in getData
        s.bind( ( HOST, PORT ) )
    File "<string>", line 1, in bind
error: [Errno 22] Invalid argument
Run Code Online (Sandbox Code Playgroud)

客户端输出/回溯:

Here is some data that is approximately the length
of the data that I am sending in my real server. It is a string that
doesn't contain any unordinary characters except for maybe a tab.
Traceback (most recent call last):
    File "client.py", line 49, in <moduel>
        main()
    File "client.py", line 46, in main
        getData()
    File "client.py", line 11, in getData
        data = sendDataRequest()
    File "client.py", line 37, in sendDataRequest
        print data
UnboundLocalError: local variable 'data' referenced before assignment
Run Code Online (Sandbox Code Playgroud)

日志:

DEBUG:root:Server listens
DEBUG:root:Client sending message
DEBUG:root:Client connects
DEBUG:root:Client starts reading from socket
DEBUG:root:Server received message
DEBUG:root:Server sends data back to client
DEBUG:root:Server closes connection
DEBUG:root:Client done reading
DEBUG:root:Client closes socket
DEBUG:root:Client sending message
DEBUG:root:Client starts reading from socket
DEBUG:root:Client throws error: [Errno 104] Connection reset by peer
Run Code Online (Sandbox Code Playgroud)

更新:我使用了Tom的getData()功能,但s.bind()在循环之前将其移至并使其工作.老实说,我不知道为什么这样可行,所以如果有人能解释为什么服务器关闭它的客户端套接字是安全的,而不是当它关闭它的服务器套接字时会很酷.谢谢!

Tom*_*ton 5

虽然我无法重现这个问题(在Windows 7 64位,Python 2.7上),但我最好的猜测是发生了以下情况:

  • 服务器侦听
  • 客户连接
  • 客户端发送"嘿好友,我需要一些数据"
  • 服务器收到这个
  • 服务器将数据发送回客户端
  • 服务器关闭套接字
  • 客户端尝试从套接字读取,发现它已被关闭
  • 客户端抛出"通过对等方重置连接"错误.

您从客户端添加的堆栈跟踪似乎支持这一理论.有可能证明某些额外的记录或类似情况不是这样吗？

其他注意事项:如果您的客户端在它收到的第一个数据中没有找到终止字符串,它会打开一个到服务器的新套接字.这看起来不对我 - 你应该从同一个套接字读取数据,直到你拥有它.

编辑:结合更多事情:

在示例日志输出中,您尚未更新代码,因此我无法查看每个日志行的来源.但是,看起来很可疑,就像你有两个并行运行的客户端(可能在不同的进程或线程中？),这导致:

我刚刚注意到最后一件事.在此示例https://docs.python.org/2/library/socket.html#example中,服务器不关闭套接字,它会关闭从侦听套接字生成的连接.可能是您有2个客户端连接到同一服务器套接字实例,当您关闭服务器套接字时,实际上是断开连接的两个客户端,而不仅仅是第一个.如果您正在运行多个客户端,则记录某种身份Eg.DEBUG:root:Client(6) done reading可能有助于证明这一点

你可以尝试以下服务器的数据线程主循环,将显示问题是否与关闭侦听套接字而不是连接套接字有关:


def getData():
    HOST = "localhost"
    PORT = 5454

    s = socket.socket( socket.AF_INET, socket.SOCK_STREAM )
    # s.setsockopt( socket.SOL_SOCKET, socket.SO_REUSEADDR, 1 ) #because linux doesn't like reusing addresses by default
    s.bind( ( HOST, PORT ) )
    logging.debug( "Server listens" )
    s.listen( 5 )

    while True:

        conn, addr = s.accept()
        logging.debug( "Client connects" )
        print "Connected by,", addr

        dataRequest = conn.recv( 1024 )
        logging.debug( "Server received message" )

        time.sleep( .01 ) #usually won't have to sample this fast

        data = """Here is some data that is approximately the length 
of the data that I am sending in my real server. It is a string that
doesn't contain any unordinary characters except for maybe a tab."""

        if not timeThread.isAlive(): #lets client know test is over
            data = "\t".join( [ data, "Terminate" ] )
            conn.send( data )
            conn.close()
            print "Finished"
            print "Press Ctrl-C to quit"
            break
        else:
            logging.debug( "Server sends data back to client" )
            conn.send( data )

        logging.debug( "Server closes connection" )
        conn.close()
Run Code Online (Sandbox Code Playgroud)

小智 5

我在这里超出了我的深度，但在研究一个可能相关的问题（Linux 上间歇性的“连接由对等重置”错误，在 Windows 上工作正常），我遇到了http://scie.nti.st/2008/ 3/14/amazon-s3-and-connection-reset-by-peer/。我们的有用调试员 Garry Dolley 总结道（2008 年！）：

“Linux 内核 2.6.17+ 增加了 TCP 窗口/缓冲区的最大大小，如果其他设备无法处理足够大的 TCP 窗口，这就会开始导致其他设备出现故障。该设备会重置连接，我们看到这是一条‘连接被对等方重置’消息。”

他给出了一个涉及/etc/sysctl.conf 的解决方案。我还没有尝试过，但可能值得一看？

归档时间：

查看次数：

16122 次

最近记录：

11 年，11 月 前
相关归档
如何从基类动态创建派生类 83
Python:看看一个集合是否完全包含另一个集合？ 71
变量名前的*和**在函数签名中是什么意思？ 64
暂时重定向stdout/stderr 55
在启动子线程时,Flask抛出'在请求上下文之外工作' 52
Google上的google Go与Python和Java的资源使用情况 51
熊猫:丢掉连续的重复 50
删除目录中的所有文件 42
通过scipy.sparse向量(或矩阵)迭代 41
Python Dictionaries与Javascript对象有什么区别？ 41
难疑归档
使用jQuery禁用/启用输入？ 2216
NPM vs. Bower vs. Browserify vs. Gulp vs. Grunt vs. Webpack 1811
如何检查SQL Server表中是否存在列？ 1792
如何在没有换行或空格的情况下打印？ 1760
Facebook如何禁用浏览器的集成开发人员工具？ 1652
对于数组,为什么a [5] == 5 [a]？ 1567
将存储过程的结果插入临时表 1526
如何为"选择"框创建占位符？ 1426
"无法找到或加载主类"是什么意思？ 1277
检查值是否是JavaScript中的对象 1194