stbz/library

胜天半子内部调用库

地址

https://gitlab.jxhh.com/stbz/library

限制

golang版本 >= 1.16

使用方法

生产者 在boot/boot.go

package boot

import (
	"github.com/gogf/gf/frame/g"
	"gitlab.jxhh.com/stbz/library.git/notify"
)

func init() {
    //加载nsq配置文件
	addr := g.Cfg().GetString("messagequeue.link")
	notify.New(&notify.NsqConfig{Addr: addr})
}

生产者 服务中调用

package test

import (
	"github.com/gogf/gf/frame/g"
	"gitlab.jxhh.com/stbz/library.git/notify"
)

func Servie() {
    //推送内容
	msgData := &define.CommonMessage{Source: upstream.Cloud, MsgSendTime: gtime.Timestamp()}
	msgJsonData,err := json.Marshal(msgData)
	if logs.CheckErr(err, "Marshal"){
		return
	}
	//调用方法
	err = notify.NsqProducers.Publish(pushTopic,string(msgJsonData))
}

消费者 在脚本文件 script/script.go消费

package script

import (
	"github.com/gogf/gf/net/ghttp"
	logs "gitlab.jxhh.com/stbz/library.git/notify"

)
        
func Run() {
    //加载nsq配置文件
	addr := g.Cfg().GetString("messagequeue.link")
    // 初始化要消费的topic channel和消费的结构体
	notify.InitConsumer(&notify.NsqConfig{Addr: addr, Channel: notify.MsgCloudTopic, Topic: notify.MsgCloudTopic, Handler: &message.CloudMessage})
    // 多个消费调用的示例
	notify.InitConsumer(&notify.NsqConfig{Addr: addr, Channel: notify.NotifyTopic, Topic: notify.NotifyTopic, Handler: &handle.Message})

	select {}
}