org.redkale.net

类 Transport

java.lang.Object

org.redkale.net.Transport

public final class Transport
extends java.lang.Object

传输客户端

详情见: https://redkale.org

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	Transport.TransportNode

字段概要

字段

限定符和类型	字段和说明
protected ObjectPool<java.nio.ByteBuffer>	bufferPool
protected java.net.InetSocketAddress	clientAddress
static java.lang.String	DEFAULT_PROTOCOL
protected TransportFactory	factory
protected java.nio.channels.AsynchronousChannelGroup	group
protected java.lang.String	name
protected java.lang.String	protocol
protected java.util.concurrent.atomic.AtomicInteger	seq
protected javax.net.ssl.SSLContext	sslContext
protected TransportStrategy	strategy
protected java.lang.String	subprotocol
protected static boolean	supportTcpNoDelay
protected boolean	tcp
protected Transport.TransportNode[]	transportNodes

构造器概要

构造器

限定符	构造器和说明
protected	Transport(java.lang.String name, java.lang.String protocol, java.lang.String subprotocol, TransportFactory factory, ObjectPool<java.nio.ByteBuffer> transportBufferPool, java.nio.channels.AsynchronousChannelGroup transportChannelGroup, javax.net.ssl.SSLContext sslContext, java.net.InetSocketAddress clientAddress, java.util.Collection<java.net.InetSocketAddress> addresses, TransportStrategy strategy)
protected	Transport(java.lang.String name, java.lang.String subprotocol, TransportFactory factory, ObjectPool<java.nio.ByteBuffer> transportBufferPool, java.nio.channels.AsynchronousChannelGroup transportChannelGroup, javax.net.ssl.SSLContext sslContext, java.net.InetSocketAddress clientAddress, java.util.Collection<java.net.InetSocketAddress> addresses, TransportStrategy strategy)

方法概要

限定符和类型	方法和说明
boolean	addRemoteAddresses(java.net.InetSocketAddress addr)
<A> void	async(java.net.SocketAddress addr, java.nio.ByteBuffer buffer, A att, java.nio.channels.CompletionHandler<java.lang.Integer,A> handler)
void	close()
Transport.TransportNode	findTransportNode(java.net.SocketAddress addr)
java.util.function.Supplier<java.nio.ByteBuffer>	getBufferSupplier()
java.net.InetSocketAddress	getClientAddress()
java.lang.String	getName()
java.net.InetSocketAddress[]	getRemoteAddresses()
java.lang.String	getSubprotocol()
java.nio.channels.AsynchronousChannelGroup	getTransportChannelGroup()
Transport.TransportNode[]	getTransportNodes()
boolean	isTCP()
void	offerBuffer(java.nio.ByteBuffer... buffers)
void	offerBuffer(java.nio.ByteBuffer buffer)
void	offerConnection(boolean forceClose, AsyncConnection conn)
java.nio.ByteBuffer	pollBuffer()
java.util.concurrent.CompletableFuture<AsyncConnection>	pollConnection(java.net.SocketAddress addr0)
boolean	removeRemoteAddresses(java.net.InetSocketAddress addr)
java.lang.String	toString()
java.net.InetSocketAddress[]	updateRemoteAddresses(java.util.Collection<java.net.InetSocketAddress> addresses)

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

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

字段详细资料

DEFAULT_PROTOCOL

public static final java.lang.String DEFAULT_PROTOCOL

另请参阅:

常量字段值

supportTcpNoDelay

protected static final boolean supportTcpNoDelay

seq

protected final java.util.concurrent.atomic.AtomicInteger seq

factory

protected final TransportFactory factory

name

protected final java.lang.String name

subprotocol

protected final java.lang.String subprotocol

tcp

protected final boolean tcp

protocol

protected final java.lang.String protocol

group

protected final java.nio.channels.AsynchronousChannelGroup group

clientAddress

protected final java.net.InetSocketAddress clientAddress

transportNodes

protected Transport.TransportNode[] transportNodes

bufferPool

protected final ObjectPool<java.nio.ByteBuffer> bufferPool

sslContext

protected final javax.net.ssl.SSLContext sslContext

strategy

protected final TransportStrategy strategy

构造器详细资料

Transport

protected Transport(java.lang.String name,
                    java.lang.String subprotocol,
                    TransportFactory factory,
                    ObjectPool<java.nio.ByteBuffer> transportBufferPool,
                    java.nio.channels.AsynchronousChannelGroup transportChannelGroup,
                    javax.net.ssl.SSLContext sslContext,
                    java.net.InetSocketAddress clientAddress,
                    java.util.Collection<java.net.InetSocketAddress> addresses,
                    TransportStrategy strategy)

Transport

protected Transport(java.lang.String name,
                    java.lang.String protocol,
                    java.lang.String subprotocol,
                    TransportFactory factory,
                    ObjectPool<java.nio.ByteBuffer> transportBufferPool,
                    java.nio.channels.AsynchronousChannelGroup transportChannelGroup,
                    javax.net.ssl.SSLContext sslContext,
                    java.net.InetSocketAddress clientAddress,
                    java.util.Collection<java.net.InetSocketAddress> addresses,
                    TransportStrategy strategy)

方法详细资料

updateRemoteAddresses

public final java.net.InetSocketAddress[] updateRemoteAddresses(java.util.Collection<java.net.InetSocketAddress> addresses)

addRemoteAddresses

public final boolean addRemoteAddresses(java.net.InetSocketAddress addr)

removeRemoteAddresses

public final boolean removeRemoteAddresses(java.net.InetSocketAddress addr)

getName

public java.lang.String getName()

getSubprotocol

public java.lang.String getSubprotocol()

close

public void close()

getClientAddress

public java.net.InetSocketAddress getClientAddress()

getTransportNodes

public Transport.TransportNode[] getTransportNodes()

findTransportNode

public Transport.TransportNode findTransportNode(java.net.SocketAddress addr)

getRemoteAddresses

public java.net.InetSocketAddress[] getRemoteAddresses()

toString

public java.lang.String toString()

覆盖:

toString 在类中 java.lang.Object

pollBuffer

public java.nio.ByteBuffer pollBuffer()

getBufferSupplier

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

offerBuffer

public void offerBuffer(java.nio.ByteBuffer buffer)

offerBuffer

public void offerBuffer(java.nio.ByteBuffer... buffers)

getTransportChannelGroup

public java.nio.channels.AsynchronousChannelGroup getTransportChannelGroup()

isTCP

public boolean isTCP()

pollConnection

public java.util.concurrent.CompletableFuture<AsyncConnection> pollConnection(java.net.SocketAddress addr0)

offerConnection

public void offerConnection(boolean forceClose,
                            AsyncConnection conn)

async

public <A> void async(java.net.SocketAddress addr,
                      java.nio.ByteBuffer buffer,
                      A att,
                      java.nio.channels.CompletionHandler<java.lang.Integer,A> handler)