SpringCloud微服務
架構演進
單體架構
垂直拆分
分散式SOA面向服務架構
微服務架構
服務呼叫方式：
RPC，早期的webservice，現在熱門的dubbo，都是RPC的典型代表
HTTP，HttpClient，OKHttp，URLConnection，RestTemplate
Euraka服務註冊中心
註冊中心
新增依賴
使用
@EnableEurekaServer
註解開啟註冊服務
@SpringBootApplication@EnableEurekaServerpublic class EurekaServerApplication { public static void main（String［］ args） { SpringApplication。run（EurekaServerApplication。class， args）； }}
編寫配置檔案application。yml
server： port： 8761eureka： instance： hostname： localhost client： registerWithEureka： false fetchRegistry： false serviceUrl： defaultZone： http：//${eureka。instance。hostname}：${server。port}/eureka/ #是否將自己註冊到Eureka服務中，預設為true（由於當前就是eureka服務，固設定為false） registerWithEureka： false #設定是否從eureka服務上獲取註冊資訊，預設為true（由於當前就是eureka服務，固設定為false） fetchRegistry： false server： # 是否開啟自我保護模式（自我保護模式，當eureka在一定時間內沒有接受到某個微服務例項的心跳包，預設90S會登出該例項）， # 一旦進入自我保護模式，若短時間內丟失大量客戶端，eureka也會保護登錄檔的資訊，不再登出 enable-self-preservation： false # 清理間隔。預設為60000ms eviction-interval-timer-in-ms： 5000
服務提供者（服務註冊）
新增依賴
<！—— Eureka客戶端 ——> 2。新增 @EnableDiscoveryClient 來開啟Eureka客戶端功能 @SpringBootApplication@EnableDiscoveryClientpublic class SpringDemoApplication { public static void main（String［］ args） { SpringApplication。run（SpringDemoApplication。class， args）； }} 3。編寫配置檔案 eureka： instance： #在呼叫服務的時候就已經變成ip地址；需要注意的是：不是在eureka中的控制檯服務例項狀態顯示。 ip-address： 127。0。0。1 prefer-ip-address： true #使用ip註冊 client： # 是否開啟健康檢查 healthcheck： enabled： true # 叢集url service-url： defaultZone： http：//127。0。0。1：8761/eureka 服務消費者（服務發現） 消費應用從註冊中心獲取服務列表，從而得知每個服務方的資訊，知道去哪裡呼叫服務方 服務續約 在註冊服務完成以後，服務提供者會維持一個心跳（定時向EurekaServer發起Rest請求），有兩個重要引數可以修改服務續約的行為 eureka： instance： #服務失效時間，預設值90秒 lease-expiration-duration-in-seconds： 90 #服務續約（renew）的間隔，預設為30秒 lease-renewal-interval-in-seconds： 30 也就是說，預設情況下每隔30秒服務會向註冊中心傳送一次心跳，證明自己還活著。如果超過90秒沒有傳送心跳，EurekaServer就會認為該服務宕機，會定時（eureka。server。eviction-interval-timer-in-ms設定的時間）從服務列表中剔除 失效剔除和自我保護 服務註冊中心在啟動時會建立一個定時任務，預設每隔一段時間（預設為60秒）將當前清單中超時（預設為90秒）沒有續約的服務剔除。 Eureka Server在執行期間，會統計心跳失敗的比例在15分鐘之內是否低於85%，如果出現低於的情況，Eureka Server會將當前的例項註冊資訊保護起來，不再刪除服務登錄檔中的資料（也就是不會登出任何微服務） Consul 特性 高效的Raft一致性演算法 支援多資料中心 支援健康檢查 HTTP和DNS支援 Consul和Eureka的區別： Consul強一致性（CP），Eureka保證高可用和最終一致性（AP） Consul使用Go語言，Eureka使用Java語言 Consul 不同於 Eureka 需要單獨安裝，官網：https：//www。consul。io/downloads Consul架構圖 Consul基本使用 服務提供者 pom。xml新增依賴 <！——SpringCloud提供的基於Consul的服務發現——> 透過@EnableDiscoveryClient註解開啟對服務發現的支援 編寫配置檔案application。yml spring： application： name： consul-provider ####consul註冊中心地址 cloud： consul： host： localhost port： 8500 discovery： service-name： ${spring。application。name} #註冊中心名字與spring的應用名稱一致 #——————————————-相關配置——————————————| #是否註冊 register： true #例項ID instance-id： ${spring。application。name}-1 #服務例項名稱 service-name： ${spring。application。name} #服務例項埠 port： ${server。port} #健康檢查路徑 healthCheckPath： /actuator/health #健康檢查時間間隔 healthCheckInterval： 15s #開啟ip地址註冊 prefer-ip-address： true #例項的請求ip ip-address： ${spring。cloud。client。ip-address} 服務消費者 pom。xml新增依賴 編寫配置檔案application。yml spring： application： name： consul-provider ####consul註冊中心地址 cloud： consul： host： localhost port： 8500 discovery： #設定不需要註冊到Consul中 register： false 負載均衡Ribbon Ribbon是 Netflix 釋出的一個負載均衡器，有助於控制 HTTP 和 TCP客戶端行為。Ribbon自動的從註冊中心中獲取服務提供者的 列表資訊，並基於內建的負載均衡演算法，請求服務。 搭建過程 啟動兩個服務例項 先編寫請求的介面 @Value（“${spring。cloud。client。ip-address}”）private String ip；@Value（“${server。port}”）private String port；@ResponseBody@RequestMapping（value = “backInfo”， method = RequestMethod。GET）public String backInfo（） { return “呼叫的是” + ip + “埠是：” + port；} 我們假設搭建兩臺服務提供者，埠分別為：8090和8091，將已有服務的配置更改為 server： #的${}表示在jvm啟動時候若能找到對應port則使用，若無則使用後面的預設值 port： ${port：8090} 另外一臺在啟動的時候可以指定埠port，在如下介面中的 VM options 中設定 -Dport=10087 啟動負載均衡 因為Eureka中已經集成了Ribbon，所以我們無需引入新的依賴。直接修改 消費者 的啟動類 @Bean@LoadBalancedpublic RestTemplate restTemplate（） { return new RestTemplate（）；} 調取服務提供者介面，頁面進行測試，可以分別請求到8090和8091兩個埠 @Autowiredprivate RestTemplate restTemplate；@ResponseBody@RequestMapping（value = “getIpAndPort”， method = RequestMethod。GET）public String printInfo（） { String url = “http：//springbootdemo/backInfo”； return restTemplate。getForObject（url， String。class）；} 負載均衡策略 Ribbon預設的負載均衡策略是輪詢，Ribbon內建了多種負載均衡策略 修改負載均衡規則的配置： springbootdemo： ribbon： NFLoadBalancerRuleClassName： com。netflix。loadbalancer。RandomRule #格式是： {服務名稱}。ribbon。NFLoadBalancerRuleClassName com。netflix。loadbalancer。RoundRobinRule ：以輪詢的方式進行負載均衡。 com。netflix。loadbalancer。RandomRule ：隨機策略 com。netflix。loadbalancer。RetryRule ：重試策略 com。netflix。loadbalancer。WeightedResponseTimeRule ：權重策略 com。netflix。loadbalancer。BestAvailableRule ：最佳策略 com。netflix。loadbalancer。AvailabilityFilteringRule ：可用過濾策略 策略選擇： 如果每個機器配置一樣，則建議不修改策略 （推薦） 如果部分機器配置強，則可以改為 WeightedResponseTimeRule 原始碼跟蹤 RibbonAutoConfifiguration->LoadBalancerAutoConfiguration->LoadBalancerInterceptor 服務呼叫Feign Feign是一種宣告式、模板化的HTTP客戶端。 基於Feign的服務呼叫 1。在消費者引入依賴 2。啟動類開啟feign支援 @SpringBootApplication@EnableDiscoveryClient@ComponentScan（basePackages = “com。jyd0124。consume_server。*”）@EnableFeignClientspublic class ConsumeServerApplication { public static void main（String［］ args） { SpringApplication。run（ConsumeServerApplication。class， args）； } @Bean @LoadBalanced public RestTemplate returnBean（） { return new RestTemplate（）； }} 3。建立介面和定義需要遠端呼叫的方法 @FeignClient（“springbootdemo”）public interface SpringBootFeign { @RequestMapping（value = “/person”， method = RequestMethod。GET） public Map 4。呼叫服務。 @Autowiredprivate SpringBootFeign springBootFeign； @ResponseBody@RequestMapping（value = “/person/{id}”， method = RequestMethod。GET）public Map 5。訪問，測試結果 負載均衡 Feign中本身已經集成了Ribbon依賴和自動配置，因此我們不需要額外引入依賴，也不需要再註冊RestTemplate 物件，可以透過 ribbon。xx 來進行全域性配置。也可以透過 服務名.ribbon.xx 來對指定服務配置。 Feign的配置 feign： client： config： feignName： ##定義FeginClient的名稱 connectTimeout： 5000 # 建立連結的超時時長 readTimeout： 5000 # 讀取超時時長 # 配置Feign的日誌級別，相當於程式碼配置方式中的Logger loggerLevel： full # Feign的錯誤解碼器，相當於程式碼配置方式中的ErrorDecoder errorDecoder： com。example。SimpleErrorDecoder # 配置重試，相當於程式碼配置方式中的Retryer retryer： com。example。SimpleRetryer # 配置攔截器，相當於程式碼配置方式中的 RequestInterceptor requestInterceptors： - com。example。FooRequestInterceptor - com。example。BarRequestInterceptor #配置熔斷不處理404異常 decode404： false 請求壓縮： 支援對請求和響應進行GZIP壓縮，以減少通訊過程中的效能損耗 #請求壓縮feign： compression： request： enabled： true # 開啟請求壓縮 response： enabled： true # 開啟響應壓縮 Hystrix支援 Feign預設也有對Hystrix的整合 feign： hystrix： enabled： true # 開啟Feign的熔斷功能 日誌級別 預設情況下Feign的日誌是沒有開啟的。 feign： client： config： feignName： loggerLevel： full #NONE【效能最佳，適用於生產】：不記錄任何日誌（預設值） #BASIC【適用於生產環境追蹤問題】：僅記錄請求方法、URL、響應狀態程式碼以及執行時間 #HEADERS：記錄BASIC級別的基礎上，記錄請求和響應的header。 #FULL【比較適用於開發及測試環境定位問題】：記錄請求和響應的header、body和元資料 熔斷器Hystrix 雪崩效應 在微服務架構中，根據業務來拆分成一個個的服務，服務與服務之間可以相互呼叫（RPC），在Spring Cloud可以用RestTemplate+Ribbon和Feign來呼叫。為了保證其高可用，單個服務通常會叢集部署。由於網路原因或者自身的原因，服務並不能保證100%可用，如果單個服務出現問題，呼叫這個服務就會出現執行緒阻塞，此時若有大量的請求湧入，Servlet容器的執行緒資源會被消耗完畢，導致服務癱瘓。服務與服務之間的依賴性，故障會傳播，會對整個微服務系統造成災難性的嚴重後果，這就是服務故障的“雪崩”效應。 Hystrix的特性 服務熔斷 Hystrix的熔斷狀態機模型： hystrix： command： default： execution。isolation。thread。timeoutInMilliseconds： 2000 circuitBreaker： errorThresholdPercentage： 50 # 觸發熔斷錯誤比例閾值，預設值50% sleepWindowInMilliseconds： 10000 # 熔斷後休眠時長，預設值5秒 requestVolumeThreshold： 10 # 觸發熔斷的最小請求次數，預設20 #配置項可以參考 HystrixCommandProperties 類 服務降級 透過HystrixdeCommand的fallback實現服務降級。 服務隔離 -執行緒池隔離策略 - 訊號量隔離策略 Ribbon中使用斷路器 在pom。xml中新增依賴 在啟動類上添加註解開啟Hystrix @SpringBootApplication@EnableDiscoveryClient@EnableHystrixpublic class ConsumeServerApplication { public static void main（String［］ args） { SpringApplication。run（ConsumeServerApplication。class， args）； } @Bean @LoadBalanced public RestTemplate returnBean（） { return new RestTemplate（）； }} 編寫熔斷降級邏輯。在方法上加上@HystrixCommand註解，並指定了fallbackMethod熔斷方法 @ResponseBody@RequestMapping（value = “/info”， method = RequestMethod。GET）@HystrixCommand（fallbackMethod = “backErrorInfo”）public String printInfo（） { String url = “http：//springbootdemo/backInfo”； return restTemplate。getForObject（url， String。class）；}public String backErrorInfo（）{ return “sorry，error”；} 測試，如果springbootdemo服務關閉，會發現頁面返回了降級處理資訊 Feign中使用斷路器 SpringCloud Fegin預設已為Feign整合了hystrix 新增配置 feign： hystrix： enabled： true # 開啟Feign的熔斷功能 配置FeignClient介面的實現類，並透過@Component注入到Ioc容器中 @Componentpublic class HystrixMethod implements SpringBootFeign { @Override public Map 在@FeignClient註解中新增降級方法 @FeignClient（name = “springbootdemo”， fallback = HystrixMethod。class）public interface SpringBootFeign { @RequestMapping（value = “/person”， method = RequestMethod。GET） public Map 關閉 springbootdemo 服務，訪問測試 Hystrix Dashboard 新增依賴 在啟動類使用@EnableHystrixDashboard註解啟用儀表盤 @SpringBootApplication@EnableDiscoveryClient@EnableHystrix@EnableHystrixDashboardpublic class ConsumeServerApplication { public static void main（String［］ args） { SpringApplication。run（ConsumeServerApplication。class， args）； } @Bean @LoadBalanced public RestTemplate returnBean（） { return new RestTemplate（）； }} 訪問頁面 遇到問題：https：//blog。csdn。net/ghyghost/article/details/108053206 斷路器聚合監控Turbine，Turbine是一個聚合Hystrix 監控資料的工具。 閘道器Gateway 介紹 Spring Cloud Gateway 是 Spring 官方基於 Spring 5。0，Spring Boot 2。0 和 Project Reactor 等技術開發的閘道器，旨在為微服務架構提供一種簡單而有效的統一的 API 路由管理方式。Spring Cloud Gateway 作為 Spring Cloud 生態系中的閘道器，目標是替代 Netflflix ZUUL，其不僅提供統一的路由方式，並且基於 Filter 鏈的方式提供了閘道器基本的功能，例如：安全，監控/埋點，和限流等。 快速入門 建立gateway-server模組，引入依賴 編寫啟動類 @SpringBootApplication@EnableDiscoveryClientpublic class GatewayServerApplication { public static void main（String［］ args） { SpringApplication。run（GatewayServerApplication。class， args）； }} 編寫路由規則 server： port： 8765spring： application： # 註冊到eureka上的應用名稱 name： gateway_server cloud： gateway： #由一個ID、一個目的URL、一組斷言工廠、一組Filter組成 routes： # 路由id，可以隨意寫 - id： consume-server-route # 代理的服務地址 uri： http：//127。0。0。1：8081 # 路由斷言，可以配置對映路徑 predicates： - Path=/person/**eureka： client： # 叢集url service-url： defaultZone： http：//127。0。0。1：8761/eureka instance： prefer-ip-address： true #使用ip註冊 ip-address： 127。0。0。1 instance-id： ${spring。cloud。client。ip-address}：${server。port} 啟動測試 路由 新增字首PrefixPath spring： application： # 註冊到eureka上的應用名稱 name： gateway_server cloud： gateway： #由一個ID、一個目的URL、一組斷言工廠、一組Filter組成 routes： # 路由id，可以隨意寫 - id： consume-server-route # 代理的服務地址 uri： http：//127。0。0。1：8081 # 路由斷言，可以配置對映路徑 predicates： - Path=/** filters： # 新增請求路徑的字首 - PrefixPath=/person 相當於PrefixPath=/personhttp：//localhost：8765/180868 ——》http：//localhost：8765/person/180868 ——》http：//localhost：8081/person/180868 去除字首StripPrefifix spring： application： # 註冊到eureka上的應用名稱 name： gateway_server cloud： gateway： #由一個ID、一個目的URL、一組斷言工廠、一組Filter組成 routes： # 路由id，可以隨意寫 - id： consume-server-route # 代理的服務地址 uri： http：//127。0。0。1：8081 # 路由斷言，可以配置對映路徑 predicates： - Path=/api/person/** filters： # 表示過濾1個路徑，2表示兩個路徑，以此類推 - StripPrefix=1 StripPrefix=1 http：//localhost：8765/api/person/180868——》http：//localhost：8765/person/180868——》http：//localhost：8081/person/180868 動態路由 uri以 lb： //開頭（lb代表從註冊中心獲取服務），後面接的就是你需要轉發到的服務名稱 spring： application： # 註冊到eureka上的應用名稱 name： gateway_server cloud： gateway： routes： # 路由id，可以隨意寫 - id： consume-server-route # 代理的服務地址 uri： lb：//springbootdemo # 路由斷言，可以配置對映路徑 predicates： - Path=/person/** 重寫轉發路徑 路由轉發是直接將匹配的路由path直接拼接到對映路徑（URI）之後，那麼往往沒有那麼便利。修改application。yaml spring： application： # 註冊到eureka上的應用名稱 name： gateway_server cloud： gateway： routes： # 路由id，可以隨意寫 - id： consume-server-route # 代理的服務地址 uri： lb：//springbootdemo # 路由斷言，可以配置對映路徑 predicates： - Path=/springbootdemo/** filters： - RewritePath=/springbootdemo/（？ 請求http：//localhost：8765/springbootdemo/person/180868 ——》http：//localhost：8765/person/180868——》http：//localhost：8081/person/180868（ 值得注意的是在yml文件中 $ 要寫成 $\ ） 基於服務發現的路由規則 spring： application： # 註冊到eureka上的應用名稱 name： gateway_server cloud： gateway： discovery： locator： #設定路由訪問方式：http：//Gateway_HOST：Gateway_PORT/大寫的serviceId/**，其中微服務應用名預設大寫訪問。 enabled： true # 該設定可以將服務名改成小寫（預設為大寫） lower-case-service-id： true 這樣，就可以透過http：//localhost：8765/springbootdemo/person？id=180868訪問 過濾器 生命週期 pre：： 這種過濾器在請求被路由之前呼叫。 post ： 這種過濾器在路由到微服務以後執行。 過濾器型別 區域性過濾器（GatewayFilter），應用到單個路由或者一個分組的路由上，透過 spring。cloud。gateway。routes。filters 配置在具體路由下，只作用在當前路由上； 全部過濾器（GlobalFilter），應用到所有的路由上，實現 GlobalFilter 介面即可 常見過濾器 過濾器名稱 說明 AddRequestHeader 對匹配上的請求加上Header AddRequestParameters 對匹配上的請求路由新增引數 AddResponseHeader 對從閘道器返回的響應新增Header StripPrefifix 對匹配上的請求路徑去除字首 配置全域性預設過濾器 spring： cloud： gateway： default-filters： - AddResponseHeader=X-Response-Default-MyName， jyd0124 其他過濾器具體可參考GatewayFilterFactory類 自定義過濾器 需求：模擬一個登入的校驗。基本邏輯：如果請求中有token引數，則認為請求有效，放行。 @Componentpublic class TokenFilter implements GlobalFilter， Ordered { private final Logger logger = LoggerFactory。getLogger（TokenFilter。class）； @Override public Mono 跨域問題 @Configurationpublic class GwCorsFilter { /** * 以下CorsWebFilter跨域處理也可以透過配置檔案進行處理 * spring： * cloud： * gateway： * globalcors： * cors-configurations： */ @Bean public CorsWebFilter corsFilter（） { CorsConfiguration config = new CorsConfiguration（）； config。setAllowCredentials（true）； // 允許cookies跨域 config。addAllowedOrigin（“*”）；// #允許向該伺服器提交請求的URI，*表示全部允許，在SpringMVC中，如果設成*，會自動轉成當前請求頭中的Origin config。addAllowedHeader（“*”）；// #允許訪問的頭資訊，*表示全部 config。setMaxAge（18000L）；// 預檢請求的快取時間（秒），即在這個時間段裡，對於相同的跨域請求不會再預檢了 config。addAllowedMethod（“OPTIONS”）；// 允許提交請求的方法型別，*表示全部允許 config。addAllowedMethod（“HEAD”）； config。addAllowedMethod（“GET”）； config。addAllowedMethod（“PUT”）； config。addAllowedMethod（“POST”）； config。addAllowedMethod（“DELETE”）； config。addAllowedMethod（“PATCH”）； UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource（new PathPatternParser（））； source。registerCorsConfiguration（“/**”， config）； return new CorsWebFilter（source）； } /** * *如果使用了註冊中心（如：Eureka），進行控制則需要增加如下配置 */ @Bean public RouteDefinitionLocator discoveryClientRouteDefinitionLocator（DiscoveryClient discoveryClient） { return new DiscoveryClientRouteDefinitionLocator（discoveryClient，new DiscoveryLocatorProperties（））； } /** * 以下是springboot2。0。5出現only one connection 的解決辦法 * @return */ @Bean public HiddenHttpMethodFilter hiddenHttpMethodFilter（） { return new HiddenHttpMethodFilter（） { @Override public Mono 負載均衡和熔斷 Gateway中預設已經集成了Ribbon負載均衡和Hystrix熔斷機制。但是所有的策略都是走的預設值，建議根據Ribbon和Hystrix手動進行配置。 閘道器限流 計數器限流演算法 漏桶演算法 令牌桶演算法 基於Filter的限流 基於Sentinel的限流 SpringCloud Config配置中心 在gitee上建立遠端配置檔案 構建config配置中心服務 構建Config-server服務，新增依賴 在config-server的啟動類新增@EnableConfigServer @SpringBootApplication@EnableDiscoveryClient@EnableConfigServerpublic class ConfigServerApplication { public static void main（String［］ args） { SpringApplication。run（ConfigServerApplication。class， args）； }} 編寫config-server配置檔案 server： port： 8888spring： application： name： config_server cloud： config： server： git： #配置檔案所在的git倉庫 uri： https：//gitee。com/jyd0124/springcloudconfig。git #配置檔案分支 default-label： master #配置檔案所在根目錄 search-paths： config #如果Git倉庫為公開倉庫，可以不填寫使用者名稱和密碼，如果是私有倉庫需要填寫 username： xxx password： xxxeureka： client： service-url： defaultZone： http：//127。0。0。1：8761/eureka #服務註冊地址 可透過http：//localhost：8888/consume-server。yml測試是否成功 獲取配置中心配置 改造其他隨便一個服務，比如我使用我自己的consume_server，新增依賴 修改配置 刪除consume_server的application。yml 檔案（因為該檔案從配置中心獲取） 建立consume_server 的bootstrap。yml 配置檔案，其內容如下 spring： cloud： config： name： consume-server # 遠端倉庫中的版本保持一致 label： master #profile： dev #透過ip直接訪問配置中心 #uri： http：//localhost：8888/ #透過eurka訪問配置中心 discovery： #配置中心服務 service-id： config-server enabled： trueeureka： client： service-url： defaultZone： http：//127。0。0。1：8761/eureka #服務註冊地址 3。啟動consume_server專案發現獲取到配置檔案將服務暴露在8081埠，測試介面可成功返回資料 補充：bootstrap。yml檔案也是Spring Boot的預設配置檔案，而且其載入的時間相比於application。yml更早。bootstrap。yml檔案相當於專案啟動時的引導檔案，內容相對固定。application。yml檔案是微服務的一些常規配置引數，變化比較頻繁。 Spring Cloud Bus服務匯流排 問題： 前面已經完成了將微服務中的配置檔案集中儲存在遠端Git倉庫，如果我們更新Git倉庫中的配置檔案，那使用者微服務是否可以及時接收到新的配置資訊並更新呢？經過測試，對於Git倉庫中配置檔案的修改並沒有及時更新到使用者微服務，只有重啟使用者微服務才能生效。如果想在不重啟微服務的情況下更新配置該如何實現呢？ 可以使用Spring Cloud Bus來實現配置的自動更新。 介紹 Spring Cloud Bus是用輕量的訊息代理將分散式的節點連線起來，可以用於廣播配置檔案的更改或者服務的監控管理。也就是訊息匯流排可以為微服務做監控，也可以實現應用程式之間相互通訊。 Spring Cloud Bus可選的訊息代理有兩種：RabbitMQ和Kafka。 具體實現可參考：https：//www。fangzhipeng。com/springcloud/2018/08/08/sc-f8-bus。html https：//www。cnblogs。com/babycomeon/p/11141160。html Spring Cloud體系技術綜合應用概覽
