leastActiveLoadBalance的NewLeastActiveLoadBalance方法创建leastActiveLoadBalance

ConsistentHashLoadBalance的init方法设置了名为consistenthash的ConsistentHashLoadBalance到extension中

registryAwareCluster的Join方法执行newRegistryAwareClusterInvoker(directory)

序本文主要研究一下dubbo-go的failsafeClusterfailsafeClusterdubbo-go-v1.4.2/cluster/cluster_impl/failsafe_cluster.go {代码...} failsafeCluster的join方法执行newFailsafeClusterInvokernewFailsafeClusterInvokerdubbo-go-v1.4.2/cluster/cluster_impl/failsafe_cluster_invoker.go {代码...} newFailsafeCluster...

序本文主要研究一下dubbo-go的forkingClusterforkingClusterdubbo-go-v1.4.2/cluster/cluster_impl/forking_cluster.go {代码...} forkingCluster的Join方法执行newForkingClusterInvokernewForkingClusterInvokerdubbo-go-v1.4.2/cluster/cluster_impl/forking_cluster_invoker.go {代码...} newForkingClusterInvoker...

序本文主要研究一下dubbo-go的failfastClusterfailfastClusterdubbo-go-v1.4.2/cluster/cluster_impl/failfast_cluster.go {代码...} failfastCluster的Join方法执行newFailFastClusterInvoker(directory)newFailFastClusterInvokerdubbo-go-v1.4.2/cluster/cluster_impl/failfast_cluster_invoker.go {代码...} newFail...

序本文主要研究一下dubbo-go的failbackClusterfailbackClusterdubbo-go-v1.4.2/cluster/cluster_impl/failback_cluster.go {代码...} failbackCluster的join方法执行newFailbackClusterInvokernewFailbackClusterInvokerdubbo-go-v1.4.2/cluster/cluster_impl/failback_cluster_invoker.go {代码...} newFailbackCluster...

序本文主要研究一下dubbo-go的broadcastClusterbroadcastClusterdubbo-go-v1.4.2/cluster/cluster_impl/broadcast_cluster.go {代码...} broadcastCluster的join方法执行newBroadcastClusterInvokernewBroadcastClusterInvokerdubbo-go-v1.4.2/cluster/cluster_impl/broadcast_cluster_invoker.go {代码...} newBroadcas...

序本文主要研究一下dubbo-go的availableClusterNewAvailableClusterdubbo-go-v1.4.2/cluster/cluster_impl/available_cluster.go {代码...} NewAvailableCluster方法实例化availableClusterJoindubbo-go-v1.4.2/cluster/cluster_impl/available_cluster.go {代码...} Join方法执行NewAvailableClusterInvokerNewAvailabl...

DefaultHealthChecker定义了outStandingRequestConutLimit、requestSuccessiveFailureThreshold、circuitTrippedTimeoutFactor属性

序本文主要研究一下dubbo-go的apolloConfigurationapolloConfigurationdubbo-go-v1.4.2/config_center/apollo/impl.go {代码...} apolloConfiguration定义了url、listeners、appConf、parser属性newApolloConfigurationdubbo-go-v1.4.2/config_center/apollo/impl.go {代码...} newApolloConfiguration方法创建AppConfig...

PrometheusReporter定义了consumerSummaryVec、providerSummaryVec、providerHistogramVec、consumerHistogramVec

kubernetesRegistry定义了cltLock、client、listenerLock、listener、dataListener、configListener属性

序本文主要研究一下dubbo-go的nacosRegistrynacosRegistrydubbo-go-v1.4.2/registry/nacos/registry.go {代码...} nacosRegistry定义了common.URL、namingClient属性newNacosRegistrydubbo-go-v1.4.2/registry/nacos/registry.go {代码...} newNacosRegistry方法先通过getNacosConfig获取nacosConfig，之后通过clients.C...

序 本文只要研究一下dubbo-go的DubboPackage DubboPackage dubbo-go-v1.4.2/protocol/dubbo/codec.go {代码...} DubboPackage定义了Header、Service、Body、Err属性 Marshal dubbo-go-v1.4.2/protocol/dubbo/codec.go {代码...} Marshal方法通过hessian.NewHessianCodec(nil)创建codec，之后执行bytes.NewBuffer(pkg) Un...

序本文主要研究一下dubbo-go的DubboProtocolDubboProtocoldubbo-go-v1.4.2/protocol/dubbo/dubbo_protocol.go {代码...} DubboProtocol嵌套了protocol.BaseProtocol，定义了serverMap、serverLock属性GetProtocoldubbo-go-v1.4.2/protocol/dubbo/dubbo_protocol.go {代码...} GetProtocol方法通过NewDubboProtocol创建du...

Invoker定义了Invoke方法；BaseInvoker定义了url、available、destroyed属性；NewBaseInvoker方法实例化了BaseInvoker，其available为true，destroyed为false；Destroy方法设置available为false，destroyed为true

Invocation定义了MethodName、ParameterTypes、ParameterValues、Arguments、Reply、Attachments、AttachmentsByKey、Invoker方法

序 本文主要研究一下dubbo-go的ProviderAuthFilter ProviderAuthFilter dubbo-go-v1.4.2/filter/filter_impl/auth/provider_auth.go {代码...} ProviderAuthFilter的init方法设置了getProviderAuthFilter getProviderAuthFilter dubbo-go-v1.4.2/filter/filter_impl/auth/provider_auth.go {代码...} getProviderAuthFil...

序 本文主要研究一下dubbo-go的ConsumerSignFilter ConsumerSignFilter dubbo-go-v1.4.2/filter/filter_impl/auth/consumer_sign.go {代码...} ConsumerSignFilter的init方法设置了getConsumerSignFilter getConsumerSignFilter dubbo-go-v1.4.2/filter/filter_impl/auth/consumer_sign.go {代码...} getConsumerSignFil...

序 本文主要研究一下dubbo-go的tracingFilter tracingFilter dubbo-go-v1.4.2/filter/filter_impl/tracing_filter.go {代码...} tracingFilter的init方法设置了newTracingFilter newTracingFilter dubbo-go-v1.4.2/filter/filter_impl/tracing_filter.go {代码...} newTracingFilter方法实例化tracingFilter Invoke dubb...

序 本文主要研究一下dubbo-go的metricsFilter metricsFilter dubbo-go-v1.4.2/filter/filter_impl/metrics_filter.go {代码...} metricsFilter定义了reporters属性 newMetricsFilter dubbo-go-v1.4.2/filter/filter_impl/metrics_filter.go {代码...} newMetricsFilter方法在metricFilterInstance为null的时候会获取conf...

序本文主要研究一下dubbo-go的HystrixFilterHystrixFilterdubbo-go-v1.4.2/filter/filter_impl/hystrix_filter.go {代码...} HystrixFilter定义了COrP、res、ifNewMap属性Invokedubbo-go-v1.4.2/filter/filter_impl/hystrix_filter.go {代码...} Invoke方法首先通过hf.ifNewMap.LoadOrStore判断该cmdName的circuit break...

序 本文主要研究一下dubbo-go的TokenFilter TokenFilter dubbo-go-v1.4.2/filter/filter_impl/token_filter.go {代码...} TokenFilter的init方法设置了GetTokenFilter GetTokenFilter dubbo-go-v1.4.2/filter/filter_impl/token_filter.go {代码...} GetTokenFilter创建了TokenFilter Invoke dubbo-go-v1.4.2/filter/fil...

序 本文主要研究一下dubbo-go的TpsLimitFilter TpsLimitFilter dubbo-go-v1.4.2/filter/filter_impl/tps_limit_filter.go {代码...} TpsLimitFilter的init设置了GetTpsLimitFilter GetTpsLimitFilter dubbo-go-v1.4.2/filter/filter_impl/tps_limit_filter.go {代码...} GetTpsLimitFilter实例化TpsLimitFilter Invoke d...

序本文主要研究一下dubbo-go的GenericFilterGenericFilterdubbo-go-v1.4.2/filter/filter_impl/generic_filter.go {代码...} GenericFilter的init方法设置了GetGenericFilterGetGenericFilterdubbo-go-v1.4.2/filter/filter_impl/generic_filter.go {代码...} GetGenericFilter方法创建了GenericFilterInvokedubbo-go-v1...

序 本文主要研究一下dubbo-go的gracefulShutdownFilter gracefulShutdownFilter dubbo-go-v1.4.2/filter/filter_impl/graceful_shutdown_filter.go {代码...} gracefulShutdownFilter定义了activeCount、shutdownConfig属性 init dubbo-go-v1.4.2/filter/filter_impl/graceful_shutdown_filter.go {代码...} init方法分...

序本文主要研究一下dubbo-go的EchoFilterEchoFilterdubbo-go-v1.4.2/filter/filter_impl/echo_filter.go {代码...} EchoFilter没有定义属性Invokedubbo-go-v1.4.2/filter/filter_impl/echo_filter.go {代码...} Invoke方法判断invocation.MethodName是否是echo，且有一个参数，是的话则返回protocol.RPCResultOnResponse...

序 本文主要研究一下dubbo-go的AccessLogFilter AccessLogFilter dubbo-go-v1.4.2/filter/filter_impl/access_log_filter.go {代码...} AccessLogFilter定义了AccessLogData类型的chan Invoke dubbo-go-v1.4.2/filter/filter_impl/access_log_filter.go {代码...} Invoke方法首先通过invoker.GetUrl().GetParam获取const...

序 本文主要研究一下rocketmq-client-go的strategy AllocateStrategy rocketmq-client-go-v2.0.0/consumer/strategy.go {代码...} AllocateStrategy定义了一个func AllocateByAveragely rocketmq-client-go-v2.0.0/consumer/strategy.go {代码...} AllocateByAveragely方法会计算averageSize，然后再根据averageSize计算...