5

我的盒子里部署了一个网络服务。我想通过各种输入检查此服务的结果。这是我正在使用的代码：

import sys
import httplib
import urllib

apUrl = "someUrl:somePort"

fileName = sys.argv[1]
conn = httplib.HTTPConnection(apUrl)

titlesFile = open(fileName, 'r')

try:
    for title in titlesFile:

        title = title.strip()
        params = urllib.urlencode({'search': 'abcd', 'text': title})
        conn.request("POST", "/somePath/", params)
        response = conn.getresponse()
        data = response.read().strip()
        print data+"\t"+title

        conn.close()

finally:
    titlesFile.close()

此代码在打印相同数量的行（28233）后给出错误。错误信息：

Traceback (most recent call last):
  File "testService.py", line 19, in ?
    conn.request("POST", "/somePath/", params)
  File "/usr/lib/python2.4/httplib.py", line 810, in request
    self._send_request(method, url, body, headers)
  File "/usr/lib/python2.4/httplib.py", line 833, in _send_request
    self.endheaders()
  File "/usr/lib/python2.4/httplib.py", line 804, in endheaders
    self._send_output()
  File "/usr/lib/python2.4/httplib.py", line 685, in _send_output
    self.send(msg)
  File "/usr/lib/python2.4/httplib.py", line 652, in send
    self.connect()
  File "/usr/lib/python2.4/httplib.py", line 636, in connect
    raise socket.error, msg
socket.error: (99, 'Cannot assign requested address')

我正在使用 Python 2.4.3。我conn.close()也在做。但是为什么会出现这个错误？

4

3 回答 3

12

这不是python问题。

在 linux 内核 2.4 中，临时端口范围是从 32768 到 61000。所以可用端口的数量 = 61000-32768+1 = 28233。据我了解，因为所讨论的 Web 服务非常快（实际上<5ms），因此所有端口用完了。该程序必须等待大约一两分钟才能关闭端口。

我所做的是计算conn.close(). 当数字为 28000 时，等待 90 秒并重置计数器。

于 2012-06-26T13:58:06.610 回答
6

BIGYaN 正确识别了问题，您可以在异常发生后立即调用“netstat -tn”来验证这一点。您将看到很多状态为“TIME_WAIT”的连接。

等待端口号再次可用的替代方法是简单地为所有请求使用一个连接。您无需conn.close()在每次调用 后调用conn.request()。您可以简单地保持连接打开，直到您完成您的请求。

于 2013-01-04T15:34:25.173 回答
1

在 Spark 中使用 python 的请求库执行多个 POST 语句时，我也遇到了类似的问题。更糟糕的是，我在每个执行程序上使用多处理来发布到服务器。因此，在几秒钟内创建了数千个连接，每个连接需要几秒钟才能从 TIME_WAIT 更改状态并为下一组连接释放端口。

在互联网上所有可用的解决方案中，通过使用 request.Session() 等来禁用keep-alive，我发现这个答案是有效的，它使用'Connection' : 'close'配置作为标头参数. 不过，您可能需要将标题内容放在 post 命令之外的单独行中。

headers = {
        'Connection': 'close'
}
with requests.Session() as session:
response = session.post('https://xx.xxx.xxx.x/xxxxxx/x', headers=headers, files=files, verify=False)
results = response.json()
print results

这是我使用上述解决方案对类似问题的回答。

于 2018-04-09T15:16:12.720 回答