0

我一直在尝试将 Active MQ 与 PHP 一起使用，而我已经能够通过命令行 PHP 脚本运行生产者和消费者。我想在浏览器中运行它。我正在使用以下代码： 

$queue  = '/test/queue';
        $msg    = $data;            
        try {
            $stomp = new Stomp('tcp://localhost:61613');

            $stomp->send($queue, $msg." ". date("Y-m-d H:i:s"));
            sleep(1);

        } catch(StompException $e) {
            echo 'Message: ' .$e->getMessage();

        }

        //subscribe to queue
        $stomp->subscribe($queue);

        /* read a frame */
        $frame = $stomp->readFrame();

        if ($frame->body === $msg) {
            echo $frame;

            /* acknowledge that the frame was received */
            $stomp->ack($frame);
        }

        /* close connection */
        unset($stomp);

在 Active MQ Web 界面上，我可以看到收到队列中的消息，但它没有出队，浏览器屏幕上也没有显示任何内容。我做错什么了吗？

提供背景信息 - 我正在尝试构建一个排队系统，其中可以将来自客户的请求放入队列中，并在队列处理请求后传递输出。

4

0 回答 0