<案例><NSQ><生产者和消费者案例>

Author: iceopen

.gitignore

@@ -0,0 +1,2 @@
+.idea
+bin

README.md

@@ -5,113 +5,5 @@ Go 语言学习资料与社区索引
 ## 类库搜索
 [整理](awesome_go.md) 感谢 https://github.com/avelino/awesome-go 上面最新整理的
 
-
-
-鉴于之前有人做的 [索引资料](https://github.com/wonderfo/wonderfogo/wiki) 已经过期超过 2 年，所以特开此坑。各位同学可以通过发起 Fork + Pull Request 的方式进行补充和更新。
-
-**最后更新时间**：2015 年 3 月 9 日
-
-## 交流社区
-
-### 中文社区
-
- - [golanghome社区](http://golanghome.com/)：基于 [WeTalk](https://github.com/beego/wetalk) 搭建的新型社区
- - [Golang 中国](http://www.golangtc.com/)：国内较早的 Go 社区，汇聚各类信息与服务
- - [Study Golang](http://studygolang.com/)：国内 Go 社区先驱，同样汇聚各类信息与服务
- - [Revel 交流论坛](http://gorevel.cn/)：[Revel](https://github.com/revel/revel) 框架的中文社区
- - [SudoChina](http://www.sudochina.com/)：基于 [beego](http://beego.me/) 的问答社区
- - QQ 群：
- 	- Go Web 编程群：259316004
- 	- Golang 中国：211938256
- 	- Go 内部实现与标准库：192706294
- 	- Golang Web 开发：231956113
- 	- Go 编程语言：102319854
- 	- Martini 交流群：371440803
-
-### 英文社区
-
-- [golang-nuts 邮件列表](https://groups.google.com/forum/#!forum/golang-nuts)：Go 语言官方指定邮件列表讨论区
-- [Go+ 社区](https://plus.google.com/u/0/communities/114112804251407510571)：Go 语言官方指定 G+ 社区
-
-## 网址导航
-
-- 官方：
-	- [Playground](http://play.golang.org)：Go 语言代码在线运行
-- 国内镜像：
-	- [Go 指南国内镜像](http://tour.golangtc.com/)
-	- [Go 语言国内下载镜像](http://www.golangtc.com/download)
-	- [Go 官方网站国内镜像](http://docs.studygolang.com/)
-- Web 框架：
-	- [beego](http://beego.me/)：国人开发的轻量级 Web 框架
-	- [Revel](https://github.com/revel/revel)：较早成熟的重量级 Web 框架
-	- [Martini](https://github.com/go-martini/martini): 一个强大为了编写模块化Web应用而生的GO语言框架
-- ORM 以及数据库驱动：
-	- [xorm](https://github.com/go-xorm/xorm)：支持 MySQL、PostgreSQL、SQLite3 以及 MsSQL
-	- [mgo](http://labix.org/mgo)：MongoDB 官方推荐驱动
-	- [SSDB](http://www.ideawu.com/ssdb/zh_cn/): 高性能 kv 数据库
-- 辅助站点：
-	- [Go Walker](https://gowalker.org)：Go 语言在线 API 文档
-	- [gobuild.io](http://gobuild.io/)：Go 语言在线二进制编译与下载
-	- [Rego](http://regoio.herokuapp.com/)：Go 语言正则在线测试
-- 开发工具：
-    - [Emacs24](http://ftp.gnu.org/gnu/emacs/)：[配置脚本](https://github.com/wackonline/hack/blob/master/install-mint-dev/install-emacs.d.sh) / [(中文社区)](http://emacser.com/)
-	- [LiteIDE](https://github.com/visualfc/liteide)
-	- [Sublime Text 2/3](http://sublimetext.com)：[配置教程](http://my.oschina.net/Obahua/blog/110767)
-	- [IntelliJ IDEA](http://www.jetbrains.com/idea/)
-    - [Atom](https://atom.io)：[配置插件](https://atom.io/packages/go-plus)(感觉还不错，类似sublime，配置比较简单)
-- 学习站点：
-	- [Go China 网络课堂](http://edu.go-china.org/)
-	- [Go by Example](https://gobyexample.com/)
-	- [GopherCasts](https://gophercasts.io/)
-	- [Go database/sql tutorial](http://go-database-sql.org/)
-- 支持 Go 的云平台：
-	- [Koding](https://koding.com/)
-	- [Nitrous.IO](https://www.nitrous.io/)
-- 其它站点：
-	- [Golang 杂志](https://flipboard.com/section/the-golang-magazine-bJ1GqB)：[订阅说明](http://bbs.go-china.org/post/476)
-	- [Reddit](http://www.reddit.com/r/golang/)
-	- [Newspaper. IO](http://www.newspaper.io/golang)：Golang 新闻订阅
-	- [Go Newsletter](http://www.golangweekly.com/)：Golang 新闻订阅
-
-## 资料汇总
-
-### 中文资料
-
-- 书籍：
-	- [《深入解析Go》](https://github.com/tiancaiamao/go-internals)
-	- [《Go实战开发》](https://github.com/astaxie/Go-in-Action)
-	- [《Go入门指南》](https://github.com/Unknwon/the-way-to-go_ZH_CN)
-	- [《Go语言标准库》](https://github.com/polaris1119/The-Golang-Standard-Library-by-Example)
-	- [《Go Web 编程》](https://github.com/astaxie/build-web-application-with-golang)
-	- [《Go语言博客实践》](https://github.com/achun/Go-Blog-In-Action)
-	- [《Go语言学习笔记》](https://github.com/qyuhen/book)
-- 翻译：
-	- [Effective Go](http://www.hellogcc.org/effective_go.html)
-- 教程：
-	- [《Go编程基础》](https://github.com/Unknwon/go-fundamental-programming)
-	- [《Go Web基础》](https://github.com/Unknwon/go-web-foundation)
-	- [《Go名库讲解》](https://github.com/Unknwon/go-rock-libraries-showcases)
-
-### 英文资料
-
-- 文档：
-	- [Go Code Review Comments](https://code.google.com/p/go-wiki/wiki/CodeReviewComments)：Go 语言代码风格指导
-	- [GopherCon 2014](https://github.com/gophercon/2014-talks)
-- 书籍：
-	- [Network programming with Go](http://jan.newmarch.name/go/)：[中文版](https://github.com/astaxie/NPWG_zh)
-	- [Practical Cryptography With Go](https://leanpub.com/gocrypto/read#leanpub-auto-select-bibliography)
-	- [An Introduction to Programming in Go](http://www.golang-book.com/)
-	- [Go Bootcamp](http://www.golangbootcamp.com/book)
-
-### 视频资料
-
-- 基础：
-	- Go Slices and Bytes - Shakeel Mahate：[优酷视频](http://v.youku.com/v_show/id_XNjkzMjM1Mjg4.html) - [Youtube](http://www.youtube.com/watch?v=dKlNSIUSfz0)
-- COSCUP 2013:
-	- Golang & ORM - 林佑安：[优酷视频](http://v.youku.com/v_show/id_XNjkzMTQ1MjYw.html) - [Youtube](http://www.youtube.com/watch?v=VwAtYGyjTks)
-- GopherCon 2014：[Youtube](http://confreaks.com/events/gophercon2014)
-- GopherCon India 2015: [Youtube](https://www.youtube.com/playlist?list=PLxFC1MYuNgJTY3uQ5Ja4F5Sz305nnrBOq)
-
-## 声明感谢
-[https://github.com/Unknwon/go-study-index](https://github.com/Unknwon/go-study-index) 信息整理
->>>>>>> dee930577ffbe85a95af0103823aed84f67b18e1
+## demo
+[学习过程中的编写](demo/README.md)

demo/README.md

@@ -0,0 +1,6 @@
+
+Golang Demo
+==============
+
+## 案例
+[nsq-demo](nsq-demo) NSQ 使用案例

demo/nsq-demo/README.md

@@ -0,0 +1,46 @@
+# 监控HTTP数据
+
+## 依赖
+- 必须：https://github.com/shirou/gopsutil
+- window必须：https://github.com/go-ole/go-ole
+- window必须：https://github.com/StackExchange/wmi
+
+## 编译方式
+- go 1.5 一下使用：gox 多平台编译
+- go 1.5 以后使用：GOOS=linux GOARCH=amd64 go build -o ./bin/nsqProducer nsq_producer.go 进行编译
+
+## 编译平台参考
+
+可用的OS和ARCH的值如下：
+
+```
+$GOOS	$GOARCH
+darwin	386
+darwin	amd64
+darwin	arm
+darwin	arm64
+dragonfly	amd64
+freebsd	386
+freebsd	amd64
+freebsd	arm
+linux	386
+linux	amd64
+linux	arm
+linux	arm64
+linux	ppc64
+linux	ppc64le
+netbsd	386
+netbsd	amd64
+netbsd	arm
+openbsd	386
+openbsd	amd64
+openbsd	arm
+plan9	386
+plan9	amd64
+solaris	amd64
+windows	386
+windows	amd64
+```
+## 部署方案：
+- 1.防火墙开发TCP：8899 端口
+- 2.Supervisord 进行部署

demo/nsq-demo/main.go

@@ -0,0 +1,49 @@
+package main
+
+import (
+	"log"
+	"time"
+	"github.com/nsqio/go-nsq"
+	"strconv"
+)
+
+func main() {
+	go startConsumer()
+	startProducer()
+}
+
+// 生产者
+func startProducer() {
+	cfg := nsq.NewConfig()
+	producer, err := nsq.NewProducer("127.0.0.1:4150", cfg)
+	if err != nil {
+		log.Fatal(err)
+	}
+	// 发布消息
+	for {
+		i := time.Now().Unix()
+		if err := producer.Publish("test", []byte("test message - "+ strconv.FormatInt(i, 10))); err != nil {
+			log.Fatal("publish error: " + err.Error())
+		}
+		time.Sleep(100 * time.Millisecond)
+	}
+}
+
+// 消费者
+func startConsumer() {
+	cfg := nsq.NewConfig()
+	consumer, err := nsq.NewConsumer("test", "sensor01", cfg)
+	if err != nil {
+		log.Fatal(err)
+	}
+	// 设置消息处理函数
+	consumer.AddHandler(nsq.HandlerFunc(func(message *nsq.Message) error {
+		log.Println(string(message.Body))
+		return nil
+	}))
+	// 连接到单例nsqd
+	if err := consumer.ConnectToNSQD("127.0.0.1:4150"); err != nil {
+		log.Fatal(err)
+	}
+	<-consumer.StopChan
+}

demo/nsq-demo/nsq_consumer.go

@@ -0,0 +1,44 @@
+package main
+
+import (
+	_ "github.com/go-sql-driver/mysql" // import your used driver
+	"github.com/nsqio/go-nsq"
+	"log"
+	"github.com/astaxie/beego/orm"
+	"fmt"
+	"time"
+	"strconv"
+)
+
+func init() {
+	orm.RegisterDataBase("default", "mysql", "root:@tcp(172.16.50.143:4000)/shtelecom?charset=utf8", 30)
+	orm.Debug = true
+
+}
+
+func main() {
+	o := orm.NewOrm()
+	o.Using("default") // 默认使用 default，你可以指定为其他数据库
+	cfg := nsq.NewConfig()
+	consumer, err := nsq.NewConsumer("shtelecom-active", "mohoo", cfg)
+	if err != nil {
+		log.Fatal(err)
+	}
+	// 设置消息处理函数
+	consumer.AddHandler(nsq.HandlerFunc(func(message *nsq.Message) error {
+		log.Println(string(message.Body))
+		i := time.Now().Unix()
+		res, err := o.Raw(" INSERT INTO openid_active (openid, acttime, type, note) VALUES(?, ?, ?, ?); ", string(message.Body), strconv.FormatInt(i, 10), "BIND", "WX").Exec()
+		if err == nil {
+			num, _ := res.RowsAffected()
+			fmt.Println("mysql row affected nums: ", num)
+		}
+		time.Sleep(3 * time.Millisecond)
+		return nil
+	}))
+	// 连接到单例nsqd
+	if err := consumer.ConnectToNSQD("172.16.50.143:4150"); err != nil {
+		log.Fatal(err)
+	}
+	<-consumer.StopChan
+}

demo/nsq-demo/nsq_producer.go

@@ -0,0 +1,71 @@
+package main
+
+import (
+	"github.com/labstack/echo"
+	"net/http"
+	"github.com/nsqio/go-nsq"
+	"log"
+	"fmt"
+	"encoding/json"
+)
+
+type ProBody struct {
+	Body    string `json:"body"`    // 主体内容
+	Uuid    string `json:"uuid"`    // 时间戳
+	Acttime string `json:"acttime"` // 活动时间
+	Type    string `json:"type"`    // 类型
+	Note    string `json:"note"`    // 备注
+}
+
+type ActBody struct {
+	Openid  string `json:"openid"`  // 主体内容
+	Acttime string `json:"acttime"` // 活动时间
+	Type    string `json:"type"`    // 类型
+	Note    string `json:"note"`    // 备注
+	Uuid    string `json:"uuid"`    // UUID
+}
+
+var producer *nsq.Producer
+
+func init() {
+	cfg := nsq.NewConfig()
+	var err error
+	producer, err = nsq.NewProducer("172.16.50.143:4150", cfg)
+	if err != nil {
+		log.Fatal(err)
+	}
+}
+
+func main() {
+	e := echo.New()
+	e.POST("/producer", func(c echo.Context) error {
+		body := new(ProBody)
+		var err error
+		if err = c.Bind(body); err != nil {
+			return c.JSON(http.StatusMethodNotAllowed, "内容体不对")
+		}
+		if body.Body == "" {
+			return c.JSON(http.StatusMethodNotAllowed, "body不能为空")
+		}
+
+		// 微信活跃数据
+		var actBody ActBody
+		actBody.Openid = body.Body
+		actBody.Acttime = body.Acttime
+		actBody.Uuid = body.Uuid
+		actBody.Type = body.Type
+		actBody.Note = body.Note
+
+		jsons, errs := json.Marshal(actBody) //转换成JSON返回的是byte[]
+		if errs != nil {
+			fmt.Println(errs.Error())
+		}
+		if err := producer.Publish("shtelecom-active", jsons); err != nil {
+			return c.JSON(http.StatusBadGateway, "publish error: "+err.Error())
+		} else {
+			e.Logger.Info("SendOk: " + body.Uuid)
+			return c.JSON(http.StatusOK, "ok")
+		}
+	})
+	e.Logger.Fatal(e.Start(":8899"))
+}