org.redkale.net

类 AsyncConnection

java.lang.Object

org.redkale.net.AsyncConnection

所有已实现的接口:

java.io.Closeable, java.lang.AutoCloseable, java.nio.channels.AsynchronousByteChannel, java.nio.channels.AsynchronousChannel, java.nio.channels.Channel

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

详情见: https://redkale.org

字段概要

字段

限定符和类型	字段和说明
protected java.util.Map<java.lang.String,java.lang.Object>	attributes
protected java.util.concurrent.atomic.AtomicLong	closedCounter
protected java.util.concurrent.atomic.AtomicLong	livingCounter
protected long	readtime
protected javax.net.ssl.SSLContext	sslContext
protected java.lang.Object	subobject
protected long	writetime

构造器概要

构造器

构造器和说明
AsyncConnection()

方法概要

限定符和类型	方法和说明
void	clearAttribute()
void	close()
static AsyncConnection	create(java.nio.channels.AsynchronousSocketChannel ch)
static AsyncConnection	create(java.nio.channels.AsynchronousSocketChannel ch, java.net.SocketAddress addr0, Context context)
static AsyncConnection	create(java.nio.channels.AsynchronousSocketChannel ch, java.net.SocketAddress addr0, int readTimeoutSeconds, int writeTimeoutSeconds)
static AsyncConnection	create(java.nio.channels.AsynchronousSocketChannel ch, javax.net.ssl.SSLContext sslContext, java.net.SocketAddress addr0, int readTimeoutSeconds, int writeTimeoutSeconds)
static AsyncConnection	create(java.nio.channels.DatagramChannel ch, java.net.SocketAddress addr, boolean client0, int readTimeoutSeconds0, int writeTimeoutSeconds0)
static AsyncConnection	create(java.net.Socket socket) 通常用于 ssl socket
static AsyncConnection	create(java.net.Socket socket, java.net.SocketAddress addr0, int readTimeoutSecond0, int writeTimeoutSecond0)
static java.util.concurrent.CompletableFuture<AsyncConnection>	createTCP(java.nio.channels.AsynchronousChannelGroup group, java.net.SocketAddress address, int readTimeoutSeconds, int writeTimeoutSeconds) 创建TCP协议客户端连接
static java.util.concurrent.CompletableFuture<AsyncConnection>	createTCP(java.nio.channels.AsynchronousChannelGroup group, javax.net.ssl.SSLContext sslContext, java.net.SocketAddress address, boolean noDelay, int readTimeoutSeconds, int writeTimeoutSeconds) 创建TCP协议客户端连接
static java.util.concurrent.CompletableFuture<AsyncConnection>	createTCP(java.nio.channels.AsynchronousChannelGroup group, javax.net.ssl.SSLContext sslContext, java.net.SocketAddress address, int readTimeoutSeconds, int writeTimeoutSeconds) 创建TCP协议客户端连接
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()
abstract boolean	isTCP()
abstract java.util.concurrent.Future<java.lang.Integer>	read(java.nio.ByteBuffer dst)
abstract <A> void	read(java.nio.ByteBuffer dst, A attachment, java.nio.channels.CompletionHandler<java.lang.Integer,? super A> handler)
abstract <A> void	read(java.nio.ByteBuffer dst, long timeout, java.util.concurrent.TimeUnit unit, A attachment, java.nio.channels.CompletionHandler<java.lang.Integer,? super A> handler)
void	removeAttribute(java.lang.String name)
void	setAttribute(java.lang.String name, java.lang.Object value)
abstract void	setReadTimeoutSeconds(int readTimeoutSeconds)
void	setSubobject(java.lang.Object value)
abstract void	setWriteTimeoutSeconds(int writeTimeoutSeconds)
abstract java.util.concurrent.Future<java.lang.Integer>	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

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

isOpen

字段详细资料

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

closedCounter

protected java.util.concurrent.atomic.AtomicLong closedCounter

livingCounter

protected java.util.concurrent.atomic.AtomicLong livingCounter

构造器详细资料

AsyncConnection

public AsyncConnection()

方法详细资料

getLastReadTime

public final long getLastReadTime()

getLastWriteTime

public final long getLastWriteTime()

isTCP

public abstract boolean isTCP()

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 java.util.concurrent.Future<java.lang.Integer> read(java.nio.ByteBuffer dst)

指定者:

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

read

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

指定者:

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

read

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

write

public abstract java.util.concurrent.Future<java.lang.Integer> write(java.nio.ByteBuffer src)

指定者:

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

write

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

指定者:

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

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)

dispose

public void dispose()

close

public void close()
           throws java.io.IOException

指定者:

close 在接口中 java.io.Closeable

指定者:

close 在接口中 java.lang.AutoCloseable

指定者:

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

指定者:

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(java.nio.channels.AsynchronousChannelGroup group,
                                                                                java.net.SocketAddress address,
                                                                                int readTimeoutSeconds,
                                                                                int writeTimeoutSeconds)

创建TCP协议客户端连接

参数:

address - 连接点子

group - 连接AsynchronousChannelGroup

readTimeoutSeconds - 读取超时秒数

writeTimeoutSeconds - 写入超时秒数

返回:

连接CompletableFuture

createTCP

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

创建TCP协议客户端连接

参数:

address - 连接点子

sslContext - SSLContext

group - 连接AsynchronousChannelGroup

readTimeoutSeconds - 读取超时秒数

writeTimeoutSeconds - 写入超时秒数

返回:

连接CompletableFuture

createTCP

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

创建TCP协议客户端连接

参数:

address - 连接点子

sslContext - SSLContext

group - 连接AsynchronousChannelGroup

noDelay - TcpNoDelay

readTimeoutSeconds - 读取超时秒数

writeTimeoutSeconds - 写入超时秒数

返回:

连接CompletableFuture

create

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

create

public static AsyncConnection create(java.net.Socket socket)

通常用于 ssl socket

参数:

socket - Socket对象

返回:

连接对象

create

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

create

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

create

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

create

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

create

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