Class NioClient

java.lang.Object

org.jgroups.blocks.cs.BaseServer

org.jgroups.blocks.cs.NioBaseServer

org.jgroups.blocks.cs.NioClient

All Implemented Interfaces:

Closeable, AutoCloseable, Client, ConnectionListener

public class NioClient
extends NioBaseServer
implements Client

Client to access servers based on TCP_NIO2

Since:

3.6.5

Author:

Bela Ban

Nested Class Summary

Nested classes/interfaces inherited from class NioBaseServer

NioBaseServer.Acceptor

Nested classes/interfaces inherited from class BaseServer

BaseServer.Reaper

Field Summary

Fields

Modifier and Type	Field	Description
protected NioConnection	conn
protected Address	remote_addr

Fields inherited from class NioBaseServer

acceptor, copy_on_partial_write, max_send_buffers, num_selects, reader_idle_time, reg_lock, registration, selector, use_direct_memory

Fields inherited from class BaseServer

client_bind_addr, client_bind_port, conn_expire_time, conn_listeners, conns, defer_client_binding, factory, linger, local_addr, locks, log, log_details, max_length, reaper, reaperInterval, receiver, recv_buf_size, running, send_buf_size, sock_conn_timeout, socket_factory, tcp_nodelay, time_service, timer, use_peer_connections

Constructor Summary

Constructors

Constructor	Description
NioClient(InetAddress bind_addr, int bind_port, InetAddress server_addr, int server_port)	Creates an instance of an NioClient that acts as a client: no server channel is created and no acceptor is started to listen for incoming connections.
NioClient(InetAddress bind_addr, int bind_port, InetAddress server_addr, int server_port, boolean vthreads)
NioClient(IpAddress bind_addr, IpAddress server_addr)	Creates an instance of an NioClient that acts as a client: no server channel is created and no acceptor is started to listen for incoming connections.

Method Summary

Modifier and Type	Method	Description
void	close(boolean graceful)
protected void	doStart()
protected void	doStop(boolean graceful)
boolean	isConnected()
Address	remoteAddress()
NioClient	remoteAddress(IpAddress addr)	Sets the address of the server.
void	send(byte[] data, int offset, int length)	Sends data to the remote server.
void	send(ByteBuffer data)	Sends data to the remote server.
void	send(ByteBuffer[] bufs)	Sends data to the remote server.
void	send(Address dest, byte[] data, int offset, int length)
void	send(Address dest, ByteBuffer buf)
void	start()
void	stop()	Stops listening for connections and handling traffic.
String	toString()

Methods inherited from class NioBaseServer

acceptorDone, acceptorRunning, copyOnPartialWrite, copyOnPartialWrite, createConnection, handleAccept, maxSendBuffers, maxSendBuffers, numDrops, numPartialWrites, numSelects, printBuffers, readerIdleTime, readerIdleTime, register, selectorOpen, useDirectMemory, useDirectMemory

Methods inherited from class BaseServer

addConnectionListener, clearConnections, clearConnections, clientBindAddress, clientBindAddress, clientBindPort, clientBindPort, close, closeConnection, closeConnection, closeConnection, closeConnection, connected, connectionClosed, connectionEstablished, connectionEstablishedTo, connExpireTime, connExpireTimeout, deferClientBinding, deferClientBinding, explanation, flush, flushAll, forAllConnections, getConnection, getLock, getMaxLength, getNumConnections, getNumOpenConnections, handleIncomingConnection, handleOutgoingConnection, hasConnection, linger, linger, localAddress, localAddress, log, log, logDetails, logDetails, notifyConnectionClosed, notifyConnectionEstablished, printConnections, reaperInterval, reaperInterval, receive, receive, receive, receiveBufferSize, receiveBufferSize, receiver, receiver, removeConnectionIfPresent, removeConnectionListener, replaceConnection, retainAll, retainAll, running, sendBufferSize, sendBufferSize, sendToAll, sendToAll, setMaxLength, socketConnectionTimeout, socketConnectionTimeout, socketFactory, socketFactory, tcpNodelay, tcpNodelay, timer, timer, timeService, timeService, toString, useAcks, useAcks, usePeerConnections, usePeerConnections, validateArgs

Methods inherited from class Object

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

Methods inherited from interface Client

localAddress

Field Details

remote_addr

protected Address remote_addr

conn

protected NioConnection conn

Constructor Details

NioClient

public NioClient(IpAddress bind_addr,
 IpAddress server_addr)

Creates an instance of an NioClient that acts as a client: no server channel is created and no acceptor is started to listen for incoming connections. Instead, a channel is created (bound to bind_addr/bind_port) and connected to server_addr/server_port. This is used to send messages to the remote server and receive messages from it. Note that there is only a single TCP connection established between the client and server.

Parameters:

bind_addr - The address to which the local channel should bind to. Can be null, then the OS picks the address

server_addr - The address of the server to connect to

NioClient

public NioClient(InetAddress bind_addr,
 int bind_port,
 InetAddress server_addr,
 int server_port)

Creates an instance of an NioClient that acts as a client: no server channel is created and no acceptor is started to listen for incoming connections. Instead, a channel is created (bound to bind_addr/bind_port) and connected to server_addr/server_port. This is used to send messages to the remote server and receive messages from it. Note that there is only a single TCP connection established between the client and server.

Parameters:

bind_addr - The address to which the local channel should bind to. Can be null, then the OS picks the address

bind_port - The local port. Can be 0, then the OS picks the port.

server_addr - The address of the server to connect to

server_port - The port of the server to connect to.

NioClient

public NioClient(InetAddress bind_addr,
 int bind_port,
 InetAddress server_addr,
 int server_port,
 boolean vthreads)

Method Details

remoteAddress

public Address remoteAddress()

Specified by:

remoteAddress in interface Client

remoteAddress

public NioClient remoteAddress(IpAddress addr)

Sets the address of the server. Has no effect when already connected.

isConnected

public boolean isConnected()

Specified by:

isConnected in interface Client

start

public void start()
           throws Exception

Overrides:

start in class BaseServer

Throws:

Exception

stop

public void stop()

Description copied from class: BaseServer

Stops listening for connections and handling traffic. Typically, socket handler or selector threads are stopped, and server sockets or channels are closed.

Overrides:

stop in class BaseServer

close

public void close(boolean graceful)
           throws IOException

Throws:

IOException

send

public void send(Address dest,
 ByteBuffer buf)
          throws Exception

Overrides:

send in class BaseServer

Throws:

Exception

send

public void send(Address dest,
 byte[] data,
 int offset,
 int length)
          throws Exception

Overrides:

send in class BaseServer

Throws:

Exception

send

public void send(byte[] data,
 int offset,
 int length)
          throws Exception

Description copied from interface: Client

Sends data to the remote server. The server's address must have been set before.

Specified by:

send in interface Client

Throws:

Exception

send

public void send(ByteBuffer data)
          throws Exception

Description copied from interface: Client

Sends data to the remote server. The server's address must have been set before.

Specified by:

send in interface Client

Throws:

Exception

send

public void send(ByteBuffer[] bufs)
          throws Exception

Description copied from interface: Client

Sends data to the remote server. The server's address must have been set before.

Specified by:

send in interface Client

Throws:

Exception

toString

public String toString()

Overrides:

toString in class BaseServer

doStart

protected void doStart()
                throws Exception

Throws:

Exception

doStop

protected void doStop(boolean graceful)