tp6中kafka使用

<?php
namespace app\util;use \RdKafka\Conf;
use \RdKafka\Producer;class Kafka{public $kafkaConfig;public $kafkaResource;//初始化public function __construct(){$this->connect();}/*** 连接*/private function connect(){$this->kafkaConfig = new Conf();$this->kafkaConfig->set('log_level', (string) LOG_DEBUG);$this->kafkaConfig->set('debug', 'all');$this->kafkaResource = new Producer($this->kafkaConfig);$this->kafkaResource->addBrokers("127.0.0.1:9092");}/*** 发布消息*/public function publishMessage($message = ""){$topic = $this->kafkaResource->newTopic("EASY_DATA");$topic->produce(RD_KAFKA_PARTITION_UA, 0, $message);$this->kafkaResource->poll(0);$this->kafkaResource->flush(10000);return true;}/*** 销毁*/public function __destruct(){// $this->channel->close();// $this->connection->close();}
}

kafka使用代码如上

<?php
namespace app\service;use app\util\Kafka;class KafkaService extends \think\Service
{/*** 注册服务*/public function register(){$this->app->bind('kafka', Kafka::class);}/*** 执行服务*/public function boot() {}
}

kafka容器服务

<?phpuse app\AppService;// 系统服务定义文件
// 服务在完成全局初始化之后执行
return [AppService::class,'\app\service\KafkaService',
];

kafka注册服务

public function test(Request $request){$res = app('kafka')->publishMessage('{"driver":2,"user_id":3,"ip":"127.0.0.1","type":7,"joinid":1}');var_dump($res);}

kafka的应用

tp6中kafka使用相关推荐

TP6中db操作数据库的方式（方法）和ORM模型操作数据库的方式（方法）
db库认知基础注:orm独立出来了,与tp5不同配置数据库: 通过env文件来具体配置,目的是不同的环境下,如线上服务器的配置只需要使用本环境的env文件就可以直接更改配置了使用db: ① tp ...
php think app_快来了解下TP6中的超级函数app()！
下面由thinkphp框架教程栏目给大家介绍TP6中的超级函数app(),希望对需要的朋友有所帮助! tp6中的助手函数app(),是一个包含极广,涵盖极深,作用巨大的助手函数,他可以调用很多方法,也 ...
linux中kafka主题修改分区,kafka_2.11-2.0.0的部署与配置修改
1 [yun@mini01 config]$ pwd 2 /app/kafka/config3 [yun@mini01 config]$ vim server.properties4 ######## ...
057 Java中kafka的Producer程序实现
1.需要启动的服务这里启动的端口是9092. bin/kafka-console-consumer.sh --topic beifeng --zookeeper linux-hadoop01.ibe ...
linux 中kafka发送数据,C++ 向kafka中发送数据
kafka是一个分布式流处理的平台,通过kafka我们可以发布和订阅流式记录.有关kafka的介绍可以参考官网或者这篇文章https://juejin.im/post/6844903495670169 ...
linux查看远程kafka安装目录,Linux系统中KafKa安装和使用方法
本文以0.10.0.1版本的kafka为例 1 下载并安装kafka# wget http://apache.fayea.com/kafka/0.10.0.1/kafka-0.10.0.1-src.t ...
五分钟搞定:Centos中Kafka和Zookeeper的快速安装教程
[提前声明] 文章由作者:张耀峰结合自己生产中的使用经验整理,最终形成简单易懂的文章写作不易,转载请注明,谢谢! 代码案例地址: ?https://github.com/Mydreamandrea ...
linux中Kafka集群的安装
kafka安装的准备工作: 1.三台虚拟机 HadoopMaster:192.168.43.19(主节点) HadoopSlave01:192.168.43.25(子节点) HadoopSlave02 ...
spring boot中kafka教程
参考了很多教程,最后精选了几篇,通俗易懂的 kafkaTemplate包装生产者工厂,生产者工厂包含具体的send发送senderProps参数,往topic里发, ConcurrentKafkaLi ...
tp6中使用微信支付sdk
一.下载微信支付sdk 二.将lib文件夹下的文件复制到目录:extend->WxPay 将example文件夹下的WxPay.Config.php文件也复制到:extend->WxPay ...

tp6中kafka使用

tp6中kafka使用相关推荐

最新文章

热门文章