org.redkale.net

类 UdpBioAsyncConnection

java.lang.Object

org.redkale.net.AsyncConnection

org.redkale.net.UdpBioAsyncConnection

所有已实现的接口:

Closeable, AutoCloseable, AsynchronousByteChannel, AsynchronousChannel, Channel

public class UdpBioAsyncConnection
extends AsyncConnection

详情见: https://redkale.org

作者:

zhangjx

字段概要

从类继承的字段 org.redkale.net.AsyncConnection

attributes, beforeCloseListener, closedCounter, eventing, livingCounter, readtime, sslContext, subobject, writetime

构造器概要

构造器

构造器和说明
UdpBioAsyncConnection(DatagramChannel ch, SocketAddress addr0, boolean client0, int readTimeoutSeconds0, int writeTimeoutSeconds0, AtomicLong livingCounter, AtomicLong closedCounter)

方法概要

限定符和类型	方法和说明
void	close()
SocketAddress	getLocalAddress()
int	getReadTimeoutSeconds()
SocketAddress	getRemoteAddress()
int	getWriteTimeoutSeconds()
boolean	isOpen()
boolean	isTCP()
Future<Integer>	read(ByteBuffer dst)
<A> void	read(ByteBuffer dst, A attachment, CompletionHandler<Integer,? super A> handler)
<A> void	read(ByteBuffer dst, long timeout, TimeUnit unit, A attachment, CompletionHandler<Integer,? super A> handler)
<T> boolean	setOption(SocketOption<T> name, T value)
void	setReadTimeoutSeconds(int readTimeoutSeconds)
void	setWriteTimeoutSeconds(int writeTimeoutSeconds)
boolean	shutdownInput()
boolean	shutdownOutput()
Set<SocketOption<?>>	supportedOptions()
Future<Integer>	write(ByteBuffer src)
<A> void	write(ByteBuffer[] srcs, int offset, int length, A attachment, CompletionHandler<Integer,? super A> handler)
<A> void	write(ByteBuffer src, A attachment, CompletionHandler<Integer,? super A> handler)

从类继承的方法 org.redkale.net.AsyncConnection

beforeCloseListener, clearAttribute, create, create, create, create, create, create, create, create, create, create, create, create, create, create, create, createTCP, createTCP, decreEventing, dispose, getAttribute, getAttributes, getLastReadTime, getLastWriteTime, getSubobject, increEventing, removeAttribute, setAttribute, setSubobject, write

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

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

构造器详细资料

UdpBioAsyncConnection

public UdpBioAsyncConnection(DatagramChannel ch,
                             SocketAddress addr0,
                             boolean client0,
                             int readTimeoutSeconds0,
                             int writeTimeoutSeconds0,
                             AtomicLong livingCounter,
                             AtomicLong closedCounter)

方法详细资料

setReadTimeoutSeconds

public void setReadTimeoutSeconds(int readTimeoutSeconds)

指定者:

setReadTimeoutSeconds 在类中 AsyncConnection

setWriteTimeoutSeconds

public void setWriteTimeoutSeconds(int writeTimeoutSeconds)

指定者:

setWriteTimeoutSeconds 在类中 AsyncConnection

getReadTimeoutSeconds

public int getReadTimeoutSeconds()

指定者:

getReadTimeoutSeconds 在类中 AsyncConnection

getWriteTimeoutSeconds

public int getWriteTimeoutSeconds()

指定者:

getWriteTimeoutSeconds 在类中 AsyncConnection

getRemoteAddress

public final SocketAddress getRemoteAddress()

指定者:

getRemoteAddress 在类中 AsyncConnection

getLocalAddress

public SocketAddress getLocalAddress()

指定者:

getLocalAddress 在类中 AsyncConnection

shutdownInput

public boolean shutdownInput()

指定者:

shutdownInput 在类中 AsyncConnection

shutdownOutput

public boolean shutdownOutput()

指定者:

shutdownOutput 在类中 AsyncConnection

setOption

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

指定者:

setOption 在类中 AsyncConnection

supportedOptions

public Set<SocketOption<?>> supportedOptions()

指定者:

supportedOptions 在类中 AsyncConnection

write

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

指定者:

write 在类中 AsyncConnection

read

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

指定者:

read 在接口中 AsynchronousByteChannel

指定者:

read 在类中 AsyncConnection

read

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

指定者:

read 在类中 AsyncConnection

read

public Future<Integer> read(ByteBuffer dst)

指定者:

read 在接口中 AsynchronousByteChannel

指定者:

read 在类中 AsyncConnection

write

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

指定者:

write 在接口中 AsynchronousByteChannel

指定者:

write 在类中 AsyncConnection

write

public Future<Integer> write(ByteBuffer src)

指定者:

write 在接口中 AsynchronousByteChannel

指定者:

write 在类中 AsyncConnection

close

public final void close()
                 throws IOException

指定者:

close 在接口中 Closeable

指定者:

close 在接口中 AutoCloseable

指定者:

close 在接口中 AsynchronousChannel

指定者:

close 在接口中 Channel

覆盖:

close 在类中 AsyncConnection

抛出:

IOException

isOpen

public final boolean isOpen()

isTCP

public final boolean isTCP()

指定者:

isTCP 在类中 AsyncConnection