聊聊dubbo-go的roundRobinLoadBalance

2020-08-13
阅读 3 分钟
1k
roundRobinLoadBalance的NewRoundRobinLoadBalance方法创建了roundRobinLoadBalance

聊聊dubbo-go的randomLoadBalance

2020-08-12
阅读 2 分钟
1.4k
序本文主要研究一下dubbo-go的randomLoadBalancerandomLoadBalancedubbo-go-v1.4.2/cluster/loadbalance/random.go {代码...} randomLoadBalance的NewRandomLoadBalance方法创建randomLoadBalanceSelectdubbo-go-v1.4.2/cluster/loadbalance/random.go {代码...} Select方法先判断invokers数量,若只有一个则返回invoker...

聊聊dubbo-go的leastActiveLoadBalance

2020-08-11
阅读 4 分钟
1.1k
leastActiveLoadBalance的NewLeastActiveLoadBalance方法创建leastActiveLoadBalance

聊聊dubbo-go的ConsistentHashLoadBalance

2020-08-10
阅读 5 分钟
1.3k
ConsistentHashLoadBalance的init方法设置了名为consistenthash的ConsistentHashLoadBalance到extension中

聊聊dubbo-go的registryAwareCluster

2020-08-09
阅读 2 分钟
1.1k
registryAwareCluster的Join方法执行newRegistryAwareClusterInvoker(directory)

聊聊dubbo-go的failsafeCluster

2020-08-08
阅读 3 分钟
1.2k
序本文主要研究一下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的forkingCluster

2020-08-07
阅读 4 分钟
1k
序本文主要研究一下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的failfastCluster

2020-08-06
阅读 5 分钟
987
序本文主要研究一下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的failbackCluster

2020-08-05
阅读 7 分钟
920
序本文主要研究一下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的broadcastCluster

2020-08-04
阅读 2 分钟
1.1k
序本文主要研究一下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的availableCluster

2020-08-03
阅读 2 分钟
1k
序本文主要研究一下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...

聊聊dubbo-go的DefaultHealthChecker

2020-08-02
阅读 5 分钟
1.5k
DefaultHealthChecker定义了outStandingRequestConutLimit、requestSuccessiveFailureThreshold、circuitTrippedTimeoutFactor属性

聊聊dubbo-go的apolloConfiguration

2020-08-01
阅读 4 分钟
1.4k
序本文主要研究一下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...

聊聊dubbo-go的PrometheusReporter

2020-07-31
阅读 6 分钟
1.1k
PrometheusReporter定义了consumerSummaryVec、providerSummaryVec、providerHistogramVec、consumerHistogramVec

聊聊dubbo-go的kubernetesRegistry

2020-07-30
阅读 3 分钟
1.7k
kubernetesRegistry定义了cltLock、client、listenerLock、listener、dataListener、configListener属性

聊聊dubbo-go的nacosRegistry

2020-07-29
阅读 5 分钟
1.4k
序本文主要研究一下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

2020-07-28
阅读 3 分钟
1k
序 本文只要研究一下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的DubboProtocol

2020-07-27
阅读 4 分钟
1.1k
序本文主要研究一下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...

聊聊dubbo-go的DubboInvoker

2020-07-26
阅读 5 分钟
1.2k
Invoker定义了Invoke方法;BaseInvoker定义了url、available、destroyed属性;NewBaseInvoker方法实例化了BaseInvoker,其available为true,destroyed为false;Destroy方法设置available为false,destroyed为true

聊聊dubbo-go的RPCInvocation

2020-07-25
阅读 4 分钟
1.8k
Invocation定义了MethodName、ParameterTypes、ParameterValues、Arguments、Reply、Attachments、AttachmentsByKey、Invoker方法

聊聊dubbo-go的ProviderAuthFilter

2020-07-24
阅读 4 分钟
1k
序 本文主要研究一下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

2020-07-23
阅读 4 分钟
943
序 本文主要研究一下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

2020-07-22
阅读 3 分钟
1.1k
序 本文主要研究一下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

2020-07-21
阅读 3 分钟
976
序 本文主要研究一下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的HystrixFilter

2020-07-20
阅读 6 分钟
1.1k
序本文主要研究一下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

2020-07-19
阅读 2 分钟
1k
序 本文主要研究一下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

2020-07-18
阅读 2 分钟
910
序 本文主要研究一下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的GenericFilter

2020-07-17
阅读 4 分钟
1.6k
序本文主要研究一下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

2020-07-16
阅读 3 分钟
1.5k
序 本文主要研究一下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的EchoFilter

2020-07-15
阅读 2 分钟
1.2k
序本文主要研究一下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...