org.redkale.net

类 Transport

java.lang.Object

org.redkale.net.Transport

public final class Transport
extends Object

传输客户端

详情见: https://redkale.org

作者:

zhangjx

嵌套类概要

嵌套类

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

字段概要

字段

限定符和类型	字段和说明
protected ObjectPool<ByteBuffer>	bufferPool
protected InetSocketAddress	clientAddress
static String	DEFAULT_PROTOCOL
protected TransportFactory	factory
protected AsynchronousChannelGroup	group
protected String	name
protected String	protocol
protected AtomicInteger	seq
protected SSLContext	sslContext
protected TransportStrategy	strategy
protected String	subprotocol
protected boolean	tcp
protected Transport.TransportNode[]	transportNodes

构造器概要

构造器

限定符	构造器和说明
protected	Transport(String name, String protocol, String subprotocol, TransportFactory factory, ObjectPool<ByteBuffer> transportBufferPool, AsynchronousChannelGroup transportChannelGroup, SSLContext sslContext, InetSocketAddress clientAddress, Collection<InetSocketAddress> addresses, TransportStrategy strategy)
protected	Transport(String name, String subprotocol, TransportFactory factory, ObjectPool<ByteBuffer> transportBufferPool, AsynchronousChannelGroup transportChannelGroup, SSLContext sslContext, InetSocketAddress clientAddress, Collection<InetSocketAddress> addresses, TransportStrategy strategy)

方法概要

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

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

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

字段详细资料

DEFAULT_PROTOCOL

public static final String DEFAULT_PROTOCOL

另请参阅:

常量字段值

seq

protected final AtomicInteger seq

factory

protected final TransportFactory factory

name

protected final String name

subprotocol

protected final String subprotocol

tcp

protected final boolean tcp

protocol

protected final String protocol

group

protected final AsynchronousChannelGroup group

clientAddress

protected final InetSocketAddress clientAddress

transportNodes

protected Transport.TransportNode[] transportNodes

bufferPool

protected final ObjectPool<ByteBuffer> bufferPool

sslContext

protected final SSLContext sslContext

strategy

protected final TransportStrategy strategy

构造器详细资料

Transport

protected Transport(String name,
                    String subprotocol,
                    TransportFactory factory,
                    ObjectPool<ByteBuffer> transportBufferPool,
                    AsynchronousChannelGroup transportChannelGroup,
                    SSLContext sslContext,
                    InetSocketAddress clientAddress,
                    Collection<InetSocketAddress> addresses,
                    TransportStrategy strategy)

Transport

protected Transport(String name,
                    String protocol,
                    String subprotocol,
                    TransportFactory factory,
                    ObjectPool<ByteBuffer> transportBufferPool,
                    AsynchronousChannelGroup transportChannelGroup,
                    SSLContext sslContext,
                    InetSocketAddress clientAddress,
                    Collection<InetSocketAddress> addresses,
                    TransportStrategy strategy)

方法详细资料

updateRemoteAddresses

public final InetSocketAddress[] updateRemoteAddresses(Collection<InetSocketAddress> addresses)

addRemoteAddresses

public final boolean addRemoteAddresses(InetSocketAddress addr)

removeRemoteAddresses

public final boolean removeRemoteAddresses(InetSocketAddress addr)

getName

public String getName()

getSubprotocol

public String getSubprotocol()

close

public void close()

getClientAddress

public InetSocketAddress getClientAddress()

getTransportNodes

public Transport.TransportNode[] getTransportNodes()

findTransportNode

public Transport.TransportNode findTransportNode(SocketAddress addr)

getRemoteAddresses

public InetSocketAddress[] getRemoteAddresses()

toString

public String toString()

覆盖:

toString 在类中 Object

pollBuffer

public ByteBuffer pollBuffer()

getBufferSupplier

public Supplier<ByteBuffer> getBufferSupplier()

offerBuffer

public void offerBuffer(ByteBuffer buffer)

offerBuffer

public void offerBuffer(ByteBuffer... buffers)

getTransportChannelGroup

public AsynchronousChannelGroup getTransportChannelGroup()

isTCP

public boolean isTCP()

pollConnection

public CompletableFuture<AsyncConnection> pollConnection(SocketAddress addr0)

offerConnection

public void offerConnection(boolean forceClose,
                            AsyncConnection conn)

async

public <A> void async(SocketAddress addr,
                      ByteBuffer buffer,
                      A att,
                      CompletionHandler<Integer,A> handler)