文章目錄

• • 樂優項目SpringCloud筆記總結
  • 注冊中心Eureka，ly-registry服務端
  • Feign實現遠程調用
  • Ribbon負載均衡
  • Hystrix熔斷器
  • zuul網關

樂優項目SpringCloud筆記總結

ly-item 商品的的mapper模塊，里面有datasource

ly-cart: 購物車模塊

ly-registry: 注冊中心服務端,其他的模塊都是客戶端

ly-api-gateway: 路由網關

ly-feign:遠程調用

注冊中心Eureka，ly-registry服務端

lyregistry這個Module作為服務端

服務端可以進行配置

server:port: 10086spring:application:name: ly-registryeureka:client:fetch-registry: falseregister-with-eureka: falseservice-url:defaultZone: http://localhost:${server.port}/eurekaserver:enable-self-preservation: false #關閉自我保護eviction-interval-timer-in-ms: 5000 #每隔5秒進行一次服務列表清理 package com.yunhe;import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;@SpringBootApplication @EnableEurekaServer public class LyRegistry {public static void main(String[] args) {SpringApplication.run(LyRegistry.class,args);} }

使用ly-user作為客戶端進行相關的測試：

package com.yunhe;import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; import org.springframework.cloud.openfeign.EnableFeignClients;@SpringBootApplication @EnableDiscoveryClient @EnableFeignClients //開啟feign功能 public class LyUserApplication {public static void main(String[] args) {SpringApplication.run(LyUserApplication.class,args);} }

加入相關的客戶端實現的依賴：

<!--eureka client--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId><version>2.0.0.RELEASE</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!--feign實現遠程調用 ly-item--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId><version>2.0.0.RELEASE</version></dependency><dependency><groupId>javax.persistence</groupId><artifactId>persistence-api</artifactId><version>1.0</version></dependency>

客戶端的配置

server:port: 10010spring:application:name: item-servicedatasource:url: jdbc:mysql://localhost:3306/leyou?characterEncoding=UTF-8&useSSL=falseusername: rootpassword: roothouzhiconghikari:maximum-pool-size: 30minimum-idle: 10eureka:client:service-url:defaultZone: http://127.0.0.1:10086/eurekainstance:lease-renewal-interval-in-seconds: 5 #每隔6秒發送一次心跳lease-expiration-duration-in-seconds: 10 #10秒不發送就過期prefer-ip-address: trueip-address: 127.0.0.1instance-id: ${spring.application.name}:${server.port}# 對Ribbon進行配置 item-service: #feign里面負載均衡配置ribbon:ConnectTimeout: 250 # Ribbon的連接超時時間ReadTimeout: 3000 # Ribbon的數據讀取超時時間OkToRetryOnAllOperations: true # 是否對所有操作都進行重試MaxAutoRetriesNextServer: 1 # 切換實例的重試次數MaxAutoRetries: 1 # 對當前實例的重試次數feign:hystrix:enabled: true # 開啟Feign的熔斷功能,默認為關閉

Feign實現遠程調用

ly-user這個模塊調用ly-item

在ly-user的pom.xml文件加入feign的依賴

在ly-user的LyApplication 啟動類上加入**@EnableFeignClients**注解

在client客戶端下面創建一個itemClient接口

@RequestMapping("brand")

加上這個前端要用的請求的路徑。

加入Service這個接口中的定義的相關的方法。

前面加上**@FeignClient(name=“item-service”)** (item-service是這個ly-item這個模塊里面的spring.application.name=item-service)

由于還沒有進行優化，我們可以先把pojo類全部復制粘貼過來

建立一個BrandController進行前端的測試，輸入這個測試類的請求就好

itemClient:

package com.yunhe.client;import com.yunhe.pojo.Brand; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.web.bind.annotation.*;import java.util.List;//注意：類上面不要寫@RequestMapping @FeignClient(name = "item-service",fallback = ItemClientFallback.class) public interface ItemClient {@GetMapping("brand")public List<Brand> listAll();} @RestController public class UserController {@Autowiredprivate ItemClient itemClient;@GetMappingpublic List<Brand> queryAllBrands(){return itemClient.listAll();} }

Ribbon負載均衡

可以知道feign和Eureka,zuul中已經自帶了ribbon和Hystrix,所以不用引入依賴.

Hystrix熔斷器

feign里面自帶熔斷器，但是默認是關閉狀態的，需要手動開啟

使ly-user模塊調用ly-item模塊，需要feign和hystrix,進行hystrix步驟：

yml文件加上：

feign:hystrix:enabled: true #開啟熔斷器

創建client包然后進行創建下面的類： //注意：類上面不要寫@RequestMapping ,這里的@GetMapping(“brand”)和ly-item里面的controller測試的請求一樣。

package com.yunhe.client;import com.yunhe.pojo.Brand; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.web.bind.annotation.*;import java.util.List;//注意：類上面不要寫@RequestMapping @FeignClient(name = "item-service",fallback = ItemClientFallback.class) public interface ItemClient {@GetMapping("brand")public List<Brand> listAll();}

創建 ItemClientFallback實現類： ly-item的服務斷了不會影響ItemClientFallback方法的執行

package com.yunhe.client;import com.yunhe.client.ItemClient; import com.yunhe.pojo.Brand; import org.springframework.stereotype.Component; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping;import java.util.List;@Component public class ItemClientFallback implements ItemClient {@Override@GetMapping("brand")public List<Brand> listAll() {System.out.println("服務斷了，嗚嗚嗚嗚。。。");return null;} }

zuul網關

創建一個單獨的模塊ly-api-gateway,所有的端口號會經過zuul處理。

當然其他的所有模塊都是注冊中心的客戶端，需要加上**@EnableDiscoveryClient,在主配置文件上面**

**引入網關的依賴,**也需要引入eureka客戶端的依賴

<!--zuul網關--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-zuul</artifactId><version>2.0.0.RELEASE</version></dependency><!--eureka client--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId><version>2.0.0.RELEASE</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency>

啟動類上面 加上**@EnableZuulProxy** 網關代理注解

在ly-api-gateway的application.yml文件中配置網關，注意一下:routes 下面的 item-service是配置文件中的spring.application.name 的名字

zuul:prefix: /api #添加路由前綴retryable: trueroutes:item-service: /item/** #商品服務user-service: /user/** #用戶微服務cart-service: /cart/** #購物車服務

網關的所有的配置文件信息

server:port: 10000spring:application:name: api-gatewayeureka:client:service-url:defaultZone: http://127.0.0.1:10086/eurekainstance:lease-renewal-interval-in-seconds: 5 #每隔6秒發送一次心跳lease-expiration-duration-in-seconds: 10 #10秒不發送就過期prefer-ip-address: trueip-address: 127.0.0.1instance-id: ${spring.application.name}:${server.port} zuul:prefix: /api # 添加路由前綴retryable: true #當網關沒有連接上來的時候是否可以重試routes:item-service: /item/** #商品微服務 /item下的所有的請求user-service: /user/** #用戶微服務cart-service: /cart/** #購物車微服務ribbon:ConnectTimeout: 60000 # 連接超時時間(ms)ReadTimeout: 60000 # 通信超時時間(ms)OkToRetryOnAllOperations: true # 是否對所有操作重試MaxAutoRetriesNextServer: 1 # 同一服務不同實例的重試次數MaxAutoRetries: 1 # 同一實例的重試次數 hystrix:command:default:execution:isolation:thread:timeoutInMillisecond: 10000 # 熔斷超時時長：10000ms

通過網關進行訪問ly-item里面的增刪改查的操作。

http://localhost:10000/api/item/brand 和 不用網關訪問的效果一樣 http://localhost:10010/brand

zuul自帶hystrix和Ribbon功能，需要我們通過配置文件開啟

網關可以進行過濾的配置

package com.yunhe.filter;import com.netflix.zuul.ZuulFilter; import com.netflix.zuul.exception.ZuulException; import org.springframework.stereotype.Component; //注意一下需要加上這個@Component組件 @Component public class LoginFilter extends ZuulFilter{/*** - pre：請求在被路由之前執行* - routing：在路由請求時調用* - post：在routing和errror過濾器之后調用* - error：處理請求時發生錯誤調用* @return*/@Overridepublic String filterType() {return "pre";}//數字越小優先級越高@Overridepublic int filterOrder() {return 1;}//是否進行過濾 true 過濾 false 不進行過濾@Overridepublic boolean shouldFilter() {return true;}//run() 過濾的方法@Overridepublic Object run() throws ZuulException {System.out.println("zuul filter執行了。。。。。");return null;} }

總結

以上是生活随笔為你收集整理的SpringCloud的五大核心组件李俊老师的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。