修改环境变量

.env

@@ -13,3 +13,8 @@ DB_NAME=cdzpay
 DB_PASSWORD=senthink123
 DB_PORT=3306
 DB_HOST=127.0.0.1
+RABBIT_HOST=rabbitmq.default.svc.cluster.local
+RABBIT_PORT=5672
+RABBIT_LOGIN=rabbitmq
+RABBIT_PASSWORD=senthink123!
+RABBIT_VHOST=cdz_gateway
\ No newline at end of file

Lib/rabbitmq/MyRabbitMq.php

@@ -8,25 +8,13 @@
 
 namespace Lib\rabbitmq;
 
+use Lib\Env;
 use Log;
 
 
 class MyRabbitMq
 {
 
-    const CONNECTION = [
-
-        'host' => 'rabbitmq.default.svc.cluster.local',
-
-        'port' => '5672',
-
-        'login' => 'rabbitmq',
-
-        'password' => 'senthink123!',
-
-        'vhost' => 'cdz_gateway',
-
-    ];
 
     /**
      * @var \AMQPConnection
@@ -60,7 +48,18 @@ class MyRabbitMq
      */
     public function __construct()
     {
-        $this->connection = new \AMQPConnection(self::CONNECTION);
+        $this->connection = new \AMQPConnection([
+
+            'host' => Env::get('RABBIT_HOST'),
+
+            'port' => Env::get('RABBIT_PORT'),
+
+            'login' => Env::get('RABBIT_LOGIN'),
+
+            'password' => Env::get('RABBIT_PASSWORD'),
+
+            'vhost' => Env::get('RABBIT_VHOST'),
+        ]);
 
         if (!$this->connection->connect()) {
 
@@ -83,7 +82,7 @@ class MyRabbitMq
      * @return \AMQPChannel
      * @throws \AMQPConnectionException
      */
-    public function getChannel():\AMQPChannel
+    public function getChannel(): \AMQPChannel
     {
 
         return $this->channel = new \AMQPChannel($this->connection);