【问题标题】:Python ICMP ping implementation when pinging multiple ips from threads?从线程ping多个ip时的Python ICMP ping实现?
【发布时间】:2012-02-11 22:01:36
【问题描述】:

我一直在 Windows 上使用jedie's python ping implementation。我可能是错的,但是当从不同的线程 ping 两台计算机(A 和 B)时,ping 将返回它收到的第一个 ping,无论来源如何。

因为这可能是 jedie 的叉子的问题,我reverted to the previous version。 (这是我下面要探索的版本)

我在receive_one_ping中添加了一行代码:(第134行或类似的)

recPacket, addr = my_socket.recvfrom(1024) # Existing line
print "dest: {}, recv addr: {}.".format(dest_addr, addr) # New line

这让我们可以看到我们收到的 ping 的地址。 (应该和目的IP一样吧?)

测试:

ping1() ping 一个已知的离线 IP (1.2.3.4),
ping2() ping 一个已知的在线 IP(192.168.1.1 - 我的路由器)

>>> from ping import do_one

>>> def ping1():
    print "Offline:", do_one("1.2.3.4",1)

>>> ping1()
Offline: None

>>> def ping2():
    print "Online:", do_one("192.168.1.1",1)

>>> ping2()
Online: dest: 192.168.1.1, recv addr: ('192.168.1.1', 0).
0.000403682590942

现在如果我们一起做:(为了简单起见,使用 Timer)

>>> from threading import Timer
>>> t1 = Timer(1, ping1)
>>> t2 = Timer(1, ping2)
>>> t1.start(); t2.start()
>>> Offline:Online: dest: 192.168.1.1, recv addr: ('192.168.1.1', 0).dest: 1.2.3.4, recv addr: ('192.168.1.1', 0).

0.0004508952953870.000423517514093

它有点混乱(由于打印不能很好地与线程一起工作),所以这里更清楚一点:

>>> Online: dest: 192.168.1.1, recv addr: ('192.168.1.1', 0).
Offline:dest: 1.2.3.4, recv addr: ('192.168.1.1', 0). # this is the issue - I assume dest should be the same as recv address?

0.000450895295387
0.000423517514093

我的问题:

  1. 谁能重现这个?

  2. ping 的行为应该是这样吗?我假设不是。

  3. 是否存在不具有此行为的 Python 的现有 ICMP ping?
    或者,您能想出一个简单的解决方法 - 即轮询 receive_one_ping 直到我们的目的地与我们的接收地址匹配?

编辑:我在python-ping github page创建了一个问题

【问题讨论】:

    标签: python multithreading ping icmp


    【解决方案1】:

    发生这种情况是因为 ICMP 的性质。 ICMP 没有端口的概念,因此 all ICMP 消息由 all 侦听器接收。

    消除歧义的常用方法是在 ICMP ECHO REQUEST 负载中设置唯一标识符,并在响应中查找它。此代码似乎可以做到这一点,但它使用当前进程 ID 来组成 ID。由于这是多线程代码,它们将共享一个进程 ID,并且当前进程中的所有侦听器都会认为所有 ECHO REPLY 都是它们自己发送的!

    您需要更改do_one() 中的ID 变量,使其在每个线程中都是唯一的。您需要在do_one() 中更改此行:

    my_ID = os.getpid() & 0xFFFF
    

    可能这可以作为替代方案,但理想情况下,您应该使用真正的 16 位散列函数:

    # add to module header
    try:
        from thread import get_ident
    except ImportError:
        try:
            from _thread import get_ident
        except ImportError:
            def get_ident():
                return 0
    
    # now in do_one() body:
    my_ID = (get_ident() ^ os.getpid()) & 0xFFFF
    

    我不知道这个模块是否有任何其他线程问题,但从粗略的检查来看,它似乎没问题。

    使用 jedie 实现,您可以对 Ping() own_id 构造函数参数进行类似的更改。您可以传入一个您知道唯一的 id(如上)并自己管理 Ping() 对象,或者您可以在构造函数中更改此行 (110):

    self.own_id = os.getpid() & 0xFFFF
    

    另请参阅this question and answer and answer comment thread 了解更多信息。

    【讨论】:

    • 太好了,谢谢。我认为我们只看到每个线程的一个回复,因为receive_one_pingpacketID == ID 时返回,并且由于它们当前始终是相同的 ID,因此它将始终返回第一个回复。我想我会让线程将唯一 ID 作为参数传递给 do_one - 我会尝试 threading.current_thread().ident
    • 啊,就是这样。好的,所以这个 ident 问题可能是唯一的问题。如果您更喜欢 jedie 实现,您可能无需修改即可使用它,只要您将自定义 id 传递给 Ping() 构造函数。
    • threading.current_thread().ident 有效(我相信线程已被弃用):在线:id:2688 ip:192.168.1.1。目的地:192.168.1.1,接收地址:('192.168.1.1',0)。 0.000427707990752 离线:id:5492 ip:1.2.3.4 无。谢谢!
    • 请注意,您的 id 必须是机器唯一的。对于单线程程序,process-id 是完美的。然而,对于多线程程序,来自threading 的线程 id 只能保证在当前进程中是唯一的。这就是我与进程 ID 进行异或运算的原因。
    • +1 用于解释“来自多个线程的 ICMP”问题,其中一个线程从另一个线程发出的 ping 接收 gnip,(并解释解决方案)。
    猜你喜欢
    • 1970-01-01
    • 2023-01-25
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2011-06-26
    • 2020-12-07
    相关资源
    最近更新 更多