导语

在时序分析及监控展示领域，Grafana无疑是开源解决方案中的翘楚，其灵活的插件机制，支持各种漂亮的面板、丰富的数据源以及强大的应用。典型的面板有Graph、Text、Singlestat、PieChart、Table、Histogram等，支持的数据源有ES、Graphite、InfluxDB、OpenTSDB、MySQL、Druid 、Prometheus、SimpleJson等，提供的应用有Zabbix、K8s等。但是某公司在分布式集群中物理机监控的数据源为gRPC方式，即连接gRPC即可获取实时物理机监控信息，如CPU，内存，磁盘，负载等信息，这样就能使用后台转发gRPC的消息，这里使用SSM框架的java后台为grafana提供的SimpleJson数据源。

作者撰文时，网上几乎没有分享SimpleJson数据源的java后台API，为此分享给大家，初次分享，不便之处请见谅。

整体架构如下所示:

一、WebAPI

如果要支持SimpleJson，后端WebAPI需要实现4个URL：

/：返回200，用于SimpleJson数据源测试连通性；
/search：返回所有可选的指标；
/query：返回对应指标的时间序列点；
/annotations：返回注解。

    @RequestMapping(value = "/", method = RequestMethod.GET)
    @ResponseBody
    public Map ReturnTest(HttpServletResponse response){

        response.setHeader("Access-Control-Allow-Headers", "accept, content-type");
        response.setHeader("Access-Control-Allow-Methods", "POST");
        response.setHeader("Access-Control-Allow-Origin", "*");

        Map<String, Object> map = new HashMap<String, Object>();
        map.put("result", "200 ok");
        return map;
    }

    @RequestMapping(value = "/search", method = RequestMethod.POST)
    @ResponseBody
    public List Search(HttpServletResponse response) {

        response.setHeader("Access-Control-Allow-Headers", "accept, content-type");
        response.setHeader("Access-Control-Allow-Methods", "POST");
        response.setHeader("Access-Control-Allow-Origin", "*");


        List<String> result = new ArrayList<String>();
        result.add("CPU");
        result.add("RAM");
        result.add("LOAD");
        result.add("SWAP");
        result.add("DISK");
        result.add("NET");
        return result;
    }
``


```java
    @RequestMapping(value = "/query", method = RequestMethod.POST)
    @ResponseBody
    public List Query(@RequestBody Map<String,Object>  params, HttpServletResponse response) {
        List<Map> targetList = (List) params.get("targets");
        List<Map<String, Object>> result = new ArrayList<Map<String, Object>>() ;
        for (Map targetMap : targetList){
            String target = (String)targetMap.get("target");
            Map scopedVars = (Map) params.get("scopedVars");
            Map IP = (Map) scopedVars.get("IP");
            String nodeIP = (String) IP.get("text");
            if (target.equals("CPU")){
                result.add(nodeMonitorService.getCpuMap(nodeIP));
            }else if (target.equals("RAM")){
                result.add(nodeMonitorService.getRamMap(nodeIP));
            }else if (target.equals("LOAD")) {
                result.add(nodeMonitorService.getLoadMap(nodeIP));
            }else if (target.equals("SWAP")){
                result.add(nodeMonitorService.getSwapMap(nodeIP));
            }else if(target.equals("DISK")){
                result = nodeMonitorService.getDiskList(nodeIP);
            }else if (target.equals("NET")){
                result = nodeMonitorService.getNetList(nodeIP);
            }
        }
        response.setHeader("Access-Control-Allow-Headers", "accept, content-type");
        response.setHeader("Access-Control-Allow-Methods", "POST");
        response.setHeader("Access-Control-Allow-Origin", "*");
        Collections.sort(result, new Comparator<Map<String, Object>>() {
            public int compare(Map<String, Object> o1, Map<String, Object> o2) {
                String name1 = String.valueOf(o1.get("target").toString()) ;
                String name2 = String.valueOf(o2.get("target").toString()) ; 
                return name1.compareTo(name2);
            }
        });
        return result;
    }

    @RequestMapping(value = "/annotations", method = RequestMethod.POST)
    @ResponseBody
    public Map Annotations() {

        Map<String, Object> map = new HashMap<String, Object>();
        map.put("result", "200 ok");
        return map;
    }

注意header里面加上这3条：

        response.setHeader("Access-Control-Allow-Headers", "accept, content-type");
        response.setHeader("Access-Control-Allow-Methods", "POST");
        response.setHeader("Access-Control-Allow-Origin", "*");

二、grafana配置

安装grafana，安装SimpleJson插件，在grafana官网，有详细说明。
启动访问，使用admin账户登录，

1、创建数据源：DataSources

type选择SimpleJson类型，URL填入后台服务的API地址，

2、创建面板dashboard

这个面板我已经分享到grafana网站了，可以前去下载：https://grafana.com/dashboards/5075

综上所述，基于SimpleJson数据源，只要配置数据源之后，按正确的方式添加API即可将数据灵活展现在Grafana中，当然SimpleJson只是一个数据源协议载体，理论上可以对接任何类型的后台数据，只要组装成它支持的格式即可。