目前架構

可以看到我們下面 服務好像有固定的資料庫可能是集群或是什麼 在前面的學習好像沒看到更複雜的呼叫，分布式很多問題，像是數據不同步，光是鎖就有一大堆，就以認證中心設計成微服務的話， 資料庫就會變成多個，這樣就不能判斷你到底是到底在哪一台呼叫，而出現你有雙重的登入資料快取在分散的資料庫解決方式可能有 一 分布式鎖 二共用同一個資料庫 這部分先以後有空再弄，目前就是先拓展為多層呼叫，今天是來實現多層的話服務溝通使用 restemplate 去溝通。

分析

我們把服務擴展為兩層一下 也就是我們要關注的

好吧開始 目前我們的 service 已經有 5個 我們要來 新增了 2 個 也就是模擬第四層 一個是 EurekaServiceFeignConsumer2 EurekaServiceFeignProvider3 其中兩個各別都是從 也就是模擬第三層 EurekaServiceFeignProvider EurekaServiceFeignConsumer 複製出來 來看一下程式碼 那麼我們原本的服務會變怎樣呢 EurekaServiceFeignProvider1 EurekaServiceFeignProvider2 要呼叫我們的 EurekaServiceFeignProvider3 所以呼叫順序就是 Zuul - > Consumer1 - > Provider1 or Provider2 -> Consumer2 > Provider3 所以先針對我們的 Consumer1 來修改

多層服務的呼叫方式

呼叫服務三 但是要取得服務四 的 response 才算呼叫完成 那就變成 要完成server3 呼叫就要 server3 -> server 4 多經過一層 server 4 這樣的話 可能會覺得我那就用我們上次 doget doposs 這兩種方法就好了那有沒有更優雅的方式呢有的歐， spring 幫我們把這些東西再往上封裝了一層也就是 restemplate (如果你想用到更複雜的呼叫你就自己從底層慢慢研究了)

Consumer1 Controller

我們新增了

code
@GetMapping("/helloEX/{id}/{id2}") public String helloEX(@PathVariable(name="id") Integer employeeId,@PathVariable(name="id2") Integer employeeId2) { System.out.print(employeeId2); String message = homeClient.home2(employeeId,employeeId2); logger.info("[eureka-fegin][ConsumerController][hello], message={}", message); // log.info("[eureka-ribbon][EurekaRibbonConntroller][syaHello], message={}", message); return message ;

好了之後 我們要看要呼叫哪一層就是我們的

Consumer1 homeClient

code
@GetMapping("/ep1") public String home2(@RequestParam (value="id", required = false) Integer employeeId,@RequestParam (value="id2", required = false) Integer employeeId2) ;

Provider 1 or 2

這邊就要稍微用到前面的技巧了 我們知道有 resttemplete 有可以去跟我們 Eureka 去要我們已經註冊的節點的伺服器名字 整體呼叫在最下面 https://openhome.cc/Gossip/Spring/RestTemplate.html https://www.jianshu.com/p/462790156554 我們用到比較關鍵的是 預設的 restemplete 是沒有辦法呼叫負載平衡的，有印象的話在前幾天用過 SPRING CLOUD 微服務入門 (三) EUREKA + CONSUMER (FEIGN) 呼叫 SERVICE 在這邊的話我們把 restemplete 注入一個有 loadblance 特性 https://blog.csdn.net/qq_18416057/article/details/79432504 這邊說的蠻清楚的 不過少了一些東西

code
@LoadBalanced @Bean RestTemplate restTemplate() { return new RestTemplate(); } @Autowired private RestTemplate restTemplate;

總而言之就是讓我們的 restemplete有可以 去 訪問 Eureka 的能力

配置 provider

application.yml

code
eureka: client: serviceUrl: defaultZone: http://localhost:8761/eureka/ register-with-eureka : true <====就是這行 讓我們的 的 服務可以去請求其他已經註冊的伺服器

那麼現在我們的 restemplete loadblance 特性

細看 Provider

這邊要注意要跟我們的 Consumer1 homeClient 裡面的 method 相對應，這邊可以看到我們對伺服器的 ip已經不是像我們之前的在寫註冊中心那樣直接doget dopost 去呼叫，restemplete ,當然也可以用這種方式去呼叫我們的註冊中心，只不過，有空再寫好了這邊做兩個範例。

code
@GetMapping("/ep1") public String home2(@RequestParam (value="id", required = false) final Integer employeeId,@RequestParam (value="id2", required = false) final Integer employeeId2) { final String message = "Hello world" + port+ employeeId+employeeId2; logger.info("[eureka-provide][EurekaServiceProviderApplication][home], message={}", message); // restTemplate = new RestTemplate(); final String fooResourceUrl = "http://feign-consumer2"; final ResponseEntity<String> response = restTemplate.getForEntity( fooResourceUrl + "/hello2/" + employeeId.toString() + "/" + employeeId2.toString(), String.class); //assertThat(response.getStatusCode(), equalTo(HttpStatus.OK)); System.out.println(response.getStatusCode().toString()+(HttpStatus.OK).toString()); System.out.println(response.getBody()+"test"); return response.getBody(); }

好了之後複製到 Provider2 兩個 Controller 一樣。

Provider3 Controller

反正 他是複製 Provider 我們直接看原始碼 這邊很簡單沒做什麼我們看 Consumer2

code
@GetMapping("/ep2") public String home(@RequestParam (value="id", required = false) Integer employeeId,@RequestParam (value="id2", required = false) Integer employeeId2) { String message = "Hello world" + port+ employeeId+employeeId2; logger.info("[eureka-provide2][EurekaServiceProviderApplication][home], message={}", message); return message; }

Provider 3 設定檔

記得換為 eureka-provider2，以便讓我們的 Consumer2 可以呼叫到

code
name: eureka-provider2

Consumer2 Controller

注意看 Url這邊可以看到 我們沒有再讓往Zuul 去訪問我們的 consumer2 了 因為我們是讓 Provider 去直接 呼叫 我們的 consumer2 , 可以注意 url 的呼叫 address 裡面的 hello2

code
@RestController public class ConsumerController { private final Logger logger = LoggerFactory.getLogger(ConsumerController.class); @Autowired private HomeClient homeClient; @GetMapping("/hello2/{id}/{id2}") public String hello(@PathVariable(name="id") Integer employeeId,@PathVariable(name="id2") Integer employeeId2) { System.out.print(employeeId2); String message = homeClient.home(employeeId,employeeId2); logger.info("[eureka-fegin2][ConsumerController][hello], message={}", message); // log.info("[eureka-ribbon][EurekaRibbonConntroller][syaHello], message={}", message); return message ; } }

Consumer2 homeClient

可以注意我們的 這邊就是填 Provider3 註冊到 Eureka的名字 也就是 eureka-provider2

code
@FeignClient(value ="eureka-provider2",fallbackFactory=HystrixClientFallbackFactory.class) public interface HomeClient { @GetMapping("/ep2") public String home(@RequestParam (value="id", required = false) Integer employeeId,@RequestParam (value="id2", required = false) Integer employeeId2) ; }

好了都沒問題的話 就 啟動 吧!

啟動

前面步驟就不說了 可以看到我訪問的是 helloEx

code
http://localhost:9000/feign-consumer/helloEX/1/12?token=Bearer%20eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJleHAiOjE1Nzc5MTUxNTksInVzZXJuYW1lIjoiamFjayJ9.UMUZWzh_ZTkhKxoSBfglSualToOTn9dm-WE9D3_huT4

這邊會覺得，有沒有更視覺化的東西可以看阿 別忘了我們的 Zipkin 就是在做這些事，我們打開 花了點時間 我把 zipkin 弄進去 docker-compose了，請注意 zipkin 啟動順序有差

code
version: '2' services: elasticsearch: build: context: elasticsearch/ volumes: - ./elasticsearch/config/elasticsearch.yml:/usr/share/elasticsearch/config/elasticsearch.yml:ro ports: - "9200:9200" - "9300:9300" environment: ES_JAVA_OPTS: "-Xmx256m -Xms256m" networks: - elk logstash: build: context: logstash/ volumes: - ./logstash/config/logstash.yml:/usr/share/logstash/config/logstash.yml:ro - ./logstash/pipeline:/usr/share/logstash/pipeline:ro ports: - "5000:5000" environment: LS_JAVA_OPTS: "-Xmx256m -Xms256m" networks: - elk depends_on: - elasticsearch kibana: build: context: kibana/ volumes: - ./kibana/config/:/usr/share/kibana/config:ro ports: - "5601:5601" networks: - elk depends_on: - elasticsearch rabbitmq : build: context: rabbitmq / volumes: - ./rabbitmq/config/:/usr/share/rabbitmq/config:ro ports: - "5672:5672" - "15672:15672" networks: - elk depends_on: - elasticsearch zipkin: build: context: zipkin / volumes: - ./zipkin/config/:/usr/share/zipkin/config:ro # Environment settings are defined here https://github.com/openzipkin/zipkin/tree/1.19.0/zipkin-server#environment-variables environment: - RABBIT_ADDRESSES=192.168.99.100:5672 - RABBIT_USER=guest - RABBIT_PASSWORD=guest - RABBIT_QUEUE=zipkin - SELF_TRACING_ENABLED=false #- RABBIT_VIRTUAL_HOST=/admin_host - JAVA_OPTS=-Dlogging.level.zipkin #=DEBUG -Dlogging.level.zipkin2=DEBUG ports: # Port used for the Zipkin UI and HTTP Api - "9411:9411" # Uncomment if you set SCRIBE_ENABLED=true # - 9410:9410 networks: - elk depends_on: - elasticsearch networks: elk: driver: bridge

應該每次初次啟動 zipkin都會找不到 rabbitmq 而退出

code
docker start "zipkin name"

服務啟動 好了之後 我們的追蹤鏈也很清楚