qidao123.com技术社区-IT企服评测·应用市场

标题: 宝塔项目PHP调用kafka消息队列简单案例 [打印本页]

作者: 天津储鑫盛钢材现货供应商 时间: 2025-3-7 16:30
标题: 宝塔项目PHP调用kafka消息队列简单案例
一、在软件市肆安装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企服之家，中国第一个企服评测及商务社交产业平台。

欢迎光临 qidao123.com技术社区-IT企服评测·应用市场 (https://dis.qidao123.com/)