新增优惠券返券消息队列

app/Amqp/Consumer/couponRebateConsumer.php

@@ -0,0 +1,28 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Amqp\Consumer;
+
+use Hyperf\Amqp\Result;
+use Hyperf\Amqp\Annotation\Consumer;
+use Hyperf\Amqp\Message\ConsumerMessage;
+use PhpAmqpLib\Message\AMQPMessage;
+
+/**
+ * @Consumer(exchange="couponRebate", routingKey="couponRebate", queue="couponRebate", name ="couponRebateConsumer", nums=1)
+ */
+class couponRebateConsumer extends ConsumerMessage
+{
+    public function consumeMessage($data, AMQPMessage $message): string
+    {
+        var_dump($data);
+        var_dump($message->getBody());
+        return Result::ACK;
+    }
+
+    public function isEnable(): bool
+    {
+        return parent::isEnable();
+    }
+}

config/autoload/amqp.php

@@ -0,0 +1,33 @@
+<?php
+
+return [
+    'default' => [
+        'host' => env('RQM_HOST', 'localhost'),
+        'port' => 5672,
+        'user' => env('RQM_USER','guest'),
+        'password' => env('RQM_PASSWORD','guest'),
+        'vhost' => '/',
+        'concurrent' => [
+            'limit' => 1,
+        ],
+        'pool' => [
+            'min_connections' => 1,
+            'max_connections' => 10,
+            'connect_timeout' => 10.0,
+            'wait_timeout' => 3.0,
+            'heartbeat' => -1,
+        ],
+        'params' => [
+            'insist' => false,
+            'login_method' => 'AMQPLAIN',
+            'login_response' => null,
+            'locale' => 'en_US',
+            'connection_timeout' => 3.0,
+            'read_write_timeout' => 6.0,
+            'context' => null,
+            'keepalive' => false,
+            'heartbeat' => 3,
+            'close_on_destruct' => false,
+        ],
+    ]
+];