Class JavaSslClientSocket

java.lang.Object

one.nio.net.Socket

one.nio.net.JavaSslClientSocket

All Implemented Interfaces:

Closeable, AutoCloseable, ByteChannel, Channel, ReadableByteChannel, WritableByteChannel

public final class JavaSslClientSocket
extends Socket

Field Summary

Fields

Modifier and Type	Field	Description
private ReadableByteChannel	inCh
private InputStream	inputStream
private WritableByteChannel	outCh
private OutputStream	outputStream
private final SSLSocket	socket
private final JavaSslClientContext	sslContext

Fields inherited from class Socket

AF_INET, AF_INET6, AF_UNIX, IPTOS_LOWDELAY, IPTOS_MINCOST, IPTOS_RELIABILITY, IPTOS_THROUGHPUT, MSG_DONTROUTE, MSG_DONTWAIT, MSG_MORE, MSG_OOB, MSG_PEEK, MSG_TRUNC, MSG_WAITALL, NO_PORT, SO_BROADCAST, SO_BSDCOMPAT, SO_DEBUG, SO_DONTROUTE, SO_ERROR, SO_KEEPALIVE, SO_LINGER, SO_NO_CHECK, SO_OOBINLINE, SO_PASSCRED, SO_PEERCRED, SO_PRIORITY, SO_RCVBUF, SO_RCVLOWAT, SO_RCVTIMEO, SO_REUSEADDR, SO_REUSEPORT, SO_SNDBUF, SO_SNDLOWAT, SO_SNDTIMEO, SO_TYPE, SOCK_DGRAM, SOCK_RAW, SOCK_RDM, SOCK_SEQPACKET, SOCK_STREAM, SOL_IP, SOL_IPV6, SOL_SOCKET, SOL_TCP, SOL_UDP, TCP_CONGESTION, TCP_CORK, TCP_DEFER_ACCEPT, TCP_INFO, TCP_KEEPCNT, TCP_KEEPIDLE, TCP_KEEPINTVL, TCP_LINGER2, TCP_MAXSEG, TCP_NODELAY, TCP_QUICKACK, TCP_SYNCNT, TCP_USER_TIMEOUT, TCP_WINDOW_CLAMP

Constructor Summary

Constructors

Constructor	Description
JavaSslClientSocket(JavaSslClientContext sslContext)

Method Summary

Modifier and Type	Method	Description
Socket	accept()
void	bind(InetAddress address, int port, int backlog)
void	close()
void	connect(InetAddress address, int port)
boolean	getDeferAccept()
boolean	getKeepAlive()
InetSocketAddress	getLocalAddress()
boolean	getNoDelay()
byte[]	getOption(int level, int option)
int	getRecvBuffer()
InetSocketAddress	getRemoteAddress()
boolean	getReuseAddr()
boolean	getReusePort()
int	getSendBuffer()
SslContext	getSslContext()
<T> T	getSslOption(SslOption<T> option)
boolean	getTcpFastOpen()
int	getTimeout()
int	getTos()
boolean	isBlocking()
boolean	isOpen()
void	listen(int backlog)
int	read(byte[] data, int offset, int count, int flags)
int	read(ByteBuffer dst)
void	readFully(byte[] data, int offset, int count)
int	readRaw(long buf, int count, int flags)
InetSocketAddress	recv(ByteBuffer dst, int flags)
int	recvMsg(Msg msg, int flags)
int	send(ByteBuffer src, int flags, InetAddress address, int port)
long	sendFile(RandomAccessFile file, long offset, long count)
int	sendMsg(Msg msg, int flags)
void	setBlocking(boolean blocking)
void	setDeferAccept(boolean deferAccept)
void	setKeepAlive(boolean keepAlive)
void	setNoDelay(boolean noDelay)
boolean	setOption(int level, int option, byte[] value)
void	setRecvBuffer(int recvBuf)
void	setReuseAddr(boolean reuseAddr, boolean reusePort)
void	setSendBuffer(int sendBuf)
void	setTcpFastOpen(boolean tcpFastOpen)
void	setTimeout(int timeout)
void	setTos(int tos)
Socket	sslUnwrap()
Socket	sslWrap(SslContext context)
int	write(byte[] data, int offset, int count, int flags)
int	write(ByteBuffer src)
void	writeFully(byte[] data, int offset, int count)
int	writeRaw(long buf, int count, int flags)

Methods inherited from class Socket

acceptNonBlocking, bind, bindInet, bindUnix, connect, connectInet, connectUnix, create, createClientSocket, createClientSocket, createDatagramSocket, createServerSocket, createUnixSocket, fromFD, getNotsentLowat, getThinLinearTimeouts, handshake, read, send, setNotsentLowat, setThinLinearTimeouts, write

Methods inherited from class Object

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

Field Details

socket

private final SSLSocket socket

sslContext

private final JavaSslClientContext sslContext

outCh

private volatile WritableByteChannel outCh

inCh

private volatile ReadableByteChannel inCh

outputStream

private volatile OutputStream outputStream

inputStream

private volatile InputStream inputStream

Constructor Details

JavaSslClientSocket

public JavaSslClientSocket(JavaSslClientContext sslContext)

Method Details

isOpen

public boolean isOpen()

Specified by:

isOpen in interface Channel

Specified by:

isOpen in class Socket

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Channel

Specified by:

close in interface Closeable

Specified by:

close in class Socket

accept

public Socket accept()
              throws IOException

Specified by:

accept in class Socket

Throws:

IOException

connect

public void connect(InetAddress address,
 int port)
             throws IOException

Specified by:

connect in class Socket

Throws:

IOException

bind

public void bind(InetAddress address,
 int port,
 int backlog)
          throws IOException

Specified by:

bind in class Socket

Throws:

IOException

writeRaw

public int writeRaw(long buf,
 int count,
 int flags)
             throws IOException

Specified by:

writeRaw in class Socket

Throws:

IOException

write

public int write(byte[] data,
 int offset,
 int count,
 int flags)
          throws IOException

Specified by:

write in class Socket

Throws:

IOException

writeFully

public void writeFully(byte[] data,
 int offset,
 int count)
                throws IOException

Specified by:

writeFully in class Socket

Throws:

IOException

send

public int send(ByteBuffer src,
 int flags,
 InetAddress address,
 int port)
         throws IOException

Specified by:

send in class Socket

Throws:

IOException

readRaw

public int readRaw(long buf,
 int count,
 int flags)
            throws IOException

Specified by:

readRaw in class Socket

Throws:

IOException

read

public int read(byte[] data,
 int offset,
 int count,
 int flags)
         throws IOException

Specified by:

read in class Socket

Throws:

IOException

readFully

public void readFully(byte[] data,
 int offset,
 int count)
               throws IOException

Specified by:

readFully in class Socket

Throws:

IOException

sendFile

public long sendFile(RandomAccessFile file,
 long offset,
 long count)
              throws IOException

Specified by:

sendFile in class Socket

Throws:

IOException

recv

public InetSocketAddress recv(ByteBuffer dst,
 int flags)

Specified by:

recv in class Socket

sendMsg

public int sendMsg(Msg msg,
 int flags)

Specified by:

sendMsg in class Socket

recvMsg

public int recvMsg(Msg msg,
 int flags)
            throws IOException

Specified by:

recvMsg in class Socket

Throws:

IOException

setBlocking

public void setBlocking(boolean blocking)

Specified by:

setBlocking in class Socket

isBlocking

public boolean isBlocking()

Specified by:

isBlocking in class Socket

setTimeout

public void setTimeout(int timeout)

Specified by:

setTimeout in class Socket

getTimeout

public int getTimeout()

Specified by:

getTimeout in class Socket

setKeepAlive

public void setKeepAlive(boolean keepAlive)

Specified by:

setKeepAlive in class Socket

getKeepAlive

public boolean getKeepAlive()

Specified by:

getKeepAlive in class Socket

setNoDelay

public void setNoDelay(boolean noDelay)

Specified by:

setNoDelay in class Socket

getNoDelay

public boolean getNoDelay()

Specified by:

getNoDelay in class Socket

setTcpFastOpen

public void setTcpFastOpen(boolean tcpFastOpen)

Specified by:

setTcpFastOpen in class Socket

getTcpFastOpen

public boolean getTcpFastOpen()

Specified by:

getTcpFastOpen in class Socket

setDeferAccept

public void setDeferAccept(boolean deferAccept)

Specified by:

setDeferAccept in class Socket

getDeferAccept

public boolean getDeferAccept()

Specified by:

getDeferAccept in class Socket

setReuseAddr

public void setReuseAddr(boolean reuseAddr,
 boolean reusePort)

Specified by:

setReuseAddr in class Socket

getReuseAddr

public boolean getReuseAddr()

Specified by:

getReuseAddr in class Socket

getReusePort

public boolean getReusePort()

Specified by:

getReusePort in class Socket

setRecvBuffer

public void setRecvBuffer(int recvBuf)

Specified by:

setRecvBuffer in class Socket

getRecvBuffer

public int getRecvBuffer()

Specified by:

getRecvBuffer in class Socket

setSendBuffer

public void setSendBuffer(int sendBuf)

Specified by:

setSendBuffer in class Socket

getSendBuffer

public int getSendBuffer()

Specified by:

getSendBuffer in class Socket

setTos

public void setTos(int tos)

Specified by:

setTos in class Socket

getTos

public int getTos()

Specified by:

getTos in class Socket

getOption

public byte[] getOption(int level,
 int option)

Specified by:

getOption in class Socket

setOption

public boolean setOption(int level,
 int option,
 byte[] value)

Specified by:

setOption in class Socket

getLocalAddress

public InetSocketAddress getLocalAddress()

Specified by:

getLocalAddress in class Socket

getRemoteAddress

public InetSocketAddress getRemoteAddress()

Specified by:

getRemoteAddress in class Socket

sslWrap

public Socket sslWrap(SslContext context)

Specified by:

sslWrap in class Socket

read

public int read(ByteBuffer dst)
         throws IOException

Throws:

IOException

write

public int write(ByteBuffer src)
          throws IOException

Throws:

IOException

sslUnwrap

public Socket sslUnwrap()

Specified by:

sslUnwrap in class Socket

getSslContext

public SslContext getSslContext()

Specified by:

getSslContext in class Socket

getSslOption

public <T> T getSslOption(SslOption<T> option)

Specified by:

getSslOption in class Socket

listen

public void listen(int backlog)
            throws IOException

Specified by:

listen in class Socket

Throws:

IOException