iot_202304_huangye_device/src/zks.com/newbbfrontsocketv2/blackbox/writedata.go

package blackbox

import (
	"encoding/json"
	"fmt"
	"github.com/nsqio/go-nsq"
)

var Producernsq *nsq.Producer
var Producernsqrequest *nsq.Producer
var err error

func Writedata_v2(data string) error {
	bdata, err := json.Marshal(data)
	Producernsqrequest.Publish(Config.Send.Nsqrequest.Topic, bdata)
	err = Producernsq.Publish(Config.Send.Nsq.Topic, bdata)
	if err != nil {
		fmt.Println("nsq err", err)
		return err
	}
	return nil
}