public class OioSocketChannel extends OioByteStreamChannel implements SocketChannel
SocketChannel
which is using Old-Blocking-IOAbstractChannel.AbstractUnsafe
Channel.Unsafe
SO_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, doWriteFileRegion
doRead, doWrite, filterOutboundMessage, metadata
doBeginRead, isCompatible, isReadPending, newUnsafe
alloc, 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, writeAndFlush
attr
alloc, 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, writeAndFlush
attr
public OioSocketChannel()
Socket
public OioSocketChannel(java.net.Socket socket)
Socket
socket
- the Socket
which is used by this instancepublic OioSocketChannel(Channel parent, java.net.Socket socket)
Socket
parent
- 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()
Channel
parent
在接口中 Channel
parent
在接口中 SocketChannel
parent
在类中 AbstractChannel
null
if this channel does not have a parent channel.public OioSocketChannelConfig config()
Channel
config
在接口中 Channel
config
在接口中 SocketChannel
public boolean isOpen()
Channel
true
if the Channel
is open and may get active laterpublic boolean isActive()
Channel
true
if the Channel
is active and so connected.isActive
在接口中 Channel
isActive
在类中 OioByteStreamChannel
public boolean isInputShutdown()
DuplexChannel
true
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
在接口中 DuplexChannel
isInputShutdown
在类中 AbstractOioByteChannel
public boolean isOutputShutdown()
isOutputShutdown
在接口中 DuplexChannel
Socket.isOutputShutdown()
@UnstableApi protected final void doShutdownOutput() throws java.lang.Exception
AbstractChannel
doShutdownOutput
在类中 AbstractChannel
java.lang.Exception
public ChannelFuture shutdownOutput()
shutdownOutput
在接口中 DuplexChannel
Socket.shutdownOutput()
protected int doReadBytes(ByteBuf buf) throws java.lang.Exception
AbstractOioByteChannel
doReadBytes
在类中 OioByteStreamChannel
buf
- the ByteBuf
into which the read bytes will be writtenjava.lang.Exception
- is thrown if an error occurredpublic ChannelFuture shutdownOutput(ChannelPromise promise)
shutdownOutput
在接口中 DuplexChannel
Will notify the given {@link ChannelPromise}
public java.net.InetSocketAddress localAddress()
Channel
SocketAddress
is supposed to be down-cast into more concrete
type such as InetSocketAddress
to retrieve the detailed
information.localAddress
在接口中 Channel
localAddress
在接口中 SocketChannel
localAddress
在类中 AbstractChannel
null
if this channel is not bound.public java.net.InetSocketAddress remoteAddress()
Channel
SocketAddress
is supposed to be down-cast into more
concrete type such as InetSocketAddress
to retrieve the detailed
information.remoteAddress
在接口中 Channel
remoteAddress
在接口中 SocketChannel
remoteAddress
在类中 AbstractChannel
null
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()
AbstractChannel
SocketAddress
which is bound locally.localAddress0
在类中 AbstractChannel
protected java.net.SocketAddress remoteAddress0()
AbstractChannel
SocketAddress
which the Channel
is connected to.remoteAddress0
在类中 AbstractChannel
protected void doBind(java.net.SocketAddress localAddress) throws java.lang.Exception
AbstractChannel
Channel
to the SocketAddress
doBind
在类中 AbstractChannel
java.lang.Exception
protected void doConnect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress) throws java.lang.Exception
AbstractOioChannel
null
otherwise.doConnect
在类中 AbstractOioChannel
java.lang.Exception
protected void doDisconnect() throws java.lang.Exception
AbstractChannel
Channel
from its remote peerdoDisconnect
在类中 AbstractChannel
java.lang.Exception
protected void doClose() throws java.lang.Exception
AbstractChannel
Channel
doClose
在类中 OioByteStreamChannel
java.lang.Exception
protected boolean checkInputShutdown()
AbstractOioByteChannel
true
. The default implementation sleeps also for
AbstractOioChannel.SO_TIMEOUT
milliseconds to simulate some blocking.protected void setReadPending(boolean readPending)
setReadPending
在类中 AbstractOioChannel