data_clean/sensitive/src/main.go

package main

import (
	"github.com/nats-io/nats.go"
	"go.mongodb.org/mongo-driver/bson"
	"jynats/jnats"
	"log"
	qu "qfw/util"
	"time"
	ul "util"
)

func init() {
	ul.InitC()
}

func mainT() {
	go RunFlowSystem()
	lock := make(chan bool)
	<-lock
}

func RunFlowSystem() {
	addr := qu.ObjToString("192.168.3.240:19090")
	jn := jnats.NewJnats(addr)
	jn.SubZip("dataprocess.clean", func(msg *nats.Msg) {
		msgInfo := &ul.MsgInfo{}
		err := bson.Unmarshal(msg.Data, &msgInfo)
		if err != nil {
			msgInfo.Err = err.Error()
		} else {
			ul.FlowHandleInfo(msgInfo)
		}
		bs, _ := bson.Marshal(msgInfo)
		msg.Respond(bs)
	})
}

func main() {
	ul.SentiveUdp() //数据流程-增量
	//go ul.AddTaskSensitiveWordsData() //词库增量-
	//ul.TestData() //临时测试数据
	lock := make(chan bool)
	<-lock
}

func ttttt() {
	log.Println("。。。。。。")
	for {
		tick := time.Tick(time.Second * 10)
		<-tick
		log.Println("执行一次")
	}
}