public String echo(String msg) {StringBuilder sb = new StringBuilder();// *) 记录输入参数sb.append("[request: {msg: msg}]");// *) 访问缓存服务sb.append("[action: access redis, consume 100ms]");// *). 访问后端数据库sb.append("[action: dao, consume 100ms]");// *). 记录返回结果sb.append("[response: {msg}]");  logger.info(sb.toString()); return msg;}

public boolean verifySession() {// ***********我要记录日志(*^__^*) ***************
}public String echo(String msg) {StringBuilder sb = new StringBuilder();// *) 调用子过程verifySession();// *) 记录输入参数sb.append("[request: {msg: msg}]");// *) 访问缓存服务if ( KeyValueEngine Access Fail ) {// *********日志记录在那里***********throw new Exception();}sb.append("[action: access redis, consume 100ms]");// *). 访问后端数据库if ( Database Access Fail ) {// *********日志记录在那里***********throw new Exception();}sb.append("[action: dao, consume 100ms]");// *). 记录返回结果sb.append("[response: {msg}]");logger.info(sb.toString());return msg;}

public class LogProxyHandler<T> implements InvocationHandler {private T instance;public LogProxyHandler(T instance) {this.instance = instance;}public Object createProxy() {return Proxy.newProxyInstance(instance.getClass().getClassLoader(), instance.getClass().getInterfaces(), this);}@Overridepublic Object invoke(Object proxy, Method method, Object[] args)throws Throwable {// *) 函数调用前, 拦截处理, 作ThreadLocal的初始化工作LoggerUtility.beforeInvoke();    // -----(1)try {Object res = method.invoke(instance, args);// *) 函数成功返回后, 拦截处理, 进行日志的集中输出 LoggerUtility.returnInvoke();    // -----(2)return res;} catch (Throwable e) {// *) 出现异常后, 拦截处理, 进行日志集中输入 // -----(3)LoggerUtility.throwableInvode("[result = exception: {%s}]", e.getMessage());throw e;}}}

public class LoggerUtility {private static final Logger rpcLogger = LoggerFactory.getLogger("rpc");public static final ThreadLocal<StringBuilder> threadLocals = new ThreadLocal<StringBuilder>();public static void beforeInvoke() {StringBuilder sb = threadLocals.get();if ( sb == null ) {sb = new StringBuilder();threadLocals.set(sb);}sb.delete(0, sb.length());}public static void returnInvoke() {StringBuilder sb = threadLocals.get();if ( sb != null ) {rpcLogger.info(sb.toString());}}public static void throwableInvode(String fmt, Object... args) {StringBuilder sb = threadLocals.get();if ( sb != null ) {rpcLogger.info(sb.toString() + " " + String.format(fmt, args));}}public static void noticeLog(String fmt, Object... args) {StringBuilder sb = threadLocals.get();if ( sb != null ) {sb.append(String.format(fmt, args));}}}

struct EchoRequest {1: required i64 logid = 1001,2: required string msg
}
struct EchoResponse {1: required i32 status,2: optional string msg
}service EchoService {EchoResponse echo(1: EchoRequest req);
}