摘要：因?yàn)楣驹跇I(yè)務(wù)中需要用到消息隊(duì)列產(chǎn)品，我選用了基于開源的產(chǎn)品，記錄下我遇到的那些部署中的坑。

因?yàn)楣驹跇I(yè)務(wù)中需要用到消息隊(duì)列產(chǎn)品，我選用了基于golang開源的nsq產(chǎn)品，記錄下我遇到的那些部署中的坑。
首先安裝nsq，這個(gè)沒什么好說的，我是直接在官網(wǎng)下載bin文件，直接部署的，環(huán)境是centOS 6.7，安裝在/opt/nsq-0.3.7.linux-amd64.go1.6目錄下；
其次是安裝nodejs，我安裝的是v6.1.0版本，這步也沒什么好講；
然后安裝nsqjs這個(gè)遇到了些坑，這里先記錄下
1、要看下gcc的版本；

$ gcc -v使用內(nèi)建 specs。
目標(biāo)：x86_64-redhat-linux
配置為：../configure --prefix=/usr --mandir=/usr/share/man --infodir=/usr/share/info --with-bugurl=http://bugzilla.redhat.com/bugzilla --enable-bootstrap --enable-shared --enable-threads=posix --enable-checking=release --with-system-zlib --enable-__cxa_atexit --disable-libunwind-exceptions --enable-gnu-unique-object --enable-languages=c,c++,objc,obj-c++,java,fortran,ada --enable-java-awt=gtk --disable-dssi --with-java-home=/usr/lib/jvm/java-1.5.0-gcj-1.5.0.0/jre --enable-libgcj-multifile --enable-java-maintainer-mode --with-ecj-jar=/usr/share/java/eclipse-ecj.jar --disable-libjava-multilib --with-ppl --with-cloog --with-tune=generic --with-arch_32=i686 --build=x86_64-redhat-linux
線程模型：posix
gcc 版本 4.4.7 20120313 (Red Hat 4.4.7-16) (GCC)

2、因?yàn)閚ode.js 4升級(jí)了v8引擎，要求gcc的版本在4.8以上，所以要先更新gcc版本；

$ rpm -ivh https://www.softwarecollections.org/en/scls/rhscl/devtoolset-3/epel-6-x86_64/download/rhscl-devtoolset-3-epel-6-x86_64.noarch.rpm
$ yum install devtoolset-3-gcc-c++
臨時(shí)使用最新版gcc：
$ scl enable devtoolset-3 bash
系統(tǒng)默認(rèn)使用gcc-4.9
$ echo "source /opt/rh/devtoolset-3/enable" >>/etc/profile

3、然后安裝nsqjs，為了項(xiàng)目的復(fù)用，我就用了全局安裝，然后把nsqjs復(fù)制到項(xiàng)目的node_modules中就可以了；

$ npm install -g nsqjs

4、把nsqjs復(fù)制到項(xiàng)目的node_modules目錄下；
5、在項(xiàng)目中建立個(gè)app.js文件，輸入以下代碼并保存：

var nsq = require("nsqjs");

var reader = new nsq.Reader("sys_topic", "sys_chan", {
    lookupdHTTPAddresses: "127.0.0.1:4161"
});

reader.connect();

reader.on("message", function(msg) {
    var t = new Date();
    console.log("time [%s] Received message [%s]: %s", t.Format("yyyy-MM-dd hh:mm:ss"), msg.id, msg.body.toString());
    msg.finish();
});

Date.prototype.Format = function(fmt) { //author: meizz 
    var o = {
        "M+": this.getMonth() + 1, //月份 
        "d+": this.getDate(), //日 
        "h+": this.getHours(), //小時(shí) 
        "m+": this.getMinutes(), //分 
        "s+": this.getSeconds(), //秒 
        "q+": Math.floor((this.getMonth() + 3) / 3), //季度 
        "S": this.getMilliseconds() //毫秒 
    };
    if (/(y+)/.test(fmt)) fmt = fmt.replace(RegExp.$1, (this.getFullYear() + "").substr(4 - RegExp.$1.length));
    for (var k in o)
        if (new RegExp("(" + k + ")").test(fmt)) fmt = fmt.replace(RegExp.$1, (RegExp.$1.length == 1) ? (o[k]) : (("00" + o[k]).substr(("" + o[k]).length)));
    return fmt;
}

6、在nsqadmin的頁面中，創(chuàng)建Topic為“sys_topic”和channel為“sys_chan”；

7、在應(yīng)用終端中，運(yùn)行這個(gè)js文件

$ node app.js

8、在另外一個(gè)終端中發(fā)布一個(gè)消息

$ curl -d "{"aa":"text","caption":"nsq_test","bool_v":true}"  "http://127.0.0.1:4151/put?topic=sys_topic&channel=sys_chan"

9、看看到我們能非常快的接收到發(fā)布的消息