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 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) |
public static final java.lang.String DEFAULT_PROTOCOL
protected final java.util.concurrent.atomic.AtomicInteger seq
protected final TransportFactory factory
protected final java.lang.String name
protected final java.lang.String subprotocol
protected final boolean tcp
protected final java.lang.String protocol
protected final java.nio.channels.AsynchronousChannelGroup group
protected final java.net.InetSocketAddress clientAddress
protected Transport.TransportNode[] transportNodes
protected final ObjectPool<java.nio.ByteBuffer> bufferPool
protected final javax.net.ssl.SSLContext sslContext
protected final 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)
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)
public final java.net.InetSocketAddress[] updateRemoteAddresses(java.util.Collection<java.net.InetSocketAddress> addresses)
public final boolean addRemoteAddresses(java.net.InetSocketAddress addr)
public final boolean removeRemoteAddresses(java.net.InetSocketAddress addr)
public java.lang.String getName()
public java.lang.String getSubprotocol()
public void close()
public java.net.InetSocketAddress getClientAddress()
public Transport.TransportNode[] getTransportNodes()
public Transport.TransportNode findTransportNode(java.net.SocketAddress addr)
public java.net.InetSocketAddress[] getRemoteAddresses()
public java.lang.String toString()
toString
在类中 java.lang.Object
public java.nio.ByteBuffer pollBuffer()
public java.util.function.Supplier<java.nio.ByteBuffer> getBufferSupplier()
public void offerBuffer(java.nio.ByteBuffer buffer)
public void offerBuffer(java.nio.ByteBuffer... buffers)
public java.nio.channels.AsynchronousChannelGroup getTransportChannelGroup()
public boolean isTCP()
public java.util.concurrent.CompletableFuture<AsyncConnection> pollConnection(java.net.SocketAddress addr0)
public void offerConnection(boolean forceClose, AsyncConnection conn)
public <A> void async(java.net.SocketAddress addr, java.nio.ByteBuffer buffer, A att, java.nio.channels.CompletionHandler<java.lang.Integer,A> handler)