开发场景

simple模式的生产者、消费者为一对一；worker模式的生产者、消费者为一对多，多个消费者依次读取、消费消息队列中的消息。

生产者

<?php
//引入服务器配置文件【WEB服务器运行无需实现  server服务的CLI模式运行必须实现】
include('server.ini');

//创建生产者【必须实现】
$simple_producter = new Simple_producter($v_host,$queue);
//$v_host为Virtual host用户名
//$queue为消息队列名称

//推送消息到队列中【必须实现】
$simple_producter->push(function(){
    //匿名回调函数中写你的业务
    //推送消息到队列中请return $var
});

消费者

<?php
//引入服务器配置文件【WEB服务器运行无需实现  server服务的CLI模式运行必须实现】
include('server.ini');

//创建消费者【必须实现】
$simple_consumer = new Simple_consumer($v_host,$queue);
//$v_host为Virtual host用户名
//$queue为消息队列名称

//从消息队列中取消息【必须实现】
$simple_consumer->pop(function($response_data){
    //匿名回调函数中写你的业务
    //$response_data为读取消息队列中的数据
    //读取消息后需确认成功消费消息请return true，否则读取消息后，该条消息仍然保持在消息队列中；
});