AMQP组件

    3. return [
    4.     'default' => [
    5.         'host' => 'localhost',
    6.         'port' => 5672,
    7.         'user' => 'guest',
    8.         'password' => 'guest',
    9.         'vhost' => '/',
    10.         'pool' => [
    11.             'min_connections' => 1,
    12.             'max_connections' => 10,
    13.             'connect_timeout' => 10.0,
    14.             'wait_timeout' => 3.0,
    15.             'heartbeat' => -1,
    16.         'params' => [
    17.             'insist' => false,
    18.             'login_method' => 'AMQPLAIN',
    19.             'login_response' => null,
    20.             'locale' => 'en_US',
    21.             'connection_timeout' => 3.0,
    23.             'context' => null,
    24.             'keepalive' => false,
    25.             'heartbeat' => 0,
    26.         ],
    27.     ],
    28. ];

    使用 generator 工具新建一个 producer

    1. <?php
    3. declare(strict_types=1);
    5. namespace App\Amqp\Producers;
    7. use Hyperf\Amqp\Message\ProducerMessage;
    10. /**
    11.  * DemoProducer
    12.  * @Producer(exchange="hyperf", routingKey="hyperf")
    13.  */
    14. class DemoProducer extends ProducerMessage
    15. {
    16.     public function __construct($id)
    17.     {
    18.         $user = User::where('id', $id)->first();
    19.         $this->payload = [
    20.             'id' => $id,
    21.             'data' => $user->toArray()
    22.         ];
    23.     }
    24. }

    通过container获取Producer实例，即可投递消息。以下实例直接使用ApplicationContext获取Producer其实并不合理，container具体使用请到di模块中查看。

    1. php bin/hyperf.php gen:amqp-consumer DemoConsumer

    在DemoConsumer文件中，我们可以修改Consumer注解对应的字段来替换对应的 exchange、routingKey 和 。其中 $data 就是解析后的元数据。示例如下。