一、测试条件：

1.1、ubuntu服务器平台

#!/bin/sh

echo "deb http://www.rabbitmq.com/debian/ testing main" >> /etc/apt/sources.list

wget -c http://www.rabbitmq.com/rabbitmq-signing-key-public.asc

apt-key add rabbitmq-signing-key-public.asc

apt-get update

apt-get install -y rabbitmq-server g++ make


rm -fr rabbitmq-signing-key-public.asc


rabbitmq-plugins enable mochiweb webmachine rabbitmq_web_dispatch amqp_client rabbitmq_management_agent rabbitmq_management


rabbitmqctl delete_user guest

rabbitmqctl add_user admin admin

rabbitmqctl set_permissions -p "/" admin ".*" ".*" ".*"

rabbitmqctl set_user_tags admin administrator


/etc/init.d/rabbitmq-server restart

1.2、安装nodejs与Rabbitmq消息服务器交互所需的node-amqp模块。

 [leekwen@ubuntu ~] mkdir node-amqp; cd node-amqp
 [leekwen@ubuntu node-amqp]$ npm install rabbitmq; npm install amqp

二、node-amqp模块的使用方法及测试实例

2.1、node-amqp所在的github地址（含API说明）

2.2、使用node-amqp的测试实例

测试代码如下：

/*
* Install Rabbitmq Server
* Install nodejs && nmp
* Run those commands:
* [leekwen@ubuntu ~] mkdir node-amqp; cd node-amqp
* [leekwen@ubuntu node-amqp]$ npm install rabbitmq
* [leekwen@ubuntu node-amqp]$ npm install amqp
*/
var amqp = require('amqp');

var connection = amqp.createConnection({url: "amqp://admin:admin@127.0.0.1:5672"});
connection.on('ready', function () {
    var callbackCalled = false;
	exchange = connection.exchange('exchange_name', {type: 'direct',autoDelete:false});
    connection.queue("queue_name",{autoDelete:false}, function(queue){
    queue.bind('exchange_name','queue_name', function() {
		exchange.publish('queue_name', 'this is message is testing ......');
		 callbackCalled = true;
		 
	 setTimeout(function() {
     console.log("Single queue bind callback succeeded");
	 //exchange.destroy();
     //queue.destroy();
	 connection.end();
     connection.destroy();
     }, 5000); 
		 
  });

    queue.subscribe(function (message) {
      console.log('At 5 second recieved message is:'+ message.data);
    });
	
  });
});