mirror of
https://github.com/tiennm99/zfoo.git
synced 2026-10-18 18:15:46 +00:00
perf[net]: 优化负载均衡的日志
This commit is contained in:
1 parent
cfaf5a5557
commit
eafd8bc7a1
3 files changed
+4
-4
No files matched your search
+2
-2
@@ -19,9 +19,9 @@ import com.zfoo.net.session.model.Session;
|
|||||||
import com.zfoo.protocol.IPacket;
|
import com.zfoo.protocol.IPacket;
|
||||||
import com.zfoo.protocol.ProtocolManager;
|
import com.zfoo.protocol.ProtocolManager;
|
||||||
import com.zfoo.protocol.collection.CollectionUtils;
|
import com.zfoo.protocol.collection.CollectionUtils;
|
||||||
|
import com.zfoo.protocol.exception.RunException;
|
||||||
import com.zfoo.protocol.model.Pair;
|
import com.zfoo.protocol.model.Pair;
|
||||||
import com.zfoo.protocol.registration.ProtocolModule;
|
import com.zfoo.protocol.registration.ProtocolModule;
|
||||||
import com.zfoo.protocol.util.StringUtils;
|
|
||||||
import com.zfoo.util.math.ConsistentHash;
|
import com.zfoo.util.math.ConsistentHash;
|
||||||
import org.springframework.lang.Nullable;
|
import org.springframework.lang.Nullable;
|
||||||
|
|
||||||
@@ -84,7 +84,7 @@ public class ConsistentHashConsumerLoadBalancer extends AbstractConsumerLoadBala
|
|||||||
consistentHash = updateModuleToConsistentHash(module);
|
consistentHash = updateModuleToConsistentHash(module);
|
||||||
}
|
}
|
||||||
if (consistentHash == null) {
|
if (consistentHash == null) {
|
||||||
throw new RuntimeException(StringUtils.format("没有服务提供者提供服务[{}]", module));
|
throw new RunException("一致性hash负载均衡[protocolId:{}]参数[argument:{}],没有服务提供者提供服务[module:{}]", packet.protocolId(), argument, module);
|
||||||
}
|
}
|
||||||
var sid = consistentHash.getRealNode(argument).getValue();
|
var sid = consistentHash.getRealNode(argument).getValue();
|
||||||
return NetContext.getSessionManager().getClientSession(sid);
|
return NetContext.getSessionManager().getClientSession(sid);
|
||||||
|
|||||||
@@ -42,7 +42,7 @@ public class RandomConsumerLoadBalancer extends AbstractConsumerLoadBalancer {
|
|||||||
var sessions = getSessionsByModule(module);
|
var sessions = getSessionsByModule(module);
|
||||||
|
|
||||||
if (sessions.isEmpty()) {
|
if (sessions.isEmpty()) {
|
||||||
throw new RunException("没有服务提供者提供服务[{}]", module);
|
throw new RunException("一致性hash负载均衡[protocolId:{}]参数[argument:{}],没有服务提供者提供服务[module:{}]", packet.protocolId(), argument, module);
|
||||||
}
|
}
|
||||||
|
|
||||||
return RandomUtils.randomEle(sessions);
|
return RandomUtils.randomEle(sessions);
|
||||||
|
|||||||
+1
-1
@@ -47,7 +47,7 @@ public class ShortestTimeConsumerLoadBalancer extends AbstractConsumerLoadBalanc
|
|||||||
var sessions = getSessionsByModule(module);
|
var sessions = getSessionsByModule(module);
|
||||||
|
|
||||||
if (sessions.isEmpty()) {
|
if (sessions.isEmpty()) {
|
||||||
throw new RunException("没有服务提供者提供服务[{}]", module);
|
throw new RunException("一致性hash负载均衡[protocolId:{}]参数[argument:{}],没有服务提供者提供服务[module:{}]", packet.protocolId(), argument, module);
|
||||||
}
|
}
|
||||||
|
|
||||||
var sortedSessions = sessions.stream()
|
var sortedSessions = sessions.stream()
|
||||||
|
|||||||
Reference in new issue
Block a user