使用Swoole的多进程创建进程池
Aug 20, 2022 · 3 min read · 场景
需要对N多个队列进行数据处理，每个队列一次处理一个数据耗时较长。要尽可能短的时间里处理一个队列数据，需要开M个进程消耗一个队列数据。N个队列需要对应 N * M 个进程处理。
但是还需要有一个限流的功能，要求单个队列每分钟最多处理100数据。
思路
使用 Swoole 的多进程 + 进程池的方案进行进程调度处理。
队列1 <----> 进程A（建立进程池）
|-- 子进程A1
|-- 子进程A2
...
