如何实现PHP ActiveMQ消息发送与接收处理的长尾？

本文共计410个文字，预计阅读时间需要2分钟。

使用PHP和ActiveMQ处理消息，用户名为test，密码为123456。发送一个注册消息到队列，并订阅该队列。代码如下：

php$stomp=new Stomp('tcp://localhost:61613');$stomp->connect('test', '123456');

// 发送注册消息到队列$stomp->send('/queue/userReg', ['content-type'=> 'application/json'], json_encode($obj));

// 订阅队列$stomp->subscribe('/queue/userReg', function ($frame) { // 处理接收到的消息 echo Received message: . $frame->body . \n;});

// 循环等待消息while (true) { // ...}

php ActiveMQ的处理消息

username = 'test'; $obj->password = '123456'; //发送一个注册消息到队列，我们这里模拟用户注册 $stomp->send('/queue/userReg', json_encode($obj)); subscribe('/queue/userReg'); while(true) { //判断是否有读取的信息 if($stomp->hasFrame()) { $frame = $stomp->readFrame(); $data = json_decode($frame->body, true); var_dump($data); //我们通过获取的数据 //处理相应的逻辑，比如存入数据库，发送验证码等一系列操作。 //$db->query("insert into user values('{$username}','{$password}')"); //sendVerify(); //表示消息被处理掉了，ack()函数很重要 $stomp->ack($frame); } sleep(1); } php ActiveMQ的发送消息

username = 'test'; $obj->password = '123456'; //发送一个注册消息到队列，我们这里模拟用户注册 $stomp->send('/queue/userReg', json_encode($obj));