关于dubbo:聊聊dubbogo的availableCluster

本文次要钻研一下dubbo-go的availableCluster

NewAvailableCluster

dubbo-go-v1.4.2/cluster/cluster_impl/available_cluster.go

type availableCluster struct{}

const available = "available"

func init() {
    extension.SetCluster(available, NewAvailableCluster)
}

// NewAvailableCluster ...
func NewAvailableCluster() cluster.Cluster {
    return &availableCluster{}
}
  • NewAvailableCluster办法实例化availableCluster

Join

dubbo-go-v1.4.2/cluster/cluster_impl/available_cluster.go

func (cluser *availableCluster) Join(directory cluster.Directory) protocol.Invoker {
    return NewAvailableClusterInvoker(directory)
}
  • Join办法执行NewAvailableClusterInvoker

NewAvailableClusterInvoker

dubbo-go-v1.4.2/cluster/cluster_impl/available_cluster_invoker.go

type availableClusterInvoker struct {
    baseClusterInvoker
}

// NewAvailableClusterInvoker ...
func NewAvailableClusterInvoker(directory cluster.Directory) protocol.Invoker {
    return &availableClusterInvoker{
        baseClusterInvoker: newBaseClusterInvoker(directory),
    }
}
  • NewAvailableClusterInvoker办法实例化availableClusterInvoker

Invoke

dubbo-go-v1.4.2/cluster/cluster_impl/available_cluster_invoker.go

func (invoker *availableClusterInvoker) Invoke(ctx context.Context, invocation protocol.Invocation) protocol.Result {
    invokers := invoker.directory.List(invocation)
    err := invoker.checkInvokers(invokers, invocation)
    if err != nil {
        return &protocol.RPCResult{Err: err}
    }

    err = invoker.checkWhetherDestroyed()
    if err != nil {
        return &protocol.RPCResult{Err: err}
    }

    for _, ivk := range invokers {
        if ivk.IsAvailable() {
            return ivk.Invoke(ctx, invocation)
        }
    }
    return &protocol.RPCResult{Err: errors.New(fmt.Sprintf("no provider available in %v", invokers))}
}
  • Invoke办法先通过invoker.directory.List(invocation)获取invokers,之后遍历invokers,对于ivk.IsAvailable()为true的执行ivk.Invoke(ctx, invocation)

小结

availableCluster的Join办法执行NewAvailableClusterInvoker,而availableClusterInvoker的Invoke办法先通过invoker.directory.List(invocation)获取invokers,之后遍历invokers,对于ivk.IsAvailable()为true的执行ivk.Invoke(ctx, invocation)

doc

  • available_cluster

【腾讯云】轻量 2核2G4M,首年65元

阿里云限时活动-云数据库 RDS MySQL  1核2G配置 1.88/月 速抢

本文由乐趣区整理发布,转载请注明出处,谢谢。

您可能还喜欢...

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注

此站点使用Akismet来减少垃圾评论。了解我们如何处理您的评论数据