zipkin:base-url: http://127.0.0.1:9411/
###全部采集
sleuth:sampler:probability: 1.0

服务名称:{{first.DATA}}
IP和端口:{{keyword1.DATA}}
错误内容:{{keyword2.DATA}}
错误时间:{{keyword3.DATA}} 

@RestController

public class TcfService {

    @RequestMapping("/tcf")

    public String tcf(Long id) {

        return "YES" + 10 % id;

    }

}

import com.alibaba.fastjson.JSONObject;
import com.tcf.service.asyn.AsynSendWechatTemplate;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.ControllerAdvice;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.client.RestTemplate;import java.net.InetAddress;
import java.net.NetworkInterface;
import java.net.SocketException;
import java.net.UnknownHostException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Enumeration;/*** 全局捕获异常*/
@ControllerAdvice
@Slf4j
public class MyExceptionHandler {@Value("${server.port}")private String serverPort;@Value("${spring.application.name}")private String serviceName;@Autowiredprivate AsynSendWechatTemplate asynSendWechatTemplate;@ExceptionHandler(value = Exception.class)public String exceptionHandler(Exception e) {log.error("未知异常！原因是:" + e);JSONObject data = new JSONObject();data.put("ip", getIpAddress());data.put("port", serverPort);data.put("serviceName", serviceName);data.put("errorMsg", e.getLocalizedMessage());SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");String format = formatter.format(new Date());data.put("errorTime", format);data.put("openId", "okYSmtzp4wWCrDCncMfGSRECVSeM");
//        HttpHeaders headers = new HttpHeaders();
//        MediaType type = MediaType.parseMediaType("application/json; charset=UTF-8");
//        headers.setContentType(type);
//        headers.add("Accept", MediaType.APPLICATION_JSON.toString());
//        HttpEntity<String> formEntity = new HttpEntity<String>(data.toString(), headers);
//        String result = restTemplate.postForEntity("http://127.0.0.1:9099/sendWechatTemplateError", formEntity, String.class).getBody();
//        log.info("result:" + result);asynSendWechatTemplate.sendWechatTemplate(data);return "系统出现错误!";}public static String getIpAddress() {String hostAddress = "";try {InetAddress address = InetAddress.getLocalHost();hostAddress = address.getHostAddress();} catch (UnknownHostException e) {}return hostAddress;}
}

    @Bean

    public RestTemplate restTemplate() {

        return new RestTemplate();

    }

import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;
import java.net.InetAddress;
import java.net.UnknownHostException;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.LinkedBlockingDeque;@Component
@Slf4j
public class AsynSendWechatTemplate {private static ArrayBlockingQueue<JSONObject> arrayBlockingQueue =new ArrayBlockingQueue<JSONObject>(1024);@Autowiredprivate RestTemplate restTemplate;public AsynSendWechatTemplate() {new Thread(new ThreadAsynSendWechatTemplate()).start();}/*** 存入到 队列中** @param data*/public void sendWechatTemplate(JSONObject data) {arrayBlockingQueue.offer(data);}class ThreadAsynSendWechatTemplate implements Runnable {@Overridepublic void run() {while (true) {JSONObject data = arrayBlockingQueue.poll();if (data != null) {HttpHeaders headers = new HttpHeaders();MediaType type = MediaType.parseMediaType("application/json; charset=UTF-8");headers.setContentType(type);headers.add("Accept", MediaType.APPLICATION_JSON.toString());HttpEntity<String> formEntity = new HttpEntity<String>(data.toString(), headers);String result = restTemplate.postForEntity("http://127.0.0.1:9099/sendWechatTemplateError", formEntity, String.class).getBody();log.info("result:" + result);}try {// 避免cpu飙高的问题Thread.sleep(100);} catch (Exception e) {}}}}public static String getIpAddress() {String hostAddress = "";try {InetAddress address = InetAddress.getLocalHost();hostAddress = address.getHostAddress();} catch (UnknownHostException e) {}return hostAddress;}
}

8 SkyWorking简介

SkyWalking是一个开源的观测平台，用于从服务和云原生等基础设施中收集、分析、聚合以及可视化数据，SkyWalking 提供了一种简便的方式来清晰地观测分布式系统，甚至可以观测横跨不同云的系统，SkyWalking 更像是一种现代的应用程序性能监控（Application Performance Monitoring，即APM）工具，专为云原生，基于容器以及分布式系统而设计。

监控--分布式追踪调用链 、jvm内存变化、智能报警、cpu飙高、服务器基本配置信息

(图片摘自：Apache SkyWalking )

9 SkyWalking架构原理

在整个skywalking的系统中，有四个角色：

1.skywalking agent和业务系统关联在一起，负责收集各种监控数据；

2.oapservice是负责处理监控数据的，比如接受skywalking agent的监控数据，并存储在数据库中（例如elasticsearch、mysql中等）;接受skywalking webapp的前端请求，从数据库查询数据，并返回数据给前端。，Skywalking oapservice通常以集群的形式存在；

3.skywalking webapp，前端界面，用于展示数据；

4.用于存储监控数据的数据库，比如mysql、elasticsearch等；

10 SkyWalking 环境搭建

1. 下载apache-skywalking-apm-6.5.0.tar安装包

2. 进入到bin目录（直接双击启动startup.bat）

3. 启动启动oapService和我们的webappService

4. 查看管理界面http://127.0.0.1:8080/

5 IDEA启动类相关配置，新增VM Options配置参数

Idea 相关的配置：

-javaagent:D:\apache-skywalking-apm-bin\agent\skywalking-agent.jar

-Dskywalking.agent.service_name=user-service

-Dskywalking.collector.backend_service=127.0.0.1:11800

11 SkyWalking获取全局追踪id

maven依赖：

        <dependency><groupId>org.apache.skywalking</groupId><artifactId>apm-toolkit-trace</artifactId><version>6.5.0</version></dependency>

String traceId = TraceContext.traceId();

[{"scopeId": 1,"scope": "SERVICE","name": "serviceA","id0": 12,"id1": 0,"ruleName": "service_resp_time_rule","alarmMessage": "alarmMessage xxxx","startTime": 1560524171000
}, {"scopeId": 1,"scope": "SERVICE","name": "serviceB","id0": 23,"id1": 0,"ruleName": "service_resp_time_rule","alarmMessage": "alarmMessage yyy","startTime": 1560524171000
}]

/*** 封装报警参数的对象*/public class AlarmMessageDto {private int scopeId;private String name;private int id0;private int id1;private String alarmMessage;private long startTime;public int getScopeId() {return scopeId;}public String getName() {return name;}public int getId0() {return id0;}public int getId1() {return id1;}public String getAlarmMessage() {return alarmMessage;}public long getStartTime() {return startTime;}public void setScopeId(int scopeId) {this.scopeId = scopeId;}public void setName(String name) {this.name = name;}public void setId0(int id0) {this.id0 = id0;}public void setId1(int id1) {this.id1 = id1;}public void setAlarmMessage(String alarmMessage) {this.alarmMessage = alarmMessage;}public void setStartTime(long startTime) {this.startTime = startTime;}
}import com.tcf.entity.AlarmMessageDto;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;import java.util.ArrayList;
import java.util.List;/*** 报警接口*/
@RestController
public class PoliceService {private List<List<AlarmMessageDto>> listAlarmMessage = new ArrayList<>();/*** 存放告警信息** @param alarmMessageList*/@RequestMapping(value = "/police", method = RequestMethod.POST)public void alarm(@RequestBody List<AlarmMessageDto> alarmMessageList) {listAlarmMessage.add(alarmMessageList);
WxMpTemplateMsgService wxMpTemplateMsgService = WxMpConfiguration.getMpServices().get(wxMpProperties.getConfigs().get(0).getAppId()).getTemplateMsgService();WxMpTemplateMessage wxMpTemplateMessage = new WxMpTemplateMessage();wxMpTemplateMessage.setTemplateId(errorTemplateId);wxMpTemplateMessage.setToUser(serviceErrorDto.getOpenId());List<WxMpTemplateData> data = new ArrayList<>();data.add(new WxMpTemplateData("first", serviceErrorDto.getServiceName()));data.add(new WxMpTemplateData("keyword1", serviceErrorDto.getIp() + ":" + serviceErrorDto.getPort()));data.add(new WxMpTemplateData("keyword2", serviceErrorDto.getErrorMsg()));SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");String format = formatter.format(serviceErrorDto.getErrorTime());data.add(new WxMpTemplateData("keyword3", format));wxMpTemplateMessage.setData(data);wxMpTemplateMessage.setUrl("http://supertian.blog.csdn.net");try {wxMpTemplateMsgService.sendTemplateMsg(wxMpTemplateMessage);} catch (Exception e) {log.error("<e:>", e);}}/*** 打印告警信息** @return*/@RequestMapping("/getListAlarmMessageDto")public List<List<AlarmMessageDto>> getListAlarmMessageDto() {return listAlarmMessage;}}