(spring-cloud-sleuth-stream+mybatis+rabbit)+(kafka+elasticsearch...

package com.keeplotus.dao.plugin; /** * @author 入江之鲸,wechar:18651820200 */ import java.util.Properties; import org.apache.ibatis.cache.CacheKey; import org.apache.ibatis.executor.Executor; import org.apache.ibatis.mapping.BoundSql; import org.apache.ibatis.mapping.MappedStatement; import org.apache.ibatis.plugin.Interceptor; import org.apache.ibatis.plugin.Intercepts; import org.apache.ibatis.plugin.Invocation; import org.apache.ibatis.plugin.Plugin; import org.apache.ibatis.plugin.Signature; import org.apache.ibatis.session.ResultHandler; import org.apache.ibatis.session.RowBounds; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.cloud.sleuth.Span; import org.springframework.cloud.sleuth.Tracer; import org.springframework.stereotype.Component; @Component @Intercepts({ @Signature(method = "update", type = Executor.class, args = { MappedStatement.class, Object.class }), @Signature(method = "query", type = Executor.class, args = { MappedStatement.class, Object.class, RowBounds.class, ResultHandler.class, CacheKey.class, BoundSql.class }), @Signature(method = "query", type = Executor.class, args = { MappedStatement.class, Object.class, RowBounds.class, ResultHandler.class }) }) public class MybatisLoggingPlugin implements Interceptor { Logger logger = LoggerFactory.getLogger(MybatisLoggingPlugin.class); @Autowired private Tracer tracer; @Override public Object intercept(Invocation invocation) throws Throwable { Object ret = null; Span span = null; try { MappedStatement mappedStatement = (MappedStatement) invocation.getArgs()[0]; // Object argument = invocation.getArgs()[1]; String state = mappedStatement.getId(); int atOf = state.lastIndexOf(".", state.lastIndexOf(".") - 1) + 1; String name = state.substring(atOf, state.length()); span = tracer.createSpan("【DB OPERATE】" + name, tracer.getCurrentSpan()); span.logEvent(System.currentTimeMillis(), Span.CLIENT_SEND); // logger.debug("Dao: {}({})", state, new // LoggingValueWrapper(argument)); ret = invocation.proceed(); // logger.debug("Dao return: {}", new LoggingValueWrapper(ret)); } finally { span.logEvent(System.currentTimeMillis(), Span.CLIENT_RECV); tracer.close(span); } return ret; } @Override public Object plugin(Object target) { return Plugin.wrap(target, this); } @Override public void setProperties(Properties properties) { } }