• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

go语言nsq源码解读一-基本介绍

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

简单介绍一下nsq.

参考 http://feilong.me/2013/05/nsq-realtime-message-processing-system 的介绍:NSQ是由知名短链接服务商bitly用Go语言开发的实时消息处理系统,具有高性能、高可靠、无视单点故障等优点,是一个非常不错的新兴的消息队列解决方案。

nsq易于配置和部署,所有参考都通过命令行指定,编译好的二进制文件,没有其它依赖项。而且支持多种消息格式。

源码下载地址:

https://github.com/nsqio/nsq

本系列文档下载的源码为0.2.27版本。

为更好的理解源码,最理想的起步当然是先了解nsq的用法。所以接下来会先讲解nsq的安装、使用。

安装nsq

1、安装golang环境。

2、安装godep,在命令行执行:

1
go get github.com/kr/godep

如果在使用go get 安装过程中报错,可以参考另一篇文章:关于go get安装git golang项目时报错的处理办法

安装之后,在%GOPATH%/bin目录下会看到有godep.exe,然后记得将%GOPATH%/bin配置到环境变量里,以后在命令行就可以直接输入godep命令来执行一些操作了。

3、安装assert,在命令行执行:

1
go get github.com/bmizerany/assert

4、接下来开始获取nsg的代码并编译。

在命令行执行:

1
godep get github.com/bitly/nsq/...

注意:后面有三个点不能少。
执行之后在%GOPATH%/bin下会有很多nsq打头的exe文件存在。
至此安装就结束了。

使用nsq

总共需要打开五个命令行窗口。
第一个执行:

1
nsqlookupd

第二个执行:

1
nsqd --lookupd-tcp-address=127.0.0.1:4160

第三个执行:

1
nsqadmin --lookupd-http-address=127.0.0.1:4161

第四个执行:

1
curl -d "hello world 1" "http://127.0.0.1:4151/put?topic=test"

第五个执行:

1
nsq_to_file --topic=test --output-dir=F:\tmp --lookupd-http-address=127.0.0.1:4161

这个命令中的output-dir参数,表示数据文件保存在目录,可以根据需要修改。
再回到第四个窗口,执行

1
curl -d "hello world 2" "http://127.0.0.1:4151/put?topic=test"
1
curl -d "hello world 3" "http://127.0.0.1:4151/put?topic=test"

经过这一串操作后,可以开始看成果了:
浏览器访问:http://127.0.0.1:4171/,
可以看到数据统计分析的页面。

打开output-dir参数设置的目录,如本例中的F:\tmp,打开里面的一个记事本文件,看到有三行:
hello world 1
hello world 2
hello world 3

至此,安装和使用就结束了。

到目前为止,我们还停留在知其然,不知其所以然的地步。完全搞不懂上面这些使用的命令行在干什么,也没理解nsq的使用价值在哪里。不过本篇呢,还是要结束了,欲知后事如何,且听下回分解。



鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Idea、PyCharm连接MySQL报错: Server returns invalid timezone. Go to 'Advanced' t ...发布时间:2022-07-10
下一篇:
Go的核心goroutine sysmon发布时间:2022-07-10
热门推荐
热门话题
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap