PHPackages                             mustafa3264/messagebus - PHPackages - PHPackages  [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register)

1. [Directory](/)
2. /
3. [Queues & Workers](/categories/queues)
4. /
5. mustafa3264/messagebus

ActiveLibrary[Queues & Workers](/categories/queues)

mustafa3264/messagebus
======================

messagebus include kafka and redis stream for hyperf

v1.0.3(3y ago)522MITPHPPHP >=8.0

Since Nov 19Pushed 3y ago1 watchersCompare

[ Source](https://github.com/jiangliuer326442/hyperf-messagebus)[ Packagist](https://packagist.org/packages/mustafa3264/messagebus)[ RSS](/packages/mustafa3264-messagebus/feed)WikiDiscussions main Synced 3w ago

READMEChangelogDependencies (4)Versions (4)Used By (0)

swoole hyperf框架 消息总线
====================

[](#swoole-hyperf框架-消息总线)

支持`kafka`和`redis stream`队列，生产者往消息总线中放入事件和相关数据

按照功能模块创建消费者进程，每个模块可以有多个消费者订阅多个事件，返回具体的消费者，订阅获得的事件以及与该事件相关的参数，供业务方逻辑处理

为生产者和消费者建立了连接池，支持消息的批量发送和批量接收

基于 `hyperf/metric` 实现对消息总线的监控，主要监控消息的延迟程度以及消息被用来处理业务逻辑耗费的时间，指标为 `messagebus_job_cost` 和 `messagebus_job_delay`,可上报到prometheus等用于监控和告警

for example：

直播业务包含主播获得收入事件和直播开播时长事件，他们被放入消息总线中 任务考核模块有每天直播大于60分钟且累计收入大于100元 —— 这个任务本身可以看作一个消费者，消费上述两个事件进行业务逻辑的处理 该sdk会返回任务标识，直播时长事件或者收入事件的相关数据供业务方处理

使用向导
----

[](#使用向导)

### 安装

[](#安装)

`composer require mustafa3264/messagebus`

`php bin/hyperf.php vendor:publish mustafa3264/messagebus`

### 配置

[](#配置)

```