rabbitmq-c build options:

Host: x86_64-unknown-linux-gnu

Version: 0.4.1

SSL/TLS: openssl

Tools: yes

Documentation: no

Examples: yes

//设置连接属性

$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应答，放回队列中

}