客户端监听服务端获取rabbitmq消息队列,rabbitmq有消息的时候客户端刷新页面才能获取到消息,监听没起到作用,请求各位大神指点迷津

浓夭不及淡久
header("Content-Type:text/html;charset=utf-8");
use Workerman\Worker;
require_once __DIR__ . '/Autoloader.php';

// 注意:这里与上个例子不同,使用的是websocket协议
$ws_worker = new Worker("websocket://192.168.1.218:5556");

// 启动4个进程对外提供服务
$ws_worker->count = 4;

// 当收到客户端发来的数据后返回hello $data给客户端
$ws_worker->onMessage = function($connection, $data)
{
    $data = json_decode($data, true);

    $conn_arg = array(
        'host' => '192.168.1.100',
        'port' => '5672',
        'login' => 'qifaoa',
        'password' => 'qifaoa@123',
        'vhost' => '/',
    );

    foreach ($data as $k => $v) {
        $exchange = $v;//交换机
        $routing_key = $v;//路由key
        $queue = $v;//队列

        if (empty($exchange) || empty($routing_key) || empty($queue)) {
            $connection->send('参数错误');
            die();
        }

        //创建连接和channel
        $conn = new AMQPConnection($conn_arg);
        if (!$conn->connect()) {
            $connection->send('rabbitmq连接失败');
            die();
        } else {
            // echo '连接成功'."\n";
        }
        $channel = new AMQPChannel($conn);

        //创建队列
        $q = new AMQPQueue($channel);
        $q->setName($queue);
        $q->setFlags(AMQP_DURABLE);//设置队列持久化
        $q->declareQueue();//声明创建队列
        $q->bind($exchange, $routing_key);//绑定交换机,指定路由键

        //消息获取
        $message = $q->get(AMQP_AUTOACK);//自动应答机制

        //判断消息是否存在
        if ($message) {
            $connection->send($message->getBody());
        } else {
            // echo json_encode('空');
        }
        $conn->disconnect();//关闭
    }
};

//连接关闭
$ws_worker->onclose = function($connection) {
    echo "connection close\n";
};

//连接错误
$worker->onError = function($connection, $code, $msg)
{
    echo "error $code $msg\n";
};

// 运行worker
Worker::runAll();
8580 2 0
2个回答

mdx2007

看你的业务逻辑就是浏览器ws发来消息,服务端收到消息连消息队列获取一次消息,获取到了就给当前客户端发消息。
那么也就是只要浏览器不发消息,就不会触发服务端连消息队列获取消息的业务逻辑。
所以浏览器需要定时给服务端发消息才行啊。

debugman

你的代码是客户端收到消息后才会触发到RabbitMQ 去Get的, 并没有主动监听RabbitMQ的消息

  • 暂无评论
年代过于久远,无法发表回答
×
🔝