发表新帖

Hyperf 中使用AMQP 异常

### 问题描述
Hyperf 框架中，websocket 接收到消息后推送至 AMQP 队列异常报错。

### Swoole版本，PHP版本，以及操作系统版本信息
PHP 7.2.33
swoole 4.5.3
系统 mac

### 相关代码
```php
<?php
declare(strict_types=1);

namespace App\Controller;

use Hyperf\Di\Annotation\Inject;
use Hyperf\Contract\OnCloseInterface;
use Hyperf\Contract\OnMessageInterface;
use Hyperf\Contract\OnOpenInterface;
use Hyperf\Utils\Codec\Json;
use Swoole\Http\Request;
use Swoole\Websocket\Frame;
use Hyperf\Amqp\Producer;
use App\Amqp\Producer\ChatMessageProducer;
use Swoole\Http\Response;
use Swoole\WebSocket\Server;

/**
 * Class WebSocketController
 * @package App\Controller
 */
class WebSocketController implements OnMessageInterface, OnOpenInterface, OnCloseInterface
{

/**
     * @Inject
     * @var Producer
     */
    private $producer;

/**
     * 连接创建成功回调事件
     *
     * @param Response|Server $server
     * @param Request $request
     */
    public function onOpen($server, Request $request): void
    {
		...
    }

/**
     * 消息接收回调事件
     *
     * @param Response|Server $server
     * @param Frame $frame
     */
    public function onMessage($server, Frame $frame): void
    {
        // 判断是否为心跳检测
        if ($frame->data == 'PING') return;
		
        $this->producer->produce(new ChatMessageProducer("我是来自 xxxx 服务器的消息]，{$frame->data}"));
    }

/**
     * 连接创建成功回调事件
     *
     * @param Response|\Swoole\Server $server
     * @param int $fd
     * @param int $reactorId
     */
    public function onClose($server, int $fd, int $reactorId): void
    {
       ...
    }
}

```

### 你期待的结果是什么？实际看到的错误信息又是什么？

![](/storage/article-column/nO0ebkZUoqfbp3KjbOz6MaGoUDBFdGaDgmhtoAck.png)

发布于5年前 · 24 次浏览 · 来自提问

YDong