多线程多 IP-portscaner 一脸萌比

import multiprocessing

def socket_port(ip, PORT):
global portdetaildict
s = socket.socket()
s.settimeout(0.1)
if s.connect_ex((ip, PORT)) == 0:
print ip, PORT, 'is open'
portdetaildict[str(ip)] += str(PORT)+';'
s.close()

def scan(ip):
s = socket.socket()
s.settimeout(0.1)
common_port_list = [80, 443, 8080]#这里可以扩展成 200 个常用端口
for port in common_port_list:
thread.start_new_thread(socket_port, (ip, int(port)))

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

if __name__ == '__main__':
q = multiprocessing.JoinableQueue()
iplines = linecache.getlines('../test.iplist')
timestart = time.time()
for oneip in iplines:
print oneip
thisip = str(oneip).strip()
map(q.put, thisip)

jobs = [multiprocessing.Process(target=worker, args=(q,)) for i in xrange(100)]
map(lambda x:x.start(),jobs)

#想写个能快速扫完指定 iplist 里所有 ip 的指定若干端口是否开放的多线程 py ，我知道倒数第二行有问题不太知道如何把 ip 传进去。。 help 。。。我真是小白。。

port

oneip

str

def

12 条回复 • 2017-01-16 22:43:52 +08:00

gouchaoer

2017-01-02 08:42:03 +08:00 via Android

第一，这是多进程
第二，这种情况异步 io 直接单进程完成，效率不知道高哪里去了

Allianzcortex

2017-01-02 08:45:37 +08:00 via iPhone

你这是多进程啊，应该用 dummy 的。
```
for p in jobs;
p.start()

q.join()
for p in jobs:
p.join()
```

类似这样的

inksong

2017-01-02 08:48:44 +08:00

@Allianzcortex 大神紧急求助！小弟对 python 不太熟求救，实在不太懂如何写，能再说的详细一点吗？十分感谢！

inksong

2017-01-02 08:49:53 +08:00

@gouchaoer 打错了。。十分抱歉。大神异步 io 单进程怎么搞啊，小弟刚大一，对编程还不太熟。。。能再说的详细一点吗，小弟肯定认真钻研！

Allianzcortex

2017-01-02 08:50:24 +08:00 via iPhone

其实我想说这种情况用 threadpoolexecutor + future 简直再合适不过了，写过一篇半成品 blog http://allianzcortex.me/2014/06/22/python-multiprocess/ 不知道有没有帮助。 @gouchaoer 说的是 asyncio ？其实没怎么用过(噗。。)

inksong

2017-01-02 08:56:48 +08:00

@Allianzcortex 额我只想用一个 JoinableQueue 来解决问题，我这个代码现在唯一的问题就是
jobs = [multiprocessing.Process(target=worker, args=(q,)) for i in xrange(100)]
这句里 q 的赋值我没太搞懂，我想把 iplist 赋值进去好让它一个一个处理，对 python 语法不熟。。。求点拨！