com.alibaba.dubbo.rpc
Class RpcStatus

java.lang.Object
  extended by com.alibaba.dubbo.rpc.RpcStatus

public class RpcStatus
extends Object

URL statistics. (API, Cached, ThreadSafe)

Author:
william.liangf
See Also:
ActiveLimitFilter, ExecuteLimitFilter, LeastActiveLoadBalance

Method Summary
static void beginCount(URL url, String methodName)
           
static void endCount(URL url, String methodName, long elapsed, boolean succeeded)
           
 Object get(String key)
          get value.
 int getActive()
          get active.
 long getAverageElapsed()
          get average elapsed.
 long getAverageTps()
          Calculate average TPS (Transaction per second).
 int getFailed()
          get failed.
 long getFailedAverageElapsed()
          get failed average elapsed.
 long getFailedElapsed()
          get failed elapsed.
 long getFailedMaxElapsed()
          get failed max elapsed.
 long getMaxElapsed()
          get max elapsed.
 Semaphore getSemaphore(int maxThreadNum)
          获取限制线程数的信号量,信号量的许可数就是executes设置的值 2017-08-21 yizhenqiang
static RpcStatus getStatus(URL url)
           
static RpcStatus getStatus(URL url, String methodName)
           
 long getSucceeded()
          get succeeded.
 long getSucceededAverageElapsed()
          get succeeded average elapsed.
 long getSucceededElapsed()
          get succeeded elapsed.
 long getSucceededMaxElapsed()
          get succeeded max elapsed.
 long getTotal()
          get total.
 long getTotalElapsed()
          get total elapsed.
static void removeStatus(URL url)
           
static void removeStatus(URL url, String methodName)
           
 void set(String key, Object value)
          set value.
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Method Detail

getStatus

public static RpcStatus getStatus(URL url)
Parameters:
url -
Returns:
status

removeStatus

public static void removeStatus(URL url)
Parameters:
url -

getStatus

public static RpcStatus getStatus(URL url,
                                  String methodName)
Parameters:
url -
methodName -
Returns:
status

removeStatus

public static void removeStatus(URL url,
                                String methodName)
Parameters:
url -

beginCount

public static void beginCount(URL url,
                              String methodName)
Parameters:
url -

endCount

public static void endCount(URL url,
                            String methodName,
                            long elapsed,
                            boolean succeeded)
Parameters:
url -
elapsed -
succeeded -

set

public void set(String key,
                Object value)
set value.

Parameters:
key -
value -

get

public Object get(String key)
get value.

Parameters:
key -
Returns:
value

getActive

public int getActive()
get active.

Returns:
active

getTotal

public long getTotal()
get total.

Returns:
total

getTotalElapsed

public long getTotalElapsed()
get total elapsed.

Returns:
total elapsed

getAverageElapsed

public long getAverageElapsed()
get average elapsed.

Returns:
average elapsed

getMaxElapsed

public long getMaxElapsed()
get max elapsed.

Returns:
max elapsed

getFailed

public int getFailed()
get failed.

Returns:
failed

getFailedElapsed

public long getFailedElapsed()
get failed elapsed.

Returns:
failed elapsed

getFailedAverageElapsed

public long getFailedAverageElapsed()
get failed average elapsed.

Returns:
failed average elapsed

getFailedMaxElapsed

public long getFailedMaxElapsed()
get failed max elapsed.

Returns:
failed max elapsed

getSucceeded

public long getSucceeded()
get succeeded.

Returns:
succeeded

getSucceededElapsed

public long getSucceededElapsed()
get succeeded elapsed.

Returns:
succeeded elapsed

getSucceededAverageElapsed

public long getSucceededAverageElapsed()
get succeeded average elapsed.

Returns:
succeeded average elapsed

getSucceededMaxElapsed

public long getSucceededMaxElapsed()
get succeeded max elapsed.

Returns:
succeeded max elapsed.

getAverageTps

public long getAverageTps()
Calculate average TPS (Transaction per second).

Returns:
tps

getSemaphore

public Semaphore getSemaphore(int maxThreadNum)
获取限制线程数的信号量,信号量的许可数就是executes设置的值 2017-08-21 yizhenqiang

Parameters:
maxThreadNum - executes设置的值
Returns:


Copyright © 2012–2017 Alibaba. All rights reserved.