如何用python寫個(gè)端口掃描器及各種并發(fā)嘗試-創(chuàng)新互聯(lián)

這期內(nèi)容當(dāng)中小編將會給大家?guī)碛嘘P(guān)如何用python寫個(gè)端口掃描器及各種并發(fā)嘗試，文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

創(chuàng)新互聯(lián)公司從2013年開始，先為前鋒等服務(wù)建站，前鋒等地企業(yè)，進(jìn)行企業(yè)商務(wù)咨詢服務(wù)。為前鋒企業(yè)網(wǎng)站制作PC+手機(jī)+微官網(wǎng)三網(wǎng)同步一站式服務(wù)解決您的所有建站問題。

端口掃描器原理很簡單，無非就是操作socket，能connect就認(rèn)定這個(gè)端口開放著。

import socket
def scan(port):
    s = socket.socket()
    if s.connect_ex(('localhost', port)) == 0:
        print port, 'open'
    s.close()
if __name__ == '__main__':
    map(scan,range(1,65536))

這樣一個(gè)最簡單的端口掃描器出來了。

等等喂，半天都沒反應(yīng)，那是因?yàn)閟ocket是阻塞的，每次連接要等很久才超時(shí)。

我們自己給它加上的超時(shí)。

s.settimeout(0.1)

再跑一遍，感覺快多了。

多線程版本

import socket
import threading
def scan(port):
    s = socket.socket()
    s.settimeout(0.1)
    if s.connect_ex(('localhost', port)) == 0:
        print port, 'open'
    s.close()

if __name__ == '__main__':
    threads = [threading.Thread(target=scan, args=(i,)) for i in xrange(1,65536)]
    map(lambda x:x.start(),threads)

運(yùn)行一下，哇，好快，快到拋出錯誤了。thread.error: can't start new thread。

想一下，這個(gè)進(jìn)程開啟了65535個(gè)線程，有兩種可能，一種是超過較大線程數(shù)了，一種是超過較大socket句柄數(shù)了。在linux可以通過ulimit來修改。

如果不修改較大限制，怎么用多線程不報(bào)錯呢？

加個(gè)queue,變成生產(chǎn)者-消費(fèi)者模式,開固定線程。

多線程+隊(duì)列版本

import socket
import threading
from Queue import Queue
def scan(port):
    s = socket.socket()
    s.settimeout(0.1)
    if s.connect_ex(('localhost', port)) == 0:
        print port, 'open'
    s.close()

def worker():
    while not q.empty():
        port = q.get()
        try:
            scan(port)
        finally:
            q.task_done()

if __name__ == '__main__':
    q = Queue()
    map(q.put,xrange(1,65535))
    threads = [threading.Thread(target=worker) for i in xrange(500)]
    map(lambda x:x.start(),threads)
    q.join()

這里開500個(gè)線程，不停的從隊(duì)列取任務(wù)來做。

multiprocessing+隊(duì)列版本

總不能開65535個(gè)進(jìn)程吧？還是用生產(chǎn)者消費(fèi)者模式

import multiprocessing
def scan(port):
    s = socket.socket()
    s.settimeout(0.1)
    if s.connect_ex(('localhost', port)) == 0:
        print port, 'open'
    s.close()

def worker(q):
    while not q.empty():
        port = q.get()
        try:
            scan(port)
        finally:
            q.task_done()

if __name__ == '__main__':
    q = multiprocessing.JoinableQueue()
    map(q.put,xrange(1,65535))
    jobs = [multiprocessing.Process(target=worker, args=(q,)) for i in xrange(100)]
    map(lambda x:x.start(),jobs)

注意這里把隊(duì)列作為一個(gè)參數(shù)傳入到worker中去，因?yàn)槭莗rocess safe的queue，不然會報(bào)錯。

還有用的是JoinableQueue()，顧名思義就是可以join()的。

gevent的spawn版本

from gevent import monkey; monkey.patch_all();
import gevent
import socket
...
if __name__ == '__main__':
    threads = [gevent.spawn(scan, i) for i in xrange(1,65536)]
    gevent.joinall(threads)

注意monkey patch必須在被patch的東西之前import,不然會Exception KeyError.比如不能先import threading,再monkey patch.

gevent的Pool版本

from gevent import monkey; monkey.patch_all();
import socket
from gevent.pool import Pool
...
if __name__ == '__main__':
    pool = Pool(500)
    pool.map(scan,xrange(1,65536))
    pool.join()

concurrent.futures版本

import socket
from Queue import Queue
from concurrent.futures import ThreadPoolExecutor
...
if __name__ == '__main__':
    q = Queue()
    map(q.put,xrange(1,65536))
    with ThreadPoolExecutor(max_workers=500) as executor:
        for i in range(500):
            executor.submit(worker,q)

上述就是小編為大家分享的如何用python寫個(gè)端口掃描器及各種并發(fā)嘗試了，如果剛好有類似的疑惑，不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

標(biāo)題名稱：如何用python寫個(gè)端口掃描器及各種并發(fā)嘗試-創(chuàng)新互聯(lián)
分享URL：http://muchs.cn/article12/cdiegc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供靜態(tài)網(wǎng)站、網(wǎng)站內(nèi)鏈、商城網(wǎng)站、網(wǎng)站建設(shè)、品牌網(wǎng)站制作、網(wǎng)站改版

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)