org.redkale.net

类 TransportFactory

java.lang.Object

org.redkale.net.TransportFactory

public class TransportFactory
extends java.lang.Object

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

详情见: https://redkale.org

字段概要

字段

限定符和类型	字段和说明
protected ObjectPool<java.nio.ByteBuffer>	bufferPool
protected java.nio.channels.AsynchronousChannelGroup	channelGroup
protected int	checkinterval
static int	DEFAULT_READTIMEOUTSECONDS
static int	DEFAULT_WRITETIMEOUTSECONDS
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
static java.lang.String	NAME_CHECKINTERVAL
static java.lang.String	NAME_PINGINTERVAL
static java.lang.String	NAME_POOLMAXCONNS
protected int	pinginterval
protected int	pongLength
protected int	poolmaxconns
protected int	readTimeoutSeconds
protected java.util.List<java.lang.ref.WeakReference<Service>>	services
protected javax.net.ssl.SSLContext	sslContext
protected TransportStrategy	strategy
protected java.util.List<java.lang.ref.WeakReference<Transport>>	transportReferences
protected int	writeTimeoutSeconds

构造器概要

构造器

限定符	构造器和说明
protected	TransportFactory(java.util.concurrent.ExecutorService executor, ObjectPool<java.nio.ByteBuffer> bufferPool, java.nio.channels.AsynchronousChannelGroup channelGroup, javax.net.ssl.SSLContext sslContext, int readTimeoutSeconds, int writeTimeoutSeconds)
protected	TransportFactory(java.util.concurrent.ExecutorService executor, ObjectPool<java.nio.ByteBuffer> bufferPool, java.nio.channels.AsynchronousChannelGroup channelGroup, javax.net.ssl.SSLContext sslContext, int readTimeoutSeconds, int writeTimeoutSeconds, TransportStrategy strategy)

方法概要

限定符和类型	方法和说明
boolean	addGroupInfo(java.lang.String groupName, java.net.InetSocketAddress... addrs)
TransportFactory	addGroupInfo(java.lang.String name, java.util.Set<java.net.InetSocketAddress> addrs)
boolean	addGroupInfo(TransportGroupInfo info)
void	addSncpService(Service service)
static TransportFactory	create(java.util.concurrent.ExecutorService executor, ObjectPool<java.nio.ByteBuffer> bufferPool, java.nio.channels.AsynchronousChannelGroup channelGroup)
static TransportFactory	create(java.util.concurrent.ExecutorService executor, ObjectPool<java.nio.ByteBuffer> bufferPool, java.nio.channels.AsynchronousChannelGroup channelGroup, int readTimeoutSeconds, int writeTimeoutSeconds)
static TransportFactory	create(java.util.concurrent.ExecutorService executor, ObjectPool<java.nio.ByteBuffer> bufferPool, java.nio.channels.AsynchronousChannelGroup channelGroup, int readTimeoutSeconds, int writeTimeoutSeconds, TransportStrategy strategy)
static TransportFactory	create(java.util.concurrent.ExecutorService executor, ObjectPool<java.nio.ByteBuffer> bufferPool, java.nio.channels.AsynchronousChannelGroup channelGroup, javax.net.ssl.SSLContext sslContext)
static TransportFactory	create(java.util.concurrent.ExecutorService executor, ObjectPool<java.nio.ByteBuffer> bufferPool, java.nio.channels.AsynchronousChannelGroup channelGroup, javax.net.ssl.SSLContext sslContext, int readTimeoutSeconds, int writeTimeoutSeconds)
static TransportFactory	create(java.util.concurrent.ExecutorService executor, ObjectPool<java.nio.ByteBuffer> bufferPool, java.nio.channels.AsynchronousChannelGroup channelGroup, javax.net.ssl.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(java.lang.String name, java.lang.String protocol, java.net.InetSocketAddress clientAddress, java.util.Collection<java.net.InetSocketAddress> addresses)
Transport	createTransport(java.lang.String name, java.lang.String protocol, java.lang.String subprotocol, java.net.InetSocketAddress clientAddress, java.util.Collection<java.net.InetSocketAddress> addresses)
Transport	createTransportTCP(java.lang.String name, java.net.InetSocketAddress clientAddress, java.util.Collection<java.net.InetSocketAddress> addresses)
TransportGroupInfo	findGroupInfo(java.lang.String group)
java.lang.String	findGroupName(java.net.InetSocketAddress addr)
java.util.function.Supplier<java.nio.ByteBuffer>	getBufferSupplier()
java.util.concurrent.ExecutorService	getExecutor()
java.util.List<TransportGroupInfo>	getGroupInfos()
java.util.logging.Logger	getLogger()
java.util.List<Service>	getServices()
void	init(AnyValue conf, java.nio.ByteBuffer pingBuffer, int pongLength)
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)
boolean	removeGroupInfo(java.lang.String groupName, java.net.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 java.lang.String NAME_POOLMAXCONNS

另请参阅:

常量字段值

NAME_PINGINTERVAL

public static final java.lang.String NAME_PINGINTERVAL

另请参阅:

常量字段值

NAME_CHECKINTERVAL

public static final java.lang.String NAME_CHECKINTERVAL

另请参阅:

常量字段值

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

services

protected final java.util.List<java.lang.ref.WeakReference<Service>> services

transportReferences

protected final java.util.List<java.lang.ref.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 javax.net.ssl.SSLContext sslContext

pongLength

protected int pongLength

strategy

protected final TransportStrategy strategy

构造器详细资料

TransportFactory

protected TransportFactory(java.util.concurrent.ExecutorService executor,
                           ObjectPool<java.nio.ByteBuffer> bufferPool,
                           java.nio.channels.AsynchronousChannelGroup channelGroup,
                           javax.net.ssl.SSLContext sslContext,
                           int readTimeoutSeconds,
                           int writeTimeoutSeconds,
                           TransportStrategy strategy)

TransportFactory

protected TransportFactory(java.util.concurrent.ExecutorService executor,
                           ObjectPool<java.nio.ByteBuffer> bufferPool,
                           java.nio.channels.AsynchronousChannelGroup channelGroup,
                           javax.net.ssl.SSLContext sslContext,
                           int readTimeoutSeconds,
                           int writeTimeoutSeconds)

方法详细资料

init

public void init(AnyValue conf,
                 java.nio.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(java.util.concurrent.ExecutorService executor,
                                      ObjectPool<java.nio.ByteBuffer> bufferPool,
                                      java.nio.channels.AsynchronousChannelGroup channelGroup)

create

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

create

public static TransportFactory create(java.util.concurrent.ExecutorService executor,
                                      ObjectPool<java.nio.ByteBuffer> bufferPool,
                                      java.nio.channels.AsynchronousChannelGroup channelGroup,
                                      int readTimeoutSeconds,
                                      int writeTimeoutSeconds,
                                      TransportStrategy strategy)

create

public static TransportFactory create(java.util.concurrent.ExecutorService executor,
                                      ObjectPool<java.nio.ByteBuffer> bufferPool,
                                      java.nio.channels.AsynchronousChannelGroup channelGroup,
                                      javax.net.ssl.SSLContext sslContext)

create

public static TransportFactory create(java.util.concurrent.ExecutorService executor,
                                      ObjectPool<java.nio.ByteBuffer> bufferPool,
                                      java.nio.channels.AsynchronousChannelGroup channelGroup,
                                      javax.net.ssl.SSLContext sslContext,
                                      int readTimeoutSeconds,
                                      int writeTimeoutSeconds)

create

public static TransportFactory create(java.util.concurrent.ExecutorService executor,
                                      ObjectPool<java.nio.ByteBuffer> bufferPool,
                                      java.nio.channels.AsynchronousChannelGroup channelGroup,
                                      javax.net.ssl.SSLContext sslContext,
                                      int readTimeoutSeconds,
                                      int writeTimeoutSeconds,
                                      TransportStrategy strategy)

createTransportTCP

public Transport createTransportTCP(java.lang.String name,
                                    java.net.InetSocketAddress clientAddress,
                                    java.util.Collection<java.net.InetSocketAddress> addresses)

createTransport

public Transport createTransport(java.lang.String name,
                                 java.lang.String protocol,
                                 java.net.InetSocketAddress clientAddress,
                                 java.util.Collection<java.net.InetSocketAddress> addresses)

createTransport

public Transport createTransport(java.lang.String name,
                                 java.lang.String protocol,
                                 java.lang.String subprotocol,
                                 java.net.InetSocketAddress clientAddress,
                                 java.util.Collection<java.net.InetSocketAddress> addresses)

findGroupName

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

findGroupInfo

public TransportGroupInfo findGroupInfo(java.lang.String group)

addGroupInfo

public boolean addGroupInfo(java.lang.String groupName,
                            java.net.InetSocketAddress... addrs)

removeGroupInfo

public boolean removeGroupInfo(java.lang.String groupName,
                               java.net.InetSocketAddress addr)

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()

getBufferSupplier

public java.util.function.Supplier<java.nio.ByteBuffer> getBufferSupplier()

getGroupInfos

public java.util.List<TransportGroupInfo> getGroupInfos()

getLogger

public java.util.logging.Logger getLogger()

addSncpService

public void addSncpService(Service service)

getServices

public java.util.List<Service> getServices()

shutdownNow

public void shutdownNow()