TagRouter的stream操作导致ConsistentHashLoadBalance每次都需要重新进行hash环的映射。

[thisiswanghy]

Environment

• Dubbo version: 2.7.4.1

ConsistentHashLoadBalance 用到了 System.identityHashCode(invokers); 来判断 hash 值，从而判断是否有服务端的上下线操作。
而TagRouter的org.apache.dubbo.rpc.cluster.router.tag.TagRouter#filterUsingStaticTag方法中的 stream 操作会修改 invokers 的值，所以 ConsistentHashLoadBalance 受到了影响。
导致即使在服务端没有上下线操作的时候，一致性hash负载均衡算法每次都需要重新进行hash环的映射。

[thisiswanghy]

#5424

[CodingSinger]

i think should replace java.lang.System#identityHashCode with hashCode .
@chickenlj
what's your opinion？

[thisiswanghy]

https://mp.weixin.qq.com/s/ctBM0WO-uWNlTWHI-TPniw
bug的详细描述

[kimmking]

@CodingSinger I commit some comments for your bugfix.

[LinShunKang]

@beiwei30
In Dubbo 2.6.x branch, there is the same problem，TagRouter always return new List<Invoker<T>>:

dubbo/dubbo-cluster/src/main/java/com/alibaba/dubbo/rpc/cluster/loadbalance/ConsistentHashLoadBalance.java

Line 47 in c894e06

int identityHashCode = System.identityHashCode(invokers);

dubbo/dubbo-cluster/src/main/java/com/alibaba/dubbo/rpc/cluster/router/tag/TagRouter.java

Lines 50 to 76 in c894e06

	public <T> List<Invoker<T>> route(List<Invoker<T>> invokers, URL url, Invocation invocation) throws RpcException {
	// filter
	List<Invoker<T>> result = new ArrayList<Invoker<T>>();
	// Dynamic param
	String tag = RpcContext.getContext().getAttachment(Constants.TAG_KEY);
	// Tag request
	if (!StringUtils.isEmpty(tag)) {
	// Select tag invokers first
	for (Invoker<T> invoker : invokers) {
	if (tag.equals(invoker.getUrl().getParameter(Constants.TAG_KEY))) {
	result.add(invoker);
	}
	}
	}
	// If Constants.REQUEST_TAG_KEY unspecified or no invoker be selected, downgrade to normal invokers
	if (result.isEmpty()) {
	// Only forceTag = true force match, otherwise downgrade
	String forceTag = RpcContext.getContext().getAttachment(Constants.FORCE_USE_TAG);
	if (StringUtils.isEmpty(forceTag) || "false".equals(forceTag)) {
	for (Invoker<T> invoker : invokers) {
	if (StringUtils.isEmpty(invoker.getUrl().getParameter(Constants.TAG_KEY))) {
	result.add(invoker);
	}
	}
	}
	}
	return result;