宝塔项目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()那一句的位置得到的是从队列里取出的数组，可直接操作)。