org.redkale.net

类 AsyncConnection

java.lang.Object

org.redkale.net.AsyncConnection

所有已实现的接口:

java.io.Closeable, java.lang.AutoCloseable, java.nio.channels.Channel, java.nio.channels.ReadableByteChannel, java.nio.channels.WritableByteChannel

直接已知子类:

TcpAioAsyncConnection, UdpBioAsyncConnection

public abstract class AsyncConnection
extends java.lang.Object
implements java.nio.channels.ReadableByteChannel, java.nio.channels.WritableByteChannel, java.lang.AutoCloseable

详情见: https://redkale.org

字段概要

字段

限定符和类型	字段和说明
protected java.util.Map<java.lang.String,java.lang.Object>	attributes
protected java.util.function.Consumer<AsyncConnection>	beforeCloseListener
protected java.util.function.Consumer<java.nio.ByteBuffer>	bufferConsumer
protected java.util.function.Supplier<java.nio.ByteBuffer>	bufferSupplier
protected java.util.concurrent.atomic.AtomicLong	closedCounter
protected java.util.concurrent.atomic.AtomicInteger	eventing
protected java.util.concurrent.atomic.AtomicLong	livingCounter
protected java.nio.ByteBuffer	readBuffer
protected long	readtime
protected javax.net.ssl.SSLContext	sslContext
protected java.lang.Object	subobject
protected long	writetime

构造器概要

构造器

限定符	构造器和说明
protected	AsyncConnection(Context context)
protected	AsyncConnection(ObjectPool<java.nio.ByteBuffer> bufferPool, javax.net.ssl.SSLContext sslContext)
protected	AsyncConnection(java.util.function.Supplier<java.nio.ByteBuffer> bufferSupplier, java.util.function.Consumer<java.nio.ByteBuffer> bufferConsumer, javax.net.ssl.SSLContext sslContext)

方法概要

限定符和类型	方法和说明
AsyncConnection	beforeCloseListener(java.util.function.Consumer<AsyncConnection> beforeCloseListener)
void	clearAttribute()
void	close()
static AsyncConnection	create(Context context, java.nio.channels.AsynchronousSocketChannel ch)
static AsyncConnection	create(Context context, java.nio.channels.AsynchronousSocketChannel ch, java.net.SocketAddress addr0, java.util.concurrent.atomic.AtomicLong livingCounter, java.util.concurrent.atomic.AtomicLong closedCounter)
static AsyncConnection	create(Context context, java.nio.channels.AsynchronousSocketChannel ch, java.net.SocketAddress addr0, int readTimeoutSeconds, int writeTimeoutSeconds)
static AsyncConnection	create(Context context, java.nio.channels.AsynchronousSocketChannel ch, java.net.SocketAddress addr0, int readTimeoutSeconds, int writeTimeoutSeconds, java.util.concurrent.atomic.AtomicLong livingCounter, java.util.concurrent.atomic.AtomicLong closedCounter)
static AsyncConnection	create(Context context, java.nio.channels.AsynchronousSocketChannel ch, javax.net.ssl.SSLContext sslContext, java.net.SocketAddress addr0, int readTimeoutSeconds, int writeTimeoutSeconds)
static AsyncConnection	create(Context context, java.nio.channels.AsynchronousSocketChannel ch, javax.net.ssl.SSLContext sslContext, java.net.SocketAddress addr0, int readTimeoutSeconds, int writeTimeoutSeconds, java.util.concurrent.atomic.AtomicLong livingCounter, java.util.concurrent.atomic.AtomicLong closedCounter)
static AsyncConnection	create(ObjectPool<java.nio.ByteBuffer> bufferPool, java.nio.channels.AsynchronousSocketChannel ch)
static AsyncConnection	create(ObjectPool<java.nio.ByteBuffer> bufferPool, java.nio.channels.AsynchronousSocketChannel ch, java.net.SocketAddress addr0, int readTimeoutSeconds, int writeTimeoutSeconds)
static AsyncConnection	create(ObjectPool<java.nio.ByteBuffer> bufferPool, java.nio.channels.AsynchronousSocketChannel ch, java.net.SocketAddress addr0, int readTimeoutSeconds, int writeTimeoutSeconds, java.util.concurrent.atomic.AtomicLong livingCounter, java.util.concurrent.atomic.AtomicLong closedCounter)
static AsyncConnection	create(ObjectPool<java.nio.ByteBuffer> bufferPool, java.nio.channels.AsynchronousSocketChannel ch, javax.net.ssl.SSLContext sslContext, java.net.SocketAddress addr0, int readTimeoutSeconds, int writeTimeoutSeconds)
static AsyncConnection	create(ObjectPool<java.nio.ByteBuffer> bufferPool, java.nio.channels.AsynchronousSocketChannel ch, javax.net.ssl.SSLContext sslContext, java.net.SocketAddress addr0, int readTimeoutSeconds, int writeTimeoutSeconds, java.util.concurrent.atomic.AtomicLong livingCounter, java.util.concurrent.atomic.AtomicLong closedCounter)
static AsyncConnection	create(ObjectPool<java.nio.ByteBuffer> bufferPool, java.nio.channels.DatagramChannel ch, java.net.SocketAddress addr, boolean client0, int readTimeoutSeconds0, int writeTimeoutSeconds0)
static AsyncConnection	create(ObjectPool<java.nio.ByteBuffer> bufferPool, java.nio.channels.DatagramChannel ch, java.net.SocketAddress addr, boolean client0, int readTimeoutSeconds0, int writeTimeoutSeconds0, java.util.concurrent.atomic.AtomicLong livingCounter, java.util.concurrent.atomic.AtomicLong closedCounter)
static AsyncConnection	create(ObjectPool<java.nio.ByteBuffer> bufferPool, java.nio.channels.DatagramChannel ch, javax.net.ssl.SSLContext sslContext, java.net.SocketAddress addr, boolean client0, int readTimeoutSeconds0, int writeTimeoutSeconds0)
static AsyncConnection	create(ObjectPool<java.nio.ByteBuffer> bufferPool, java.nio.channels.DatagramChannel ch, javax.net.ssl.SSLContext sslContext, java.net.SocketAddress addr, boolean client0, int readTimeoutSeconds0, int writeTimeoutSeconds0, java.util.concurrent.atomic.AtomicLong livingCounter, java.util.concurrent.atomic.AtomicLong closedCounter)
static java.util.concurrent.CompletableFuture<AsyncConnection>	createTCP(Context context, java.nio.channels.AsynchronousChannelGroup group, java.net.SocketAddress address, int readTimeoutSeconds, int writeTimeoutSeconds) 创建TCP协议客户端连接
static java.util.concurrent.CompletableFuture<AsyncConnection>	createTCP(ObjectPool<java.nio.ByteBuffer> bufferPool, java.nio.channels.AsynchronousChannelGroup group, java.net.SocketAddress address, int readTimeoutSeconds, int writeTimeoutSeconds) 创建TCP协议客户端连接
static java.util.concurrent.CompletableFuture<AsyncConnection>	createTCP(ObjectPool<java.nio.ByteBuffer> bufferPool, java.nio.channels.AsynchronousChannelGroup group, javax.net.ssl.SSLContext sslContext, java.net.SocketAddress address, int readTimeoutSeconds, int writeTimeoutSeconds) 创建TCP协议客户端连接
static java.util.concurrent.CompletableFuture<AsyncConnection>	createTCP(java.util.function.Supplier<java.nio.ByteBuffer> bufferSupplier, java.util.function.Consumer<java.nio.ByteBuffer> bufferConsumer, java.nio.channels.AsynchronousChannelGroup group, javax.net.ssl.SSLContext sslContext, java.net.SocketAddress address, int readTimeoutSeconds, int writeTimeoutSeconds) 创建TCP协议客户端连接
int	decreEventing()
void	dispose()
<T> T	getAttribute(java.lang.String name)
java.util.Map<java.lang.String,java.lang.Object>	getAttributes()
long	getLastReadTime()
long	getLastWriteTime()
abstract java.net.SocketAddress	getLocalAddress()
abstract int	getReadTimeoutSeconds()
abstract java.net.SocketAddress	getRemoteAddress()
<T> T	getSubobject()
abstract int	getWriteTimeoutSeconds()
int	increEventing()
abstract boolean	isOpen()
abstract boolean	isTCP()
void	offerBuffer(java.nio.Buffer... buffers)
void	offerBuffer(java.nio.Buffer buffer)
java.nio.ByteBuffer	pollReadBuffer()
java.nio.ByteBuffer	pollWriteBuffer()
abstract int	read(java.nio.ByteBuffer dst)
abstract void	read(java.nio.channels.CompletionHandler<java.lang.Integer,java.nio.ByteBuffer> handler)
abstract void	read(long timeout, java.util.concurrent.TimeUnit unit, java.nio.channels.CompletionHandler<java.lang.Integer,java.nio.ByteBuffer> handler)
void	removeAttribute(java.lang.String name)
void	setAttribute(java.lang.String name, java.lang.Object value)
abstract <T> boolean	setOption(java.net.SocketOption<T> name, T value)
void	setReadBuffer(java.nio.Buffer buffer)
abstract void	setReadTimeoutSeconds(int readTimeoutSeconds)
void	setSubobject(java.lang.Object value)
abstract void	setWriteTimeoutSeconds(int writeTimeoutSeconds)
abstract boolean	shutdownInput()
abstract boolean	shutdownOutput()
abstract java.util.Set<java.net.SocketOption<?>>	supportedOptions()
abstract int	write(java.nio.ByteBuffer src)
<A> void	write(java.nio.ByteBuffer[] srcs, A attachment, java.nio.channels.CompletionHandler<java.lang.Integer,? super A> handler)
abstract <A> void	write(java.nio.ByteBuffer[] srcs, int offset, int length, A attachment, java.nio.channels.CompletionHandler<java.lang.Integer,? super A> handler)
abstract <A> void	write(java.nio.ByteBuffer src, A attachment, java.nio.channels.CompletionHandler<java.lang.Integer,? super A> handler)

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

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

字段详细资料

sslContext

protected javax.net.ssl.SSLContext sslContext

attributes

protected java.util.Map<java.lang.String,java.lang.Object> attributes

subobject

protected java.lang.Object subobject

readtime

protected volatile long readtime

writetime

protected volatile long writetime

bufferSupplier

protected final java.util.function.Supplier<java.nio.ByteBuffer> bufferSupplier

bufferConsumer

protected final java.util.function.Consumer<java.nio.ByteBuffer> bufferConsumer

readBuffer

protected java.nio.ByteBuffer readBuffer

livingCounter

protected java.util.concurrent.atomic.AtomicLong livingCounter

closedCounter

protected java.util.concurrent.atomic.AtomicLong closedCounter

beforeCloseListener

protected java.util.function.Consumer<AsyncConnection> beforeCloseListener

eventing

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

构造器详细资料

AsyncConnection

protected AsyncConnection(Context context)

AsyncConnection

protected AsyncConnection(ObjectPool<java.nio.ByteBuffer> bufferPool,
                          javax.net.ssl.SSLContext sslContext)

AsyncConnection

protected AsyncConnection(java.util.function.Supplier<java.nio.ByteBuffer> bufferSupplier,
                          java.util.function.Consumer<java.nio.ByteBuffer> bufferConsumer,
                          javax.net.ssl.SSLContext sslContext)

方法详细资料

getLastReadTime

public final long getLastReadTime()

getLastWriteTime

public final long getLastWriteTime()

increEventing

public final int increEventing()

decreEventing

public final int decreEventing()

isOpen

public abstract boolean isOpen()

指定者:

isOpen 在接口中 java.nio.channels.Channel

isTCP

public abstract boolean isTCP()

shutdownInput

public abstract boolean shutdownInput()

shutdownOutput

public abstract boolean shutdownOutput()

setOption

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

supportedOptions

public abstract java.util.Set<java.net.SocketOption<?>> supportedOptions()

getRemoteAddress

public abstract java.net.SocketAddress getRemoteAddress()

getLocalAddress

public abstract java.net.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 int read(java.nio.ByteBuffer dst)
                  throws java.io.IOException

指定者:

read 在接口中 java.nio.channels.ReadableByteChannel

抛出:

java.io.IOException

read

public abstract void read(java.nio.channels.CompletionHandler<java.lang.Integer,java.nio.ByteBuffer> handler)

read

public abstract void read(long timeout,
                          java.util.concurrent.TimeUnit unit,
                          java.nio.channels.CompletionHandler<java.lang.Integer,java.nio.ByteBuffer> handler)

write

public abstract int write(java.nio.ByteBuffer src)
                   throws java.io.IOException

指定者:

write 在接口中 java.nio.channels.WritableByteChannel

抛出:

java.io.IOException

write

public abstract <A> void write(java.nio.ByteBuffer src,
                               A attachment,
                               java.nio.channels.CompletionHandler<java.lang.Integer,? super A> handler)

write

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

write

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

setReadBuffer

public void setReadBuffer(java.nio.Buffer buffer)

pollReadBuffer

public java.nio.ByteBuffer pollReadBuffer()

offerBuffer

public void offerBuffer(java.nio.Buffer buffer)

offerBuffer

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

pollWriteBuffer

public java.nio.ByteBuffer pollWriteBuffer()

dispose

public void dispose()

beforeCloseListener

public AsyncConnection beforeCloseListener(java.util.function.Consumer<AsyncConnection> beforeCloseListener)

close

public void close()
           throws java.io.IOException

指定者:

close 在接口中 java.io.Closeable

指定者:

close 在接口中 java.lang.AutoCloseable

指定者:

close 在接口中 java.nio.channels.Channel

抛出:

java.io.IOException

getSubobject

public final <T> T getSubobject()

setSubobject

public void setSubobject(java.lang.Object value)

setAttribute

public void setAttribute(java.lang.String name,
                         java.lang.Object value)

getAttribute

public final <T> T getAttribute(java.lang.String name)

removeAttribute

public final void removeAttribute(java.lang.String name)

getAttributes

public final java.util.Map<java.lang.String,java.lang.Object> getAttributes()

clearAttribute

public final void clearAttribute()

createTCP

public static java.util.concurrent.CompletableFuture<AsyncConnection> createTCP(ObjectPool<java.nio.ByteBuffer> bufferPool,
                                                                                java.nio.channels.AsynchronousChannelGroup group,
                                                                                java.net.SocketAddress address,
                                                                                int readTimeoutSeconds,
                                                                                int writeTimeoutSeconds)

创建TCP协议客户端连接

参数:

bufferPool - ByteBuffer对象池

address - 连接点子

group - 连接AsynchronousChannelGroup

readTimeoutSeconds - 读取超时秒数

writeTimeoutSeconds - 写入超时秒数

返回:

连接CompletableFuture

createTCP

public static java.util.concurrent.CompletableFuture<AsyncConnection> createTCP(Context context,
                                                                                java.nio.channels.AsynchronousChannelGroup group,
                                                                                java.net.SocketAddress address,
                                                                                int readTimeoutSeconds,
                                                                                int writeTimeoutSeconds)

创建TCP协议客户端连接

参数:

context - Context

address - 连接点子

group - 连接AsynchronousChannelGroup

readTimeoutSeconds - 读取超时秒数

writeTimeoutSeconds - 写入超时秒数

返回:

连接CompletableFuture

createTCP

public static java.util.concurrent.CompletableFuture<AsyncConnection> createTCP(ObjectPool<java.nio.ByteBuffer> bufferPool,
                                                                                java.nio.channels.AsynchronousChannelGroup group,
                                                                                javax.net.ssl.SSLContext sslContext,
                                                                                java.net.SocketAddress address,
                                                                                int readTimeoutSeconds,
                                                                                int writeTimeoutSeconds)

创建TCP协议客户端连接

参数:

bufferPool - ByteBuffer对象池

address - 连接点子

sslContext - SSLContext

group - 连接AsynchronousChannelGroup

readTimeoutSeconds - 读取超时秒数

writeTimeoutSeconds - 写入超时秒数

返回:

连接CompletableFuture

createTCP

public static java.util.concurrent.CompletableFuture<AsyncConnection> createTCP(java.util.function.Supplier<java.nio.ByteBuffer> bufferSupplier,
                                                                                java.util.function.Consumer<java.nio.ByteBuffer> bufferConsumer,
                                                                                java.nio.channels.AsynchronousChannelGroup group,
                                                                                javax.net.ssl.SSLContext sslContext,
                                                                                java.net.SocketAddress address,
                                                                                int readTimeoutSeconds,
                                                                                int writeTimeoutSeconds)

创建TCP协议客户端连接

参数:

bufferSupplier - ByteBuffer生产器

bufferConsumer - ByteBuffer回收器

address - 连接点子

sslContext - SSLContext

group - 连接AsynchronousChannelGroup

readTimeoutSeconds - 读取超时秒数

writeTimeoutSeconds - 写入超时秒数

返回:

连接CompletableFuture

create

public static AsyncConnection create(ObjectPool<java.nio.ByteBuffer> bufferPool,
                                     java.nio.channels.DatagramChannel ch,
                                     java.net.SocketAddress addr,
                                     boolean client0,
                                     int readTimeoutSeconds0,
                                     int writeTimeoutSeconds0)

create

public static AsyncConnection create(ObjectPool<java.nio.ByteBuffer> bufferPool,
                                     java.nio.channels.DatagramChannel ch,
                                     java.net.SocketAddress addr,
                                     boolean client0,
                                     int readTimeoutSeconds0,
                                     int writeTimeoutSeconds0,
                                     java.util.concurrent.atomic.AtomicLong livingCounter,
                                     java.util.concurrent.atomic.AtomicLong closedCounter)

create

public static AsyncConnection create(ObjectPool<java.nio.ByteBuffer> bufferPool,
                                     java.nio.channels.DatagramChannel ch,
                                     javax.net.ssl.SSLContext sslContext,
                                     java.net.SocketAddress addr,
                                     boolean client0,
                                     int readTimeoutSeconds0,
                                     int writeTimeoutSeconds0)

create

public static AsyncConnection create(ObjectPool<java.nio.ByteBuffer> bufferPool,
                                     java.nio.channels.DatagramChannel ch,
                                     javax.net.ssl.SSLContext sslContext,
                                     java.net.SocketAddress addr,
                                     boolean client0,
                                     int readTimeoutSeconds0,
                                     int writeTimeoutSeconds0,
                                     java.util.concurrent.atomic.AtomicLong livingCounter,
                                     java.util.concurrent.atomic.AtomicLong closedCounter)

create

public static AsyncConnection create(Context context,
                                     java.nio.channels.AsynchronousSocketChannel ch)

create

public static AsyncConnection create(Context context,
                                     java.nio.channels.AsynchronousSocketChannel ch,
                                     java.net.SocketAddress addr0,
                                     java.util.concurrent.atomic.AtomicLong livingCounter,
                                     java.util.concurrent.atomic.AtomicLong closedCounter)

create

public static AsyncConnection create(Context context,
                                     java.nio.channels.AsynchronousSocketChannel ch,
                                     java.net.SocketAddress addr0,
                                     int readTimeoutSeconds,
                                     int writeTimeoutSeconds)

create

public static AsyncConnection create(Context context,
                                     java.nio.channels.AsynchronousSocketChannel ch,
                                     javax.net.ssl.SSLContext sslContext,
                                     java.net.SocketAddress addr0,
                                     int readTimeoutSeconds,
                                     int writeTimeoutSeconds)

create

public static AsyncConnection create(Context context,
                                     java.nio.channels.AsynchronousSocketChannel ch,
                                     java.net.SocketAddress addr0,
                                     int readTimeoutSeconds,
                                     int writeTimeoutSeconds,
                                     java.util.concurrent.atomic.AtomicLong livingCounter,
                                     java.util.concurrent.atomic.AtomicLong closedCounter)

create

public static AsyncConnection create(Context context,
                                     java.nio.channels.AsynchronousSocketChannel ch,
                                     javax.net.ssl.SSLContext sslContext,
                                     java.net.SocketAddress addr0,
                                     int readTimeoutSeconds,
                                     int writeTimeoutSeconds,
                                     java.util.concurrent.atomic.AtomicLong livingCounter,
                                     java.util.concurrent.atomic.AtomicLong closedCounter)

create

public static AsyncConnection create(ObjectPool<java.nio.ByteBuffer> bufferPool,
                                     java.nio.channels.AsynchronousSocketChannel ch)

create

public static AsyncConnection create(ObjectPool<java.nio.ByteBuffer> bufferPool,
                                     java.nio.channels.AsynchronousSocketChannel ch,
                                     java.net.SocketAddress addr0,
                                     int readTimeoutSeconds,
                                     int writeTimeoutSeconds)

create

public static AsyncConnection create(ObjectPool<java.nio.ByteBuffer> bufferPool,
                                     java.nio.channels.AsynchronousSocketChannel ch,
                                     javax.net.ssl.SSLContext sslContext,
                                     java.net.SocketAddress addr0,
                                     int readTimeoutSeconds,
                                     int writeTimeoutSeconds)

create

public static AsyncConnection create(ObjectPool<java.nio.ByteBuffer> bufferPool,
                                     java.nio.channels.AsynchronousSocketChannel ch,
                                     java.net.SocketAddress addr0,
                                     int readTimeoutSeconds,
                                     int writeTimeoutSeconds,
                                     java.util.concurrent.atomic.AtomicLong livingCounter,
                                     java.util.concurrent.atomic.AtomicLong closedCounter)

create

public static AsyncConnection create(ObjectPool<java.nio.ByteBuffer> bufferPool,
                                     java.nio.channels.AsynchronousSocketChannel ch,
                                     javax.net.ssl.SSLContext sslContext,
                                     java.net.SocketAddress addr0,
                                     int readTimeoutSeconds,
                                     int writeTimeoutSeconds,
                                     java.util.concurrent.atomic.AtomicLong livingCounter,
                                     java.util.concurrent.atomic.AtomicLong closedCounter)