rabbitmq->getProducer('notifyProducer'); $msg = serialize(['type' => 'ghs_new_order_notify', 'orderId' => $orderId]); $producer->publish($msg, 'notifyExchange', 'notifyRoute'); } catch (\Exception $e) { $msg = $e->getMessage(); $remind = "供货商新订单通知,生产消息报错 {$orderId} {$msg}"; noticeUtil::push($remind, '15280215347'); } } }