webit / message-bus
1.0.0
2018-01-05 06:14 UTC
Requires
- php: >=7.0
Requires (Dev)
- phpunit/phpunit: ^6.0
- psr/log: ^1.0
Suggests
- psr/log: To use logging publisher, consumer and exception handlers.
This package is auto-updated.
Last update: 2024-09-20 22:43:19 UTC
README
该库提供了一个抽象层,用于向/从消息总线发布/消费消息。
安装
composer require webit/message-bus ^1.0.0
概念介绍
消息
消息是用于由发布者发布并由消费者消费的简单容器。
$message = new Message('message-type', json_encode(['some' => 'data to be sent']));
消息 类型是必需的,用于识别发送的消息类型,并有助于了解如何处理。消息 内容是消息本身。它可以是任何字符串(不一定是json)。
发布者和消费者
发布者通过底层基础设施发布消息,但消费者等待消息进行处理。
基础设施将由一个单独的包提供。它应该提供 "webit/message-bus-infrastructure:^1.0.0" Composer 虚拟包。
测试
./vendor/bin/phpunit