/tuya-pulsar-sdk-go

Tuya Pulsar sdk for go

Primary LanguageGoMIT LicenseMIT

pulsar-client-go

使用前准备

  1. AccessID 由涂鸦平台提供
  2. AccessKey 由涂鸦平台提供
  3. pulsar地址 根据不同的业务区域，选择pulsar地址。可以从涂鸦对接文档中查询

Example

package main

import (
	"context"
	"encoding/base64"
	"encoding/json"
	"time"

	pulsar "github.com/tuya/tuya-pulsar-sdk-go"
	"github.com/tuya/tuya-pulsar-sdk-go/pkg/tylog"
	"github.com/tuya/tuya-pulsar-sdk-go/pkg/tyutils"
	"github.com/sirupsen/logrus"
)

func main() {
	pulsar.SetInternalLogLevel(logrus.DebugLevel)
	tylog.SetGlobalLog("sdk", false)
	accessID := "accessID"
	accessKey := "accessKey"
	topic := pulsar.TopicForAccessID(accessID)

	// create client
	cfg := pulsar.ClientConfig{
		PulsarAddr: pulsar.PulsarAddrCN,
	}
	c := pulsar.NewClient(cfg)

	// create consumer
	csmCfg := pulsar.ConsumerConfig{
		Topic: topic,
		Auth:  pulsar.NewAuthProvider(accessID, accessKey),
	}
	csm, _ := c.NewConsumer(csmCfg)

	// handle message
	csm.ReceiveAndHandle(context.Background(), &helloHandler{AesSecret: accessKey[8:24]})

	time.Sleep(10 * time.Second)
}

type helloHandler struct {
	AesSecret string
}

func (h *helloHandler) HandlePayload(ctx context.Context, msg *pulsar.Message, payload []byte) error {
	tylog.Info("payload preview", tylog.String("payload", string(payload)))

	// let's decode the payload with AES
	m := map[string]interface{}{}
	err := json.Unmarshal(payload, &m)
	if err != nil {
		tylog.Error("json unmarshal failed", tylog.ErrorField(err))
		return nil
	}
	bs := m["data"].(string)
	de, err := base64.StdEncoding.DecodeString(string(bs))
	if err != nil {
		tylog.Error("base64 decode failed", tylog.ErrorField(err))
		return nil
	}
	decode := tyutils.EcbDecrypt(de, []byte(h.AesSecret))
	tylog.Info("aes decode", tylog.ByteString("decode payload", decode))

	return nil
}

注意事项

  1. 确保accessID，accessKey是正确的
  2. 确保pulsar地址是正确的，应该使用pulsar://mqe.tuyaus.com:7285模式而不是 pulsar+ssl://mqe.tuyaus.com:7285
  3. 尽量确保你使用的sdk代码版本是最新的

About debug

通过下面的代码，你可以在终端看到所有和pulsar服务的通信

func main(){
	pulsar.SetInternalLogLevel(logrus.DebugLevel)
	// other code
}

通过下面的代码，你可以看到tuya_pulsar_go_sdk的日志信息。 与此同时，日志会保存在logs/sdk.log文件中

func main(){
	tylog.SetGlobalLog("sdk", false)
}

在正式环境，你可能不希望sdk日志都输出在终端，此时建议你使用下面的代码。 将日志只输出到文件中。

func main(){
	tylog.SetGlobalLog("sdk", true)
}