springcloud集成zipkin 思维笔记模板_ProcessOn思维导图、流程图

简介

zipkin是twitter开源的分布式跟踪系统，主要用来收集系统的实时数据，从而追踪系统的调用问题。

官网

https://zipkin.io/

spring 文档

https://docs.spring.io/spring-cloud-sleuth/docs/current/reference/html/integrations.html#sleuth-openfeign-integration

安装zipkin

docker-compose.yml代码

version: '3'
services:
  zipkin:
    image: openzipkin/zipkin
    container_name: zipkin
    ports:
      - 9411:9411

启动命令 docker-compose up -d

服务项目代码

项目导入pom依赖

<dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-sleuth-zipkin</artifactId>
  </dependency>

application.yml配置

spring
  zipkin:
    base-url: http://192.168.56.1:9411
    discovery-client-enabled: false #关闭服务发现，否则springcloud 会把zipkin的服务url当做服务名称
    sender:
      type: web #使用http的方式传输数据
  sleuth:
    trace-id128: true
    sampler:
      probability: 1 #抽样采集率为100% 默认为0.1即10%
    baggage:
      tag-fields: tag_name

HelloController.java代码

@Slf4j
@RestController
public class HelloController {

    @Autowired
    ZipkinService zipkinService;
    @SentinelResource(value="hello")
    @RequestMapping(value = "/hello",produces = "text/json")
    public String hello(){
        log.info("say hello word!");
        //远程调用
        String s = zipkinService.helloWord();
        return s;
    }

}

验证

浏览器输入请求地址：http://localhost:9000/hello

浏览器访问zipkin地址查看效果：http://192.168.56.10:9411/zipkin/

nginx配置

upstream zipkin{
  server 192.168.56.10:9411;
}
server {
    listen       9411;
    server_name  localhost;

    location / {
       proxy_pass  http://zipkin;
    }
}

错误

Caused by: java.lang.ClassNotFoundException: org.springframework.boot.actuate.autoconfigure.endpoint.web.WebEndpointProperties

解决方案：将pom.xml的依赖替换

<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-actuator</artifactId>
        </dependency>
替换为
<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>

直接持久化到mysql

优点：简单，无需添加额外的中间件，缺点：服务性能消耗较大

创建数据库

create DATABASE zipkin;

建表

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;

调整zipkin的docker-compose.yml新增mysql相关配置

docker-compose.yml文件

version: '3'
services:
  zipkin:
    image: openzipkin/zipkin
    environment:
      - TZ=Asia/Shanghai
      - JAVA_OPTS=-XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=128m -Xms100m -Xmx1024m -Xmn256m
      - STORAGE_TYPE=mysql
      - MYSQL_DB=zipkin
      - MYSQL_USER=root
      - MYSQL_PASS=root
      - MYSQL_HOST=192.168.56.10
      - MSYQL_TCP_PORT=3306
    container_name: zipkin
    ports:
      - 9411:9411

重新启动zipkin

docker-compose down &&docker-compose up -d&&dopcker-compose logs -f

通过rabbitmq持久化到mysql

基于以上直接持久化到mysql的数据库脚本

安装rabbitmq，docker方式启动，根据实际情况修改启动脚本

docker run -d --restart=always --name rabbitmq -p 5672:5672 \
-p 15672:15672 -e RABBITMQ_DEFAULT_USER='admin' \
-e RABBITMQ_DEFAULT_PASS='admin'  \
-e RABBITMQ_NODENAME='MYNODE@localhost'   \
-v /home/rabbitmq/data:/var/lib/rabbitmq \
-v /home/rabbitmq/definitions.json:/opt/definitions.json  \
-v /home/rabbitmq/rabbitmq.config:/etc/rabbitmq/rabbitmq.config  \
-v /etc/localtime:/etc/localtime rabbitmq:management-alpine

服务项目application.yml配置

子主题

添加rabbitmq配置项

version: '3'
services:
  zipkin:
    image: openzipkin/zipkin
    environment:
      - TZ=Asia/Shanghai
      - JAVA_OPTS=-XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=128m -Xms100m -Xmx1024m -Xmn256m
      - STORAGE_TYPE=mysql
      #数据库链接信息
      - MYSQL_DB=zipkin
      - MYSQL_USER=root
      - MYSQL_PASS=root
      - MYSQL_HOST=192.168.56.10
      - MSYQL_TCP_PORT=3306
      #rabitmq链接信息
      - RABBIT_ADDRESSES=192.168.56.10:5672
      - RABBIT_USER=admin
      - RABBIT_PASSWORD=admin
      - RABBIT_QUEUE=zipkin
      - RABBIT_VIRTUAL_HOST=/
    container_name: zipkin
    ports:
      - 9411:9411

项目启动报错

Parameter 2 of method reporter in org.springframework.cloud.sleuth.zipkin2.ZipkinAutoConfiguration required a bean of type 'zipkin2.reporter.Sender' that could not be found.

需要注入Sender与ConnectFactory

@Configuration
public class ZipkinConfig {
    @Autowired
    private RabbitProperties rabbitProperties;
    @Bean
    Sender rabbitSender2(){
        ConnectionFactory connectionFactory=new ConnectionFactory();
        connectionFactory.setHost(rabbitProperties.getHost());
        connectionFactory.setPort(rabbitProperties.getPort());
        connectionFactory.setUsername(rabbitProperties.getUsername());
        connectionFactory.setPassword(rabbitProperties.getPassword());
        return RabbitMQSender.newBuilder()
                .connectionFactory(connectionFactory)
                .queue("zipkin")
                .addresses(rabbitProperties.getHost()+":"+rabbitProperties.getPort())
                .build();
    }

}

浏览器访问验证

持久化到elasticsearch

待完善。。。。