hprose.client

类 HproseClient

java.lang.Object

hprose.client.HproseClient

所有已实现的接口:

HproseInvoker

直接已知子类:

HproseHttpClient, HproseTcpClient

public abstract class HproseClient
extends Object
implements HproseInvoker

字段概要

字段

限定符和类型	字段和说明
FilterHandlerManager	afterFilter
FilterHandlerManager	beforeFilter
protected static ScheduledExecutorService	executor
HproseErrorEvent	onError
protected String	uri

构造器概要

构造器

限定符	构造器和说明
protected	HproseClient()
protected	HproseClient(HproseMode mode)
protected	HproseClient(String uri)
protected	HproseClient(String[] uris)
protected	HproseClient(String[] uris, HproseMode mode)
protected	HproseClient(String uri, HproseMode mode)

方法概要

限定符和类型	方法和说明
void	addAfterFilterHandler(FilterHandler handler)
void	addBeforeFilterHandler(FilterHandler handler)
void	addFilter(HproseFilter filter)
void	addInvokeHandler(InvokeHandler handler)
void	close()
static HproseClient	create(String uri)
static HproseClient	create(String[] uris, HproseMode mode)
static HproseClient	create(String uri, HproseMode mode)
HproseFilter	getFilter()
Integer	getId()
int	getRetry()
int	getTimeout()
Object	invoke(String name)
<T> T	invoke(String name, Class<T> returnType)
<T> T	invoke(String name, Class<T> returnType, InvokeSettings settings)
void	invoke(String name, HproseCallback1<?> callback)
void	invoke(String name, HproseCallback1<?> callback, HproseErrorEvent errorEvent)
void	invoke(String name, HproseCallback1<?> callback, HproseErrorEvent errorEvent, InvokeSettings settings)
void	invoke(String name, HproseCallback1<?> callback, InvokeSettings settings)
<T> void	invoke(String name, HproseCallback1<T> callback, Class<T> returnType)
<T> void	invoke(String name, HproseCallback1<T> callback, Class<T> returnType, InvokeSettings settings)
<T> void	invoke(String name, HproseCallback1<T> callback, HproseErrorEvent errorEvent, Class<T> returnType)
<T> void	invoke(String name, HproseCallback1<T> callback, HproseErrorEvent errorEvent, Class<T> returnType, InvokeSettings settings)
Object	invoke(String name, InvokeSettings settings)
Object	invoke(String name, Object[] args)
<T> T	invoke(String name, Object[] args, Class<T> returnType)
<T> T	invoke(String name, Object[] args, Class<T> returnType, InvokeSettings settings)
void	invoke(String name, Object[] args, HproseCallback<?> callback)
void	invoke(String name, Object[] args, HproseCallback<?> callback, HproseErrorEvent errorEvent)
void	invoke(String name, Object[] args, HproseCallback<?> callback, HproseErrorEvent errorEvent, InvokeSettings settings)
void	invoke(String name, Object[] args, HproseCallback<?> callback, InvokeSettings settings)
<T> void	invoke(String name, Object[] args, HproseCallback<T> callback, Class<T> returnType)
<T> void	invoke(String name, Object[] args, HproseCallback<T> callback, Class<T> returnType, InvokeSettings settings)
<T> void	invoke(String name, Object[] args, HproseCallback<T> callback, HproseErrorEvent errorEvent, Class<T> returnType)
<T> void	invoke(String name, Object[] args, HproseCallback<T> callback, HproseErrorEvent errorEvent, Class<T> returnType, InvokeSettings settings)
void	invoke(String name, Object[] args, HproseCallback1<?> callback)
void	invoke(String name, Object[] args, HproseCallback1<?> callback, HproseErrorEvent errorEvent)
void	invoke(String name, Object[] args, HproseCallback1<?> callback, HproseErrorEvent errorEvent, InvokeSettings settings)
void	invoke(String name, Object[] args, HproseCallback1<?> callback, InvokeSettings settings)
<T> void	invoke(String name, Object[] args, HproseCallback1<T> callback, Class<T> returnType)
<T> void	invoke(String name, Object[] args, HproseCallback1<T> callback, Class<T> returnType, InvokeSettings settings)
<T> void	invoke(String name, Object[] args, HproseCallback1<T> callback, HproseErrorEvent errorEvent, Class<T> returnType)
<T> void	invoke(String name, Object[] args, HproseCallback1<T> callback, HproseErrorEvent errorEvent, Class<T> returnType, InvokeSettings settings)
Object	invoke(String name, Object[] args, InvokeSettings settings)
boolean	isByref()
boolean	isFailswitch()
boolean	isIdempontent()
boolean	isSimple()
static void	registerClientFactory(String scheme, Class<? extends HproseClient> clientClass)
boolean	removeFilter(HproseFilter filter)
protected abstract ByteBuffer	sendAndReceive(ByteBuffer buffer, int timeout)
protected abstract void	sendAndReceive(ByteBuffer buffer, ReceiveCallback callback, int timeout)
void	setByref(boolean byref)
void	setFailswitch(boolean failswitch)
void	setFilter(HproseFilter filter)
void	setIdempontent(boolean idempontent)
void	setRetry(int retry)
void	setSimple(boolean simple)
void	setTimeout(int timeout)
void	subscribe(String name, Action<Object> callback)
void	subscribe(String name, Action<Object> callback, int timeout)
<T> void	subscribe(String name, Action<T> callback, Type type)
<T> void	subscribe(String name, Action<T> callback, Type type, int timeout)
void	subscribe(String name, Integer id, Action<Object> callback)
void	subscribe(String name, Integer id, Action<Object> callback, int timeout)
<T> void	subscribe(String name, Integer id, Action<T> callback, Type type)
<T> void	subscribe(String name, Integer id, Action<T> callback, Type type, int timeout)
void	unsubscribe(String name)
<T> void	unsubscribe(String name, Action<T> callback)
void	unsubscribe(String name, Integer id)
<T> void	unsubscribe(String name, Integer id, Action<T> callback)
HproseClient	use(InvokeHandler handler)
<T> T	useService(Class<T> type)
<T> T	useService(Class<T> type, String ns)
void	useService(String uri)
void	useService(String[] uris)
<T> T	useService(String[] uris, Class<T> type)
<T> T	useService(String[] uris, Class<T> type, String ns)
<T> T	useService(String uri, Class<T> type)
<T> T	useService(String uri, Class<T> type, String ns)

从类继承的方法 java.lang.Object

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

字段详细资料

executor

protected static final ScheduledExecutorService executor

uri

protected String uri

onError

public HproseErrorEvent onError

beforeFilter

public final FilterHandlerManager beforeFilter

afterFilter

public final FilterHandlerManager afterFilter

构造器详细资料

HproseClient

protected HproseClient()

HproseClient

protected HproseClient(HproseMode mode)

HproseClient

protected HproseClient(String uri)

HproseClient

protected HproseClient(String uri,
                       HproseMode mode)

HproseClient

protected HproseClient(String[] uris)

HproseClient

protected HproseClient(String[] uris,
                       HproseMode mode)

方法详细资料

close

public void close()

registerClientFactory

public static void registerClientFactory(String scheme,
                                         Class<? extends HproseClient> clientClass)

create

public static HproseClient create(String uri)
                           throws IOException,
                                  URISyntaxException

抛出:

IOException

URISyntaxException

create

public static HproseClient create(String uri,
                                  HproseMode mode)
                           throws IOException,
                                  URISyntaxException

抛出:

IOException

URISyntaxException

create

public static HproseClient create(String[] uris,
                                  HproseMode mode)
                           throws IOException,
                                  URISyntaxException

抛出:

IOException

URISyntaxException

getTimeout

public final int getTimeout()

setTimeout

public final void setTimeout(int timeout)

getRetry

public final int getRetry()

setRetry

public final void setRetry(int retry)

isIdempontent

public final boolean isIdempontent()

setIdempontent

public final void setIdempontent(boolean idempontent)

isFailswitch

public final boolean isFailswitch()

setFailswitch

public final void setFailswitch(boolean failswitch)

isByref

public final boolean isByref()

setByref

public final void setByref(boolean byref)

isSimple

public final boolean isSimple()

setSimple

public final void setSimple(boolean simple)

getFilter

public final HproseFilter getFilter()

setFilter

public final void setFilter(HproseFilter filter)

addFilter

public final void addFilter(HproseFilter filter)

removeFilter

public final boolean removeFilter(HproseFilter filter)

useService

public final void useService(String uri)

useService

public final void useService(String[] uris)

useService

public final <T> T useService(Class<T> type)

useService

public final <T> T useService(String uri,
                              Class<T> type)

useService

public final <T> T useService(String[] uris,
                              Class<T> type)

useService

public final <T> T useService(Class<T> type,
                              String ns)

useService

public final <T> T useService(String uri,
                              Class<T> type,
                              String ns)

useService

public final <T> T useService(String[] uris,
                              Class<T> type,
                              String ns)

addInvokeHandler

public final void addInvokeHandler(InvokeHandler handler)

addBeforeFilterHandler

public final void addBeforeFilterHandler(FilterHandler handler)

addAfterFilterHandler

public final void addAfterFilterHandler(FilterHandler handler)

use

public final HproseClient use(InvokeHandler handler)

sendAndReceive

protected abstract ByteBuffer sendAndReceive(ByteBuffer buffer,
                                             int timeout)
                                      throws Throwable

抛出:

Throwable

sendAndReceive

protected abstract void sendAndReceive(ByteBuffer buffer,
                                       ReceiveCallback callback,
                                       int timeout)

invoke

public final void invoke(String name,
                         HproseCallback1<?> callback)

指定者:

invoke 在接口中 HproseInvoker

invoke

public final void invoke(String name,
                         HproseCallback1<?> callback,
                         HproseErrorEvent errorEvent)

指定者:

invoke 在接口中 HproseInvoker

invoke

public final void invoke(String name,
                         HproseCallback1<?> callback,
                         InvokeSettings settings)

指定者:

invoke 在接口中 HproseInvoker

invoke

public final void invoke(String name,
                         HproseCallback1<?> callback,
                         HproseErrorEvent errorEvent,
                         InvokeSettings settings)

指定者:

invoke 在接口中 HproseInvoker

invoke

public final void invoke(String name,
                         Object[] args,
                         HproseCallback1<?> callback)

指定者:

invoke 在接口中 HproseInvoker

invoke

public final void invoke(String name,
                         Object[] args,
                         HproseCallback1<?> callback,
                         HproseErrorEvent errorEvent)

指定者:

invoke 在接口中 HproseInvoker

invoke

public final void invoke(String name,
                         Object[] args,
                         HproseCallback1<?> callback,
                         InvokeSettings settings)

指定者:

invoke 在接口中 HproseInvoker

invoke

public final void invoke(String name,
                         Object[] args,
                         HproseCallback1<?> callback,
                         HproseErrorEvent errorEvent,
                         InvokeSettings settings)

指定者:

invoke 在接口中 HproseInvoker

invoke

public final <T> void invoke(String name,
                             HproseCallback1<T> callback,
                             Class<T> returnType)

指定者:

invoke 在接口中 HproseInvoker

invoke

public final <T> void invoke(String name,
                             HproseCallback1<T> callback,
                             HproseErrorEvent errorEvent,
                             Class<T> returnType)

指定者:

invoke 在接口中 HproseInvoker

invoke

public final <T> void invoke(String name,
                             HproseCallback1<T> callback,
                             Class<T> returnType,
                             InvokeSettings settings)

指定者:

invoke 在接口中 HproseInvoker

invoke

public final <T> void invoke(String name,
                             HproseCallback1<T> callback,
                             HproseErrorEvent errorEvent,
                             Class<T> returnType,
                             InvokeSettings settings)

指定者:

invoke 在接口中 HproseInvoker

invoke

public final <T> void invoke(String name,
                             Object[] args,
                             HproseCallback1<T> callback,
                             Class<T> returnType)

指定者:

invoke 在接口中 HproseInvoker

invoke

public final <T> void invoke(String name,
                             Object[] args,
                             HproseCallback1<T> callback,
                             HproseErrorEvent errorEvent,
                             Class<T> returnType)

指定者:

invoke 在接口中 HproseInvoker

invoke

public final <T> void invoke(String name,
                             Object[] args,
                             HproseCallback1<T> callback,
                             Class<T> returnType,
                             InvokeSettings settings)

指定者:

invoke 在接口中 HproseInvoker

invoke

public final <T> void invoke(String name,
                             Object[] args,
                             HproseCallback1<T> callback,
                             HproseErrorEvent errorEvent,
                             Class<T> returnType,
                             InvokeSettings settings)

指定者:

invoke 在接口中 HproseInvoker

invoke

public final void invoke(String name,
                         Object[] args,
                         HproseCallback<?> callback)

指定者:

invoke 在接口中 HproseInvoker

invoke

public final void invoke(String name,
                         Object[] args,
                         HproseCallback<?> callback,
                         HproseErrorEvent errorEvent)

指定者:

invoke 在接口中 HproseInvoker

invoke

public final void invoke(String name,
                         Object[] args,
                         HproseCallback<?> callback,
                         InvokeSettings settings)

指定者:

invoke 在接口中 HproseInvoker

invoke

public final void invoke(String name,
                         Object[] args,
                         HproseCallback<?> callback,
                         HproseErrorEvent errorEvent,
                         InvokeSettings settings)

指定者:

invoke 在接口中 HproseInvoker

invoke

public final <T> void invoke(String name,
                             Object[] args,
                             HproseCallback<T> callback,
                             Class<T> returnType)

指定者:

invoke 在接口中 HproseInvoker

invoke

public final <T> void invoke(String name,
                             Object[] args,
                             HproseCallback<T> callback,
                             HproseErrorEvent errorEvent,
                             Class<T> returnType)

指定者:

invoke 在接口中 HproseInvoker

invoke

public final <T> void invoke(String name,
                             Object[] args,
                             HproseCallback<T> callback,
                             Class<T> returnType,
                             InvokeSettings settings)

指定者:

invoke 在接口中 HproseInvoker

invoke

public final <T> void invoke(String name,
                             Object[] args,
                             HproseCallback<T> callback,
                             HproseErrorEvent errorEvent,
                             Class<T> returnType,
                             InvokeSettings settings)

指定者:

invoke 在接口中 HproseInvoker

invoke

public final Object invoke(String name)
                    throws Throwable

指定者:

invoke 在接口中 HproseInvoker

抛出:

Throwable

invoke

public final Object invoke(String name,
                           InvokeSettings settings)
                    throws Throwable

指定者:

invoke 在接口中 HproseInvoker

抛出:

Throwable

invoke

public final Object invoke(String name,
                           Object[] args)
                    throws Throwable

指定者:

invoke 在接口中 HproseInvoker

抛出:

Throwable

invoke

public final Object invoke(String name,
                           Object[] args,
                           InvokeSettings settings)
                    throws Throwable

指定者:

invoke 在接口中 HproseInvoker

抛出:

Throwable

invoke

public final <T> T invoke(String name,
                          Class<T> returnType)
                   throws Throwable

指定者:

invoke 在接口中 HproseInvoker

抛出:

Throwable

invoke

public final <T> T invoke(String name,
                          Class<T> returnType,
                          InvokeSettings settings)
                   throws Throwable

指定者:

invoke 在接口中 HproseInvoker

抛出:

Throwable

invoke

public final <T> T invoke(String name,
                          Object[] args,
                          Class<T> returnType)
                   throws Throwable

指定者:

invoke 在接口中 HproseInvoker

抛出:

Throwable

invoke

public final <T> T invoke(String name,
                          Object[] args,
                          Class<T> returnType,
                          InvokeSettings settings)
                   throws Throwable

指定者:

invoke 在接口中 HproseInvoker

抛出:

Throwable

subscribe

public final void subscribe(String name,
                            Action<Object> callback)
                     throws Throwable

抛出:

Throwable

subscribe

public final void subscribe(String name,
                            Action<Object> callback,
                            int timeout)
                     throws Throwable

抛出:

Throwable

subscribe

public final void subscribe(String name,
                            Integer id,
                            Action<Object> callback)

subscribe

public final void subscribe(String name,
                            Integer id,
                            Action<Object> callback,
                            int timeout)

subscribe

public final <T> void subscribe(String name,
                                Action<T> callback,
                                Type type)
                         throws Throwable

抛出:

Throwable

subscribe

public final <T> void subscribe(String name,
                                Action<T> callback,
                                Type type,
                                int timeout)
                         throws Throwable

抛出:

Throwable

subscribe

public final <T> void subscribe(String name,
                                Integer id,
                                Action<T> callback,
                                Type type)

subscribe

public final <T> void subscribe(String name,
                                Integer id,
                                Action<T> callback,
                                Type type,
                                int timeout)

unsubscribe

public void unsubscribe(String name)

unsubscribe

public <T> void unsubscribe(String name,
                            Action<T> callback)

unsubscribe

public void unsubscribe(String name,
                        Integer id)

unsubscribe

public <T> void unsubscribe(String name,
                            Integer id,
                            Action<T> callback)

getId

public Integer getId()