PHP使用ActiveMQ实现消息队列的方法详解_php技巧_

 composer require fusesource/stomp-php:2.0.*

connect(); $userId = 1001; $result = $connect->send('email',$userId); //比如发邮件 var_dump($result);

 $data = array('id'=>1001,'email'=>'110@qq.com','content'=>'test'); $result = $connect->send('email',json_encode($data)); 

 //消息持久化 persistent为true，字符串的'true' $result = $connect->send('email',json_encode($data),array('persistent'=>'true'));

connect(); //订阅队列消息 $connect->subscribe('email'); if ($connect->hasFrameToRead()){ $frame = $connect->readFrame(); print_r($frame); }

 FuseSource\Stomp\Frame Object ( [command] => MESSAGE [headers] => Array ( [expires] => 0 [destination] => /queue/email [priority] => 4 [message-id] => ID:localhost.localdomain-38488-1488196907415-3:2:-1:1:1 [timestamp] => 1489477647931 ) [body] => {"id":1001,"email":"110@qq.com","content":"test"} )

 do{ if ($connect->hasFrameToRead()){ $frame = $connect->readFrame(); print_r($frame->body); } } while (true);

 if ($connect->hasFrameToRead()){ $frame = $connect->readFrame(); //print_r($frame->body); //做业务逻辑 //具体发送邮件的业务 //send email //最后通知mq，我们已经处理了该条消息 $connect->ack($frame); }

 do{ //会等待，直到有可用消息，才执行后面代码 if ($connect->hasFrameToRead()){ $frame = $connect->readFrame(); //print_r($frame->body); //做业务逻辑 //具体发送邮件的业务 //send email sleep(2); //模拟延时 //最后通知mq，我们已经处理了该条消息 $connect->ack($frame); } //控制循环 $next = true; if (file_exists(__DIR__.'/stop')){ //如果有名为stop的一个文件 //就不循环了 $next = false; } } while ($next);