com.alipay.remoting.rpc

Class RpcClient

java.lang.Object

com.alipay.remoting.AbstractLifeCycle

com.alipay.remoting.AbstractBoltClient

com.alipay.remoting.rpc.RpcClient

All Implemented Interfaces:

BoltClient, ConfigurableInstance, Configuration, LifeCycle

public class RpcClient
extends AbstractBoltClient

Client for Rpc.

Field Summary

Fields

Modifier and Type	Field and Description
protected RpcRemoting	rpcRemoting

Constructor Summary

Constructors

Constructor and Description
RpcClient()

Method Summary

Modifier and Type	Method and Description
void	addConnectionEventProcessor(ConnectionEventType type, ConnectionEventProcessor processor) Add processor to process connection event.
boolean	checkConnection(String address) check connection, the address format example - 127.0.0.1:12200?
boolean	checkConnection(String address, boolean createIfAbsent) check connection, the address format example - 127.0.0.1:12200?
boolean	checkConnection(String address, boolean createIfAbsent, boolean createAsync) check connection, the address format example - 127.0.0.1:12200?
void	closeConnection(String addr) Close all connections of a address
void	closeConnection(Url url) Close all connections of a Url
void	closeStandaloneConnection(Connection conn) Close a standalone connection
Connection	createStandaloneConnection(String address, int connectTimeout) Create a stand alone connection using address, address format example - 127.0.0.1:12200 Notice: Each time you can this method, will create a new connection.
Connection	createStandaloneConnection(String ip, int port, int connectTimeout) Create a stand alone connection using ip and port.
void	disableConnectionMonitorSwitch() Deprecated.
void	disableConnHeartbeat(String address) Disable heart beat for a certain connection.
void	disableConnHeartbeat(Url url) Disable heart beat for a certain connection.
void	disableReconnectSwith() Deprecated.
void	enableConnectionMonitorSwitch() Deprecated.
void	enableConnHeartbeat(String address) Enable heart beat for a certain connection.
void	enableConnHeartbeat(Url url) Enable heart beat for a certain connection.
void	enableReconnectSwitch() Deprecated.
RemotingAddressParser	getAddressParser() Getter method for property addressParser.
Map<String,List<Connection>>	getAllManagedConnections() get all connections managed by rpc client
Connection	getConnection(String address, int connectTimeout) Get a connection using address, address format example - 127.0.0.1:12200?
Connection	getConnection(Url url, int connectTimeout) Get a connection using a Url.
ConnectionManager	getConnectionManager() Getter method for property connectionManager.
void	init() Deprecated.
Object	invokeSync(Connection conn, Object request, int timeoutMillis) Synchronous invocation using a Connection Notice: DO NOT modify the request object concurrently when this method is called.
Object	invokeSync(Connection conn, Object request, InvokeContext invokeContext, int timeoutMillis) Synchronous invocation with a InvokeContext, common api notice please see BoltClient.invokeSync(Connection, Object, int)
Object	invokeSync(String address, Object request, int timeoutMillis) Synchronous invocation using a string address, address format example - 127.0.0.1:12200?
Object	invokeSync(String address, Object request, InvokeContext invokeContext, int timeoutMillis) Synchronous invocation with a InvokeContext, common api notice please see BoltClient.invokeSync(String, Object, int)
Object	invokeSync(Url url, Object request, int timeoutMillis) Synchronous invocation using a parsed Url Notice: DO NOT modify the request object concurrently when this method is called.
Object	invokeSync(Url url, Object request, InvokeContext invokeContext, int timeoutMillis) Synchronous invocation with a InvokeContext, common api notice please see BoltClient.invokeSync(Url, Object, int)
void	invokeWithCallback(Connection conn, Object request, InvokeCallback invokeCallback, int timeoutMillis) Callback invocation using a Connection You can specify an implementation of InvokeCallback to get the result.
void	invokeWithCallback(Connection conn, Object request, InvokeContext invokeContext, InvokeCallback invokeCallback, int timeoutMillis) Callback invocation with a InvokeContext, common api notice please see BoltClient.invokeWithCallback(Connection, Object, InvokeCallback, int)
void	invokeWithCallback(String address, Object request, InvokeCallback invokeCallback, int timeoutMillis) Callback invocation using a string address, address format example - 127.0.0.1:12200?
void	invokeWithCallback(String address, Object request, InvokeContext invokeContext, InvokeCallback invokeCallback, int timeoutMillis) Callback invocation with a InvokeContext, common api notice please see BoltClient.invokeWithCallback(String, Object, InvokeCallback, int)
void	invokeWithCallback(Url url, Object request, InvokeCallback invokeCallback, int timeoutMillis) Callback invocation using a parsed Url You can specify an implementation of InvokeCallback to get the result.
void	invokeWithCallback(Url url, Object request, InvokeContext invokeContext, InvokeCallback invokeCallback, int timeoutMillis) Callback invocation with a InvokeContext, common api notice please see BoltClient.invokeWithCallback(Url, Object, InvokeCallback, int)
RpcResponseFuture	invokeWithFuture(Connection conn, Object request, int timeoutMillis) Future invocation using a Connection You can get result use the returned RpcResponseFuture.
RpcResponseFuture	invokeWithFuture(Connection conn, Object request, InvokeContext invokeContext, int timeoutMillis) Future invocation with a InvokeContext, common api notice please see BoltClient.invokeWithFuture(Connection, Object, int)
RpcResponseFuture	invokeWithFuture(String address, Object request, int timeoutMillis) Future invocation using a string address, address format example - 127.0.0.1:12200?
RpcResponseFuture	invokeWithFuture(String address, Object request, InvokeContext invokeContext, int timeoutMillis) Future invocation with a InvokeContext, common api notice please see BoltClient.invokeWithFuture(String, Object, int)
RpcResponseFuture	invokeWithFuture(Url url, Object request, int timeoutMillis) Future invocation using a parsed Url You can get result use the returned RpcResponseFuture.
RpcResponseFuture	invokeWithFuture(Url url, Object request, InvokeContext invokeContext, int timeoutMillis) Future invocation with a InvokeContext, common api notice please see BoltClient.invokeWithFuture(Url, Object, int)
boolean	isConnectionMonitorSwitchOn() Deprecated.
boolean	isReconnectSwitchOn() Deprecated.
void	oneway(Connection conn, Object request) One way invocation using a Connection Notice: DO NOT modify the request object concurrently when this method is called.
void	oneway(Connection conn, Object request, InvokeContext invokeContext) Oneway invocation with a InvokeContext, common api notice please see BoltClient.oneway(Connection, Object)
void	oneway(String address, Object request) One way invocation using a string address, address format example - 127.0.0.1:12200?
void	oneway(String address, Object request, InvokeContext invokeContext) Oneway invocation with a InvokeContext, common api notice please see BoltClient.oneway(Connection, Object)
void	oneway(Url url, Object request) One way invocation using a parsed Url Notice: DO NOT modify the request object concurrently when this method is called.
void	oneway(Url url, Object request, InvokeContext invokeContext) Oneway invocation with a InvokeContext, common api notice please see BoltClient.oneway(Url, Object)
void	registerUserProcessor(UserProcessor<?> processor) Use UserProcessorRegisterHelperUserProcessorRegisterHelper to help register user processor for client side.
void	setAddressParser(RemotingAddressParser addressParser) Setter method for property addressParser.
void	setConnectionManager(ConnectionManager connectionManager) Setter method for property connectionManager.
void	setMonitorStrategy(ConnectionMonitorStrategy monitorStrategy) Setter method for property monitorStrategy.
void	shutdown() Shutdown.
void	startup()

Methods inherited from class com.alipay.remoting.AbstractBoltClient

conf, initWriteBufferWaterMark, netty_buffer_high_watermark, netty_buffer_low_watermark, option, option, switches

Methods inherited from class com.alipay.remoting.AbstractLifeCycle

ensureStarted, isStarted

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.alipay.remoting.LifeCycle

isStarted

Field Detail

rpcRemoting

protected RpcRemoting rpcRemoting

Constructor Detail

RpcClient

public RpcClient()

Method Detail

init

@Deprecated
public void init()

Deprecated.

Please use startup() instead

shutdown

public void shutdown()

Shutdown.

Notice:

Rpc client can not be used any more after shutdown. If you need, you should destroy it, and instantiate another one.

Specified by:

shutdown in interface LifeCycle

Overrides:

shutdown in class AbstractLifeCycle

startup

public void startup()
             throws LifeCycleException

Specified by:

startup in interface LifeCycle

Overrides:

startup in class AbstractLifeCycle

Throws:

LifeCycleException

oneway

public void oneway(String address,
                   Object request)
            throws RemotingException,
                   InterruptedException

Description copied from interface: BoltClient

One way invocation using a string address, address format example - 127.0.0.1:12200?key1=value1&key2=value2

Notice:

1. DO NOT modify the request object concurrently when this method is called.
2. When do invocation, use the string address to find a available connection, if none then create one.
• You can use RpcConfigs.CONNECT_TIMEOUT_KEY to specify connection timeout, time unit is milliseconds, e.g [127.0.0.1:12200?_CONNECTTIMEOUT=3000]
• You can use RpcConfigs.CONNECTION_NUM_KEY to specify connection number for each ip and port, e.g [127.0.0.1:12200?_CONNECTIONNUM=30]
• You can use RpcConfigs.CONNECTION_WARMUP_KEY to specify whether need warmup all connections for the first time you call this method, e.g [127.0.0.1:12200?_CONNECTIONWARMUP=false]
3. You should use BoltClient.closeConnection(String addr) to close it if you want.

Parameters:

address - target address

request - request

Throws:

RemotingException

InterruptedException

oneway

public void oneway(String address,
                   Object request,
                   InvokeContext invokeContext)
            throws RemotingException,
                   InterruptedException

Description copied from interface: BoltClient

Oneway invocation with a InvokeContext, common api notice please see BoltClient.oneway(Connection, Object)

Parameters:

address - target address

request - request

invokeContext - invoke context

Throws:

RemotingException

InterruptedException

oneway

public void oneway(Url url,
                   Object request)
            throws RemotingException,
                   InterruptedException

Description copied from interface: BoltClient

One way invocation using a parsed Url

Notice:

1. DO NOT modify the request object concurrently when this method is called.
2. When do invocation, use the parsed Url to find a available connection, if none then create one.
• You can use Url.setConnectTimeout(int) to specify connection timeout, time unit is milliseconds.
• You can use Url.setConnNum(int) to specify connection number for each ip and port.
• You can use Url.setConnWarmup(boolean) to specify whether need warmup all connections for the first time you call this method.
3. You should use BoltClient.closeConnection(Url url) to close it if you want.

Parameters:

url - target url

request - object

Throws:

RemotingException

InterruptedException

oneway

public void oneway(Url url,
                   Object request,
                   InvokeContext invokeContext)
            throws RemotingException,
                   InterruptedException

Description copied from interface: BoltClient

Oneway invocation with a InvokeContext, common api notice please see BoltClient.oneway(Url, Object)

Parameters:

url - url

request - request

invokeContext - invoke context

Throws:

RemotingException

InterruptedException

oneway

public void oneway(Connection conn,
                   Object request)
            throws RemotingException

Description copied from interface: BoltClient

One way invocation using a Connection

Notice:
DO NOT modify the request object concurrently when this method is called.

Parameters:

conn - target connection

request - request

Throws:

RemotingException

oneway

public void oneway(Connection conn,
                   Object request,
                   InvokeContext invokeContext)
            throws RemotingException

Description copied from interface: BoltClient

Oneway invocation with a InvokeContext, common api notice please see BoltClient.oneway(Connection, Object)

Parameters:

conn - target connection

request - request

invokeContext - invoke context

Throws:

RemotingException

invokeSync

public Object invokeSync(String address,
                         Object request,
                         int timeoutMillis)
                  throws RemotingException,
                         InterruptedException

Description copied from interface: BoltClient

Synchronous invocation using a string address, address format example - 127.0.0.1:12200?key1=value1&key2=value2

Notice:

1. DO NOT modify the request object concurrently when this method is called.
2. When do invocation, use the string address to find a available connection, if none then create one.
• You can use RpcConfigs.CONNECT_TIMEOUT_KEY to specify connection timeout, time unit is milliseconds, e.g [127.0.0.1:12200?_CONNECTTIMEOUT=3000]
• You can use RpcConfigs.CONNECTION_NUM_KEY to specify connection number for each ip and port, e.g [127.0.0.1:12200?_CONNECTIONNUM=30]
• You can use RpcConfigs.CONNECTION_WARMUP_KEY to specify whether need warmup all connections for the first time you call this method, e.g [127.0.0.1:12200?_CONNECTIONWARMUP=false]
3. You should use BoltClient.closeConnection(String addr) to close it if you want.

Parameters:

address - target address

request - request

timeoutMillis - timeout millisecond

Returns:

result object

Throws:

RemotingException

InterruptedException

invokeSync

public Object invokeSync(String address,
                         Object request,
                         InvokeContext invokeContext,
                         int timeoutMillis)
                  throws RemotingException,
                         InterruptedException

Description copied from interface: BoltClient

Synchronous invocation with a InvokeContext, common api notice please see BoltClient.invokeSync(String, Object, int)

Parameters:

address - target address

request - request

invokeContext - invoke context

timeoutMillis - timeout in millisecond

Returns:

result object

Throws:

RemotingException

InterruptedException

invokeSync

public Object invokeSync(Url url,
                         Object request,
                         int timeoutMillis)
                  throws RemotingException,
                         InterruptedException

Description copied from interface: BoltClient

Synchronous invocation using a parsed Url

Notice:

1. DO NOT modify the request object concurrently when this method is called.
2. When do invocation, use the parsed Url to find a available connection, if none then create one.
• You can use Url.setConnectTimeout(int) to specify connection timeout, time unit is milliseconds.
• You can use Url.setConnNum(int) to specify connection number for each ip and port.
• You can use Url.setConnWarmup(boolean) to specify whether need warmup all connections for the first time you call this method.
3. You should use BoltClient.closeConnection(Url url) to close it if you want.

Parameters:

url - target url

request - request

timeoutMillis - timeout in millisecond

Returns:

Object

Throws:

RemotingException

InterruptedException

invokeSync

public Object invokeSync(Url url,
                         Object request,
                         InvokeContext invokeContext,
                         int timeoutMillis)
                  throws RemotingException,
                         InterruptedException

Description copied from interface: BoltClient

Synchronous invocation with a InvokeContext, common api notice please see BoltClient.invokeSync(Url, Object, int)

Parameters:

url - target url

request - request

invokeContext - invoke context

timeoutMillis - timeout in millisecond

Returns:

result object

Throws:

RemotingException

InterruptedException

invokeSync

public Object invokeSync(Connection conn,
                         Object request,
                         int timeoutMillis)
                  throws RemotingException,
                         InterruptedException

Description copied from interface: BoltClient

Synchronous invocation using a Connection

Notice:
DO NOT modify the request object concurrently when this method is called.

Parameters:

conn - target connection

request - request

timeoutMillis - timeout in millisecond

Returns:

Object

Throws:

RemotingException

InterruptedException

invokeSync

public Object invokeSync(Connection conn,
                         Object request,
                         InvokeContext invokeContext,
                         int timeoutMillis)
                  throws RemotingException,
                         InterruptedException

Description copied from interface: BoltClient

Synchronous invocation with a InvokeContext, common api notice please see BoltClient.invokeSync(Connection, Object, int)

Parameters:

conn - target connection

request - request

invokeContext - invoke context

timeoutMillis - timeout in millis

Returns:

Object

Throws:

RemotingException

InterruptedException

invokeWithFuture

public RpcResponseFuture invokeWithFuture(String address,
                                          Object request,
                                          int timeoutMillis)
                                   throws RemotingException,
                                          InterruptedException

Description copied from interface: BoltClient

Future invocation using a string address, address format example - 127.0.0.1:12200?key1=value1&key2=value2
You can get result use the returned RpcResponseFuture.

Notice:

1. DO NOT modify the request object concurrently when this method is called.
2. When do invocation, use the string address to find a available connection, if none then create one.
• You can use RpcConfigs.CONNECT_TIMEOUT_KEY to specify connection timeout, time unit is milliseconds, e.g [127.0.0.1:12200?_CONNECTTIMEOUT=3000]
• You can use RpcConfigs.CONNECTION_NUM_KEY to specify connection number for each ip and port, e.g [127.0.0.1:12200?_CONNECTIONNUM=30]
• You can use RpcConfigs.CONNECTION_WARMUP_KEY to specify whether need warmup all connections for the first time you call this method, e.g [127.0.0.1:12200?_CONNECTIONWARMUP=false]
3. You should use BoltClient.closeConnection(String addr) to close it if you want.

Parameters:

address - target address

request - request

timeoutMillis - timeout in millisecond

Returns:

RpcResponseFuture

Throws:

RemotingException

InterruptedException

invokeWithFuture

public RpcResponseFuture invokeWithFuture(String address,
                                          Object request,
                                          InvokeContext invokeContext,
                                          int timeoutMillis)
                                   throws RemotingException,
                                          InterruptedException

Description copied from interface: BoltClient

Future invocation with a InvokeContext, common api notice please see BoltClient.invokeWithFuture(String, Object, int)

Parameters:

address - target address

request - request

invokeContext - invoke context

timeoutMillis - timeout in millisecond

Returns:

RpcResponseFuture

Throws:

RemotingException

InterruptedException

invokeWithFuture

public RpcResponseFuture invokeWithFuture(Url url,
                                          Object request,
                                          int timeoutMillis)
                                   throws RemotingException,
                                          InterruptedException

Description copied from interface: BoltClient

Future invocation using a parsed Url
You can get result use the returned RpcResponseFuture.

Notice:

1. DO NOT modify the request object concurrently when this method is called.
2. When do invocation, use the parsed Url to find a available connection, if none then create one.
• You can use Url.setConnectTimeout(int) to specify connection timeout, time unit is milliseconds.
• You can use Url.setConnNum(int) to specify connection number for each ip and port.
• You can use Url.setConnWarmup(boolean) to specify whether need warmup all connections for the first time you call this method.
3. You should use BoltClient.closeConnection(Url url) to close it if you want.

Parameters:

url - target url

request - request

timeoutMillis - timeout in millisecond

Returns:

RpcResponseFuture

Throws:

RemotingException

InterruptedException

invokeWithFuture

public RpcResponseFuture invokeWithFuture(Url url,
                                          Object request,
                                          InvokeContext invokeContext,
                                          int timeoutMillis)
                                   throws RemotingException,
                                          InterruptedException

Description copied from interface: BoltClient

Future invocation with a InvokeContext, common api notice please see BoltClient.invokeWithFuture(Url, Object, int)

Parameters:

url - target url

request - request

invokeContext - invoke context

timeoutMillis - timeout in millis

Returns:

RpcResponseFuture

Throws:

RemotingException

InterruptedException

invokeWithFuture

public RpcResponseFuture invokeWithFuture(Connection conn,
                                          Object request,
                                          int timeoutMillis)
                                   throws RemotingException

Description copied from interface: BoltClient

Future invocation using a Connection
You can get result use the returned RpcResponseFuture.

Notice:
DO NOT modify the request object concurrently when this method is called.

Parameters:

conn - target connection

request - request

timeoutMillis - timeout in millis

Returns:

RpcResponseFuture

Throws:

RemotingException

invokeWithFuture

public RpcResponseFuture invokeWithFuture(Connection conn,
                                          Object request,
                                          InvokeContext invokeContext,
                                          int timeoutMillis)
                                   throws RemotingException

Description copied from interface: BoltClient

Future invocation with a InvokeContext, common api notice please see BoltClient.invokeWithFuture(Connection, Object, int)

Parameters:

conn - target connection

request - request

invokeContext - context

timeoutMillis - timeout millisecond

Returns:

RpcResponseFuture

Throws:

RemotingException

invokeWithCallback

public void invokeWithCallback(String address,
                               Object request,
                               InvokeCallback invokeCallback,
                               int timeoutMillis)
                        throws RemotingException,
                               InterruptedException

Description copied from interface: BoltClient

Callback invocation using a string address, address format example - 127.0.0.1:12200?key1=value1&key2=value2
You can specify an implementation of InvokeCallback to get the result.

Notice:

1. DO NOT modify the request object concurrently when this method is called.
2. When do invocation, use the string address to find a available connection, if none then create one.
• You can use RpcConfigs.CONNECT_TIMEOUT_KEY to specify connection timeout, time unit is milliseconds, e.g [127.0.0.1:12200?_CONNECTTIMEOUT=3000]
• You can use RpcConfigs.CONNECTION_NUM_KEY to specify connection number for each ip and port, e.g [127.0.0.1:12200?_CONNECTIONNUM=30]
• You can use RpcConfigs.CONNECTION_WARMUP_KEY to specify whether need warmup all connections for the first time you call this method, e.g [127.0.0.1:12200?_CONNECTIONWARMUP=false]
3. You should use BoltClient.closeConnection(String addr) to close it if you want.

Parameters:

address - target address

request - request

invokeCallback - callback

timeoutMillis - timeout in millisecond

Throws:

RemotingException

InterruptedException

invokeWithCallback

public void invokeWithCallback(String address,
                               Object request,
                               InvokeContext invokeContext,
                               InvokeCallback invokeCallback,
                               int timeoutMillis)
                        throws RemotingException,
                               InterruptedException

Description copied from interface: BoltClient

Callback invocation with a InvokeContext, common api notice please see BoltClient.invokeWithCallback(String, Object, InvokeCallback, int)

Parameters:

address - target address

request - request

invokeContext - context

invokeCallback - callback

timeoutMillis - timeout in millisecond

Throws:

RemotingException

InterruptedException

invokeWithCallback

public void invokeWithCallback(Url url,
                               Object request,
                               InvokeCallback invokeCallback,
                               int timeoutMillis)
                        throws RemotingException,
                               InterruptedException

Description copied from interface: BoltClient

Callback invocation using a parsed Url
You can specify an implementation of InvokeCallback to get the result.

Notice:

1. DO NOT modify the request object concurrently when this method is called.
2. When do invocation, use the parsed Url to find a available connection, if none then create one.
• You can use Url.setConnectTimeout(int) to specify connection timeout, time unit is milliseconds.
• You can use Url.setConnNum(int) to specify connection number for each ip and port.
• You can use Url.setConnWarmup(boolean) to specify whether need warmup all connections for the first time you call this method.
3. You should use BoltClient.closeConnection(Url url) to close it if you want.

Parameters:

url - target url

request - request

invokeCallback - callback

timeoutMillis - timeout in millisecond

Throws:

RemotingException

InterruptedException

invokeWithCallback

public void invokeWithCallback(Url url,
                               Object request,
                               InvokeContext invokeContext,
                               InvokeCallback invokeCallback,
                               int timeoutMillis)
                        throws RemotingException,
                               InterruptedException

Description copied from interface: BoltClient

Callback invocation with a InvokeContext, common api notice please see BoltClient.invokeWithCallback(Url, Object, InvokeCallback, int)

Parameters:

url - target url

request - request

invokeContext - context

invokeCallback - callback

timeoutMillis - timeout in millisecond

Throws:

RemotingException

InterruptedException

invokeWithCallback

public void invokeWithCallback(Connection conn,
                               Object request,
                               InvokeCallback invokeCallback,
                               int timeoutMillis)
                        throws RemotingException

Description copied from interface: BoltClient

Callback invocation using a Connection
You can specify an implementation of InvokeCallback to get the result.

Notice:
DO NOT modify the request object concurrently when this method is called.

Parameters:

conn - target connection

request - request

invokeCallback - callback

timeoutMillis - timeout in millisecond

Throws:

RemotingException

invokeWithCallback

public void invokeWithCallback(Connection conn,
                               Object request,
                               InvokeContext invokeContext,
                               InvokeCallback invokeCallback,
                               int timeoutMillis)
                        throws RemotingException

Description copied from interface: BoltClient

Callback invocation with a InvokeContext, common api notice please see BoltClient.invokeWithCallback(Connection, Object, InvokeCallback, int)

Parameters:

conn - target connection

request - request

invokeContext - invoke context

invokeCallback - callback

timeoutMillis - timeout in millisecond

Throws:

RemotingException

addConnectionEventProcessor

public void addConnectionEventProcessor(ConnectionEventType type,
                                        ConnectionEventProcessor processor)

Description copied from interface: BoltClient

Add processor to process connection event.

Parameters:

type - connection event type

processor - connection event process

registerUserProcessor

public void registerUserProcessor(UserProcessor<?> processor)

Description copied from interface: BoltClient

Use UserProcessorRegisterHelperUserProcessorRegisterHelper to help register user processor for client side.

createStandaloneConnection

public Connection createStandaloneConnection(String ip,
                                             int port,
                                             int connectTimeout)
                                      throws RemotingException

Description copied from interface: BoltClient

Create a stand alone connection using ip and port.

Notice:

Each time you call this method, will create a new connection. Bolt will not control this connection. You should use BoltClient.closeStandaloneConnection(com.alipay.remoting.Connection) to close it.