作者:mobiledu2502923573 | 来源:互联网 | 2023-08-29 06:06
php框架|LaravelLaravelphp框架-Laravel下面由Laravel教学栏目给大家推荐ApacheKafka扩展包,希望对需要的朋友有所帮助!windows任务管
php框架|Laravel
Laravel
php框架-Laravel
下面由Laravel教学栏目给大家推荐Apache Kafka扩展包,希望对需要的朋友有所帮助!
windows任务管理器源码,vscode 编辑器创建新分支,ubuntu源码包,集成的tomcat无法自启动,sqlite c 时间,重庆网页设计图片,阿里云免费云服务器有什么用,discuz免费收费插件,前端html框架源码,爬虫怕烟么,php stdout,专业做seo的公司,软件出售网站源码,情人节html网页下载,phpcms 单页面模板,广告页面模板网站,cms信息管理系统,自动识别验证码程序lzw
商城微网站源码下载,ubuntu删除所有安装,tomcat登陆不进去,爬虫python的利弊,计算机编程中的php,在线seo代理lzw
Laravel Kafka 扩展包(https://github.com/mateusjunges/laravel-kafka)让你在 Laravel 应用中使用 Apache Kafka 生产者和消费者变得简单。使用
publishOn
方法,可以让你流畅的配置和发布消息:
b2bb2c商城源码,mac版本vscode汉化,Ubuntu安装udeb,本地tomcat ip,sqlite求列平均数,你希望爬虫帮你解决什么问题,物流管理系统php,浙江seo推广咨询热线,驾校管理网站模板,织梦dedecms商城模板(购物商城)lzw
use Junges\Kafka\Facades\Kafka;Kafka::publishOn('broker', 'topic') ->withConfigOption('property-name', 'property-value') ->withConfigOptions([ 'property-name' => 'property-value' ]);
下面展示如何通过这个包在 Laravel 应用中向 Kafka 发送消息:
use Junges\Kafka\Facades\Kafka;/** @var \Junges\Kafka\Producers\ProducerBuilder $producer */$producer = Kafka::publishOn('broker', 'topic') ->withConfigOptions(['key' => 'value']) ->withKafkaKey('your-kafka-key') ->withKafkaKey('kafka-key') ->withHeaders(['header-key' => 'header-value']);$producer->send();
这里是消费者订阅消息的示例:
use Junges\Kafka\Facades\Kafka;$cOnsumer= Kafka::createConsumer('broker')->subscribe('topic');// 通过回调函数处理:$consumer->withHandler(function(\RdKafka\Message $message) { // 消息处理});// Invokable handler:class Handler{ public function __invoke(\RdKafka\Message $message){ //消息处理 }}$consumer->withHandler(Handler::class)
这个包的其他功能请见 readme:(https://github.com/mateusjunges/laravel-kafka/blob/master/README.md)
最大消息消费数量配置死信队列 – 维基百科 配置中间件配置在测试中使用 Kafka::fake()
方法模拟 Kafka 生产者开发模式下开启调试消息体可配置
这个包需要 rdkafka 扩展提供 Kafka 生成级别高效的 PHP 客户端。 Github 上有包详细的安装说明,和 源码 。
译文地址:https://learnku.com/laravel/t/61072