<labs><基础案例提交>

Author: iceopen

demo/nsq-demo/README.md

@@ -1,13 +1,12 @@
 # 监控HTTP数据
 
 ## 依赖
-- 必须：https://github.com/shirou/gopsutil
-- window必须：https://github.com/go-ole/go-ole
-- window必须：https://github.com/StackExchange/wmi
+- 必须：github.com/labstack/echo
 
 ## 编译方式
 - go 1.5 一下使用：gox 多平台编译
-- go 1.5 以后使用：GOOS=linux GOARCH=amd64 go build -o ./bin/nsqProducer nsq_producer.go 进行编译
+- go 1.5 以后使用：GOOS=linux GOARCH=amd64 go build -o ./bin/nsqProducer nsq_producer.go
+- go 1.5 以后使用：GOOS=windows GOARCH=amd64 go build -o ./bin/nsqConsumer.exe nsq_consumer.go
 
 ## 编译平台参考
 

demo/nsq-demo/nsq_consumer.go

@@ -1,19 +1,25 @@
 package main
 
 import (
+	"encoding/json"
+	"github.com/astaxie/beego/orm"
 	_ "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
+type ActBody struct {
+	Openid  string `json:"openid"`  // 主体内容
+	Acttime string `json:"acttime"` // 活动时间
+	Type    string `json:"type"`    // 类型
+	Note    string `json:"note"`    // 备注
+	Uuid    string `json:"uuid"`    // UUID
+}
 
+func init() {
+	orm.RegisterDataBase("default", "mysql", "mohoo:mohoo@tcp(172.16.50.143:4000)/shtelecom?charset=utf8", 30)
+	orm.Debug = false
 }
 
 func main() {
@@ -26,19 +32,27 @@ func main() {
 	}
 	// 设置消息处理函数
 	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()
+		var actBody ActBody
+		errJson := json.Unmarshal(message.Body, &actBody)
+		if errJson != nil {
+			return err
+		}
+		_, err := o.Raw("INSERT INTO openid_active (openid, acttime, type, note, uuid) VALUES(?, ?, ?, ?, ?); ", actBody.Openid, actBody.Acttime, actBody.Type, actBody.Note, actBody.Uuid).Exec()
 		if err == nil {
-			num, _ := res.RowsAffected()
-			fmt.Println("mysql row affected nums: ", num)
+			log.Println("id:", actBody.Openid, " time:", actBody.Acttime)
+		} else {
+			log.Fatal(err.Error())
+			panic(1)
 		}
-		time.Sleep(3 * time.Millisecond)
+		time.Sleep(5 * time.Millisecond)
 		return nil
 	}))
 	// 连接到单例nsqd
 	if err := consumer.ConnectToNSQD("172.16.50.143:4150"); err != nil {
 		log.Fatal(err)
 	}
+	//if err := consumer.ConnectToNSQD("127.0.0.1:4150"); err != nil {
+	//	log.Fatal(err)
+	//}
 	<-consumer.StopChan
 }

demo/nsq-demo/nsq_producer.go

@@ -31,8 +31,11 @@ func init() {
 	cfg := nsq.NewConfig()
 	var err error
 	producer, err = nsq.NewProducer("172.16.50.143:4150", cfg)
+	//producer, err = nsq.NewProducer("127.0.0.1:4150", cfg)
 	if err != nil {
 		log.Fatal(err)
+	} else {
+		log.Println("nsq 链接正常")
 	}
 }
 
@@ -42,7 +45,7 @@ func main() {
 		body := new(ProBody)
 		var err error
 		if err = c.Bind(body); err != nil {
-			return c.JSON(http.StatusMethodNotAllowed, "内容体不对")
+			return c.JSON(http.StatusMethodNotAllowed, "JSON body 内容体不对"+err.Error())
 		}
 		if body.Body == "" {
 			return c.JSON(http.StatusMethodNotAllowed, "body不能为空")

labs/buffered-channels/main.go

@@ -0,0 +1,11 @@
+package main
+
+import "fmt"
+
+func main() {
+	ch := make(chan int, 2)
+	ch <- 1
+	ch <- 2
+	fmt.Println(<-ch)
+	fmt.Println(<-ch)
+}

labs/channels/main.go

@@ -0,0 +1,22 @@
+package main
+
+import "fmt"
+
+func sum(s []int, c chan int) {
+	sum := 0
+	for _, v := range s {
+		sum += v
+	}
+	c <- sum // 将和送入 c
+}
+
+func main() {
+	s := []int{7, 2, 8, -9, 4, 0}
+
+	c := make(chan int)
+	go sum(s[:len(s)/2], c)
+	go sum(s[len(s)/2:], c)
+	x, y := <-c, <-c // 从 c 中接收
+
+	fmt.Println(x, y, x+y)
+}

labs/goroutine/main.go

@@ -0,0 +1,18 @@
+package main
+
+import (
+	"fmt"
+	"time"
+)
+
+func say(s string) {
+	for i := 0; i < 5; i++ {
+		time.Sleep(100 * time.Millisecond)
+		fmt.Println(s)
+	}
+}
+
+func main() {
+	go say("world")
+	say("hello")
+}

labs/range-and-close/main.go

@@ -0,0 +1,22 @@
+package main
+
+import (
+	"fmt"
+)
+
+func fibonacci(n int, c chan int) {
+	x, y := 0, 1
+	for i := 0; i < n; i++ {
+		c <- x
+		x, y = y, x+y
+	}
+	close(c)
+}
+
+func main() {
+	c := make(chan int, 10)
+	go fibonacci(cap(c), c)
+	for i := range c {
+		fmt.Println(i)
+	}
+}

labs/test-benchmark/add_test.go

@@ -0,0 +1,46 @@
+package main
+
+import "testing"
+
+func Add(x int, y int) (z int) {
+	z = x + y
+	return
+}
+
+type ForTest struct {
+	num int
+}
+
+func (this *ForTest) Loops() {
+	for i := 0; i < 10000; i++ {
+		this.num++
+	}
+}
+
+type AddArray struct {
+	result int
+	add_1  int
+	add_2  int
+}
+
+func BenchmarkLoops(b *testing.B) {
+	var test ForTest
+	ptr := &test
+	// 必须循环 b.N 次 。 这个数字 b.N 会在运行中调整，以便最终达到合适的时间消耗。方便计算出合理的数据。 （ 免得数据全部是 0 ）
+	for i := 0; i < b.N; i++ {
+		ptr.Loops()
+	}
+}
+
+func TestAdd(t *testing.T) {
+	var test_data = [3]AddArray{
+		{2, 1, 1},
+		{5, 2, 3},
+		{4, 2, 2},
+	}
+	for _, v := range test_data {
+		if v.result != Add(v.add_1, v.add_2) {
+			t.Errorf("Add( %d , %d ) != %d \n", v.add_1, v.add_2, v.result)
+		}
+	}
+}