[Enhancement] Design and Implementation of dubbogo-contrib

[jasondeng1997]

This is a place for various extensions in the dubbogo ecosystem that aren't part of the dubbogo core. 目前现状： 1.dubbogo中各个扩展都在一个包内，导致dubbogo目前主仓库臃肿 2.各个扩展麻烦，不易维护 3.对于dubbogo来说，这是一次极大的优化，无论是在性能和用户体验 1.设计方案 dubbogo已经通过社区开发者的支持，完成了 ETCD、ZooKeeper、Eureka、Consul、Nacos、Polaris 多种服务发现模式，当然也支持注册中心模式，建立起了强大且完备的社区生态，供用户按需灵活选用。

  更多服务发现组件参看扩展仓库：dubbogoContrib-nacos。
   现在本身就可以插件化，dubbo-go可能要先单独设计出来一个 dubbogo-spi，dubbo插件的 interface 定义，单独拎出来 dubbogo 依赖 dubbo-spi，插件依赖 dubbo-spi，用户引入对应插件 go.mod 即可自动启用 ，以不调整用户的使用方式为最小代价实现。
  除了组件和仓库。dubbogo启动流程也可以考虑精简，做到最小可运行集合足够小，就一个rpc，其他微服务和配置可插拔。

具体实现： 1.设想一个经典的dubbo-go示例就是这个最小集合的rpc使用方式，纯api。

2.微服务、治理、配置组装、多协议和各种能力和示例

使用方式 以 原有的注册为例

import ( "github.com/dubbogo/gost/log/logger"

    perrors "github.com/pkg/errors"

    api "github.com/polarismesh/polaris-go"
    "github.com/polarismesh/polaris-go/pkg/model"

)

import ( "dubbo.apache.org/dubbo-go/v3/common" "dubbo.apache.org/dubbo-go/v3/common/constant" "dubbo.apache.org/dubbo-go/v3/common/extension" "dubbo.apache.org/dubbo-go/v3/registry" "dubbo.apache.org/dubbo-go/v3/remoting" "dubbo.apache.org/dubbo-go/v3/remoting/polaris" )

const ( RegistryConnDelay = 3 defaultHeartbeatIntervalSec = 5 )

func init() { extension.SetRegistry(constant.PolarisKey, newPolarisRegistry) }

// newPolarisRegistry will create new instance func newPolarisRegistry(url *common.URL) (registry.Registry, error) { if err := polaris.InitSDKContext(url); err != nil { return &polarisRegistry{}, err }

    providerApi, err := polaris.GetProviderAPI()
    if err != nil {
            return nil, err
    }

    consumerApi, err := polaris.GetConsumerAPI()
    if err != nil {
            return nil, err
    }

    pRegistry := &polarisRegistry{
            url:          url,
            namespace:    url.GetParam(constant.RegistryNamespaceKey, constant.PolarisDefaultNamespace),
            provider:     providerApi,
            consumer:     consumerApi,
            registryUrls: make([]*common.URL, 0, 4),
            watchers:     map[string]*PolarisServiceWatcher{},
    }

    return pRegistry, nil

}

type polarisRegistry struct { namespace string url *common.URL consumer api.ConsumerAPI provider api.ProviderAPI lock sync.RWMutex registryUrls []*common.URL listenerLock sync.RWMutex watchers map[string]*PolarisServiceWatcher }

// Register will register the service @url to its polaris registry center. func (pr *polarisRegistry) Register(url *common.URL) error { if getCategory(url) != "providers" { return nil }

    serviceName := url.Interface()
    request := createRegisterParam(url, serviceName)
    request.Namespace = pr.namespace
    resp, err := pr.provider.RegisterInstance(request)
    if err != nil {
            return err
    }

    if resp.Existed {
            logger.Warnf("instance already regist, namespace:%+v, service:%+v, host:%+v, port:%+v",
                    request.Namespace, request.Service, request.Host, request.Port)
    }
    url.SetParam(constant.PolarisInstanceID, resp.InstanceID)

    pr.lock.Lock()
    pr.registryUrls = append(pr.registryUrls, url)
    pr.lock.Unlock()

    return nil

}

dubbogo框架提供服务注册与发现的扩展，目前已经支持与业界主流注册中心对接。 dubbogo完成了 ETCD、ZooKeeper、Eureka、Consul、Nacos、Polaris 多种服务发现模式，当然也支持 DNS 解析以及 Static IP 直连访问模式，建立起了强大且完备的社区生态，供用户按需灵活选用。 更多服务发现组件参看扩展仓库：dubbogo-contrib/registry-nacos

以 DNS Resolver 为例 import (... dns "github.com/dubbogo-contrib/resolver-dns" ) func main() {... client, err := echo.NewClient("echo", client.WithResolver(dns.NewDNSResolver())) if err != nil { log.Fatal(err)} ...}

import ( "github.com/dubbogo/gost/log/logger"

    perrors "github.com/pkg/errors"

    api "github.com/dubbogoContrib-polaris/polaris-go"
    "github.com/polarismesh/polaris-go/pkg/model"

)

import ( "dubbo.apache.org/dubbo-go/v3/common" "dubbo.apache.org/dubbo-go/v3/common/constant" "dubbo.apache.org/dubbo-go/v3/common/extension" "dubbo.apache.org/dubbo-go/v3/registry" "dubbo.apache.org/dubbo-go/v3/remoting" "dubbo.apache.org/dubbo-go/v3/remoting/polaris" ) Copy 具体实现：以polaris为例，设计出以polaris为例的dubbogoContrib-polaris扩展，目前打算先实现dubbogoContrib-polaris扩展后，继续其他扩展。

[mark4z]

听起来不错，不过协议层做扩展形式可能会有些困难，尤其是triple协议

[chuntaojun]

1、能不能在不破坏现有用户的使用方式的情况下，把 dubbogo 的所有扩展点定义单独抽出来成为一个单独的 dubbogo-extensions，所有的插件实现依赖 dubbogo-extensions 2、用户引入插件的方式就和引入 mysql 依赖一样, import _ "xxx" 即可自动启用插件，然后配置文件那一块还是一样走现在的配置

[chickenlj]

我也觉得这个模式不错，可以先往这个方向探索

[chickenlj]

@chuntaojun @jasondeng1997 @mark4z 这个 issue 还是专注在仓库组织的讨论，中间可能涉及一些插件设计机制。

另外一块非常重要的，是关于 dubbo-go 启动加载流程这一块，需要分析出启动过程依赖哪些组件、详细的工作流程，咱们需要那块也同步的做起来，争取能真正在运行层面实现 dubbo-go 的轻量化，可以再起一个 issue 来单独跟进。