gozmq的安装与使用教程(zeromq分布式消息队列+golang)

实现功能：用go实现消息队列的写入与读取(打算用在发送邮件服务)

环境工具：
Centos 64X 6.4
zeromq 3.2.4：zeromq.org
golang：http://golang.org/

这一步很简单，只需要从http://code.google.com/p/go/downloads 下载到服务器，解压到/usr/local/go目录，再设置一下系统变量就可以了．

wget https://go.googlecode.com/files/go1.1.2.linux-amd64.tar.gz
tar -C /usr/local -xzf go1.1.2.linux-amd64.tar.gz

设置系统变量GOROOT

/usr/local/go/binPATH/etc/profile$HOME/.profile

export PATH=$PATH:/usr/local/go/bin

执行命令 #source /etc/profile 使环境变量生效．

设置项目环境变量GOPATH

下面我们需要设置开发项目使用的环境变量GOPATH的路径．可直接在命令行下执行下面的命令，也可以将下面的命令写入/etc/profile(或者 $HOME/.profile)中，这样下次使用的时候变量不会丢失．参考：http://golang.org/doc/code.html

$ mkdir $HOME/go
For convenience, add the workspace’s bin subdirectory to your PATH:

$ export GOPATH=$HOME/go
$ export PATH=$PATH:$GOPATH/bin

#source /etc/profile

到此为止，go的配置基本上已经完成．可以用 go env 命令查看相关的配置信息.

linux_go_env

二．安装zeromq

参考：http://blog.haohtml.com/archives/13798,这里使用的是zeromq 2.3.4版本

三．安装gozmq

如果没有安装git的话，先安装一下.参考：http://blog.haohtml.com/archives/10093

cd ~/go
go get -tags zmq_3_x github.com/alecthomas/gozmq

如果出现

“# pkg-config –cflags libzmq libzmq libzmq libzmqPackage libzmq was not found in the pkg-config search path.Perhaps you should add the directory containing `libzmq.pc’to the PKG_CONFIG_PATH environment variableNo package ‘libzmq’ foundPackage libzmq was not found in the pkg-config search path.Perhaps you should add the directory containing `libzmq.pc’to the PKG_CONFIG_PATH environment variableNo package ‘libzmq’ foundPackage libzmq was not found in the pkg-config search path.Perhaps you should add the directory containing `libzmq.pc’to the PKG_CONFIG_PATH environment variableNo package ‘libzmq’ foundPackage libzmq was not found in the pkg-config search path.Perhaps you should add the directory containing `libzmq.pc’to the PKG_CONFIG_PATH environment variableNo package ‘libzmq’ foundexit status 1”

错误,提示没有在pkgconfig路径找到libzmq.pc文件，主要是pkgconfig路径的问题，只要配置一下pkgconfig目录给用户环境变量PKG_CONFIG_PATH即可．

export PKG_CONFIG_PATH=/usr/local/lib/pkgconfig

四．程序开发

直接将https://github.com/alecthomas/gozmq提供的两段代码写到zmqServer.go 和 zmqClient.go两个文件即可．(也可以直接下载提供的实例https://github.com/alecthomas/gozmq/tree/master/examples)

这个时候开两个终端．一个执行服务端，一个执行客户端．

server端：

go run zmqServer.go

注意这个时候，不会有什么东西输出的，因为客户商没有任何写入操作．下面执行客户端．注意看一下server端的变化

客户端:

go run zmqClient.go

这个时候会发现客户端有10个写入操作(生产者)，而服务端有10个输出操作(消费者).说明一切正常，否则请检查上面的操作是否有误．

zmq_client

zmq_server
至于下面的操作，看开发者怎么使用了．