org.redkale.net

类 UdpBioAsyncConnection

java.lang.Object

org.redkale.net.AsyncConnection

org.redkale.net.UdpBioAsyncConnection

所有已实现的接口:

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

public class UdpBioAsyncConnection
extends AsyncConnection

详情见: https://redkale.org

字段概要

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

attributes, beforeCloseListener, bufferConsumer, bufferSupplier, closedCounter, eventing, livingCounter, readBuffer, readtime, sslContext, subobject, writetime

构造器概要

构造器

构造器和说明

UdpBioAsyncConnection(java.util.function.Supplier<java.nio.ByteBuffer> bufferSupplier, java.util.function.Consumer<java.nio.ByteBuffer> bufferConsumer, java.nio.channels.DatagramChannel ch, javax.net.ssl.SSLContext sslContext, java.net.SocketAddress addr0, boolean client0, int readTimeoutSeconds0, int writeTimeoutSeconds0, java.util.concurrent.atomic.AtomicLong livingCounter, java.util.concurrent.atomic.AtomicLong closedCounter)

方法概要

限定符和类型	方法和说明
void	close()
java.net.SocketAddress	getLocalAddress()
int	getReadTimeoutSeconds()
java.net.SocketAddress	getRemoteAddress()
int	getWriteTimeoutSeconds()
boolean	isOpen()
boolean	isTCP()
int	read(java.nio.ByteBuffer dst)
void	read(java.nio.channels.CompletionHandler<java.lang.Integer,java.nio.ByteBuffer> handler)
void	read(long timeout, java.util.concurrent.TimeUnit unit, java.nio.channels.CompletionHandler<java.lang.Integer,java.nio.ByteBuffer> handler)
<T> boolean	setOption(java.net.SocketOption<T> name, T value)
void	setReadTimeoutSeconds(int readTimeoutSeconds)
void	setWriteTimeoutSeconds(int writeTimeoutSeconds)
boolean	shutdownInput()
boolean	shutdownOutput()
java.util.Set<java.net.SocketOption<?>>	supportedOptions()
int	write(java.nio.ByteBuffer src)
<A> void	write(java.nio.ByteBuffer[] srcs, int offset, int length, A attachment, java.nio.channels.CompletionHandler<java.lang.Integer,? super A> handler)
<A> void	write(java.nio.ByteBuffer src, A attachment, java.nio.channels.CompletionHandler<java.lang.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, createTCP, createTCP, decreEventing, dispose, getAttribute, getAttributes, getLastReadTime, getLastWriteTime, getSubobject, increEventing, offerBuffer, offerBuffer, pollReadBuffer, pollWriteBuffer, removeAttribute, setAttribute, setReadBuffer, setSubobject, write

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

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

构造器详细资料

UdpBioAsyncConnection

public UdpBioAsyncConnection(java.util.function.Supplier<java.nio.ByteBuffer> bufferSupplier,
                             java.util.function.Consumer<java.nio.ByteBuffer> bufferConsumer,
                             java.nio.channels.DatagramChannel ch,
                             javax.net.ssl.SSLContext sslContext,
                             java.net.SocketAddress addr0,
                             boolean client0,
                             int readTimeoutSeconds0,
                             int writeTimeoutSeconds0,
                             java.util.concurrent.atomic.AtomicLong livingCounter,
                             java.util.concurrent.atomic.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 java.net.SocketAddress getRemoteAddress()

指定者:

getRemoteAddress 在类中 AsyncConnection

getLocalAddress

public java.net.SocketAddress getLocalAddress()

指定者:

getLocalAddress 在类中 AsyncConnection

shutdownInput

public boolean shutdownInput()

指定者:

shutdownInput 在类中 AsyncConnection

shutdownOutput

public boolean shutdownOutput()

指定者:

shutdownOutput 在类中 AsyncConnection

setOption

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

指定者:

setOption 在类中 AsyncConnection

supportedOptions

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

指定者:

supportedOptions 在类中 AsyncConnection

write

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

指定者:

write 在类中 AsyncConnection

read

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

指定者:

read 在类中 AsyncConnection

read

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

指定者:

read 在类中 AsyncConnection

read

public int read(java.nio.ByteBuffer dst)
         throws java.io.IOException

指定者:

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

指定者:

read 在类中 AsyncConnection

抛出:

java.io.IOException

write

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

指定者:

write 在类中 AsyncConnection

write

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

指定者:

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

指定者:

write 在类中 AsyncConnection

抛出:

java.io.IOException

close

public final void close()
                 throws java.io.IOException

指定者:

close 在接口中 java.io.Closeable

指定者:

close 在接口中 java.lang.AutoCloseable

指定者:

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

覆盖:

close 在类中 AsyncConnection

抛出:

java.io.IOException

isOpen

public final boolean isOpen()

指定者:

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

指定者:

isOpen 在类中 AsyncConnection

isTCP

public final boolean isTCP()

指定者:

isTCP 在类中 AsyncConnection