public class OioSocketChannel extends OioByteStreamChannel implements SocketChannel
SocketChannel which is using Old-Blocking-IOAbstractChannel.AbstractUnsafeChannel.UnsafeSO_TIMEOUT| 构造器和说明 |
|---|
OioSocketChannel()
Create a new instance with an new
Socket |
OioSocketChannel(Channel parent,
java.net.Socket socket)
Create a new instance from the given
Socket |
OioSocketChannel(java.net.Socket socket)
Create a new instance from the given
Socket |
| 限定符和类型 | 方法和说明 |
|---|---|
protected boolean |
checkInputShutdown()
Check if the input was shutdown and if so return
true. |
OioSocketChannelConfig |
config()
Returns the configuration of this channel.
|
protected void |
doBind(java.net.SocketAddress localAddress)
Bind the
Channel to the SocketAddress |
protected void |
doClose()
Close the
Channel |
protected void |
doConnect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress)
Connect to the remote peer using the given localAddress if one is specified or
null otherwise. |
protected void |
doDisconnect()
Disconnect this
Channel from its remote peer |
protected int |
doReadBytes(ByteBuf buf)
Read bytes from the underlying Socket.
|
protected void |
doShutdownOutput()
Called when conditions justify shutting down the output portion of the channel.
|
boolean |
isActive()
Return
true if the Channel is active and so connected. |
boolean |
isInputShutdown()
Returns
true if and only if the remote peer shut down its output so that no more
data is received from this channel. |
boolean |
isOpen()
Returns
true if the Channel is open and may get active later |
boolean |
isOutputShutdown() |
java.net.InetSocketAddress |
localAddress()
Returns the local address where this channel is bound to.
|
protected java.net.SocketAddress |
localAddress0()
Returns the
SocketAddress which is bound locally. |
ServerSocketChannel |
parent()
Returns the parent of this channel.
|
java.net.InetSocketAddress |
remoteAddress()
Returns the remote address where this channel is connected to.
|
protected java.net.SocketAddress |
remoteAddress0()
Return the
SocketAddress which the Channel is connected to. |
protected void |
setReadPending(boolean readPending) |
ChannelFuture |
shutdownOutput() |
ChannelFuture |
shutdownOutput(ChannelPromise promise) |
activate, available, doWriteBytes, doWriteFileRegiondoRead, doWrite, filterOutboundMessage, metadatadoBeginRead, isCompatible, isReadPending, newUnsafealloc, bind, bind, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doDeregister, doRegister, equals, eventLoop, flush, hashCode, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, newChannelPipeline, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, pipeline, read, toString, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlushattralloc, bind, bind, close, close, closeFuture, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, eventLoop, flush, isRegistered, isWritable, metadata, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, pipeline, read, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlushattrpublic OioSocketChannel()
Socketpublic OioSocketChannel(java.net.Socket socket)
Socketsocket - the Socket which is used by this instancepublic OioSocketChannel(Channel parent, java.net.Socket socket)
Socketparent - the parent Channel which was used to create this instance. This can be null if the
has no parent as it was created by your self.socket - the Socket which is used by this instancepublic ServerSocketChannel parent()
Channelparent 在接口中 Channelparent 在接口中 SocketChannelparent 在类中 AbstractChannelnull if this channel does not have a parent channel.public OioSocketChannelConfig config()
Channelconfig 在接口中 Channelconfig 在接口中 SocketChannelpublic boolean isOpen()
Channeltrue if the Channel is open and may get active laterpublic boolean isActive()
Channeltrue if the Channel is active and so connected.isActive 在接口中 ChannelisActive 在类中 OioByteStreamChannelpublic boolean isInputShutdown()
DuplexChanneltrue if and only if the remote peer shut down its output so that no more
data is received from this channel. Note that the semantic of this method is different from
that of Socket.shutdownInput() and Socket.isInputShutdown().isInputShutdown 在接口中 DuplexChannelisInputShutdown 在类中 AbstractOioByteChannelpublic boolean isOutputShutdown()
isOutputShutdown 在接口中 DuplexChannelSocket.isOutputShutdown()@UnstableApi protected final void doShutdownOutput() throws java.lang.Exception
AbstractChanneldoShutdownOutput 在类中 AbstractChanneljava.lang.Exceptionpublic ChannelFuture shutdownOutput()
shutdownOutput 在接口中 DuplexChannelSocket.shutdownOutput()protected int doReadBytes(ByteBuf buf) throws java.lang.Exception
AbstractOioByteChanneldoReadBytes 在类中 OioByteStreamChannelbuf - the ByteBuf into which the read bytes will be writtenjava.lang.Exception - is thrown if an error occurredpublic ChannelFuture shutdownOutput(ChannelPromise promise)
shutdownOutput 在接口中 DuplexChannelWill notify the given {@link ChannelPromise}public java.net.InetSocketAddress localAddress()
ChannelSocketAddress is supposed to be down-cast into more concrete
type such as InetSocketAddress to retrieve the detailed
information.localAddress 在接口中 ChannellocalAddress 在接口中 SocketChannellocalAddress 在类中 AbstractChannelnull if this channel is not bound.public java.net.InetSocketAddress remoteAddress()
ChannelSocketAddress is supposed to be down-cast into more
concrete type such as InetSocketAddress to retrieve the detailed
information.remoteAddress 在接口中 ChannelremoteAddress 在接口中 SocketChannelremoteAddress 在类中 AbstractChannelnull if this channel is not connected.
If this channel is not connected but it can receive messages
from arbitrary remote addresses (e.g. DatagramChannel,
use DefaultAddressedEnvelope.recipient() to determine
the origination of the received message as this method will
return null.protected java.net.SocketAddress localAddress0()
AbstractChannelSocketAddress which is bound locally.localAddress0 在类中 AbstractChannelprotected java.net.SocketAddress remoteAddress0()
AbstractChannelSocketAddress which the Channel is connected to.remoteAddress0 在类中 AbstractChannelprotected void doBind(java.net.SocketAddress localAddress)
throws java.lang.Exception
AbstractChannelChannel to the SocketAddressdoBind 在类中 AbstractChanneljava.lang.Exceptionprotected void doConnect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress)
throws java.lang.Exception
AbstractOioChannelnull otherwise.doConnect 在类中 AbstractOioChanneljava.lang.Exceptionprotected void doDisconnect()
throws java.lang.Exception
AbstractChannelChannel from its remote peerdoDisconnect 在类中 AbstractChanneljava.lang.Exceptionprotected void doClose()
throws java.lang.Exception
AbstractChannelChanneldoClose 在类中 OioByteStreamChanneljava.lang.Exceptionprotected boolean checkInputShutdown()
AbstractOioByteChanneltrue. The default implementation sleeps also for
AbstractOioChannel.SO_TIMEOUT milliseconds to simulate some blocking.protected void setReadPending(boolean readPending)
setReadPending 在类中 AbstractOioChannel