实现功能:用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
至于下面的操作,看开发者怎么使用了.