宝塔项目PHP调用kafka消息队列简单案例

打印 上一主题 下一主题

主题 1922|帖子 1922|积分 5766

一、在软件市肆安装kafka

 二、php扩展开启rdkafka,调用phpinfo确认扩展开启乐成:

 
三、建立一个生产者和一个消耗者,例如生产者producer.php   消耗者consumer.php  以及一个调用生产者往队列放入消息的方法,例如test.php

1.producer.php内容:

3.test.php内容:

 

 
四:运行效果,打开终端:运行消耗者:php consumer.php start  (生产环境可以添加守护进程)。浏览器打开test.php,或者新窗口命令行运行php test.php start即可看到效果
后续处理队列消息,在消耗者consumer.php获取到消息那边处理即可(ps:print_r()那一句的位置得到的是从队列里取出的数组,可直接操作)。

 

 

免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。

本帖子中包含更多资源

您需要 登录 才可以下载或查看,没有账号?立即注册

x
回复

使用道具 举报

0 个回复

倒序浏览

快速回复

您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

天津储鑫盛钢材现货供应商

论坛元老
这个人很懒什么都没写!
快速回复 返回顶部 返回列表