timebug/hyperf-rocketmq

a rocketmq for hyperf

v1.0.5 2022-07-27 09:28 UTC

Requires

• php: 8.0.*
• ext-xmlreader: *
• ext-xmlwriter: *
• alibabacloud/ons-20190214: ^1.0
• doctrine/instantiator: ^1.2.0
• guzzlehttp/guzzle: >=7.4.5
• hyperf/contract: ~2.2.0
• hyperf/di: ~2.2.0
• hyperf/event: ^2.2
• hyperf/pool: ~2.2.0
• hyperf/process: ~2.2.0
• hyperf/utils: ~2.2.0
• psr/container: ^1.0|^2.0
• psr/event-dispatcher: ^1.0
• psr/log: ^1.0|^2.0

Requires (Dev)

• friendsofphp/php-cs-fixer: ^3.0
• mockery/mockery: ^1.0
• phpstan/phpstan: ^1.0
• phpunit/phpunit: >=7.0
• swoole/ide-helper: ^4.5

Suggests

• hyperf/event: Declare queue and start consumers automatically.
• swow/swow: Required to create swow components.

MIT

• php
• rocketMq
• hyperf

README

引入Composer包

composer require timebug/hyperf-rocketmq

新建生产者

#[Producer(poolName: "default", topic: "test_topic", groupId: "test_group", messageTag: "tMsgKey", properties: ["a" => 1])]
class DemoProducer extends ProducerMessage
{
    public function __construct(array $data)
    {
        // 设置消息内容
        $this->setPayload($data);
        $this->setMessageKey('tMsgKey01');
    }

}

新建消费者

#[Consumer(name: "Consumer", poolName: "default", topic: "test_topic", groupId: "test_group", messageTag: "tMsgKey")]
class DemoConsumer extends ConsumerMessage
{
    public function consumeMessage(RocketMQMessage $message): void
    {
        var_dump($message->getMessageId());
        var_dump($this->unserialize($message->getMessageBody()));
        var_dump($message->getPublishTime());
    }
}