From 1b4fc8c66026c77abf734126b4e7662e386ec0f5 Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期二, 16 五月 2023 16:50:46 +0800
Subject: [PATCH] for go get
---
TST/test/test.go | 14 ++++++--------
1 files changed, 6 insertions(+), 8 deletions(-)
diff --git a/TST/test/test.go b/TST/test/test.go
index 62d1fae..2e1a679 100644
--- a/TST/test/test.go
+++ b/TST/test/test.go
@@ -4,10 +4,8 @@
"context"
"fmt"
"log"
- "nsqCli/nsqclient"
+ "nsqclient/nsqclient"
"time"
-
- "github.com/nsqio/go-nsq"
)
func produce(two bool) {
@@ -49,14 +47,14 @@
ch := make(chan struct{})
count := 0
- c.AddHandler(nsq.HandlerFunc(func(msg *nsq.Message) error {
+ c.AddHandler(func(data []byte) error {
count++
- fmt.Println("recv msg ", string(msg.Body), " size", count)
+ fmt.Println("recv msg ", string(data), " size", count)
if count > 999000 {
ch <- struct{}{}
}
return nil
- }))
+ })
// go c.Run("192.168.20.108:4150", 2)
go c.RunLookupd("192.168.20.108:4161", 2)
@@ -69,8 +67,8 @@
}
func Test() {
- go produce(false)
+ go produce(true)
- // go consume("test2", "sensor01")
+ go consume("test2", "sensor01")
consume("test", "sensor01")
}
--
Gitblit v1.8.0