更新

app-ghs/controllers/TestController.php

@@ -48,7 +48,7 @@ class TestController extends BaseController
         $producer->publish($msg, 'ex1', 'route1');
 
         $producer = Yii::$app->rabbitmq->getProducer('notifyProducer');
-        $msg = json_encode(['type' => 'order_new', 'msg' => 'new order']);
+        $msg = serialize(['type' => 'order_new', 'msg' => 'new order']);
         $producer->publish($msg, 'notifyExchange', 'notifyRoute');
     }
 

common/components/rabbitmq/consumer/notifyConsumer.php

@@ -27,7 +27,7 @@ class notifyConsumer implements ConsumerInterface
     {
         try {
             // 反序列化消息体
-            $data = json_decode($msg->body, true);
+            $data = unserialize($msg->body);
 
             if (!is_array($data)) {
                 Yii::error("Invalid notify message format: {$msg->body}", 'rabbitmq.notify');