首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >聊聊dubbo-go的broadcastCluster

聊聊dubbo-go的broadcastCluster

作者头像
code4it
发布2020-08-11 10:17:29
3370
发布2020-08-11 10:17:29
举报
文章被收录于专栏:码匠的流水账码匠的流水账

本文主要研究一下dubbo-go的broadcastCluster

broadcastCluster

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

type broadcastCluster struct{}

const broadcast = "broadcast"

func init() {
    extension.SetCluster(broadcast, NewBroadcastCluster)
}

// NewBroadcastCluster ...
func NewBroadcastCluster() cluster.Cluster {
    return &broadcastCluster{}
}

func (cluster *broadcastCluster) Join(directory cluster.Directory) protocol.Invoker {
    return newBroadcastClusterInvoker(directory)
}
  • broadcastCluster的join方法执行newBroadcastClusterInvoker

newBroadcastClusterInvoker

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

type broadcastClusterInvoker struct {
    baseClusterInvoker
}

func newBroadcastClusterInvoker(directory cluster.Directory) protocol.Invoker {
    return &broadcastClusterInvoker{
        baseClusterInvoker: newBaseClusterInvoker(directory),
    }
}
  • newBroadcastClusterInvoker方法实例化broadcastClusterInvoker

Invoke

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

func (invoker *broadcastClusterInvoker) 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}
    }

    var result protocol.Result
    for _, ivk := range invokers {
        result = ivk.Invoke(ctx, invocation)
        if result.Error() != nil {
            logger.Warnf("broadcast invoker invoke err: %v when use invoker: %v\n", result.Error(), ivk)
            err = result.Error()
        }
    }
    if err != nil {
        return &protocol.RPCResult{Err: err}
    }
    return result
}
  • Invoke方法首先通过invoker.directory.List(invocation)获取invokers,之后遍历invokers,挨个执行result = ivk.Invoke(ctx, invocation),如果最后err不为nil,则返回err,否则返回最后的result

小结

broadcastCluster的join方法执行newBroadcastClusterInvoker;其Invoke方法首先通过invoker.directory.List(invocation)获取invokers,之后遍历invokers,挨个执行result = ivk.Invoke(ctx, invocation),如果最后err不为nil,则返回err,否则返回最后的result

doc

  • broadcast_cluster
本文参与 腾讯云自媒体分享计划,分享自微信公众号。
原始发表:2020-08-04,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 码匠的流水账 微信公众号,前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • broadcastCluster
  • newBroadcastClusterInvoker
  • Invoke
  • 小结
  • doc
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档