/smq

Swoole for NSQ; 使用swoole实现MQ(simple message queue),参考NSQ的简单实现;

Primary LanguagePHP

smq

使用swoole实现了一个简单的MQ,主要是参考NSQ的模型;但是大大简化了,使用telnet进行简单交互;只实现sub/pub,有兴趣的可以继续扩展;

另外一个是对于熟悉php的同学,可以比较好的理解NSQ的代码底层运行和设计逻辑,虽然不同语言,但是实现方式大同小异;

php bin/mq.php # 开始执行
  1. 发布订阅
  2. 持久化数据
  3. 优雅退出