RabbitMQ的安装与基本使用

//设置连接属性  
$connArgs = array(  
                    ‘host‘           => ‘localhost‘,  
                    ‘port‘           => ‘5672‘,  
                    ‘login‘           => ‘guest‘,  
                    ‘password‘ => ‘guest‘,  
                    ‘vhost‘          => ‘/‘  
);  
  
//创建RabbitMQ连接  
$conn = new AMQPConnection($connArgs);  
if (!$conn->connect()) {  
     echo ‘cannot connect to the broker‘;  
}  
  
//创建channel  
$channel = new AMQPChannel($conn);  
  
//设置队列名称  
$exchangeName = ‘exchange‘;  
$routingKey = ‘key_test‘;      
$queueName = ‘queue_test_1‘;  
$queue = new AMQPQueue($channel);  
$queue->setName($queueName);//设置名称  
$queue->setFlags(AMQP_DURABLE);//持久化队列，当代理重启动后依然存在,并包括它们中的完整数据  
$queue->declare();//声明此队列  
$queue->bind(‘exchange‘,$routingKey);//使用某交换机，并绑定某路由关键字  
  
//消费数据方式一：非阻塞方式  
// while(true)  
// {  
//      sleep(1);  
//      $envelope = $queue->get(AMQP_AUTOACK) ;//第一个参数表示自动ACK应答  
//      if ($envelope){  
//           $messages = $envelope->getBody();  
//           echo $messages;  
//      }  
// }  
  
  
//消费数据方式二：以阻塞模式消费数据（推荐）  
while(true)  
{  
          $queue->consume(‘processMessage‘);//第一个参数表示要回调的方法名，第二个参数设置为AMQP_AUTOACK，表示自动ACK应答  
}  
/** 
* 定义回调方法 
*/  
function processMessage($envelope, $queue)  
{  
     $messages = $envelope->getBody();#获取消息数据  
     echo $messages;  
     $queue->ack($envelope->getDeliveryTag()); //处理成功后，手动发送ACK应答  
     //$queue->nack($envelope->getDeliveryTag()); //处理不成功，手动发送NO-ACK应答，放回队列中   
}