背景

理解，首先 MCube 会依据模板缓存状态判断是否需要网络获取最新模板，当获取到模板后进行模板加载，加载阶段会将产物转换为视图树的结构，转换完成后将通过表达式引擎解析表达式并取得正确的值，通过事件解析引擎解析用户自定义事件并完成事件的绑定，完成解析赋值以及事件绑定后进行视图的渲染，最终将

部门中一核心应用，因为各种原因其依赖的MySQL数据库一直处于高水位运行，无论是硬件资源，还是磁盘使用率或者QPS等都处于较高水位，急需在大促前完成对应的治理，降低各项指标，以保障在大促期间平稳运行，以期更好的支撑前端业务。

基本情况

理解，首先 MCube 会依据模板缓存状态判断是否需要网络获取最新模板，当获取到模板后进行模板加载，加载阶段会将产物转换为视图树的结构，转换完成后将通过表达式引擎解析表达式并取得正确的值，通过事件解析引擎解析用户自定义事件并完成事件的绑定，完成解析赋值以及事件绑定后进行视图的渲染，最终将

import org.apache.ibatis.executor.Executor;import org.apache.ibatis.mapping.BoundSql;import org.apache.ibatis.mapping.MappedStatement;import org.apache.ibatis.mapping.ParameterMapping;import org.apache.ibatis.plugin.*;import org.apache.ibatis.session.ResultHandler;import org.apache.ibatis.session.RowBounds;
import java.lang.reflect.InvocationTargetException;import java.util.HashMap;import java.util.List;import java.util.Map;import java.util.Properties;
@Intercepts({        @Signature(type = Executor.class, method = "query",                args = {MappedStatement.class, Object.class, RowBounds.class, ResultHandler.class})})public class ParameterInterceptor implements Interceptor {
    private final Map<Object, Object> mappedStatementIdMap = new HashMap<Object, Object>();
    @Override    public Object intercept(Invocation invocation) throws InvocationTargetException, IllegalAccessException {        Object[] queryArgs = invocation.getArgs();
        MappedStatement mappedStatement = null;        if (queryArgs[0] instanceof MappedStatement) {            mappedStatement = (MappedStatement) queryArgs[0];        }
        if (null != mappedStatement && mappedStatementIdMap.containsKey(mappedStatement.getId())) {                        BoundSql boundSql = mappedStatement.getBoundSql(queryArgs[1]);
            List<ParameterMapping> parameterMappingList = boundSql.getParameterMappings();
            if (parameterMappingList.isEmpty()) {                Profiler.businessAlarm(mappedStatement.getId(), "查询参数为空");                throw new BadArgumentException("查询参数为空，请确认入参是否有值");            }
        }
        return invocation.proceed();    }
    @Override    public Object plugin(Object target) {        return Plugin.wrap(target, this);    }
    @Override    public void setProperties(Properties properties) {        for (Object key : properties.keySet()) {            mappedStatementIdMap.put(key, 1);        }    }}

<jsf:filterid="callFilter"ref="jsfInvokeFilter"/>

import com.jd.jsf.gd.filter.AbstractFilter;import com.jd.jsf.gd.msg.RequestMessage;import com.jd.jsf.gd.msg.ResponseMessage;import com.jd.jsf.gd.util.RpcContext;import com.jd.ump.profiler.proxy.Profiler;import org.springframework.stereotype.Component;import java.util.HashMap;import java.util.Map;@Componentpublic class JsfInvokeFilter extends AbstractFilter {        private static final String API_PROVIDER_METHOD_COUNT_KEY = "api.jsf.provider.method.count.key";    private static final String API_CONSUMER_METHOD_COUNT_KEY = "api.jsf.consumer.method.count.key";    @Override    public ResponseMessage invoke(RequestMessage requestMessage) {        String key;        if (RpcContext.getContext().isProviderSide()) {            key = API_PROVIDER_METHOD_COUNT_KEY;        } else {            key = API_CONSUMER_METHOD_COUNT_KEY;        }        String method = requestMessage.getClassName() + "." + requestMessage.getMethodName();        Map<String, String> tags = new HashMap<String, String>(2);        tags.put("bMark", method);        tags.put("bCount", "1");        Profiler.sourceDataByStr(key, tags);        return getNext().invoke(requestMessage);    }}

import osimport openpyxlimport jsonimport requestsfrom cookies import Cookieimport time
headers = {    'Cookie': Cookie,    'Content-Type': 'application/json',    'token': '******',    'erp': '******'}

def get_jsf(start_time, end_time):    url = 'http://xxx.taishan.jd.com/api/xxx/xxx/xxx/'    body = {}    params = {'startTime': start_time,              'endTime': end_time,              'endPointKey': 'api.jsf.provider.method.count.key',              'quickTime': int((end_time - start_time) / 1000),              'markFlag': 'true',              'markLimit': 500}
    res = requests.post(url=url, data=json.dumps(body), params=params, headers=headers)
    print('url: ', res.request.url)      
    res_json = json.loads(res.text)
    title = ['序号', 'jsf key', '次数', '占比%', '峰值', '次/秒', '峰值时间']    i = 0
    keys = {}    marks = res_json['response_data']['marks']    for mark in marks:        keys.setdefault(mark, [0, 0, 0, ''])
    data = []    records = res_json['response_data']['monitorData']    print(len(records))    for key, value in records.items():        count = 0        max_val = 0        max_time = ''        for val in value:            v = val['value']            count += v            if v > max_val:                max_val = v                max_time = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(int(val['dateTime'] / 1000)))        keys[key] = [count, max_val, int(max_val / 1200), max_time]
    key_list = sorted(keys.items(), key=lambda x: x[1], reverse=True)    
    all_count = key_list[0][1][0]
    for key in key_list:        values = [i, key[0], key[1][0], str(round(key[1][0] / all_count * 100, 2)) + '%', key[1][1], key[1][2], key[1][3]]        data.append(values)        i += 1                path = r"/Users/xxx/Documents/治理/QPS治理/"    os.chdir(path)      workbook = openpyxl.Workbook()    sheet = workbook.active    sheet.title = 'JSF接口调用次数统计'    sheet.append(title)    for record in data:        sheet.append(record)    workbook.save('JSF接口调用次数统计-' + str(start_time / 1000) + '-' + str(end_time / 1000) + '.xlsx')

def change_time(dt):        time_array = time.strptime(dt, "%Y-%m-%d %H:%M:%S")        timestamp = time.mktime(time_array)    return int(timestamp * 1000)

if __name__ == '__main__':    start_time = '2024-03-06 12:20:00'    end_time = '2024-03-07 12:20:00'
    get_jsf(change_time(start_time), change_time(end_time))

▪功能支撑：会员成长体系、等级计算策略、权益体系、营销底层能力支持

▪用户活跃：会员关怀、用户触达、活跃活动、业务线交叉获客、拉新促活

‍‍