原文地址：http://www.cnblogs.com/skyblog/p/6213683.html

隨著微服務數量不斷增長，需要跟蹤一個請求從一個微服務到下一個微服務的傳播過程， Spring Cloud Sleuth 正是解決這個問題，它在日誌中引入唯一ID，以保證微服務調用之間的一致性，這樣你就能跟蹤某個請求是如何從一個微服務傳遞到下一個。

　　如果你有使用AOP攔截Servlet的經驗，做一個基於AOP的簡單服務統計和跟蹤很容易。但要像Zipkin那樣能夠跟蹤服務調用鏈就比較困難了。所謂調用鏈，就是A服務調用B服務，B服務又調用了C、D服務。這樣一個鏈要想統計跟蹤，要寫不少代碼。而Spring Cloud Sleuth能讓你不寫一行代碼的情況下完成這些。

　　本文涉及5個spring boot工程：

　　前三個驗證基本的Sleuth使用，後面兩個演示如果使用消息中間件作為Zipkin的源，以及如果將Zipkin的監控數據配置到mysql數據庫。由於前者和後者在配置方面相差較大，因此有必要將其分開展示。簡單的Sleuth應用，在這裏是指Sleuth http應用，就是Sleuth通過http請求的方式將監控日誌推送到Zipkin服務器。如圖所示，cloud-sleuth-server其實就是Zipkin Server它接收來自微服務cloud-sleuth-service1和cloud-sleuth-service2的監控日誌推送，cloud-sleuth-service1調用了cloud-sleuth-service2，形成一個簡單的調用鏈。其中cloud-sleuth-service1 pom配置：

<dependencies>
　　<dependency>
　　    <groupId>org.springframework.boot</groupId>
　　    <artifactId>spring-boot-starter-web</artifactId>
　　</dependency>
　　<dependency>
　　    <groupId>org.springframework.boot</groupId>
　　    <artifactId
 
>spring-boot-starter-actuator</artifactId>
　　</dependency>
　　<dependency>
       <groupId>org.springframework.cloud</groupId>
       <artifactId>spring-cloud-starter-sleuth</artifactId>
    </dependency>
    <dependency>
       <groupId>org.springframework.cloud</groupId>
       <artifactId>spring-cloud-sleuth-zipkin</artifactId>
     </dependency>               
 </dependencies>

SleuthClientApplication應用：

@SpringBootApplication
public class SleuthClientApplication {
 
    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
 
    public static void main(String[] args) {
        SpringApplication.run(SleuthClientApplication.class, args);
    }
}
 
@RestController
class HomeController {
 
    private static final Log log = LogFactory.getLog(HomeController.class);
    @Autowired
    private RestTemplate restTemplate;
     
    private String url="http://localhost:9986";
 
    @RequestMapping("/service1")
    public String service1() throws Exception {
        log.info("service1");
        Thread.sleep(200L);
        String s = this.restTemplate.getForObject(url + "/service2", String.class);
        return s;
    }  
}

application.properties：
spring.application.name=sleuthService1
server.port=9987
spring.zipkin.baseUrl=http://localhost:9966
spring.zipkin.enabled=true

　　只需要在pom文件裏配置spring-cloud-sleuth-zipkin並且在配置文件裏配置spring.zipkin.baseUrl，那麽service1就可以把監控日誌發送給目標是baseUrl指向的Zipkin服務器，就是會自動調用zipkin的某個rest接口將監控日誌傳給它。

　　Zipkin Server的pom配置：

　<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>io.zipkin</groupId>
            <artifactId>zipkin-ui</artifactId>
            <scope>runtime</scope>
        </dependency>
        <dependency>
            <groupId>io.zipkin.java</groupId>
            <artifactId>zipkin-server</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-sleuth</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-sleuth-zipkin</artifactId>
    </dependency>

SleuthServerApplication：

@SpringBootApplication
@EnableZipkinServer
public class SleuthServerApplication {
 
     
    public static void main(String[] args) {
        SpringApplication.run(SleuthServerApplication.class,args);
    }
}

　　application.properties配置：

spring.application.name=sleuthServer
server.port=9966

　　至於service2，配置和service1一樣，就是Application裏面增加了servcie2 rest接口：

@SpringBootApplication
public class SleuthClientApplication {
     
    public static void main(String[] args) {
        SpringApplication.run(SleuthClientApplication.class, args);
    }
}
 
@RestController
class HiController {
 
    private static final Log log = LogFactory.getLog(HiController.class);
 
    @RequestMapping("/service2")
    public String hi() throws Exception {
        log.info("service2");
        Thread.sleep(100L);
        return "service2";
    }
}  

　　運行後，訪問service1，再按照zipkin server配置的端口打開zipkin server的監控頁面，運行結果如下：

　　點開某一個請求後，會看到詳細的調用鏈請求信息：

點開調用鏈的某個請求可以看更詳細的請求信息：

　　上圖所示，依次是：

　　Sleuthservcie1 Client Send：service1發起請求service2的時間戳。

　　Sleuthservcie2 Server Receive：service2收到請求的時間戳。

　　Sleuthservcie2 Server Send：service2處理完發送結果時間戳。

　　Sleuthservcie1 Client Receive：service1收到結果的時間戳。

　　圖中最上方就是這個請求所用的總的時間，各個環節的處理請求時間一目了然。

　　如果是生產環境，一般需要用到第二套方案。就是先把日誌發送到消息隊列，然後再由zipkin接受，zipkin接收後保存日誌到數據庫。具體的配置也很簡單，要註意的地方就是spring 官方的例子找不到消息中間件的具體配置，可能是在某個地方有默認，筆者還是自己配置了一下：

　　spring.sleuth.sampler.percentage=1.0

　　spring.rabbitmq.host=127.0.0.1

　　spring.rabbitmq.port=5672

　　spring.rabbitmq.username=guest

　　spring.rabbitmq.password=guest

　　spring.rabbitmq.virtualHost=/

　　消息隊列只需要配置上就會自動創建隊列。數據庫配置也是如此，其官方例子中也有，只需配置上就會自動建表。

　　spring.datasource.schema=classpath:/mysql.sql

　　spring.datasource.url=jdbc:mysql://${MYSQL_HOST:localhost}:3306/test

　　spring.datasource.username=root

　　spring.datasource.password=123

　　spring.datasource.initialize=true

　　spring.datasource.continueOnError=true

　　spring.sleuth.enabled=false

　　zipkin.storage.type=mysql

　　具體參照源碼，源碼在老地方：https://git.oschina.net/zhou666/spring-cloud-7simple

Spring Sleuth和Zipkin跟蹤微服務