使用 ListenConfig 監聽 Nacos 配置的變更,以即時獲取最新的配置值。

描述

使用以下接口監聽 Nacos 配置的變更。

ListenConfig(params vo.ConfigParam) (err error)

請求參數

參數 參數類型 描述
ConfigParam.DataId String 配置 ID,采用類似 package.class(如 com.taobao.tc.refund.log.level)的命名規則保證全局唯一性。建議根據配置的業務含義來定義 class 部分。全部字符均為小寫。只允許使用英文字符和 4 種特殊字符(“.”、“:”、“-”、“_”),不超過 256 字節。
ConfigParam.Group String 配置分組,建議填寫產品名:模塊名(如 ACM:Test)來保證唯一性。只允許使用英文字符和 4 種特殊字符(“.”、“:”、“-”、“_”),不超過 128 字節。
ConfigParam.OnChange Function 配置內容變更后回調的函數。

示例

Go 格式

說明 請將代碼中的 ${endpoint}${namespace}${accessKey}${secretKey} 分別替換為 ACM 控制臺上命名空間詳情對話框內的 End Point命名空間 IDAccessKeySecretKey。出于安全考慮,建議使用 RAM 用戶的 AccessKey 和 SecretKey。
package main

import (
    "fmt"
    "github.com/nacos-group/nacos-sdk-go/clients"
    "github.com/nacos-group/nacos-sdk-go/common/constant"
    "github.com/nacos-group/nacos-sdk-go/vo"
    "time"
)

func main() {
    // 從控制臺命名空間管理的"命名空間詳情"中拷貝 End Point、命名空間 ID
    var endpoint = "${endpoint}"
    var namespaceId = "${namespaceId}"

    // 推薦使用 RAM 用戶的 accessKey、secretKey
    var accessKey = "${accessKey}"
    var secretKey = "${secretKey}"


    clientConfig := constant.ClientConfig{
        //
        Endpoint:       endpoint + ":8080",
        NamespaceId:    namespaceId,
        AccessKey:      accessKey,
        SecretKey:      secretKey,
        TimeoutMs:      5 * 1000,
        ListenInterval: 30 * 1000,
    }

    configClient, err := clients.CreateConfigClient(map[string]interface{}{
        "clientConfig": clientConfig,
    })

    if err != nil {
        fmt.Println(err)
        return
    }

    var dataId = "com.alibaba.nacos.example.properties"
    var group = "DEFAULT_GROUP"

    // 監聽配置
    configClient.ListenConfig(vo.ConfigParam{
        DataId: dataId,
        Group:  group,
        OnChange: func(namespace, group, dataId, data string) {
            fmt.Println("ListenConfig group:" + group + ", dataId:" + dataId + ", data:" + data)
        },
    })

}