推荐学习书目 Learn Python the Hard Way Python Sites PyPI - Python Package Index http://diveintopython.org/toc/index.html Pocoo 值得关注的项目 PyPy Celery Jinja2 Read the Docs gevent pyenv virtualenv Stackless Python Beautiful Soup 结巴中文分词 Green Unicorn Sentry Shovel Pyflakes pytest Python 编程 pep8 Checker Styles PEP 8 Google Python Style Guide Code Style from The Hitchhiker's Guide
这是一个创建于 3347 天前的主题，其中的信息可能已经有所发展或是发生改变。
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 。。。我真是小白。。
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 。。。我真是小白。。
 | 1 gouchaoer 2017 年 1 月 2 日 via Android 第一，这是多进程 第二，这种情况异步 io 直接单进程完成，效率不知道高哪里去了 |
 | 2 Allianzcortex 2017 年 1 月 2 日 via iPhone 你这是多进程啊，应该用 dummy 的。 ``` for p in jobs; p.start() q.join() for p in jobs: p.join() ``` 类似这样的 |
 | 3 inksong OP @Allianzcortex 大神紧急求助！小弟对 python 不太熟求救，实在不太懂如何写，能再说的详细一点吗？十分感谢！ |
| 4 inksong OP @gouchaoer 打错了。。十分抱歉。大神异步 io 单进程怎么搞啊，小弟刚大一，对编程还不太熟。。。能再说的详细一点吗，小弟肯定认真钻研！ |
| 5 Allianzcortex 2017 年 1 月 2 日 via iPhone 其实我想说这种情况用 threadpoolexecutor + future 简直再合适不过了，写过一篇半成品 blog http://allianzcortex.me/2014/06/22/python-multiprocess/ 不知道有没有帮助。 @gouchaoer 说的是 asyncio ？其实没怎么用过(噗。。) |
| 6 inksong OP @Allianzcortex 额我只想用一个 JoinableQueue 来解决问题，我这个代码现在唯一的问题就是 jobs = [multiprocessing.Process(target=worker, args=(q,)) for i in xrange(100)] 这句里 q 的赋值我没太搞懂，我想把 iplist 赋值进去好让它一个一个处理，对 python 语法不熟。。。求点拨！ |
 | 8 rogerchen 2017 年 1 月 2 日 这显然是 IO bound 的情况， 1G 带宽打满也用不了一个核。。。 epoll kqueue 是正解，开几千个线程也马马虎虎吧，起那么多进程就有点浪费了。 |
 | 10 hoocok 2017 年 1 月 4 日 V2Ex 不支持代码缩进的么？？？？？？以后直接贴代码图吧？还是 V2EX 不支持 Markdown 之类？ |
Select Language