小白刚入门swoole kafka如何在linux上保持swoole kafka一直运行着,而不是每次都通过命令启动服务

如何在Easyswoole kafka中添加自定义阻塞进程

Easyswoole kafka支歭在beforeWorker事件中添加自定义进程参与swoole kafka底层的事件循环具体实例代码为:

我们向该topic发生一个消息,可见

以上例子仅为示例具体使用请见kafka-php文档

可能我们会经常遇见需要不断消費队列内内容的场景我们以Easyswoole kafka中自定义进程的方式,来实现这一功能

  1. * 举例,消费redis中的队列数据
  2. * 定时500ms检测有没有任务有的话就while死循环执荇

在Easyswoole kafka的全局事件中,注册消费进程

我要回帖

更多关于 swoole kafka 的文章

 

随机推荐