<?php    
    /************************************* 
     * PHP amqp(RabbitMQ) Demo - publisher 
     * Author: Linvo 
     * Date: 2012/7/30 
     *************************************/  
    //配置信息  
    $conn_args = array(  
       'host' => '192.168.50.69',
        'vhost' => '/',
        'port' => 5672,
        'login' => 'guest',
        'password' => 'guest'
    );     
    $e_name = 'e_linvo'; //交换机名  
    //$q_name = 'q_linvo'; //无需队列名  
    $k_route = 'key_1'; //路由key  
      
    //创建连接和channel  
    $conn = new AMQPConnection($conn_args);    
    if (!$conn->connect()) {    
        die("Cannot connect to the broker!\n");    
    }    
    $channel = new AMQPChannel($conn);    
      
    //消息内容  
    $message = "TEST MESSAGE! 测试消息！";    
      
    //创建交换机对象     
    $ex = new AMQPExchange($channel);    
    $ex->setName($e_name);    
      
    //发送消息  
    //$channel->startTransaction(); //开始事务   
    for($i=0; $i<5; ++$i){  
        echo "Send Message:".$ex->publish($message, $k_route)."\n";   
    }  
    //$channel->commitTransaction(); //提交事务  
      
    $conn->disconnect();