SpringCloud集成sleuth和zipkin实现微服务链路追踪的实战分享

https://github.com/openzipkin/zipkin/blob/master/zipkin-storage/mysql-v1/src/main/resources/mysql.sql
--
-- copyright the openzipkin authors
-- spdx-license-identifier: apache-2.0
--

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;

<properties>
    <spring-cloud.version>2021.0.5</spring-cloud.version>
</properties>
<dependencies>
    <dependency>
        <groupid>org.springframework.cloud</groupid>
        <artifactid>spring-cloud-dependencies</artifactid>
        <version>${spring-cloud.version}</version>
        <type>pom</type>
        <scope>import</scope>
    </dependency>
    <dependency>
        <groupid>org.springframework.cloud</groupid>
        <artifactid>spring-cloud-starter-sleuth</artifactid>
        <version>3.1.10</version>
    </dependency>
    <dependency>
        <groupid>org.springframework.cloud</groupid>
        <artifactid>spring-cloud-sleuth-zipkin</artifactid>
        <version>3.1.10</version>
    </dependency>
</dependencies>

spring:
  zipkin:
    #zipkin服务所在地址
    base-url: http://127.0.0.1:9411/
    sender:
      type: web #使用http的方式传输数据
    #配置采样百分比
    sleuth:
      sampler:
        probability: 1 # 将采样比例设置为 1.0，也就是全部都需要。默认是0.1也就是10%，一般情况下，10%就够用了
##打开debug日志
logging:
  level:
    org.springframework.web.servlet.dispatcherservlet: debug

/**
 * 计算订单金额
 * @param orderid
 * @author senfel
 * @date 2024/12/9 18:25
 * @return java.lang.string
 */
@requestmapping("/getorderamount")
public string getorderamount(@requestparam(name = "orderid") string orderid) {
    return orderservice.getorderamount(orderid);
}

/**
 * feeservice
 * @author senfel
 * @version 1.0
 * @date 2024/12/9 18:02
 */
@feignclient(name = "order-service",fallback = orderservicefallback.class)
public interface getorderamount {

    /**
     * 获取订单金额
     * @param orderid
     * @author senfel
     * @date 2024/12/9 18:06
     * @return java.lang.string
     */
    @requestmapping(value = "/order/getorderamount",method = requestmethod.get)
    string getorderamount(@requestparam(name = "orderid") string orderid);
}

/**
 * 获取订单金额
 * @param orderid
 * @author senfel
 * @date 2024/12/9 18:06
 * @return java.lang.string
 */
@requestmapping(value = "/getorderamount",method = requestmethod.get)
public string getorderamount(@requestparam(name = "orderid") string orderid){
    return financeservice.getfee(orderid);
}

/**
 * financeservice
 * @author senfel
 * @version 1.0
 * @date 2024/12/9 18:10
 */
@feignclient(name = "finance-service",fallback = financeservicefallback.class)
public interface financeservice {

    /**
     * 获取费用
     * @param orderid
     * @author senfel
     * @date 2024/12/9 18:12
     * @return java.lang.string
     */
    @requestmapping(value = "/finance/getfee",method = requestmethod.get)
    string getfee(@requestparam(name = "orderid") string orderid);
}

/**
 * 获取费用
 * @param orderid
 * @author senfel
 * @date 2024/12/9 18:12
 * @return java.lang.string
 */
@requestmapping(value = "/getfee",method = requestmethod.get)
public string getfee(@requestparam(name = "orderid") string orderid) {
    return "100";
}