uncleqiu/hyperf-rocketmq-sdk

Aliyun RocketMQ http sdk for php framework hyperf

v1.0.0 2023-11-18 06:19 UTC

Requires

• php: >=8.0
• ext-dom: *
• ext-xmlreader: *
• hyperf/config: ^3.0
• hyperf/di: 3.0.*
• hyperf/framework: 3.0.*
• hyperf/guzzle: ^3.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

• swow/swow: Required to create swow components.

MIT

• uncle qiu

• php
• rocketMq
• hyperf

README

English | 中文

Introduction

Based on Alibaba Cloud aliyunmq/mq-http-sdk, the rocketmq sdk that supports the hyperf framework.

Installation

Use composer to install hyperf-rocketmq-sdk into your project:

composer require uncleqiu/hyperf-rocketmq-sdk

use composer.json

{
    "require": {
      "uncleqiu/hyperf-rocketmq-sdk": "dev-master"
    }
}

and run

composer install

Configuration

php bin/hyperf.php vendor:publish uncleqiu/hyperf-rocketmq-sdk

Example

Send a message

<?php
    $messageData = [
        'name' => 'uncleqiu',
    ];
    (new \Uncleqiu\RocketMQ\Client())->push('topic_key1', $messageData);

Consume message

You can run this command to generate a custom command line

php bin/hyperf.php gen:command TestConsumeCommand

And then write your consume logic code

<?php

declare(strict_types=1);

namespace App\Command;

use Hyperf\Command\Command as HyperfCommand;
use Hyperf\Command\Annotation\Command;
use Psr\Container\ContainerInterface;
use Uncleqiu\RocketMQ\Client;

#[Command]
class TestConsumeCommand extends HyperfCommand
{
    public function __construct(protected ContainerInterface $container)
    {
        parent::__construct('consume:topic_one');
    }

    public function configure()
    {
        parent::configure();
        $this->setDescription('Consume the rocketmq data');
    }

    public function handle()
    {
        $this->line('Begin Consume....', 'info');
        (new Client())->consume('topic_key1', $this);
    }

    // rocketmq data consume processing logic
    public function handlerMessage($message)
    {
        $mqData = json_decode($message->getMessageBody(), true);
        // write your consume logic......
        var_dump($mqData);
    }
}

Finally, run your custom command line

php bin/hyperf.php consume:topic_one