10.5.4 使用消息中间件收集数据

青旅半醒 2023-07-04 12:40 8阅读 0赞

## zipkin server ##

<dependency>
          <groupId>io.zipkin.java</groupId>
          <artifactId>zipkin-autoconfigure-ui</artifactId>
        </dependency>
        <dependency>
          <groupId>io.zipkin.java</groupId>
          <artifactId>zipkin-server</artifactId>
        </dependency>
    
        
        <dependency>
          <groupId>io.zipkin.java</groupId>
          <artifactId>zipkin-autoconfigure-collector-rabbitmq</artifactId>
          <version>2.3.1</version>
        </dependency>
    
    
    	    
        <dependency>
          <groupId>org.springframework.cloud</groupId>
          <artifactId>spring-cloud-sleuth-zipkin-stream</artifactId>
        </dependency>
        <dependency>
          <groupId>org.springframework.cloud</groupId>
          <artifactId>spring-cloud-starter-sleuth</artifactId>
        </dependency>
        <dependency>
          <groupId>org.springframework.cloud</groupId>
          <artifactId>spring-cloud-stream-binder-rabbit</artifactId>
        </dependency>

application.yml

server:
      port: 9411
    zipkin:
      collector:
        rabbitmq:
          addresses: localhost:5672
          password: guest
          username: guest
          queue: zipkin

# 改造微服务 #

<dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
          <groupId>org.springframework.cloud</groupId>
          <artifactId>spring-cloud-starter-zipkin</artifactId>
        </dependency>
        <dependency>
          <groupId>org.springframework.amqp</groupId>
          <artifactId>spring-rabbit</artifactId>
        </dependency>

application.yml

application:
        name: microservice-provider-user
      sleuth:
        sampler:
          percentage: 1.0
      rabbitmq:
        host: localhost
        port: 5672
        username: guest
        password: guest
      zipkin:
        rabbitmq:
          queue: zipkin

http://localhost:9411/zipkin/

http://localhost:8010/user/1 就有请求的链路追踪

# 存储跟踪数据 到 elasticsearch #

还支持：mysql cassandra等

<dependency>
          <groupId>io.zipkin.java</groupId>
          <artifactId>zipkin-autoconfigure-ui</artifactId>
        </dependency>
        <dependency>
          <groupId>io.zipkin.java</groupId>
          <artifactId>zipkin-server</artifactId>
        </dependency>
    
        <dependency>
          <groupId>io.zipkin.java</groupId>
          <artifactId>zipkin-autoconfigure-collector-rabbitmq</artifactId>
          <version>2.3.1</version>
        </dependency>
    
        
        <dependency>
          <groupId>io.zipkin.java</groupId>
          <artifactId>zipkin-autoconfigure-storage-elasticsearch-http</artifactId>
          <version>2.3.1</version>
        </dependency>

zipkin:
      collector:
        rabbitmq:
          addresses: localhost:5672
          password: guest
          username: guest
          queue: zipkin
      storage:
        type: elasticsearch
        elasticsearch:
          cluster: elasticsearch
          hosts: http://localhost:9200
          index: zipkin
          index-shards: 5
          index-replicas: 1

http://localhost:9411/zipkin/

http://localhost:9200/\_search