微服务框架saf-4：saf-dubbo之度量

private static final PrometheusMetricProfilerProcessor PROFILE_DUBBO_OUT = new PrometheusMetricProfilerProcessor(
"dubbo_requests_out", "dubbo:out", "dubbo_requests_out", new String[] { "class", "method" });
 
private static final Gauge PROFILE_DUBBO_FTL_OUT = Gauge.build().name("dubbo_requests_out_ftl")
.help("dubbo_requests_out_ftl").labelNames("class", "method").register();
 
private static final Set<String> FTL_OUT_MARKED_SET = Sets.newConcurrentHashSet();
 
@Override
public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
 
// 可以开关控制是否开启monitor
if (!MonitorConfig.ENABLE_MONITOR_DUBBO) {
return invoker.invoke(invocation);
}
 
// motanRPC class
String clazz = SafDubboUtil.getShortName(invoker.getInterface().getName());
 
// motanRPC method
String method = clazz + "." + invocation.getMethodName();
 
// invalid and return at once.
if (StringUtils.isEmpty(method) || StringUtils.isEmpty(clazz)) {
return invoker.invoke(invocation);
}
 
long begin = System.nanoTime();
boolean specialException = true;
boolean isError = false;
// 判断是否是第一次访问
final boolean firstAccessFlag = beforeCall(clazz, method);
 
Result result = null;
 
try {
result = invoker.invoke(invocation);
if (result == null) {
isError = true;
} else {
if (result.getException() != null) {
isError = true;
}
}
specialException = false;
return result;
} catch (Exception e) {
// 这里有可能跑出RuntimeException,这里不能吞异常
// TODO 后续要对Exception分类
log.error(e.getMessage(), e);
isError = true;
return null;
} finally {
if (specialException) {
isError = true;
}
afterCall(clazz, method, begin, isError, firstAccessFlag);
}
}

#!/bin/bash

for((i=1;i<=100000000;i++));  
do
    curl http://saf-sample-dubbo-apollo-web-prod/shop/getShop?shopId=1
done