利用 python 做了个队列消费者（器） 伪代码：
while True:
job = beanstalk.watch('test')
body = job.body
if (body.type == 'sms'):
sendsms(body.params,job)
elif (body.type == 'email'):
sendemail(body.params,job)
怎么可以更优雅的让他动态 fork 出另外一个线程去执行，而让这个 worker 的主入口继续获取别的队列内容。
 |
1
Lax Sep 3, 2017
while job = beanstalk.watch('test'):
fork do blablabla... any way, fork 出来的是进程 |
 |
2
NoAnyLove Sep 3, 2017
concurrent.future
话说，你到底想要在线程中执行还是进程中执行啊？ fork 不是用来创建新进程的吗？ |
 |
3
cevincheung OP @NoAnyLove #2 描述有点问题，总之目标就是建立一个队列内容获取的东西，一旦获取就赶紧丢给真正执行这个队列的负责 [人] ，然后继续获取其他队列中数据。
|
 |
4
wuhang89 Sep 4, 2017
都用队列了，多开几个进程呗，上层拿一个 supervisor 做个守护进程好了，搞那么麻烦干嘛。
|
 |
5
keakon Sep 4, 2017
理论上性能最好的方式是设置 SO_REUSEPORT，每个进程都去监听 beanstalk 的端口即可。不过需要手动改下客户端源码。
|
|
6
keakon Sep 4, 2017
想错了，又不是服务端，SO_REUSEPORT 都不用设置，直接多进程消费即可。
|
 |
7
laike9m Sep 4, 2017
|
 |
8
yylucifer Sep 6, 2017
我擦，和我以前写过的消息队列居然是一样的，我也用的 beanstalk。。
这个可以写得很复杂，简单点就做个反射调用就可以了。。 |
Select Language