pulsar-client-go

仓库迁移

该仓库停止更新，请迁移至https://github.com/tuya/tuya-pulsar-sdk-go

使用前准备

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

Example

package main

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

    pulsar "github.com/TuyaInc/tuya_pulsar_sdk_go"
    "github.com/TuyaInc/tuya_pulsar_sdk_go/pkg/tylog"
    "github.com/TuyaInc/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)
}