如何强制使用python打开套接字关闭？

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了如何强制使用python打开套接字关闭？，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1861字，纯文字阅读大概需要3分钟。

内容图文

我目前正在使用此lib来测试我已设置的kafka服务器：https://github.com/dsully/pykafka

import kafka
import time

def test_kafka_server(n=1):
    for i in range(0,n):
        producer = kafka.producer.Producer('test',host='10.137.8.192')
        message = kafka.message.Message(str(time.time()))
        producer.send(message)
        producer.disconnect()

def main():
    test_kafka_server(100000)

if __name__ == '__main__':
    main()

最终发生的事情是我最终超载了我自己的本地机器.

我得到错误10055,根据谷歌意味着“Windows已经用完了TCP / IP套接字缓冲区,因为有太多连接一次打开.”根据netstat,producer.disconnect()没有关闭套接字,而是将其置于TIME_WAIT状态.

ipython调试器指向这一行：

C:\Python27\lib\socket.pyc in meth(name, self, *args)
    222     proto = property(lambda self: self._sock.proto, doc="the socket protocol")
    223 
--> 224 def meth(name,self,*args):
    225     return getattr(self._sock,name)(*args)
    226 

作为罪魁祸首,但这似乎陷入了低于我感到满意的事情.

我搜索过并发现这个Python socket doesn’t close connection properly建议：

setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)

所以,我在io.py文件中使用该选项重建了pykafka lib：

  def connect(self):
    """ Connect to the Kafka server. """
    global socket
    self.socket = socket.socket()
    self.socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    self.socket.connect((self.host, self.port))

我仍然得到同样的错误.

我不是把setsockopt线放在正确的位置吗？还有什么我可以尝试的吗？

解决方法:

您所描述的是套接字级别的正常TCP行为.当用户级程序关闭套接字时,内核不会立即释放套接字.它进入TIME_WAIT状态：

TIME-WAIT (either server or client) represents waiting for enough
time to pass to be sure the remote TCP received the acknowledgment of
its connection termination request. [According to RFC 793 a connection
can stay in TIME-WAIT for a maximum of four minutes known as a MSL
(maximum segment lifetime).

所以套接字已关闭. socket.SO_REUSEADDR用于侦听器(服务器),不影响客户端连接.好吧,绑定套接字时真的用过.

内容总结

以上是互联网集市为您收集整理的如何强制使用python打开套接字关闭？全部内容，希望文章能够帮你解决如何强制使用python打开套接字关闭？所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端