系统核心组件及架包

系统版本

Nacos中间件

1.1.4

Sentinel中间件

1.8.4

Zipkin-server 中间件

2.23.19

org.springframework.boot

2.2.4.RELEASE

spring-cloud-dependencies

Hoxton.SR1

spring-cloud-alibaba-dependencies

2.2.0.RELEASE

spring-cloud-starter-alibaba-nacos-discovery

1.5.0.RELEASE

spring-cloud-starter-alibaba-nacos-config

2.2.0.RELEASE

nacos-client

1.1.4

spring-cloud-starter-alibaba-sentinel

1.5.1.RELEASE

sentinel-datasource-nacos

1.7.1

sentinel-core

1.7.1

spring-cloud-starter-gateway

2.2.1.RELEASE

spring-cloud-starter-bootstrap

3.0.1

spring-boot-starter-webflux

2.2.4.RELEASE

spring-cloud-starter-zipkin

2.2.1.RELEASE

spring-cloud-starter-openfeign

2.2.1.RELEASE

<dependencyManagement>

    <dependencies>

        <!--spring cloud-->

        <dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-parent</artifactId>

            <version>2.2.4.RELEASE</version>

            <type>pom</type>

            <scope>import</scope>

        </dependency>

       <dependency>

            <groupId>org.springframework.cloud</groupId>

            <artifactId>spring-cloud-dependencies</artifactId>

            <version>Hoxton.SR1</version>

            <type>pom</type>

            <scope>import</scope>

        </dependency>

        <dependency>

            <groupId>com.alibaba.cloud</groupId>

            <artifactId>spring-cloud-alibaba-dependencies</artifactId>

            <version>2.2.0.RELEASE</version>

            <scope>import</scope>

            <type>pom</type>

        </dependency>

        <dependency>

            <groupId>com.alibaba.cloud</groupId>

          <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>

            <version>1.5.0.RELEASE</version>

        </dependency>

        <!--spring cloud-->

...... 其他依赖

</dependencyManagement>

<!-- 向注册中心进行服务注册 -->

<dependency>

        <groupId>com.alibaba.nacos</groupId>

        <artifactId>nacos-client</artifactId> <!--1.1.4-->

       <version>1.1.4</version>

</dependency>

<dependency>

      <groupId>com.alibaba.cloud</groupId>

      <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>

      <version>1.5.0.RELEASE</version>

</dependency>

<!-- 向注册中心进行服务注册 -->

spring:

  application:

    name: ddky-risk-cloud-provider

  cloud:

    nacos:

      discovery:

        server-addr: 127.0.0.1:8848

@RestController

@RequestMapping("/riskConfig")

@Slf4j

public class RiskConfigServer {

    @Autowired

    private RiskConfigService riskConfigService;

    @RequestMapping(value="/getRiskConfig",method = {RequestMethod.GET,RequestMethod.POST})

    public RiskConfig getRiskConfig(String riskCode){

        log.info("请求参数：{}",riskCode);

        RiskConfig res = riskConfigService.queryRiskConfig(riskCode); // *service 服务

        log.info("响应结果：{}",JsonTools.writeValueAsString(res));

        return res;

    }

}

<!-- 向注册中心进行服务注册 -->

<dependency>

        <groupId>com.alibaba.nacos</groupId>

        <artifactId>nacos-client</artifactId> <!--1.1.4-->

        <version>1.1.4</version>

</dependency>

<dependency>

      <groupId>com.alibaba.cloud</groupId>

      <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>

      <version>1.5.0.RELEASE</version>

</dependency>

<!-- 向注册中心进行服务注册 -->

spring:

  application:

    name: ddky-risk-cloud-consumer

  cloud:

    nacos:

      discovery:

        server-addr: 127.0.0.1:8848

@RestController

@RequestMapping("riskConfig")

public class RiskConfigController extends BaseController {

    @Autowired

    protected ServiceInstanceLoadBalancer serviceInstanceLoadBalancer;

    @GetMapping(value = "/getRiskConfig", produces = {"application/json;charset=UTF-8"})

    @ResponseBody

    public ServiceResult<?> getRiskConfig(String riskCode) {

        try {

            ServiceResult result = new ServiceResult<>();

//serviceInstance = loadBalancerClient.choose("ddky-risk-cloud-provider");

            ServiceInstance serviceInstance = serviceInstanceLoadBalancer.getServiceInstance();

            String targetUrl = serviceInstance.getUri() + "/riskConfig/getRiskConfig";

            log.info("获取服务端请求地址"+targetUrl);

            LinkedMultiValueMap<String, Object> params = new LinkedMultiValueMap<String,Object>();

            params.add("riskCode",riskCode);

            Map<String,Object> objectMap = new HashMap<>();

            objectMap.put("riskCode",riskCode);

            RiskConfig config = restTemplate.postForObject(targetUrl,params,RiskConfig.class,objectMap);

            result.setResult(config);

            return  result;

        }catch (Exception e){

            log.error("保存异常",e);

            return new ServiceResult<>(ResultCodeEnum.failure.getIndex(),e.getMessage());

        }

    }

}

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.cloud.client.ServiceInstance;

import org.springframework.cloud.client.discovery.DiscoveryClient;

import org.springframework.stereotype.Component;

import java.net.InetAddress;

import java.util.List;

import java.util.Random;

import java.util.concurrent.atomic.AtomicInteger;

/**

 * nacos 手动实现服务治理负责均衡 随机，轮询，Hash

 */

@Component

public class ServiceInstanceLoadBalancer {

    //nacos 提供者服务名称

    @Value("${server.cloud.name}")

    private String providerServer;

    //负载均衡策略,该配置可改成动态方式

    @Value("${server.instance.type:0}")

    private String instanceType; // 0-随机,1-轮询,2-Hash

    //随机

    private static final String RANDOM = "0";

    //轮询

    //private static final String POLL = "1";

    //Hash

    private static final String HASH = "2";

    //获取随机数

    private static final Random random = new Random();

    //nacos注册服务客户端

    @Autowired

    protected DiscoveryClient discoveryClient;

    //CAS 原子类

    private AtomicInteger poll = new AtomicInteger(0);

    //获取服务提供者

    public ServiceInstance getServiceInstance(){

        List<ServiceInstance> serviceInstanceList = discoveryClient.getInstances(providerServer);

        ServiceInstance serviceInstance =null;

        try {

            if (RANDOM.equals(instanceType)) {//随机

                serviceInstance = serviceInstanceList.get(random.nextInt(serviceInstanceList.size()));

            } else if (HASH.equals(instanceType)) {//IP Hash

                serviceInstance = serviceInstanceList.get(getIpHash() % serviceInstanceList.size());

            } else {//轮询,默认

                serviceInstance = serviceInstanceList.get(poll.getAndIncrement() % serviceInstanceList.size());

            }

        }catch (Exception e){

        }

        return serviceInstance;

    }

    //获取IP Hash

    private int getIpHash(){

        try {

            return InetAddress.getLocalHost().getHostAddress().hashCode();

        } catch (Exception e) {

            return 0;

        }

    }

}

<dependency>

    <groupId>org.springframework.cloud</groupId>

    <artifactId>spring-cloud-starter-openfeign</artifactId>

<version>2.2.1-SNAPSHOT</version>

</dependency>

feign:

  client:

    config:

      feignName: ##定义FeginClient的名称

        connectTimeout: 5000 # 链路链接超时时间

        readTimeout: 5000 # 读取超时时间

        # 配置Feign的日志级别，相当于代码配置方式中的Logger

        loggerLevel: full

package com.ddky.risk.cloud.feign;

import com.ddky.risk.cloud.domain.RiskConfig;

import com.ddky.risk.cloud.response.ServiceResult;

import org.springframework.cloud.openfeign.FeignClient;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestParam;

@FeignClient(value="ddky-risk-cloud-provider",path ="/riskConfig")

public interface RiskConfigFeign {

    @RequestMapping("/getRiskConfig")

    public ServiceResult<RiskConfig> getRiskConfig(@RequestParam(value="riskCode") String riskCode);

}

@RestController

@RequestMapping("/riskConfig")

@Slf4j

public class RiskConfigServer {

    @Autowired

    private RiskConfigService riskConfigService;

    @RequestMapping(value="/getRiskConfig",method = {RequestMethod.GET,RequestMethod.POST})

    @ResponseBody

    public ServiceResult<RiskConfig> getRiskConfig(HttpServletRequest request,String riskCode){

        log.info("请求参数：{}",riskCode);

        ServiceResult result = new ServiceResult();

        RiskConfig res = riskConfigService.queryRiskConfig(riskCode);

        log.info("响应结果：{}",JsonTools.writeValueAsString(res));

        result.setResult(res);

        return result;

    }

}

@Slf4j

@RestController

@RequestMapping("riskConfig")

public class RiskConfigController extends BaseController {

    @Autowired

    private RiskConfigFeign riskConfigFeign;

    @GetMapping(value = "/getRiskConfigFeign", produces = {"application/json;charset=UTF-8"})

    @ResponseBody

    public ServiceResult<?> getRiskConfigFeign(ServiceRequest<String> params) {

        try {

            ServiceResult<RiskConfig> result = riskConfigFeign.getRiskConfig(params.getData());

            return result;

        }catch (Exception e){

            log.error("保存异常",e);

            return new ServiceResult<>(ResultCodeEnum.failure.getIndex(),e.getMessage());

        }

    }

}

<!-- 向注册中心进行服务注册 -->

<dependency>

        <groupId>com.alibaba.nacos</groupId>

        <artifactId>nacos-client</artifactId><!--1.1.4-->

<version>1.1.4</version>

</dependency>

<dependency>

    <groupId>com.alibaba.cloud</groupId>

    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>

<version>1.5.1.RELEASE</version>

</dependency>

<dependency>

    <groupId>com.alibaba.cloud</groupId>

    <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>

    <version>1.5.1.RELEASE</version>

</dependency>

<dependency>

    <groupId>com.alibaba.csp</groupId>

    <artifactId>sentinel-datasource-nacos</artifactId>

<version>1.7.1</version>

</dependency>

<dependency>

       <groupId>com.alibaba.csp</groupId>

       <artifactId>sentinel-core</artifactId>

       <version>1.7.1</version>

</dependency>

#添加sentinel依赖后 暴露/actuator/sentinel

management:

  endpoints:

    web:

      exposure:

        include: '*'

spring:

  application:

    name: ddky-risk-cloud-provider

  cloud:

    nacos:

      discovery:

        server-addr: 127.0.0.1:8848

    sentinel:  # sentinel 接入配置

      eager: true

      transport:

        dashboard: 127.0.0.1:8080   #指定sentinel控制台的地址

        port: 8719

        clientIp: 127.0.0.1

      datasource:  #sentinel使用nacos接入持久化配置

        flow:

          nacos:

            serverAddr: 127.0.0.1:8848   

            dataId: ddky-risk-cloud-provider-flow

            groupId: DEFAULT_GROUP

            dataType: json

            ruleType: flow

package com.ddky.risk.cloud.request;

import com.fasterxml.jackson.annotation.JsonIgnoreProperties;

import java.io.Serializable;

@JsonIgnoreProperties(ignoreUnknown = true)

public class ServiceRequest <T> implements Serializable {

    private static final long serialVersionUID = -1L;

    private T data;

    public ServiceRequest(T data) {

        this.data = data;

    }

    public ServiceRequest() {

    }

    public T getData() {

        return data;

    }

    public void setData(T data) {

        this.data = data;

    }

}

package com.ddky.risk.cloud.response;

import com.ddky.risk.cloud.enums.ResultCodeEnum;

import com.ddky.risk.cloud.exception.BusinessException;

import com.fasterxml.jackson.annotation.JsonIgnoreProperties;

import java.io.Serializable;

/**

 * 通用返回值

 */

@JsonIgnoreProperties(ignoreUnknown = true)

public class ServiceResult<T> implements Serializable {

   private static final long serialVersionUID = -394529804715984961L;

   private Integer code;

   private String msg;

   private T result;

   public ServiceResult() {

      this(ResultCodeEnum.Success);

   }

   public ServiceResult(ResultCodeEnum resultCode) {

      this.code = resultCode.getIndex();

      this.msg = resultCode.getMessage();

   }

   public ServiceResult(Integer code, String msg) {

      this.code = code;

      this.msg = msg;

   }

   public ServiceResult(BusinessException e) {

      this.code = e.getCode();

      this.msg = e.getMessage();

   }

...

   public Integer getCode() {

      return this.code;

   }

   public void setCode(Integer code) {

      this.code = code;

   }

    ...

}

package com.ddky.risk.cloud.exception;

import com.alibaba.csp.sentinel.slots.block.BlockException;

import com.alibaba.csp.sentinel.slots.block.authority.AuthorityException;

import com.alibaba.csp.sentinel.slots.block.degrade.DegradeException;

import com.alibaba.csp.sentinel.slots.block.flow.FlowException;

import com.alibaba.csp.sentinel.slots.block.flow.param.ParamFlowException;

import com.ddky.risk.cloud.enums.ResultCodeEnum;

import com.ddky.risk.cloud.request.ServiceRequest;

import com.ddky.risk.cloud.response.ServiceResult;

// 自定义sentinel处理器

public class SentienlException {

    /**

     * 系统异常时，捕获并返回错误

     * @param data

     * @param e

     * @return

     */

    public static ServiceResult errorException(ServiceRequest data,Throwable e){

        return new ServiceResult(ResultCodeEnum.failure.getIndex(),e.getClass().getName()+":"+e.getMessage());

    }

    /**

     * sentinel 限流异常时，封装并返回错误

     * @param data

     * @param e

     * @return

     */

    public static ServiceResult blockException(ServiceRequest data,BlockException e){

        if (e instanceof FlowException) {//限制异常

            return new ServiceResult(ResultCodeEnum.flow_error);

        } else if (e instanceof ParamFlowException) {//热点参数异常

            return new ServiceResult(ResultCodeEnum.hot_error);

        } else if (e instanceof DegradeException) {//降级异常

            return new ServiceResult(ResultCodeEnum.degrade_error);

        } else if (e instanceof AuthorityException) {//受权异常

            return new ServiceResult(ResultCodeEnum.auth_error);

        }

        //提供安全异常

        return new ServiceResult(ResultCodeEnum.system_block_error);

    }

}

package com.ddky.risk.cloud.webserver;

import com.alibaba.csp.sentinel.annotation.SentinelResource;

import com.ddky.risk.cloud.domain.RiskConfig;

import com.ddky.risk.cloud.exception.SentienlException;

import com.ddky.risk.cloud.request.ServiceRequest;

import com.ddky.risk.cloud.response.ServiceResult;

import com.ddky.risk.cloud.service.nacos.RiskConfigService;

import com.ddky.risk.cloud.util.JsonTools;

import lombok.extern.slf4j.Slf4j;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.springframework.web.bind.annotation.ResponseBody;

import org.springframework.web.bind.annotation.RestController;

/**

 * @author ysf

 * @version 1.0

 * @description: TODO

 * @date 2022/2/14 10:07

 */

@RestController

@RequestMapping("/riskConfig")

@Slf4j

public class RiskConfigServer {

    @Autowired

    private RiskConfigService riskConfigService;

    @RequestMapping(value="/getRiskConfig",method = {RequestMethod.GET,RequestMethod.POST})

    @ResponseBody

    @SentinelResource(value="/getRiskConfig",blockHandler = "blockException",blockHandlerClass = {SentienlException.class},fallback = "errorException",fallbackClass = {SentienlException.class})

    public ServiceResult<RiskConfig> getRiskConfig(ServiceRequest<String> riskCode){

        log.info("请求参数：{}",riskCode);

        ServiceResult result = new ServiceResult();

        RiskConfig res = riskConfigService.queryRiskConfig(riskCode.getData());

        log.info("响应结果：{}",JsonTools.writeValueAsString(res));

        result.setResult(res);

        return result;

    }

}

FLOW("flow", FlowRule.class),

DEGRADE("degrade", DegradeRule.class),

PARAM_FLOW("param-flow", ParamFlowRule.class),

SYSTEM("system", SystemRule.class),

AUTHORITY("authority", AuthorityRule.class),

GW_FLOW("gw-flow", "com.alibaba.csp.sentinel.adapter.gateway.common.rule.GatewayFlowRule"),

GW_API_GROUP("gw-api-group", "com.alibaba.csp.sentinel.adapter.gateway.common.api.ApiDefinition");

[{

    "resource": "/getRiskConfig",

    "limitApp": "default",

    "grade": 1,

    "count": 1,

    "strategy": 0,

    "controlBehavior": 0,

    "clusterMode": false

}]

[{

  "resource": "/getRiskConfig",

  "grade": "0",

  "count": "1",

  "slowRatioThreshold": "0.1",

  "timeWindow": "1",

  "minRequestAmount": "1",

  "statIntervalMs": "1000"

}]

[{

  "resource": "/getRiskConfig",

  "paramIdx": "0",

  "count": "1",

  "durationInSec": "1",

  "clusterMode": false,

  "paramFlowItemList":[{

  "classType": "java.lang.String",

  "object": "10001",

  "count":"1"

  }]

}]

[{

  "highestCpuUsage：CPU":1

}]

[{

  "resource":"/getRiskConfig",

  "limitApp":"",

  "strategy":0

}]

<dependency>

    <groupId>com.alibaba.cloud</groupId>

    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>

<version>1.5.1.RELEASE</version>

</dependency>

<dependency>

    <groupId>com.alibaba.cloud</groupId>

    <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>

<version>2.2.0.RELEASE</version>

</dependency>

<dependency>

    <groupId>org.springframework.cloud</groupId>

    <artifactId>spring-cloud-starter-gateway</artifactId>

<version>2.2.1.RELEASE</version>

</dependency>

<dependency>

    <groupId>org.springframework.cloud</groupId>

    <artifactId>spring-cloud-starter-bootstrap</artifactId>

    <version>3.0.1</version><!-- 使用nacos动态配置使用 -->

</dependency>

<dependency>

    <groupId>org.springframework.boot</groupId>

    <artifactId>spring-boot-starter-webflux</artifactId>

<version>2.2.4.RELEASE</version>

</dependency>

server:

  port: 8888

logging:

  config: classpath:logback.xml

  level:

    org:

      springframework:

        boot:

          autoconfigure: ERROR         # 日志不打印条件评估报告

spring:

  application:

    name: ddky-risk-cloud-getway # 应用名称

  cloud:

    nacos:

      discovery:

        server-addr: localhost:8848

    gateway:

      discovery:

        locator:

          enabled: true

      routes:

        - id: ddky-risk-cloud-consumer  #路由标识符，区别于其他 Route

          uri: lb://ddky-risk-cloud-consumer #路由指向的目的地 uri，即客户端请求最终被转发到的微服务

          predicates:  #断言，用于条件判断，只有断言都返回真，才会真正的执行路由

            - Path=/riskConfig/**

server:

  port: 8888

logging:

  config: classpath:logback.xml

  level:

    org:

      springframework:

        boot:

          autoconfigure: ERROR         # 日志不打印条件评估报告

spring:

  application:

    name: ddky-risk-cloud-getway # 应用名称

spring:

  cloud:

    nacos:

      discovery:

        server-addr: 127.0.0.1:8848

      config: #nacos config 配置

        server-addr: 127.0.0.1:8848

        file-extension: yaml #文件内容及格式

        group: DEFAULT_GROUP

        prefix: ddky-risk-cloud-getway  #nacos 动态配置前缀

例如：

<script src="${path}/static/js/other/select/dynamic-column.js" type="text/javascript"></script>

改为

<script src="http://localhost:8081/static/js/other/select/dynamic-column.js" type="text/javascript"></script>

spring:

  cloud:

    gateway:

      discovery:

        locator:

          enabled: true

      routes:

        - id: ddky-risk-cloud-consumer  #路由标识符，区别于其他 Route

          uri: lb://ddky-risk-cloud-consumer #路由指向的目的地 uri，即客户端请求最终被转发到的微服务

          predicates:  #断言，用于条件判断，只有断言都返回真，才会真正的执行路由

            - Path=/riskConfig/**

        - id: ddky-risk-cloud-consumer-static  #路由标识符，区别于其他 Route

          uri: lb://ddky-risk-cloud-consumer #路由指向的目的地 uri，即客户端请求最终被转发到的微服务

          predicates:  #断言，用于条件判断，只有断言都返回真，才会真正的执行路由  

            - Path=/static/**

CREATE TABLE IF NOT EXISTS zipkin_spans (

  `trace_id_high` BIGINT NOT NULL DEFAULT 0 COMMENT 'If non zero, this means the trace uses 128 bit traceIds instead of 64 bit',

  `trace_id` BIGINT NOT NULL,

  `id` BIGINT NOT NULL,

  `name` VARCHAR(255) NOT NULL,

  `remote_service_name` VARCHAR(255),

  `parent_id` BIGINT,

  `debug` BIT(1),

  `start_ts` BIGINT COMMENT 'Span.timestamp(): epoch micros used for endTs query and to implement TTL',

  `duration` BIGINT COMMENT 'Span.duration(): micros used for minDuration and maxDuration query',

  PRIMARY KEY (`trace_id_high`, `trace_id`, `id`)

) ENGINE=InnoDB ROW_FORMAT=COMPRESSED CHARACTER SET=utf8 COLLATE utf8_general_ci;

ALTER TABLE zipkin_spans ADD INDEX(`trace_id_high`, `trace_id`) COMMENT 'for getTracesByIds';

ALTER TABLE zipkin_spans ADD INDEX(`name`) COMMENT 'for getTraces and getSpanNames';

ALTER TABLE zipkin_spans ADD INDEX(`remote_service_name`) COMMENT 'for getTraces and getRemoteServiceNames';

ALTER TABLE zipkin_spans ADD INDEX(`start_ts`) COMMENT 'for getTraces ordering and range';

CREATE TABLE IF NOT EXISTS zipkin_annotations (

  `trace_id_high` BIGINT NOT NULL DEFAULT 0 COMMENT 'If non zero, this means the trace uses 128 bit traceIds instead of 64 bit',

  `trace_id` BIGINT NOT NULL COMMENT 'coincides with zipkin_spans.trace_id',

  `span_id` BIGINT NOT NULL COMMENT 'coincides with zipkin_spans.id',

  `a_key` VARCHAR(255) NOT NULL COMMENT 'BinaryAnnotation.key or Annotation.value if type == -1',

  `a_value` BLOB COMMENT 'BinaryAnnotation.value(), which must be smaller than 64KB',

  `a_type` INT NOT NULL COMMENT 'BinaryAnnotation.type() or -1 if Annotation',

  `a_timestamp` BIGINT COMMENT 'Used to implement TTL; Annotation.timestamp or zipkin_spans.timestamp',

  `endpoint_ipv4` INT COMMENT 'Null when Binary/Annotation.endpoint is null',

  `endpoint_ipv6` BINARY(16) COMMENT 'Null when Binary/Annotation.endpoint is null, or no IPv6 address',

  `endpoint_port` SMALLINT COMMENT 'Null when Binary/Annotation.endpoint is null',

  `endpoint_service_name` VARCHAR(255) COMMENT 'Null when Binary/Annotation.endpoint is null'

) ENGINE=InnoDB ROW_FORMAT=COMPRESSED CHARACTER SET=utf8 COLLATE utf8_general_ci;

ALTER TABLE zipkin_annotations ADD UNIQUE KEY(`trace_id_high`, `trace_id`, `span_id`, `a_key`, `a_timestamp`) COMMENT 'Ignore insert on duplicate';

ALTER TABLE zipkin_annotations ADD INDEX(`trace_id_high`, `trace_id`, `span_id`) COMMENT 'for joining with zipkin_spans';

ALTER TABLE zipkin_annotations ADD INDEX(`trace_id_high`, `trace_id`) COMMENT 'for getTraces/ByIds';

ALTER TABLE zipkin_annotations ADD INDEX(`endpoint_service_name`) COMMENT 'for getTraces and getServiceNames';

ALTER TABLE zipkin_annotations ADD INDEX(`a_type`) COMMENT 'for getTraces and autocomplete values';

ALTER TABLE zipkin_annotations ADD INDEX(`a_key`) COMMENT 'for getTraces and autocomplete values';

ALTER TABLE zipkin_annotations ADD INDEX(`trace_id`, `span_id`, `a_key`) COMMENT 'for dependencies job';

CREATE TABLE IF NOT EXISTS zipkin_dependencies (

  `day` DATE NOT NULL,

  `parent` VARCHAR(255) NOT NULL,

  `child` VARCHAR(255) NOT NULL,

  `call_count` BIGINT,

  `error_count` BIGINT,

  PRIMARY KEY (`day`, `parent`, `child`)

) ENGINE=InnoDB ROW_FORMAT=COMPRESSED CHARACTER SET=utf8 COLLATE utf8_general_ci;

<dependency>

    <groupId>org.springframework.cloud</groupId>

    <artifactId>spring-cloud-starter-zipkin</artifactId>

<version>2.2.1-SNAPSHOT</version>

</dependency>

spring:

  sleuth:

    web:

      client:

        enabled: true #开启链路采集

    sampler:

      probability: 1.0 #默认采集数据量 1-百分百，0.1-百分十

  zipkin:

    base-url: http://127.0.0.1:9411/  #制定链路日志收集地址

public ResponseEntity doPathUrl(HttpServletRequest request,String targetUrl,Object obj){

   //设置header信息

   Map map = MDC.getCopyOfContextMap();//获取trace信息

   HttpHeaders requestHandler = new HttpHeaders();

   String traceId = map.get("traceId")+"";

   String parentSpanId = map.get("spanId")+"";

   String spanId =  HexCodec.toLowerHex(nextId());

   String sampled = "1";

   requestHandler.add("X-B3-TraceId", traceId);

   requestHandler.add("X-B3-SpanId",spanId);

   requestHandler.add("X-B3-ParentSpanId", parentSpanId);

   requestHandler.add("X-B3-Sampled", sampled);

   MultiValueMap<String, Object> params = new LinkedMultiValueMap<>();

   params.add("riskCode",obj);

   HttpEntity<MultiValueMap> entity = new HttpEntity<>(params,requestHandler);

   return restTemplate.postForEntity(targetUrl,entity,ServiceResult.class);

}