1.前言

在上一篇spring-cloud-sleuth+zipkin追蹤服務實現(二)中我們講述了利用mq的方式傳送資料，儲存在mysql，實際生產過程中呼叫資料量非常的大，mysql儲存並不是很好的選擇，這時我們可以採用elasticsearch進行儲存。
我們還是使用之前上一節中的三個程式做修改，方便大家看到對比不同點。這裡每個專案名都加了一個es，用來表示區別。

2.使用前提

這裡選用elasticsearch 2.x版本。
安裝elasticsearch的方法詳見本人的文章elk搭建實戰中elasticsearch部分。

3、microservice-zipkin-stream-server-es

要使用elasticsearch的話，必須在pom.xml中宣告相關的依賴。同時不使用mysql，那麼去掉mysql相關的依賴。

全部maven依賴如下：

```
   <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
    <!--zipkin依賴-->
    <!--此依賴會自動引入spring-cloud-sleuth-stream並且引入zipkin的依賴包-->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-sleuth-zipkin-stream</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
    </dependency>

    <dependency>
        <groupId>io.zipkin.java</groupId>
        <artifactId>zipkin-autoconfigure-ui</artifactId>
        <scope>runtime</scope>
    </dependency>


    <dependency>
        <groupId>io.zipkin.java</groupId>
        <artifactId>zipkin</artifactId>
        <version>1.24.0</version>
    </dependency>

    <!--儲存到資料庫需要如下依賴-->
    <!-- 新增 spring-data-elasticsearch的依賴 -->
    <dependency>
        <groupId>io.zipkin.java</groupId>
        <artifactId>zipkin-autoconfigure-storage-elasticsearch-http</artifactId>
        <version>1.24.0</version>
        <optional>true</optional>
    </dependency>     
```
 

由於使用了訊息中介軟體rabbit mq以及elasticsearch，所以我們還需要在配置檔案application.properties加入相關的配置：

 server.port=11030
spring.application.name=microservice-zipkin-stream-server-es
#zipkin資料儲存到資料庫中需要進行如下配置
#表示當前程式不使用sleuth
spring.sleuth.enabled=false
#表示zipkin資料儲存方式是elasticsearch
zipkin.storage.StorageComponent = elasticsearch
zipkin.storage.type=elasticsearch


zipkin.storage.elasticsearch.cluster=elasticsearch-zipkin-cluster
zipkin.storage.elasticsearch.hosts=127.0.0.1:9300
# zipkin.storage.elasticsearch.pipeline=
zipkin.storage.elasticsearch.max-requests=64
zipkin.storage.elasticsearch.index=zipkin
zipkin.storage.elasticsearch.index-shards=5
zipkin.storage.elasticsearch.index-replicas=1



#rabbitmq配置
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
 

為了避免http通訊的干擾，我們將原來的監聽埠有11020更改為11030，啟動程式，未報錯且能夠看到rabbit連線日誌，說明程式啟動成功。

4.microservice-zipkin-stream-client-es、microservice-zipkin-client-stream-backend-es

與上一節中的程式碼保持一致，當然為了以示區別，埠也做了相應的調整

5.測試

6.專案原始碼：

6.參考文件：