PHP使用ActiveMQ实例

(编辑：jimmy 日期: 2025/11/7 浏览：2)

使用点对点(Point To Point)模型

点对点模型特点：

只有一个消费者可以接收到消息
不能重复消费

生产者producer.php代码：

<"/queue/userReg";
    // 4.发送一个注册消息到队列
    $stomp->send($queneName, json_encode($obj));
  }
} catch (StompException $e) {
  die('Connection failed: ' . $e->getMessage());
}

消费者1consumer1.php代码：

<"htmlcode">

<"//img.jbzj.com/file_images/article/201802/201802051422001.jpg" alt="" />
使用发布/订阅(Publish Subscribe)模型
发布/订阅模型特点：
多个消费者都可以收到消息

能重复消费

生产者producer.php代码：


<"/topic/userReg";
    // 4.发送一个注册消息到队列
    $stomp->send($queneName, json_encode($obj));
  }
} catch (StompException $e) {
  die('Connection failed: ' . $e->getMessage());
}


消费者1consumer1.php代码：


<"htmlcode">

"//img.jbzj.com/file_images/article/201802/201802051422002.jpg" alt="" />

        
            上一篇：实例讲解PHP页面静态化
            下一篇：详解PHP中mb_strpos的使用