如何使用自定义过滤器记录表单的访问次数

<web-app>
   <filter>
       <filter-name>ShowVisitCountFilter</filter-name>
       <filter-class>kd.bos.filter.ShowVisitCountFilter</filter-class>
       <filter-order>50001</filter-order>
       <filter-mapping>
           <url-pattern>*</url-pattern>
       </filter-mapping>
   </filter>
</web-app>

（2）开发自定义过滤器类

public class ShowVisitCountFilter implements Filter {

    @Override
    public void init(FilterConfig filterConfig) throws ServletException {
        Filter.super.init(filterConfig);//filter.ShowVisitCountFilter
    }

    @Override
    public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
        HttpServletRequest httpRequest = (HttpServletRequest) servletRequest;
        Map<String, String[]> parameterMap = httpRequest.getParameterMap();
        String[] appids = parameterMap.get("appId");//应用标识
        String[] fs = parameterMap.get("f");//表单标识
        if (appids != null && appids.length > 0) {
            if (appids[0].equals("bos")) {//过滤掉平台的请求
                filterChain.doFilter(servletRequest, servletResponse);
                return;
            }
            if (fs != null && fs.length > 0) {
                MessagePublisher mp = null;
                //简单模拟发出多次请求
                for (int i = 0; i < 100; i++) {
//                    if (i > 4) {
//                        fs[0] = String.valueOf(i);
//                        parameterMap.put("f", fs);
//                    }
                    try {//mq生产消息
                        mp = MQFactory.get().createSimplePublisher("kdec_showcloud", "erkai_queue");
                        mp.publish(parameterMap);
                    } finally {
                        mp.close();
                    }
                }

            }
        }
        filterChain.doFilter(servletRequest, servletResponse);
    }
}

2、通过rabbitmq异步累加访问量

(1)由于轻量级环境的MQ是使用内存模拟出来的，因此需要重新安装rabbitmq后，在启动参数中添加如下信息

特别注意，如果配置填写错误，会报错rabbitmq config error: null。

cosmic.set("lightweightdeploy","fasle");//非轻量级模式启动
String mqHost = "127.0.0.1";
        String mqPort = "18001";  // 默认5672
        String webPort = "5672";  // 默认5672
        String mqUser = "admin";//账号
        String mqPwd = "admin";//密码
        String mqVhost = "ierp";//
        StringBuilder builder = new StringBuilder();
        builder.append("type=rabbitmq").append("\n")
                .append("host=").append(mqHost).append("\n")
                .append("port=").append(mqPort).append("\n")
//                .append("webport=").append(webPort).append("\n")
                .append("user=").append(mqUser).append("\n")
                .append("password=").append(mqPwd).append("\n")
                .append("vhost=").append(mqVhost);
        cosmic.set("mq.server", builder.toString());

(2)安装及配置好rabbit信息之后，在resources包下配置消息队列信息

<root>
    <region name="kdec_showcloud">
        <queue name="erkai_queue" appid="kdec_showapp">
<!--            <consumer class="kd.bos.mymq.DemoConsumer" concurrency='5'></consumer>并行量为5-->
            <consumer class="kd.bos.mymq.DemoConsumer" ></consumer>
        </queue>
    </region>
</root>

注意分应用部署模式下，当前服务节点的appids中如果包含队列信息中配置的appid才可以消费该队列的消息

（3）开发消费者类

public class DemoConsumer implements MessageConsumer {
    Log log = LogFactory.getLog(getClass());

    @Override
    public v