简单的推送消息服务

  • 订阅者注册推送地址,关注的事件
  • 服务端将消息存储redis队列
  • 服务端开N个进程,读取redis队列并推送到订阅者url
  • 推送错误进入错误队列
  • 服务定时发送错误队列消息

原型

  • swoole->addProcess(swoole_process)增加的进程不能start()
  • process结束后会被master进程再次创建,所以要么阻塞或进epoll循环
  • 参考 http://wiki.swoole.com/wiki/page/390.html
  • 与worker或task进程通信参考  http://wiki.swoole.com/wiki/page/363.html

 

发表评论

您的电子邮箱地址不会被公开。 必填项已用*标注