From c590ccf87aa96c1f7dd17f803884739dc80c3736 Mon Sep 17 00:00:00 2001 From: qiaomr <1393092021@qq.com> Date: Sat, 6 Jan 2024 14:29:46 +0800 Subject: [PATCH] =?UTF-8?q?=E8=8E=B7=E5=8F=96=20memory?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ConsistentHashOfMemoryConsumerLoadBalancer.java | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/net/src/main/java/com/zfoo/net/consumer/balancer/ConsistentHashOfMemoryConsumerLoadBalancer.java b/net/src/main/java/com/zfoo/net/consumer/balancer/ConsistentHashOfMemoryConsumerLoadBalancer.java index 1167336c..8e8fb365 100644 --- a/net/src/main/java/com/zfoo/net/consumer/balancer/ConsistentHashOfMemoryConsumerLoadBalancer.java +++ b/net/src/main/java/com/zfoo/net/consumer/balancer/ConsistentHashOfMemoryConsumerLoadBalancer.java @@ -2,8 +2,12 @@ package com.zfoo.net.consumer.balancer; import com.zfoo.net.NetContext; import com.zfoo.net.session.Session; +import org.apache.curator.shaded.com.google.common.collect.Lists; import org.apache.curator.shaded.com.google.common.util.concurrent.AtomicLongMap; +import java.util.List; +import java.util.Map; + /** * 记忆化一致性hash * @@ -46,4 +50,8 @@ public class ConsistentHashOfMemoryConsumerLoadBalancer extends ConsistentHashCo } return loadBalancer; } + + public static Map getUid2sidMap(){ + return uid2sidMap.asMap(); + } }