Tp5使用Kafka：封装生产者、消费者操作类

生产者、消费者操作类"/>

Tp5使用Kafka：封装生产者、消费者操作类

【相关文章】PHP操作Kafka：php-rdkafka扩展的安装

1、config.php中配置：

//kafka连接配置
'kafka_server' => ['host' => '127.0.0.1:9092','topic' => 'topic1',
],

2、创建一个生产者 KafkaProducer.php ：

<?php
namespace app\index\controller;
class KafkaProducer
{private $_rk = null;private $_topic = null;private static $_instance = null;private $_config = [];//定义单例模式的变量public static function getInstance(){if (empty(self::$_instance)) {self::$_instance = new self();}return self::$_instance;}private function __construct(){$this->_config = config('kafka_server');$this->_rk = new \RdKafka\Producer();$this-&