From 4244acad88afc44ae8a34a8fbd9e296780a0cc64 Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期二, 16 五月 2023 16:00:36 +0800
Subject: [PATCH] remove github.com nsq depend
---
main.go | 16 +++++++---------
1 files changed, 7 insertions(+), 9 deletions(-)
diff --git a/main.go b/main.go
index ededf6a..24250f3 100644
--- a/main.go
+++ b/main.go
@@ -10,8 +10,6 @@
"sync"
"time"
"unsafe"
-
- "github.com/nsqio/go-nsq"
)
//export createProducer
@@ -62,7 +60,7 @@
type consumer struct {
nsqcon *nsqclient.NsqConsumer
lck sync.Mutex
- msgs []*nsq.Message
+ msgs [][]byte
}
//export createConsumer
@@ -89,12 +87,12 @@
//export Run
func Run(ch unsafe.Pointer, addr string) {
c := ccvt(ch)
- c.nsqcon.AddHandler(nsq.HandlerFunc(func(msg *nsq.Message) error {
+ c.nsqcon.AddHandler(func(msg []byte) error {
c.lck.Lock()
defer c.lck.Unlock()
c.msgs = append(c.msgs, msg)
return nil
- }))
+ })
c.nsqcon.Run(addr, 1)
}
@@ -102,12 +100,12 @@
//export RunLookupd
func RunLookupd(ch unsafe.Pointer, lookAddr string) {
c := ccvt(ch)
- c.nsqcon.AddHandler(nsq.HandlerFunc(func(msg *nsq.Message) error {
+ c.nsqcon.AddHandler(func(msg []byte) error {
c.lck.Lock()
defer c.lck.Unlock()
c.msgs = append(c.msgs, msg)
return nil
- }))
+ })
c.nsqcon.RunLookupd(lookAddr, 1)
}
@@ -124,9 +122,9 @@
msg := c.msgs[0]
c.msgs = c.msgs[1:]
- *size = C.size_t(len(msg.Body))
+ *size = C.size_t(len(msg))
ptr := C.malloc(*size)
- C.memcpy(ptr, unsafe.Pointer(&msg.Body[0]), *size)
+ C.memcpy(ptr, unsafe.Pointer(&msg[0]), *size)
*data = ptr
return true
--
Gitblit v1.8.0