consumer->onMessage = function(AsyncTcpConnection $con, $data)use($service,$access_key) {
//服务文件处理(['messageId' => $message_id]));
};
$consumer->connect();
// 设置连接的onClose回调), WebSocketMessageType.Text, true, CancellationToken.None);
}
```
#### 为此你搜索到了哪些方案及不适用的原因