为消息队列 RocketMQ 版集成 DNS 高可用插件--TrafficRoute DNS 套件-火山引擎

文档中心

立即注册

TrafficRoute DNS 套件

请输入

集成 DNS 高可用插件

为消息队列 RocketMQ 版集成 DNS 高可用插件

本文档介绍如何在火山引擎消息队列 RocketMQ 版的 Golang 客户端中集成 dns-stale-cache 插件。

前提条件

您的 Golang 必须是 1.18 或更高版本。
您的 RocketMQ 客户端使用的 rocketmq-client-go SDK 必须是 v2 版本。dns-stale-cache 不支持其他版本的 rocketmq-client-go SDK。

把 dns-stale-cache 插件集成到 SDK 工程

参见以下示例代码。

rocketmq-client-go SDK v2

import (
    "fmt"
    "os"

    "github.com/apache/rocketmq-client-go/v2/producer"
    . "github.com/volcengine/dns-stale-cache/common"
    . "github.com/volcengine/dns-stale-cache/rocketmq/v2"
)

func NewMQ() {
    addrs := []string{"127.0.0.1:9876"}

    p, _ := producer.NewDefaultProducer(
        producer.WithNsResolver(NewCacheResolver(addrs,
           WithCacheFirst(true),
           WithIPConsistance(true),
           WithDnsTimeout(2*time.Second),
        )),
        producer.WithRetry(2),
    )
    err := p.Start()
    if err != nil {
       fmt.Printf("start producer error: %s", err.Error())
       os.Exit(1)
    }
}

API 参考

func NewCacheResolver

NewCacheResolver(addr []string, opts ...Option)

输入参数

参数名称	类型	是否必选	说明
addr	[]string	是	RocketMQ 客户端的 NameServer 地址。
opt	Option	否	缓存配置选项。参见缓存配置选项。

缓存配置选项

参数	说明
`func WithCacheFirst(preferUse bool) Option`	是否优先返回缓存中匹配的查询结果。 true：域名解析时，优先返回缓存中匹配的查询结果，同时异步向 DNS 服务器发起 DNS 查询请求，并使用查询结果刷新缓存。 false：（默认）域名解析时，优先从 DNS 服务器获取查询结果。如果获取失败，再使用缓存中匹配的查询结果。
`func WithIPConsistance(preferUse bool) Option`	是否把在内存中缓存的查询结果保存到文件。 false：（默认）不把缓存的查询结果保存到文件。 true：把缓存的查询结果保存到文件。默认路径是 `/home/ip_info`。
`func WithDnsTimeout(timeout time.Duration) Option`	向 DNS 服务器发起 DNS 查询请求的超时时间。如果在超时前没有获取查询结果，会使用缓存中匹配的查询结果。默认值为 1 s。

返回参数

类型	说明
*CacheResolver	实现 `NsResolver` 接口中的方法。

最近更新时间：2024.01.15 16:19:59

这个页面对您有帮助吗？

有用

无用