模块 org.redkale

程序包 org.redkale.net.sncp

类 SncpRpcGroups

java.lang.Object

org.redkale.net.sncp.SncpRpcGroups

public class SncpRpcGroups
extends Object

协议地址组合对象, 对应application.xml中group节点信息

详情见: https://redkale.org

从以下版本开始:

2.8.0

作者:

zhangjx

字段概要

字段

修饰符和类型	字段	说明
protected ConcurrentHashMap<String,Set<InetSocketAddress>>	sncpClusters
protected ConcurrentHashMap<String,SncpRpcGroup>	sncpRpcGroups

构造器概要

构造器

构造器	说明
SncpRpcGroups()

方法概要

修饰符和类型	方法	说明
SncpRpcGroup	computeIfAbsent(String group, String protocol)
boolean	containsGroup(String group)
String	getGroup(InetSocketAddress address)
SncpRpcGroup	getSncpRpcGroup(String group)
boolean	isLocalGroup(String sncpGroup, InetSocketAddress sncpAddress, ClassFilter.FilterEntry entry)
InetSocketAddress	nextRemoteAddress(String resourceid)
void	putClusterAddress(String resourceid, Set<InetSocketAddress> set)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

sncpRpcGroups

protected final ConcurrentHashMap<String,SncpRpcGroup> sncpRpcGroups

sncpClusters

protected final ConcurrentHashMap<String,Set<InetSocketAddress>> sncpClusters

构造器详细资料

SncpRpcGroups

public SncpRpcGroups()

方法详细资料

getSncpRpcGroup

public SncpRpcGroup getSncpRpcGroup(String group)

containsGroup

public boolean containsGroup(String group)

computeIfAbsent

public SncpRpcGroup computeIfAbsent(String group,
                                    String protocol)

nextRemoteAddress

public InetSocketAddress nextRemoteAddress(String resourceid)

putClusterAddress

public void putClusterAddress(String resourceid,
                              Set<InetSocketAddress> set)

getGroup

public String getGroup(InetSocketAddress address)

isLocalGroup

public boolean isLocalGroup(String sncpGroup,
                            InetSocketAddress sncpAddress,
                            ClassFilter.FilterEntry entry)