Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 800
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 800
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 800
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 800
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 806
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 808
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 811
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 828
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 829
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 75
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 76
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 75
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 76
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 75
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 76
Warning: Undefined variable $img_type in /www/wwwroot/www.zhaohaoblog.com/wp-content/plugins/wpjam-basic/cdn/remote.php on line 86
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 75
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 76
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 75
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 76
Warning: Undefined variable $img_type in /www/wwwroot/www.zhaohaoblog.com/wp-content/plugins/wpjam-basic/cdn/remote.php on line 86
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 75
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 76
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 75
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 76
Warning: Undefined variable $img_type in /www/wwwroot/www.zhaohaoblog.com/wp-content/plugins/wpjam-basic/cdn/remote.php on line 86
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 75
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 76
Warning: Undefined variable $img_type in /www/wwwroot/www.zhaohaoblog.com/wp-content/plugins/wpjam-basic/cdn/remote.php on line 86
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 75
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 76
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 75
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 76
Warning: Undefined array key 0 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 75
Warning: Undefined array key 1 in /www/wwwroot/www.zhaohaoblog.com/wp-includes/media.php on line 76
文章目录
- 安装教程 kafka和php的rdkafka扩展教程网上有很多,大家可以自行查询,例如:Kafka-php－使用 PHP 编写的 Kafka 客户端
- 不清楚里面的api的可以在文档中查询 kafka中文文档
- 创建 composer.json填写内容 { "require": { "nmred/kafka-php": "v0.2.0.8" } }
- <?php require_once __DIR__ . '/Vendor/autoload.php';use KafkaProducerConfig; use KafkaProducer;//异步方式调用 config = ProducerConfig::getInstance(); //设置数据刷新时间(毫秒)config->setMetadataRefreshIntervalMs(10); //地址 config->setMetadataBrokerList('localhost:9092'); //设置代理版本config->setBrokerVersion('0.9.0.1'); //开启消息确认 config->setRequiredAck(1);config->setIsAsyn(false); //设置生产间隔 config->setProduceInterval(500); //生产者producer = new Producer(function () { return array([ 'topic' => 'test',//主题 'value' => 'test message', 'key' => 'testKey',//key ]); }); producer->success(function (result) { echo '投递成功' . json_encode(result, 256) . PHP_EOL; });producer->error(function (result) { echo '投递失败' . json_encode(result, 256) . PHP_EOL; }); $producer->send(true);
- <?php require_once __DIR__ . '/Vendor/autoload.php';use KafkaProducerConfig; use KafkaProducer;config = ProducerConfig::getInstance(); //这是元组数据刷新间隔毫秒config->setMetadataRefreshIntervalMs(10); //代理地址 config->setMetadataBrokerList('localhost:9092'); //设置代理版本config->setBrokerVersion('0.9.0.1'); //开启消息确认 config->setRequiredAck(1);config->setIsAsyn(false); //生产间隔 config->setProduceInterval(10);producer = new Producer(); for (i = 0;i < 100; i++) {result = producer->send(array( [ 'topic' => 'test',//主题 'value' => 'test message', 'key' => '',//key ] )); echo '投递成功' . json_encode(result, 256) . PHP_EOL; }
- <?php require_once __DIR__ . '/Vendor/autoload.php'; use KafkaConsumerConfig; use KafkaConsumer; config = ConsumerConfig::getInstance();config->setMetadataRefreshIntervalMs(10); config->setMetadataBrokerList('localhost:9092'); //设置分组分区config->setGroupId('test'); config->setBrokerVersion('0.9.0.1');config->setTopics(['test']); //设置偏移量 config->setOffsetReset('earliest');consumer = new Consumer(); consumer->start(function (topic, part,message) { var_dump($message); });
安装教程 kafka和php的rdkafka扩展教程网上有很多,大家可以自行查询,例如:Kafka-php－使用 PHP 编写的 Kafka 客户端
不清楚里面的api的可以在文档中查询 kafka中文文档
创建 composer.json填写内容
{
"require": {
"nmred/kafka-php": "v0.2.0.8"
}
}
<?php
require_once __DIR__ . '/Vendor/autoload.php';
use KafkaProducerConfig;
use KafkaProducer;
//异步方式调用
config = ProducerConfig::getInstance();
//设置数据刷新时间(毫秒)config->setMetadataRefreshIntervalMs(10);
//地址
config->setMetadataBrokerList('localhost:9092');
//设置代理版本config->setBrokerVersion('0.9.0.1');
//开启消息确认
config->setRequiredAck(1);config->setIsAsyn(false);
//设置生产间隔
config->setProduceInterval(500);
//生产者producer = new Producer(function () {
return array([
'topic' => 'test',//主题
'value' => 'test message',
'key' => 'testKey',//key
]);
});
producer->success(function (result) {
echo '投递成功' . json_encode(result, 256) . PHP_EOL;
});producer->error(function (result) {
echo '投递失败' . json_encode(result, 256) . PHP_EOL;
});
$producer->send(true);
<?php
require_once __DIR__ . '/Vendor/autoload.php';
use KafkaProducerConfig;
use KafkaProducer;
//异步方式调用
config = ProducerConfig::getInstance();
//设置数据刷新时间(毫秒)config->setMetadataRefreshIntervalMs(10);
//地址
config->setMetadataBrokerList('localhost:9092');
//设置代理版本config->setBrokerVersion('0.9.0.1');
//开启消息确认
config->setRequiredAck(1);config->setIsAsyn(false);
//设置生产间隔
config->setProduceInterval(500);
//生产者producer = new Producer(function () {
return array([
'topic' => 'test',//主题
'value' => 'test message',
'key' => 'testKey',//key
]);
});
producer->success(function (result) {
echo '投递成功' . json_encode(result, 256) . PHP_EOL;
});producer->error(function (result) {
echo '投递失败' . json_encode(result, 256) . PHP_EOL;
});
$producer->send(true);
<?php
require_once __DIR__ . '/Vendor/autoload.php';
use KafkaProducerConfig;
use KafkaProducer;
config = ProducerConfig::getInstance();
//这是元组数据刷新间隔毫秒config->setMetadataRefreshIntervalMs(10);
//代理地址
config->setMetadataBrokerList('localhost:9092');
//设置代理版本config->setBrokerVersion('0.9.0.1');
//开启消息确认
config->setRequiredAck(1);config->setIsAsyn(false);
//生产间隔
config->setProduceInterval(10);producer = new Producer();
for (i = 0;i < 100; i++) {result = producer->send(array(
[
'topic' => 'test',//主题
'value' => 'test message',
'key' => '',//key
]
));
echo '投递成功' . json_encode(result, 256) . PHP_EOL;
}
<?php
require_once __DIR__ . '/Vendor/autoload.php';
use KafkaProducerConfig;
use KafkaProducer;
config = ProducerConfig::getInstance();
//这是元组数据刷新间隔毫秒config->setMetadataRefreshIntervalMs(10);
//代理地址
config->setMetadataBrokerList('localhost:9092');
//设置代理版本config->setBrokerVersion('0.9.0.1');
//开启消息确认
config->setRequiredAck(1);config->setIsAsyn(false);
//生产间隔
config->setProduceInterval(10);producer = new Producer();
for (i = 0;i < 100; i++) {result = producer->send(array(
[
'topic' => 'test',//主题
'value' => 'test message',
'key' => '',//key
]
));
echo '投递成功' . json_encode(result, 256) . PHP_EOL;
}
<?php
require_once __DIR__ . '/Vendor/autoload.php';
use KafkaConsumerConfig;
use KafkaConsumer;
config = ConsumerConfig::getInstance();config->setMetadataRefreshIntervalMs(10);
config->setMetadataBrokerList('localhost:9092');
//设置分组分区config->setGroupId('test');
config->setBrokerVersion('0.9.0.1');config->setTopics(['test']);
//设置偏移量
config->setOffsetReset('earliest');consumer = new Consumer();
consumer->start(function (topic, part,message) {
var_dump($message);
});
<?php
require_once __DIR__ . '/Vendor/autoload.php';
use KafkaConsumerConfig;
use KafkaConsumer;
config = ConsumerConfig::getInstance();config->setMetadataRefreshIntervalMs(10);
config->setMetadataBrokerList('localhost:9092');
//设置分组分区config->setGroupId('test');
config->setBrokerVersion('0.9.0.1');config->setTopics(['test']);
//设置偏移量
config->setOffsetReset('earliest');consumer = new Consumer();
consumer->start(function (topic, part,message) {
var_dump($message);
});
相关文章
docker build centos8系统php8.1+swoole等各种扩展镜像dockerfile
目前这个build的dockerfile只用在测试开发环境哈，需要优化opcache啥的自己开启一下哈 FROM centos:8 MAINTAINER zhaohao731869706@163.com ENV PHP_VERSION=8.1 ENV LANG=C.UTF-8 RUN ln -sf /usr/share/z …
hyperf配合hyperf-swagger一条命令根据响应体生成生成swagger文档
先上实现代码 <?php declare(strict_types=1); /** * This file is part of hyperf-tt. * * @link https://github.com/zhaohao19941221/hyperf-tt * @document https://github.com/zhaohao19941221/hype …
带你学习hyperf-7.1 特性
特性 Channel 通道 类似于 go 语言的 chan，Channel 可为多生产者协程和多消费者协程模式提供支持。底层自动实现了协程的切换和调度。 Channel 与 PHP 的数组类似，仅占用内存，没有其他额外的资源申请，所 …
带你学习hyperf-6.1 问题汇总
6.1 问题汇总 1. Guzzle Http客户端 请求时未记录日志文件,并将日志打印至终端 解决方案: 升级swoole至最新 2. hyperf与laravel 队列事务失败处理 场景: 当前有数据1,2,3投入队列,假设1，2，3都有创建的需 …
带你学习hyperf-5.2 Guzzle Http客户端
5.2 Guzzle Http客户端 安装composer包 composer require hyperf/guzzle 配置 在实例化客户端的时候以参数的方式做配置 参数均来自于 Guzzle Http文档里的配置信息 使用 <?php namespace AppController; …
带你学习hyperf-5.1 Redis协程客户端
5.1 Redis协程客户端 安装composer包 composer require hyperf/redis 配置 在config/autoload/redis.php下 <?php return [ 'default' => [ 'host' => env('REDIS_HOST', 'localhost'), 'auth' =&g …
带你学习hyperf-4.1 数据库配置文件
4.2 配置文件 配置文件所在路径 config/autoload/databases.php 配置文件中的参数 读写分离 <?php return [ 'default' => [ 'driver' => env('DB_DRIVER', 'mysql'), // 读库 'read' => [ 'hos …
带你学习hyperf-4.1 数据库
4.1 须知 与laravel的 Eloquent ORM 操作基本相同 借鉴5.4版本改造,有一些细节上的区别,比如事务等级处理等具体会在下文问题汇总中详细说明 hyperf/db-connection 是在orm的基础之上实现连接池,它基于 hype …
带你学习hyperf-3.9 AOP 面向切面编程
3.9 AOP 面向切面编程 概念 AOP 为 Aspect Oriented Programming 的缩写，意为：面向切面编程，通过动态代理等技术实现程序功能的统一维护的一种技术。AOP 是 OOP 的延续，也是 Hyperf 中的一个重要内容， …
带你学习hyperf-3.8事件
3.8事件 事件机制 事件模式必须基于 PSR-14 去实现。 Hyperf 的事件管理器默认由 hyperf/event 实现，该组件亦可用于其它框架或应用，只需通过 Composer 将该组件引入即可。 composer require hyperf/event …
