zoukankan      html  css  js  c++  java
  • Prometheus 普罗米修斯监控

    周末在家无聊 看新闻 看到关于监控的东西 拿来玩玩 试一下 感觉还蛮有意思 特此记录一下

    这里只介绍客户端的配置

    1:首先在POM中添加依赖

    复制代码
    <dependency>
                <groupId>io.prometheus</groupId>
                <artifactId>simpleclient</artifactId>
                <version>${prometheus.version}</version>
            </dependency>
            <!-- Hotspot JVM metrics-->
            <dependency>
                <groupId>io.prometheus</groupId>
                <artifactId>simpleclient_hotspot</artifactId>
                <version>${prometheus.version}</version>
            </dependency>
            <!-- Exposition servlet-->
            <dependency>
                <groupId>io.prometheus</groupId>
                <artifactId>simpleclient_servlet</artifactId>
                <version>${prometheus.version}</version>
            </dependency>
            <!-- Pushgateway exposition-->
            <dependency>
                <groupId>io.prometheus</groupId>
                <artifactId>simpleclient_pushgateway</artifactId>
                <version>${prometheus.version}</version>
            </dependency>
            <dependency>
                <groupId>io.prometheus</groupId>
                <artifactId>simpleclient_spring_web</artifactId>
                <version>${prometheus.version}</version>
            </dependency>
    复制代码

    2:在web.xml文件里添加servlet拦截器

        <servlet>
            <servlet-name>PrometheusServlet</servlet-name>
            <servlet-class>io.prometheus.client.exporter.MetricsServlet</servlet-class>
        </servlet>
        <servlet-mapping>
            <servlet-name>PrometheusServlet</servlet-name>
            <url-pattern>/metrics</url-pattern>
        </servlet-mapping>
    web.xml

    3:添加拦截器class

    public class WebInterceptor extends HandlerInterceptorAdapter {
    
    </span><span style="color: #0000ff;">private</span> <span style="color: #0000ff;">static</span> Logger logger = Logger.getLogger(WebInterceptor.<span style="color: #0000ff;">class</span><span style="color: #000000;">);
    
    </span><span style="color: #0000ff;">private</span> <span style="color: #0000ff;">static</span> <span style="color: #0000ff;">final</span> String SYSTEM_ID= "BLOAN-GJJ"<span style="color: #000000;">;
    
    </span><span style="color: #0000ff;">private</span> <span style="color: #0000ff;">static</span> <span style="color: #0000ff;">final</span> String APP_ID= "gjj-ics-credit"<span style="color: #000000;">;
    
    </span><span style="color: #0000ff;">private</span> <span style="color: #0000ff;">static</span> <span style="color: #0000ff;">final</span> String TYPE = "java"<span style="color: #000000;">;
    
    
    </span><span style="color: #0000ff;">private</span> <span style="color: #0000ff;">static</span> <span style="color: #0000ff;">final</span> Histogram requestLatency =<span style="color: #000000;"> Histogram.build()
            .name(</span>"service_requests_latency_seconds"<span style="color: #000000;">)
            .help(</span>"Request latency in seconds."<span style="color: #000000;">)
            .labelNames(</span>"systemId", "appId", "type", "name", "method"<span style="color: #000000;">).register();
    
    </span><span style="color: #0000ff;">private</span> ThreadLocal&lt;Histogram.Timer&gt;<span style="color: #000000;"> timerThreadLocal;
    
    @Override
    </span><span style="color: #0000ff;">public</span> <span style="color: #0000ff;">boolean</span> preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) <span style="color: #0000ff;">throws</span><span style="color: #000000;"> Exception {
        </span><span style="color: #0000ff;">return</span> <span style="color: #0000ff;">super</span><span style="color: #000000;">.preHandle(request, response, handler);
    }
    
    @Override
    </span><span style="color: #0000ff;">public</span> <span style="color: #0000ff;">void</span> postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, ModelAndView modelAndView) <span style="color: #0000ff;">throws</span><span style="color: #000000;"> Exception {
        String name </span>= <span style="color: #0000ff;">this</span><span style="color: #000000;">.getName(request, handler).toLowerCase();
        String method </span>=<span style="color: #000000;"> request.getMethod().toUpperCase();
        timerThreadLocal </span>= <span style="color: #0000ff;">new</span> ThreadLocal&lt;&gt;<span style="color: #000000;">();
        timerThreadLocal.set(requestLatency.labels(SYSTEM_ID, APP_ID, TYPE, name, method).startTimer());
        </span><span style="color: #0000ff;">super</span><span style="color: #000000;">.postHandle(request, response, handler, modelAndView);
    }
    
    @Override
    </span><span style="color: #0000ff;">public</span> <span style="color: #0000ff;">void</span> afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) <span style="color: #0000ff;">throws</span><span style="color: #000000;"> Exception {
        </span><span style="color: #0000ff;">super</span><span style="color: #000000;">.afterCompletion(request, response, handler, ex);
        </span><span style="color: #0000ff;">if</span> (timerThreadLocal.get() != <span style="color: #0000ff;">null</span><span style="color: #000000;">) {
            timerThreadLocal.get().observeDuration();
        }
    }
    
    @Override
    </span><span style="color: #0000ff;">public</span> <span style="color: #0000ff;">void</span> afterConcurrentHandlingStarted(HttpServletRequest request, HttpServletResponse response, Object handler) <span style="color: #0000ff;">throws</span><span style="color: #000000;"> Exception {
        </span><span style="color: #0000ff;">super</span><span style="color: #000000;">.afterConcurrentHandlingStarted(request, response, handler);
    }
    
    </span><span style="color: #0000ff;">private</span><span style="color: #000000;"> String getName(HttpServletRequest request, Object handler) {
        String name </span>= ""<span style="color: #000000;">;
        </span><span style="color: #0000ff;">try</span><span style="color: #000000;"> {
            </span><span style="color: #0000ff;">if</span> (handler != <span style="color: #0000ff;">null</span>
                    &amp;&amp; handler <span style="color: #0000ff;">instanceof</span><span style="color: #000000;"> HandlerMethod) {
                HandlerMethod method </span>=<span style="color: #000000;"> (HandlerMethod) handler;
                String className </span>=<span style="color: #000000;"> ((HandlerMethod) handler).getBeanType().getName();
                name </span>= className + "." +<span style="color: #000000;"> method.getMethod().getName();
            } </span><span style="color: #0000ff;">else</span><span style="color: #000000;"> {
                name </span>=<span style="color: #000000;"> request.getRequestURI();
            }
        } </span><span style="color: #0000ff;">catch</span><span style="color: #000000;"> (Exception ex) {
            logger.error(</span>"getName"<span style="color: #000000;">, ex);
        } </span><span style="color: #0000ff;">finally</span><span style="color: #000000;"> {
            </span><span style="color: #0000ff;">return</span><span style="color: #000000;"> name;
        }
    }
    

    }

    View Code

    4:配置初始化的类

    @Component
    public class PrometheusConfig {
    
    </span><span style="color: #0000ff;">private</span> <span style="color: #0000ff;">static</span> Logger logger = Logger.getLogger(PrometheusConfig.<span style="color: #0000ff;">class</span><span style="color: #000000;">);
    
    @PostConstruct
    </span><span style="color: #0000ff;">public</span> <span style="color: #0000ff;">void</span><span style="color: #000000;"> initialize() {
        logger.info(</span>"prometheus init..."<span style="color: #000000;">);
        DefaultExports.initialize();
        logger.info(</span>"prometheus has been initialized..."<span style="color: #000000;">);
    }
    

    }

    PrometheusConfig.class

    5:springmvc.xml中 添加拦截器

            <mvc:interceptor>
                <bean class="com.pingan.credit.interceptor.WebInterceptor"/>
            </mvc:interceptor>    

    6:spring-application.xml 初始化 初始化类中的方法

     <bean id="prometheusConfig" class="com.pingan.credit.service.PrometheusConfig" init-method="initialize" />

     7:添加controller

    复制代码
    @Controller
    public class MetricsController {
        private CollectorRegistry registry;
    
    </span><span style="color: #008000;">/**</span><span style="color: #008000;">
     * Construct a MetricsServlet for the default registry.
     </span><span style="color: #008000;">*/</span>
    <span style="color: #0000ff;">public</span><span style="color: #000000;"> MetricsController() {
        </span><span style="color: #0000ff;">this</span><span style="color: #000000;">(CollectorRegistry.defaultRegistry);
    }
    
    </span><span style="color: #008000;">/**</span><span style="color: #008000;">
     * Construct a MetricsServlet for the given registry.
     </span><span style="color: #008000;">*/</span>
    <span style="color: #0000ff;">private</span><span style="color: #000000;"> MetricsController(CollectorRegistry registry) {
        </span><span style="color: #0000ff;">this</span>.registry =<span style="color: #000000;"> registry;
    }
    
    @RequestMapping(value</span>="/metrics",method=<span style="color: #000000;"> RequestMethod.GET)
    </span><span style="color: #0000ff;">public</span> <span style="color: #0000ff;">void</span> metrics(<span style="color: #0000ff;">final</span><span style="color: #000000;"> HttpServletRequest req,
                        </span><span style="color: #0000ff;">final</span> HttpServletResponse resp) <span style="color: #0000ff;">throws</span><span style="color: #000000;"> ServletException,
            IOException {
        resp.setStatus(HttpServletResponse.SC_OK);
        resp.setContentType(TextFormat.CONTENT_TYPE_004);
    
        </span><span style="color: #0000ff;">try</span> (Writer writer =<span style="color: #000000;"> resp.getWriter()) {
            TextFormat.write004(writer,
                    registry.filteredMetricFamilySamples(parse(req)));
            writer.flush();
        }
    }
    
    </span><span style="color: #0000ff;">private</span> Set&lt;String&gt;<span style="color: #000000;"> parse(HttpServletRequest req) {
        String[] includedParam </span>= req.getParameterValues("name[]"<span style="color: #000000;">);
        </span><span style="color: #0000ff;">if</span> (includedParam == <span style="color: #0000ff;">null</span><span style="color: #000000;">) {
            </span><span style="color: #0000ff;">return</span><span style="color: #000000;"> Collections.emptySet();
        } </span><span style="color: #0000ff;">else</span><span style="color: #000000;"> {
            </span><span style="color: #0000ff;">return</span> <span style="color: #0000ff;">new</span> HashSet&lt;&gt;<span style="color: #000000;">(Arrays.asList(includedParam));
        }
    }
    

    }

    复制代码

    启动tomcat 以及你的project 然后进入localhost:8080/metrics就可以看到JVM的信息了

    原文地址:https://www.cnblogs.com/showme1942/p/7457451.html
  • 相关阅读:
    KL散度、JS散度和交叉熵
    np.dot()计算两个变量的乘积
    numpy 相关统计
    sns.FacetGrid(),map用法
    df.to_dict()转化为字典数据
    springboot 热部署
    Springboot thymeleaf
    springboot 静态资源
    springboot yaml part2
    Warning: You cannot set a form field before rendering a field associated with the value. ant desgin pro form 表单报错
  • 原文地址:https://www.cnblogs.com/jpfss/p/11887467.html
Copyright © 2011-2022 走看看