从线程ping多个ips时的Python ICMP ping实现?

Ale*_*x L 2 python multithreading ping icmp

我一直在Windows上使用jedie的python ping实现.我可能是错的,但是当从不同的线程ping两台计算机(A和B)时,ping将返回它收到的第一个ping,无论源是什么.

因为它可能是jedie's fork的一个问题,所以我回到了之前的版本.(这是我将在下面探讨的版本)

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

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

这允许我们查看我们正在接收的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
Run Code Online (Sandbox Code Playgroud)

现在,如果我们一起做:(使用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
Run Code Online (Sandbox Code Playgroud)

它有点受损(由于打印不能很好地处理线程),所以这里有点清楚:

>>> 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
Run Code Online (Sandbox Code Playgroud)

我的问题:

  1. 任何人都可以重新创建吗?

  2. 应该ping这样吗?我假设没有.

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

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

Fra*_*ila 5

由于ICMP的性质,这种情况正在发生.ICMP没有端口概念,因此所有 ICMP消息都被所有侦听器接收.

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

您需要更改ID变量,do_one()以使其是每个线程唯一的.您需要更改以下行do_one():

my_ID = os.getpid() & 0xFFFF
Run Code Online (Sandbox Code Playgroud)

可能这将作为替代方案,但理想情况下,您应该使用真正的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
Run Code Online (Sandbox Code Playgroud)

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

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

self.own_id = os.getpid() & 0xFFFF
Run Code Online (Sandbox Code Playgroud)

另请参阅此问题并回答并回答评论主题以获取更多信息.