多線程Ping網段

fping 192.168.1.1-254

import sys
import subprocess
from threading import Thread
from Queue import Queue


if sys.hexversion < 0x02040000 :

print >> sys.stderr, 'Your python version is too old (%s)' % \

(sys.version.split()[ 0 ])

print >> sys.stderr, 'You need at least Python 2.4'

sys.exit( 1 )

 
class CreateThread(Thread):

def __init__( self , func, args, name = ""):

Thread.__init__( self )

self .__name = name

self .__func = func

self .__args = args

 

def run( self ):

apply( self .__func, self .__args)

 
class FPing(object):

def __init__( self , network, tnum):

self .network = network

self .tnum = tnum

 
def ip_process( self , network):

start = network.split( '-' )[ 0 ].split( '.' )[ 3 ]

end = network.split( '-' )[ 1 ]

ip = network.split( '-' )[ 0 ].split( '.' )[ : 3 ]

ip_3 = '.' .join(ip)

return (start, end, ip_3)

 
def check_grama( self , network):

check = network.find( '-' )

if check = = - 1 :

self .usage()

sys.exit( 1 )

 

def usage( self ):

print '''Usage: python fping.py ip-num

example:

python fping 192.168.1.1-255'''


def ping_scan( self , num, iq, oq):

​​while True :

try :

ip = iq.get()

print "[*]Thread %s: Pinging %s" % (num, ip)

ret = subprocess.call( "ping -c 1 -w 3 %s" % ip, shell = True ,

stdout = open( '/dev/null' , 'w' ), stderr = subprocess.STDOUT)

if ret = = 0 :

print "[*]%s: is alive." % ip

oq.put(ip)

else :

print "[*]%s: did not respond" % ip

iq.task_done()

except Exception:

print "Threading Exception !"

sys.exit( 1 )

 
def active( self ):

worker_num = self .tnum

in_q = Queue()

ou_q = Queue()

 
start, end, ip3 = self .ip_process( self .network)

 
for ip1 in xrange(int(start), int(end) + 1 ):

ip = ip3 + '.' + str(ip1)

in_q.put(ip)

 
for i in xrange(worker_num):

worker = CreateThread( self .ping_scan, (i, in_q, out_q), self .ping_scan.__name__)

worker.setDaemon( True )

worker.start()

 
print "[*]Main Thread Waiting."

in_q.join()

out_q.join()

print "[*]Done!"

 
if __name__ = = '__main__' :

thread_worker_num = 10

fping = FPing(sys.argv[ 1 ], thread_worker_num)

if len(sys.argv) ! = 2 :

fping.usage()

sys.exit( 1 )

fping.active()