timebug / hyperf-rocketmq

a rocketmq for hyperf

Maintainers

Details

github.com/ChuckJack/hyperf_rocketmq

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)

Suggests

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

Provides

None

Conflicts

None

Replaces

None

MIT 70d2fa8c8ca0e16dafcb8ba19cf073ee4244c1fa

php rocketMq hyperf

dev-master
v1.0.5
v1.0.4

This package is auto-updated.

Last update: 2025-03-27 15:01:57 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());
    }
}