timebug/hyperf-rocketmq

a rocketmq for hyperf

Installs: 132

Dependents: 0

Suggesters: 0

Security: 0

Stars: 0

Watchers: 1

Forks: 0

pkg:composer/timebug/hyperf-rocketmq

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

This package is auto-updated.

Last update: 2025-09-27 15:55:30 UTC


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());
    }
}