org.redkale.net

类 TransportFactory

java.lang.Object

org.redkale.net.TransportFactory

直接已知子类:

SncpTransportFactory

public class TransportFactory
extends java.lang.Object

作者:

zhangjx

字段概要

字段

限定符和类型	字段和说明
protected ObjectPool<java.nio.ByteBuffer>	bufferPool
protected java.nio.channels.AsynchronousChannelGroup	channelGroup
protected java.util.concurrent.ExecutorService	executor
protected java.util.Map<java.net.InetSocketAddress,java.lang.String>	groupAddrs
protected java.util.Map<java.lang.String,TransportGroupInfo>	groupInfos
protected static java.util.logging.Logger	logger

构造器概要

构造器

构造器和说明
TransportFactory(java.util.concurrent.ExecutorService executor, ObjectPool<java.nio.ByteBuffer> bufferPool, java.nio.channels.AsynchronousChannelGroup channelGroup)

方法概要

限定符和类型	方法和说明
TransportFactory	addGroupInfo(java.lang.String name, java.net.InetSocketAddress... addrs)
TransportFactory	addGroupInfo(java.lang.String name, java.util.Set<java.net.InetSocketAddress> addrs)
boolean	addGroupInfo(TransportGroupInfo info)
TransportGroupInfo	findGroupInfo2(java.lang.String group)
java.lang.String	findGroupName(java.net.InetSocketAddress addr)
java.util.concurrent.ExecutorService	getExecutor()
Transport[]	loadDiffGroupTransports(java.net.InetSocketAddress sncpAddress, java.util.Set<java.lang.String> diffGroups)
Transport	loadRemoteTransport(java.net.InetSocketAddress sncpAddress, java.util.Set<java.lang.String> groups)
Transport	loadSameGroupTransport(java.net.InetSocketAddress sncpAddress)
void	shutdownNow()

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

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

字段详细资料

logger

protected static final java.util.logging.Logger logger

executor

protected final java.util.concurrent.ExecutorService executor

bufferPool

protected final ObjectPool<java.nio.ByteBuffer> bufferPool

channelGroup

protected final java.nio.channels.AsynchronousChannelGroup channelGroup

groupAddrs

protected final java.util.Map<java.net.InetSocketAddress,java.lang.String> groupAddrs

groupInfos

protected final java.util.Map<java.lang.String,TransportGroupInfo> groupInfos

构造器详细资料

TransportFactory

public TransportFactory(java.util.concurrent.ExecutorService executor,
                        ObjectPool<java.nio.ByteBuffer> bufferPool,
                        java.nio.channels.AsynchronousChannelGroup channelGroup)

方法详细资料

findGroupName

public java.lang.String findGroupName(java.net.InetSocketAddress addr)

findGroupInfo2

public TransportGroupInfo findGroupInfo2(java.lang.String group)

addGroupInfo

public TransportFactory addGroupInfo(java.lang.String name,
                                     java.net.InetSocketAddress... addrs)

addGroupInfo

public TransportFactory addGroupInfo(java.lang.String name,
                                     java.util.Set<java.net.InetSocketAddress> addrs)

addGroupInfo

public boolean addGroupInfo(TransportGroupInfo info)

loadSameGroupTransport

public Transport loadSameGroupTransport(java.net.InetSocketAddress sncpAddress)

loadDiffGroupTransports

public Transport[] loadDiffGroupTransports(java.net.InetSocketAddress sncpAddress,
                                           java.util.Set<java.lang.String> diffGroups)

loadRemoteTransport

public Transport loadRemoteTransport(java.net.InetSocketAddress sncpAddress,
                                     java.util.Set<java.lang.String> groups)

getExecutor

public java.util.concurrent.ExecutorService getExecutor()

shutdownNow

public void shutdownNow()