org.redkale.net

类 AsyncConnection

java.lang.Object

org.redkale.net.AsyncConnection

所有已实现的接口:

Closeable, AutoCloseable, AsynchronousByteChannel, AsynchronousChannel, Channel

直接已知子类:

TcpAioAsyncConnection, TcpBioAsyncConnection, TcpNioAsyncConnection, UdpBioAsyncConnection

public abstract class AsyncConnection
extends Object
implements AsynchronousByteChannel, AutoCloseable

详情见: https://redkale.org

作者:

zhangjx

字段概要

字段

限定符和类型	字段和说明
protected Map<String,Object>	attributes
protected Consumer<AsyncConnection>	beforeCloseListener
protected AtomicLong	closedCounter
protected AtomicInteger	eventing
protected AtomicLong	livingCounter
protected long	readtime
protected SSLContext	sslContext
protected Object	subobject
protected long	writetime

构造器概要

构造器

构造器和说明
AsyncConnection()

方法概要

限定符和类型	方法和说明
AsyncConnection	beforeCloseListener(Consumer<AsyncConnection> beforeCloseListener)
void	clearAttribute()
void	close()
static AsyncConnection	create(AsynchronousSocketChannel ch)
static AsyncConnection	create(AsynchronousSocketChannel ch, SocketAddress addr0, Context context)
static AsyncConnection	create(AsynchronousSocketChannel ch, SocketAddress addr0, Context context, AtomicLong livingCounter, AtomicLong closedCounter)
static AsyncConnection	create(AsynchronousSocketChannel ch, SocketAddress addr0, int readTimeoutSeconds, int writeTimeoutSeconds)
static AsyncConnection	create(AsynchronousSocketChannel ch, SocketAddress addr0, int readTimeoutSeconds, int writeTimeoutSeconds, AtomicLong livingCounter, AtomicLong closedCounter)
static AsyncConnection	create(AsynchronousSocketChannel ch, SSLContext sslContext, SocketAddress addr0, int readTimeoutSeconds, int writeTimeoutSeconds)
static AsyncConnection	create(AsynchronousSocketChannel ch, SSLContext sslContext, SocketAddress addr0, int readTimeoutSeconds, int writeTimeoutSeconds, AtomicLong livingCounter, AtomicLong closedCounter)
static AsyncConnection	create(DatagramChannel ch, SocketAddress addr, boolean client0, int readTimeoutSeconds0, int writeTimeoutSeconds0)
static AsyncConnection	create(DatagramChannel ch, SocketAddress addr, boolean client0, int readTimeoutSeconds0, int writeTimeoutSeconds0, AtomicLong livingCounter, AtomicLong closedCounter)
static AsyncConnection	create(Socket socket) 通常用于 ssl socket
static AsyncConnection	create(SocketChannel ch, SocketAddress addr0, Selector selector, Context context)
static AsyncConnection	create(SocketChannel ch, SocketAddress addr, Selector selector, int readTimeoutSeconds0, int writeTimeoutSeconds0)
static AsyncConnection	create(SocketChannel ch, SocketAddress addr, Selector selector, int readTimeoutSeconds0, int writeTimeoutSeconds0, AtomicLong livingCounter, AtomicLong closedCounter)
static AsyncConnection	create(Socket socket, SocketAddress addr0, int readTimeoutSecond0, int writeTimeoutSecond0)
static AsyncConnection	create(Socket socket, SocketAddress addr0, int readTimeoutSecond0, int writeTimeoutSecond0, AtomicLong livingCounter, AtomicLong closedCounter)
static CompletableFuture<AsyncConnection>	createTCP(AsynchronousChannelGroup group, SocketAddress address, int readTimeoutSeconds, int writeTimeoutSeconds) 创建TCP协议客户端连接
static CompletableFuture<AsyncConnection>	createTCP(AsynchronousChannelGroup group, SSLContext sslContext, SocketAddress address, int readTimeoutSeconds, int writeTimeoutSeconds) 创建TCP协议客户端连接
int	decreEventing()
void	dispose()
<T> T	getAttribute(String name)
Map<String,Object>	getAttributes()
long	getLastReadTime()
long	getLastWriteTime()
abstract SocketAddress	getLocalAddress()
abstract int	getReadTimeoutSeconds()
abstract SocketAddress	getRemoteAddress()
<T> T	getSubobject()
abstract int	getWriteTimeoutSeconds()
int	increEventing()
abstract boolean	isTCP()
abstract Future<Integer>	read(ByteBuffer dst)
abstract <A> void	read(ByteBuffer dst, A attachment, CompletionHandler<Integer,? super A> handler)
abstract <A> void	read(ByteBuffer dst, long timeout, TimeUnit unit, A attachment, CompletionHandler<Integer,? super A> handler)
void	removeAttribute(String name)
void	setAttribute(String name, Object value)
abstract <T> boolean	setOption(SocketOption<T> name, T value)
abstract void	setReadTimeoutSeconds(int readTimeoutSeconds)
void	setSubobject(Object value)
abstract void	setWriteTimeoutSeconds(int writeTimeoutSeconds)
abstract boolean	shutdownInput()
abstract boolean	shutdownOutput()
abstract Set<SocketOption<?>>	supportedOptions()
abstract Future<Integer>	write(ByteBuffer src)
<A> void	write(ByteBuffer[] srcs, A attachment, CompletionHandler<Integer,? super A> handler)
abstract <A> void	write(ByteBuffer[] srcs, int offset, int length, A attachment, CompletionHandler<Integer,? super A> handler)
abstract <A> void	write(ByteBuffer src, A attachment, CompletionHandler<Integer,? super A> handler)

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

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

从接口继承的方法 java.nio.channels.Channel

isOpen

字段详细资料

sslContext

protected SSLContext sslContext

attributes

protected Map<String,Object> attributes

subobject

protected Object subobject

readtime

protected volatile long readtime

writetime

protected volatile long writetime

livingCounter

protected AtomicLong livingCounter

closedCounter

protected AtomicLong closedCounter

beforeCloseListener

protected Consumer<AsyncConnection> beforeCloseListener

eventing

protected final AtomicInteger eventing

构造器详细资料

AsyncConnection

public AsyncConnection()

方法详细资料

getLastReadTime

public final long getLastReadTime()

getLastWriteTime

public final long getLastWriteTime()

increEventing

public final int increEventing()

decreEventing

public final int decreEventing()

isTCP

public abstract boolean isTCP()

shutdownInput

public abstract boolean shutdownInput()

shutdownOutput

public abstract boolean shutdownOutput()

setOption

public abstract <T> boolean setOption(SocketOption<T> name,
                                      T value)

supportedOptions

public abstract Set<SocketOption<?>> supportedOptions()

getRemoteAddress

public abstract SocketAddress getRemoteAddress()

getLocalAddress

public abstract SocketAddress getLocalAddress()

getReadTimeoutSeconds

public abstract int getReadTimeoutSeconds()

getWriteTimeoutSeconds

public abstract int getWriteTimeoutSeconds()

setReadTimeoutSeconds

public abstract void setReadTimeoutSeconds(int readTimeoutSeconds)

setWriteTimeoutSeconds

public abstract void setWriteTimeoutSeconds(int writeTimeoutSeconds)

read

public abstract Future<Integer> read(ByteBuffer dst)

指定者:

read 在接口中 AsynchronousByteChannel

read

public abstract <A> void read(ByteBuffer dst,
                              A attachment,
                              CompletionHandler<Integer,? super A> handler)

指定者:

read 在接口中 AsynchronousByteChannel

read

public abstract <A> void read(ByteBuffer dst,
                              long timeout,
                              TimeUnit unit,
                              A attachment,
                              CompletionHandler<Integer,? super A> handler)

write

public abstract Future<Integer> write(ByteBuffer src)

指定者:

write 在接口中 AsynchronousByteChannel

write

public abstract <A> void write(ByteBuffer src,
                               A attachment,
                               CompletionHandler<Integer,? super A> handler)

指定者:

write 在接口中 AsynchronousByteChannel

write

public final <A> void write(ByteBuffer[] srcs,
                            A attachment,
                            CompletionHandler<Integer,? super A> handler)

write

public abstract <A> void write(ByteBuffer[] srcs,
                               int offset,
                               int length,
                               A attachment,
                               CompletionHandler<Integer,? super A> handler)

dispose

public void dispose()

beforeCloseListener

public AsyncConnection beforeCloseListener(Consumer<AsyncConnection> beforeCloseListener)

close

public void close()
           throws IOException

指定者:

close 在接口中 Closeable

指定者:

close 在接口中 AutoCloseable

指定者:

close 在接口中 AsynchronousChannel

指定者:

close 在接口中 Channel

抛出:

IOException

getSubobject

public final <T> T getSubobject()

setSubobject

public void setSubobject(Object value)

setAttribute

public void setAttribute(String name,
                         Object value)

getAttribute

public final <T> T getAttribute(String name)

removeAttribute

public final void removeAttribute(String name)

getAttributes

public final Map<String,Object> getAttributes()

clearAttribute

public final void clearAttribute()

createTCP

public static CompletableFuture<AsyncConnection> createTCP(AsynchronousChannelGroup group,
                                                           SocketAddress address,
                                                           int readTimeoutSeconds,
                                                           int writeTimeoutSeconds)

创建TCP协议客户端连接

参数:

address - 连接点子

group - 连接AsynchronousChannelGroup

readTimeoutSeconds - 读取超时秒数

writeTimeoutSeconds - 写入超时秒数

返回:

连接CompletableFuture

createTCP

public static CompletableFuture<AsyncConnection> createTCP(AsynchronousChannelGroup group,
                                                           SSLContext sslContext,
                                                           SocketAddress address,
                                                           int readTimeoutSeconds,
                                                           int writeTimeoutSeconds)

创建TCP协议客户端连接

参数:

address - 连接点子

sslContext - SSLContext

group - 连接AsynchronousChannelGroup

readTimeoutSeconds - 读取超时秒数

writeTimeoutSeconds - 写入超时秒数

返回:

连接CompletableFuture

create

public static AsyncConnection create(Socket socket)

通常用于 ssl socket

参数:

socket - Socket对象

返回:

连接对象

create

public static AsyncConnection create(Socket socket,
                                     SocketAddress addr0,
                                     int readTimeoutSecond0,
                                     int writeTimeoutSecond0)

create

public static AsyncConnection create(Socket socket,
                                     SocketAddress addr0,
                                     int readTimeoutSecond0,
                                     int writeTimeoutSecond0,
                                     AtomicLong livingCounter,
                                     AtomicLong closedCounter)

create

public static AsyncConnection create(SocketChannel ch,
                                     SocketAddress addr,
                                     Selector selector,
                                     int readTimeoutSeconds0,
                                     int writeTimeoutSeconds0)

create

public static AsyncConnection create(SocketChannel ch,
                                     SocketAddress addr0,
                                     Selector selector,
                                     Context context)

create

public static AsyncConnection create(SocketChannel ch,
                                     SocketAddress addr,
                                     Selector selector,
                                     int readTimeoutSeconds0,
                                     int writeTimeoutSeconds0,
                                     AtomicLong livingCounter,
                                     AtomicLong closedCounter)

create

public static AsyncConnection create(DatagramChannel ch,
                                     SocketAddress addr,
                                     boolean client0,
                                     int readTimeoutSeconds0,
                                     int writeTimeoutSeconds0)

create

public static AsyncConnection create(DatagramChannel ch,
                                     SocketAddress addr,
                                     boolean client0,
                                     int readTimeoutSeconds0,
                                     int writeTimeoutSeconds0,
                                     AtomicLong livingCounter,
                                     AtomicLong closedCounter)

create

public static AsyncConnection create(AsynchronousSocketChannel ch)

create

public static AsyncConnection create(AsynchronousSocketChannel ch,
                                     SocketAddress addr0,
                                     int readTimeoutSeconds,
                                     int writeTimeoutSeconds)

create

public static AsyncConnection create(AsynchronousSocketChannel ch,
                                     SSLContext sslContext,
                                     SocketAddress addr0,
                                     int readTimeoutSeconds,
                                     int writeTimeoutSeconds)

create

public static AsyncConnection create(AsynchronousSocketChannel ch,
                                     SocketAddress addr0,
                                     Context context)

create

public static AsyncConnection create(AsynchronousSocketChannel ch,
                                     SocketAddress addr0,
                                     int readTimeoutSeconds,
                                     int writeTimeoutSeconds,
                                     AtomicLong livingCounter,
                                     AtomicLong closedCounter)

create

public static AsyncConnection create(AsynchronousSocketChannel ch,
                                     SSLContext sslContext,
                                     SocketAddress addr0,
                                     int readTimeoutSeconds,
                                     int writeTimeoutSeconds,
                                     AtomicLong livingCounter,
                                     AtomicLong closedCounter)

create

public static AsyncConnection create(AsynchronousSocketChannel ch,
                                     SocketAddress addr0,
                                     Context context,
                                     AtomicLong livingCounter,
                                     AtomicLong closedCounter)