从线程ping多个ip时Python ICMP ping实现？

Question

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

因为这可能是 jedie 的 fork 的问题，我 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 上创建了一个问题

Answer 1

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

消除歧义的通常方法是在 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了解更多信息。