org.redkale.net

类 TransportFactory

java.lang.Object

org.redkale.net.TransportFactory

public class TransportFactory
extends Object

System.getProperty("net.transport.pinginterval", "30") 心跳周期，默认30秒 System.getProperty("net.transport.checkinterval", "30") 检查不可用地址周期，默认30秒

详情见: https://redkale.org

作者:

zhangjx

字段概要

字段

限定符和类型	字段和说明
protected ObjectPool<ByteBuffer>	bufferPool
protected AsynchronousChannelGroup	channelGroup
protected int	checkinterval
static int	DEFAULT_READTIMEOUTSECONDS
static int	DEFAULT_WRITETIMEOUTSECONDS
protected ExecutorService	executor
protected Map<InetSocketAddress,String>	groupAddrs
protected Map<String,TransportGroupInfo>	groupInfos
protected static Logger	logger
static String	NAME_CHECKINTERVAL
static String	NAME_PINGINTERVAL
static String	NAME_POOLMAXCONNS
protected int	pinginterval
protected int	pongLength
protected int	poolmaxconns
protected int	readTimeoutSeconds
protected List<WeakReference<Service>>	services
protected SSLContext	sslContext
protected TransportStrategy	strategy
protected List<WeakReference<Transport>>	transportReferences
protected int	writeTimeoutSeconds

构造器概要

构造器

限定符	构造器和说明
protected	TransportFactory(ExecutorService executor, ObjectPool<ByteBuffer> bufferPool, AsynchronousChannelGroup channelGroup, SSLContext sslContext, int readTimeoutSeconds, int writeTimeoutSeconds)
protected	TransportFactory(ExecutorService executor, ObjectPool<ByteBuffer> bufferPool, AsynchronousChannelGroup channelGroup, SSLContext sslContext, int readTimeoutSeconds, int writeTimeoutSeconds, TransportStrategy strategy)

方法概要

限定符和类型	方法和说明
boolean	addGroupInfo(String groupName, InetSocketAddress... addrs)
TransportFactory	addGroupInfo(String name, Set<InetSocketAddress> addrs)
boolean	addGroupInfo(TransportGroupInfo info)
void	addSncpService(Service service)
static TransportFactory	create(ExecutorService executor, ObjectPool<ByteBuffer> bufferPool, AsynchronousChannelGroup channelGroup)
static TransportFactory	create(ExecutorService executor, ObjectPool<ByteBuffer> bufferPool, AsynchronousChannelGroup channelGroup, int readTimeoutSeconds, int writeTimeoutSeconds)
static TransportFactory	create(ExecutorService executor, ObjectPool<ByteBuffer> bufferPool, AsynchronousChannelGroup channelGroup, int readTimeoutSeconds, int writeTimeoutSeconds, TransportStrategy strategy)
static TransportFactory	create(ExecutorService executor, ObjectPool<ByteBuffer> bufferPool, AsynchronousChannelGroup channelGroup, SSLContext sslContext)
static TransportFactory	create(ExecutorService executor, ObjectPool<ByteBuffer> bufferPool, AsynchronousChannelGroup channelGroup, SSLContext sslContext, int readTimeoutSeconds, int writeTimeoutSeconds)
static TransportFactory	create(ExecutorService executor, ObjectPool<ByteBuffer> bufferPool, AsynchronousChannelGroup channelGroup, SSLContext sslContext, int readTimeoutSeconds, int writeTimeoutSeconds, TransportStrategy strategy)
static TransportFactory	create(int threads)
static TransportFactory	create(int threads, int bufferPoolSize, int bufferCapacity)
static TransportFactory	create(int threads, int bufferPoolSize, int bufferCapacity, int readTimeoutSeconds, int writeTimeoutSeconds)
Transport	createTransport(String name, String protocol, InetSocketAddress clientAddress, Collection<InetSocketAddress> addresses)
Transport	createTransport(String name, String protocol, String subprotocol, InetSocketAddress clientAddress, Collection<InetSocketAddress> addresses)
Transport	createTransportTCP(String name, InetSocketAddress clientAddress, Collection<InetSocketAddress> addresses)
TransportGroupInfo	findGroupInfo(String group)
String	findGroupName(InetSocketAddress addr)
Supplier<ByteBuffer>	getBufferSupplier()
ExecutorService	getExecutor()
List<TransportGroupInfo>	getGroupInfos()
Logger	getLogger()
List<Service>	getServices()
void	init(AnyValue conf, ByteBuffer pingBuffer, int pongLength)
Transport[]	loadDiffGroupTransports(InetSocketAddress sncpAddress, Set<String> diffGroups)
Transport	loadRemoteTransport(InetSocketAddress sncpAddress, Set<String> groups)
Transport	loadSameGroupTransport(InetSocketAddress sncpAddress)
boolean	removeGroupInfo(String groupName, InetSocketAddress addr)
void	shutdownNow()

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

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

字段详细资料

DEFAULT_READTIMEOUTSECONDS

@Comment(value="\u9ed8\u8ba4TCP\u8bfb\u53d6\u8d85\u65f6\u79d2\u6570")
public static int DEFAULT_READTIMEOUTSECONDS

DEFAULT_WRITETIMEOUTSECONDS

@Comment(value="\u9ed8\u8ba4TCP\u5199\u5165\u8d85\u65f6\u79d2\u6570")
public static int DEFAULT_WRITETIMEOUTSECONDS

NAME_POOLMAXCONNS

public static final String NAME_POOLMAXCONNS

另请参阅:

常量字段值

NAME_PINGINTERVAL

public static final String NAME_PINGINTERVAL

另请参阅:

常量字段值

NAME_CHECKINTERVAL

public static final String NAME_CHECKINTERVAL

另请参阅:

常量字段值

logger

protected static final Logger logger

executor

protected final ExecutorService executor

bufferPool

protected final ObjectPool<ByteBuffer> bufferPool

channelGroup

protected final AsynchronousChannelGroup channelGroup

groupAddrs

protected final Map<InetSocketAddress,String> groupAddrs

groupInfos

protected final Map<String,TransportGroupInfo> groupInfos

services

protected final List<WeakReference<Service>> services

transportReferences

protected final List<WeakReference<Transport>> transportReferences

poolmaxconns

protected int poolmaxconns

checkinterval

protected int checkinterval

pinginterval

protected int pinginterval

readTimeoutSeconds

protected int readTimeoutSeconds

writeTimeoutSeconds

protected int writeTimeoutSeconds

sslContext

protected SSLContext sslContext

pongLength

protected int pongLength

strategy

protected final TransportStrategy strategy

构造器详细资料

TransportFactory

protected TransportFactory(ExecutorService executor,
                           ObjectPool<ByteBuffer> bufferPool,
                           AsynchronousChannelGroup channelGroup,
                           SSLContext sslContext,
                           int readTimeoutSeconds,
                           int writeTimeoutSeconds,
                           TransportStrategy strategy)

TransportFactory

protected TransportFactory(ExecutorService executor,
                           ObjectPool<ByteBuffer> bufferPool,
                           AsynchronousChannelGroup channelGroup,
                           SSLContext sslContext,
                           int readTimeoutSeconds,
                           int writeTimeoutSeconds)

方法详细资料

init

public void init(AnyValue conf,
                 ByteBuffer pingBuffer,
                 int pongLength)

create

public static TransportFactory create(int threads)

create

public static TransportFactory create(int threads,
                                      int bufferPoolSize,
                                      int bufferCapacity)

create

public static TransportFactory create(int threads,
                                      int bufferPoolSize,
                                      int bufferCapacity,
                                      int readTimeoutSeconds,
                                      int writeTimeoutSeconds)

create

public static TransportFactory create(ExecutorService executor,
                                      ObjectPool<ByteBuffer> bufferPool,
                                      AsynchronousChannelGroup channelGroup)

create

public static TransportFactory create(ExecutorService executor,
                                      ObjectPool<ByteBuffer> bufferPool,
                                      AsynchronousChannelGroup channelGroup,
                                      int readTimeoutSeconds,
                                      int writeTimeoutSeconds)

create

public static TransportFactory create(ExecutorService executor,
                                      ObjectPool<ByteBuffer> bufferPool,
                                      AsynchronousChannelGroup channelGroup,
                                      int readTimeoutSeconds,
                                      int writeTimeoutSeconds,
                                      TransportStrategy strategy)

create

public static TransportFactory create(ExecutorService executor,
                                      ObjectPool<ByteBuffer> bufferPool,
                                      AsynchronousChannelGroup channelGroup,
                                      SSLContext sslContext)

create

public static TransportFactory create(ExecutorService executor,
                                      ObjectPool<ByteBuffer> bufferPool,
                                      AsynchronousChannelGroup channelGroup,
                                      SSLContext sslContext,
                                      int readTimeoutSeconds,
                                      int writeTimeoutSeconds)

create

public static TransportFactory create(ExecutorService executor,
                                      ObjectPool<ByteBuffer> bufferPool,
                                      AsynchronousChannelGroup channelGroup,
                                      SSLContext sslContext,
                                      int readTimeoutSeconds,
                                      int writeTimeoutSeconds,
                                      TransportStrategy strategy)

createTransportTCP

public Transport createTransportTCP(String name,
                                    InetSocketAddress clientAddress,
                                    Collection<InetSocketAddress> addresses)

createTransport

public Transport createTransport(String name,
                                 String protocol,
                                 InetSocketAddress clientAddress,
                                 Collection<InetSocketAddress> addresses)

createTransport

public Transport createTransport(String name,
                                 String protocol,
                                 String subprotocol,
                                 InetSocketAddress clientAddress,
                                 Collection<InetSocketAddress> addresses)

findGroupName

public String findGroupName(InetSocketAddress addr)

findGroupInfo

public TransportGroupInfo findGroupInfo(String group)

addGroupInfo

public boolean addGroupInfo(String groupName,
                            InetSocketAddress... addrs)

removeGroupInfo

public boolean removeGroupInfo(String groupName,
                               InetSocketAddress addr)

addGroupInfo

public TransportFactory addGroupInfo(String name,
                                     Set<InetSocketAddress> addrs)

addGroupInfo

public boolean addGroupInfo(TransportGroupInfo info)

loadSameGroupTransport

public Transport loadSameGroupTransport(InetSocketAddress sncpAddress)

loadDiffGroupTransports

public Transport[] loadDiffGroupTransports(InetSocketAddress sncpAddress,
                                           Set<String> diffGroups)

loadRemoteTransport

public Transport loadRemoteTransport(InetSocketAddress sncpAddress,
                                     Set<String> groups)

getExecutor

public ExecutorService getExecutor()

getBufferSupplier

public Supplier<ByteBuffer> getBufferSupplier()

getGroupInfos

public List<TransportGroupInfo> getGroupInfos()

getLogger

public Logger getLogger()

addSncpService

public void addSncpService(Service service)

getServices

public List<Service> getServices()

shutdownNow

public void shutdownNow()