作者：李俱順

原文：https://www.4async.com/2021/05/building-your-own-dapr-service-discovery/

在上一篇文章中，我其實(shí)遺留了一個問題：如何定義dapr的服務(wù)發(fā)現(xiàn)呢？其實(shí)在后面閱讀dapr的源碼之后也前一篇文章的評論中提到了答案：目前dapr提供了內(nèi)置兩種服務(wù)發(fā)現(xiàn)模式：K8s模式和用于獨(dú)立部署的mDNS模式。mDNS模式在某些網(wǎng)絡(luò)環(huán)境下可能存在問題（比如跨機(jī)房），不過沒有關(guān)系，dapr同時提供了可擴(kuò)展能力，可以通過定義自主的服務(wù)發(fā)現(xiàn)能力擴(kuò)展dapr的邊界。

從 NameResolution 到 Resolver 接口

在?pkg/components/nameresolution/registry.go?文件中，dapr定義了一個?NameResolution?結(jié)構(gòu)體用于服務(wù)注冊和發(fā)現(xiàn)：

type (// NameResolution is a name resolution component definition.NameResolution struct {Name stringFactoryMethod func() nr.Resolver}// Registry handles registering and creating name resolution components.Registry interface {Register(components ...NameResolution)Create(name, version string) (nr.Resolver, error)}nameResolutionRegistry struct {resolvers map[string]func() nr.Resolver} )

其中真正的服務(wù)解析則是依靠?components-contrib?中實(shí)現(xiàn)了?Resolver?接口的具體實(shí)現(xiàn)執(zhí)行。

// Resolver is the interface of name resolver. type Resolver interface {// Init initializes name resolver.Init(metadata Metadata) error// ResolveID resolves name to address.ResolveID(req ResolveRequest) (string, error) }

其中?Init?會在 Runtime 初始化時被調(diào)用，而?ResolveID?則會在服務(wù)查詢時調(diào)用。比如在?pkg/messaging/direct_messaging.go?的方法?getRemoteApp?中進(jìn)行服務(wù)的解析：

func (d *directMessaging) getRemoteApp(appID string) (remoteApp, error) {id, namespace, err := d.requestAppIDAndNamespace(appID)if err != nil {return remoteApp{}, err}request := nr.ResolveRequest{ID: id, Namespace: namespace, Port: d.grpcPort}address, err := d.resolver.ResolveID(request)if err != nil {return remoteApp{}, err}return remoteApp{namespace: namespace,id: id,address: address,}, nil }

當(dāng)然，事實(shí)上這樣并不完全足夠，還需要把這個服務(wù)注冊放入dapr支持的服務(wù)中去：

runtime.WithNameResolutions(nr_loader.New("mdns", func() nr.Resolver {return nr_mdns.NewResolver(logContrib)}),nr_loader.New("kubernetes", func() nr.Resolver {return nr_kubernetes.NewResolver(logContrib)}),nr_loader.New("consul", func() nr.Resolver {return nr_consul.NewResolver(logContrib)}), ),

上面的這些是設(shè)定的dpar目前支持的一些服務(wù)發(fā)現(xiàn)功能，而我們之前服務(wù)發(fā)現(xiàn)也一直使用的 Consul 實(shí)現(xiàn)，已經(jīng)滿足我們的需求了…????拖延癥害人啊！

從原理到實(shí)現(xiàn)

上面提到了我們需要實(shí)現(xiàn)一個?Resolver?接口的實(shí)現(xiàn)，我們可以預(yù)見到我們大概會需要這么一個東西:

type resolver struct {}// NewResolver creates Consul name resolver. func NewResolver() nr.Resolver// Init will configure component. It will also register service or validate client connection based on config func (r *resolver) Init(metadata nr.Metadata) error // ResolveID resolves name to address via consul func (r *resolver) ResolveID(req nr.ResolveRequest) (string, error)

接下來就需要一個?client *consul.Client?去實(shí)現(xiàn)服務(wù)的注冊：

type resolver struct {client *consul.Client }func (r *resolver) Init(metadata nr.Metadata) error {// ...if err := r.client.Agent().ServiceRegister(regData); err != nil {return fmt.Errorf("failed to register consul service: %w", err)}// ... }

注冊服務(wù)完成后，在調(diào)用具體的服務(wù)時，我們需要獲取具體的服務(wù)地址：

func (r *resolver) ResolveID(req nr.ResolveRequest) (string, error) {// ...services, _, err := r.client.Health().Service(req.ID, "", true, cfg.QueryOptions)// ... }

當(dāng)然上面的演示代碼只是部分核心功能代碼，如果需要拓展更多的實(shí)現(xiàn)細(xì)節(jié)內(nèi)容，需要查看具體的官方接收社區(qū)貢獻(xiàn)的實(shí)現(xiàn)：components-contrib/nameresolution/consul

相關(guān)文章：

• Dapr能否引領(lǐng)云原生中間件的未來？
  

• 云原生 | 阿里巴巴的Dapr實(shí)踐與探索

• Dapr | 云原生的抽象與實(shí)現(xiàn)

• Dapr 可視化指南

• Dapr 知多少 | 分布式應(yīng)用運(yùn)行時

• Dapr 正式發(fā)布 1.0

• Dapr 交通流量控制示例

• Dapr是如何簡化微服務(wù)的開發(fā)和部署

• 微軟開源微服務(wù)運(yùn)行時Dapr，賦能云原生應(yīng)用開發(fā)

• YARP實(shí)現(xiàn)Dapr服務(wù)調(diào)用的反向代理

• Dapr微服務(wù)應(yīng)用開發(fā)系列0：概述

• Dapr微服務(wù)應(yīng)用開發(fā)系列1：環(huán)境配置

• Dapr微服務(wù)應(yīng)用開發(fā)系列2：Hello World與SDK初接觸

• Dapr微服務(wù)應(yīng)用開發(fā)系列3：服務(wù)調(diào)用構(gòu)件塊

• Dapr微服務(wù)應(yīng)用開發(fā)系列4：狀態(tài)管理構(gòu)件塊

• Dapr微服務(wù)應(yīng)用開發(fā)系列5：發(fā)布訂閱構(gòu)建塊

• Windows環(huán)境下Dapr入門

• 云原生 | .NET 5 with Dapr 初體驗(yàn)

• 通過Dapr實(shí)現(xiàn)一個簡單的基于.net的微服務(wù)電商系統(tǒng)

• 通過Dapr實(shí)現(xiàn)一個簡單的基于.net的微服務(wù)電商系統(tǒng)(二)——通訊框架講解

• 通過Dapr實(shí)現(xiàn)一個簡單的基于.net的微服務(wù)電商系統(tǒng)(三)——一步一步教你如何擼Dapr

• 通過Dapr實(shí)現(xiàn)一個簡單的基于.net的微服務(wù)電商系統(tǒng)(四)——一步一步教你如何擼Dapr之訂閱發(fā)布

• 通過Dapr實(shí)現(xiàn)一個簡單的基于.net的微服務(wù)電商系統(tǒng)(五)——一步一步教你如何擼Dapr之狀態(tài)管理

• 通過Dapr實(shí)現(xiàn)一個簡單的基于.net的微服務(wù)電商系統(tǒng)(六)——一步一步教你如何擼Dapr之Actor服務(wù)

• 通過Dapr實(shí)現(xiàn)一個簡單的基于.net的微服務(wù)電商系統(tǒng)(七)——一步一步教你如何擼Dapr之服務(wù)限流

• 通過Dapr實(shí)現(xiàn)一個簡單的基于.net的微服務(wù)電商系統(tǒng)(八)——一步一步教你如何擼Dapr之鏈路追蹤

• 通過Dapr實(shí)現(xiàn)一個簡單的基于.net的微服務(wù)電商系統(tǒng)(九)——一步一步教你如何擼Dapr之OAuth2授權(quán)

• 通過Dapr實(shí)現(xiàn)一個簡單的基于.net的微服務(wù)電商系統(tǒng)(九)——一步一步教你如何擼Dapr之OAuth2授權(quán)-百度版

• 通過Dapr實(shí)現(xiàn)一個簡單的基于.net的微服務(wù)電商系統(tǒng)(十)——一步一步教你如何擼Dapr之綁定
  

• 通過Dapr實(shí)現(xiàn)一個簡單的基于.net的微服務(wù)電商系統(tǒng)(十一)——一步一步教你如何擼Dapr之自動擴(kuò)/縮容
  

• WebAssembly + Dapr = 下一代云原生運(yùn)行時？

• dapr 應(yīng)用開發(fā) | 環(huán)境配置

• 乘風(fēng)破浪，.Net Core遇見Dapr，為云原生而生的分布式應(yīng)用運(yùn)行時

• Dapr案例之高德 Serverless 平臺建設(shè)及實(shí)踐

• 在非容器(集群)環(huán)境下運(yùn)行dapr

總結(jié)

以上是生活随笔為你收集整理的构建属于你自己的dapr服务发现的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。