springcloud項目快速開始起始模板的實現(xiàn)
1.創(chuàng)建實體類模塊
引入依賴(這里使用tkmybatis的依賴)
<dependencies> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <version>1.18.20</version> </dependency> <dependency> <groupId>tk.mybatis</groupId> <artifactId>mapper-spring-boot-starter</artifactId> <version>2.0.2</version> </dependency> </dependencies>
效果如下
2.創(chuàng)建配置中心,搭建注冊中心集群
選擇依賴(修改spring cloud版本號)
修改application.yml搭建server集群 此處要注意域名解析peer1,peer2,peer3
server: port: 9004 spring: application: name: euraka-server eureka: client: service-url: #如果是集群,,后面用逗號隔開 defaultZone: http://127.0.0.1:9004/eureka #自己本身就是服務(wù)注冊中心,聲明不注冊自己 register-with-eureka: false #聲明自己不拉取自己的服務(wù)注冊列表 fetch-registry: false instance: # ?跳間隔時間 lease-renewal-interval-in-seconds: 30 # 沒收到?跳多?時間剔除 lease-expiration-duration-in-seconds: 90 server: enable-self-preservation: false # 關(guān)閉?我保護模式(缺省為打開) eviction-interval-timer-in-ms: 1000 # 掃描失效服務(wù)的間隔時間(缺省為60*1000ms) logging: level: com.netflix: warn --- spring: config: activate: on-profile: peer1 server: port: 9003 eureka: instance: hostname: peer1 client: service-url: defaultZone: http://peer2:9004/eureka,http://peer3:9005/eureka --- spring: config: activate: on-profile: peer2 server: port: 9004 eureka: instance: hostname: peer2 client: service-url: defaultZone: http://peer1:9003/eureka,http://peer3:9005/eureka --- spring: config: activate: on-profile: peer3 server: port: 9005 eureka: instance: hostname: peer3 client: service-url: defaultZone: http://peer1:9003/eureka,http://peer2:9004/eureka
啟動器加@EnableEurekaServer注解
3.創(chuàng)建網(wǎng)關(guān)(修改版本號)
?網(wǎng)關(guān)yml配置文件
server: port: 9006 spring: application: name: api-gateway cloud: gateway: routes: - id: service uri: http://127.0.0.1:9001 predicates: - Path=/pay/{segment} filters: - name: CircuitBreaker args: name: backendA fallbackUri: forward:/fallbackA #全部允許跨域訪問 globalcors: cors-configurations: '[/**]': allowed-origin-patterns: "*" # spring boot2.4配置 # allowed-origins: "*" allowed-headers: "*" allow-credentials: true allowed-methods: - GET - POST - DELETE - PUT - OPTION eureka: client: service-url: defaultZone: http://127.0.0.1:9004/eureka #網(wǎng)關(guān)熔斷,快速降級 resilience4j: circuitbreaker: configs: default: failureRateThreshold: 30 #失敗請求百分比,超過這個比例,CircuitBreaker變?yōu)镺PEN狀態(tài) slidingWindowSize: 10 #滑動窗口的大小,配置COUNT_BASED,表示10個請求,配置TIME_BASED表示10秒 minimumNumberOfCalls: 5 #最小請求個數(shù),只有在滑動窗口內(nèi),請求個數(shù)達到這個個數(shù),才會觸發(fā)CircuitBreader對于斷路器的判斷 slidingWindowType: TIME_BASED #滑動窗口的類型 permittedNumberOfCallsInHalfOpenState: 3 #當CircuitBreaker處于HALF_OPEN狀態(tài)的時候,允許通過的請求個數(shù) automaticTransitionFromOpenToHalfOpenEnabled: true #設(shè)置true,表示自動從OPEN變成HALF_OPEN,即使沒有請求過來 waitDurationInOpenState: 2s #從OPEN到HALF_OPEN狀態(tài)需要等待的時間 recordExceptions: #異常名單 - java.lang.Exception instances: backendA: baseConfig: default backendB: failureRateThreshold: 50 slowCallDurationThreshold: 2s #慢調(diào)用時間閾值,高于這個閾值的呼叫視為慢調(diào)用,并增加慢調(diào)用比例。 slowCallRateThreshold: 30 #慢調(diào)用百分比閾值,斷路器把調(diào)用時間大于slowCallDurationThreshold,視為慢調(diào)用,當慢調(diào)用比例大于閾值,斷路器打開,并進行服務(wù)降級 slidingWindowSize: 10 slidingWindowType: TIME_BASED minimumNumberOfCalls: 2 permittedNumberOfCallsInHalfOpenState: 2 waitDurationInOpenState: 120s #從OPEN到HALF_OPEN狀態(tài)需要等待的時間
創(chuàng)建網(wǎng)關(guān)熔斷對應(yīng)降級方法
@RestController @Slf4j public class FallbackController { @GetMapping("/fallbackA") public ResponseEntity fallbackA() { return ResponseEntity.ok("服務(wù)不可用,降級"); } }
啟動器加@EnableDiscoveryClient 或@EnableEurekaClient注解
還可以在網(wǎng)關(guān)中設(shè)置全局或局部過濾器
4.搭建配置中心
添加依賴()另加下面依賴實現(xiàn)git倉庫自動刷新,需要配合rabbitmq使用,需要內(nèi)網(wǎng)穿透
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-bus-amqp</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId> </dependency>
?yml配置文件(可以更改本地作為配置中心)
server: port: 9007 spring: rabbitmq: host: 127.0.0.1 port: 5672 username: guest password: guest application: name: cloud-config cloud: config: server: git: uri: https://gitee.com/zhaoy999/springcloud_config.git search-paths: config default-label: master #配置中心設(shè)在本地使用 # profiles: # active: native # cloud: # config: # server: # native: # search-locations: classpath:/config eureka: client: service-url: defaultZone: http://127.0.0.1:9004/eureka #git倉庫配置中心自動刷新 management: endpoints: web: exposure: include: bus-refresh endpoint: bus-refresh: enabled: true
在已經(jīng)指定好的倉庫config目錄下創(chuàng)建配置文件
5.構(gòu)思需要的微服務(wù)(每個微服務(wù)既可以是提供者也可以是消費者)
引入依賴(需要另外引入下面代碼塊的依賴)
!!!修改,先不要加sleuth依賴,會報錯
這里使用的tkmybatis操作持久層
<!--使用rabbitmq鏈路追蹤,接收rabbitmq隊列消息,實現(xiàn)配置的自動刷新--> <dependency> <groupId>org.springframework.amqp</groupId> <artifactId>spring-rabbit</artifactId> </dependency> <!--微服務(wù)限流--> <dependency> <groupId>io.github.resilience4j</groupId> <artifactId>resilience4j-ratelimiter</artifactId> <version>1.7.0</version> </dependency> <!-- 信號量隔離--> <dependency> <groupId>io.github.resilience4j</groupId> <artifactId>resilience4j-bulkhead</artifactId> <version>1.7.0</version> </dependency> <!-- 配置自動刷新,需要配合@RefreshScope注解--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-bus-amqp</artifactId> </dependency> <!-- 可不用--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId> </dependency> <!--數(shù)據(jù)庫連接--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-jdbc</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> </dependency> <!--tkmybatis--> <dependency> <groupId>tk.mybatis</groupId> <artifactId>mapper-spring-boot-starter</artifactId> <version>2.0.2</version> </dependency> <!--PageHelper分頁插件--> <dependency> <groupId>com.github.pagehelper</groupId> <artifactId>pagehelper</artifactId> <version>5.1.11</version> </dependency> <!--前后端分離使用的thymeleaf--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-thymeleaf</artifactId> </dependency> <!--tkmybatis使用,增強mybatis不能用--> <dependency> <groupId>com.github.pagehelper</groupId> <artifactId>pagehelper-spring-boot-starter</artifactId> <version>1.2.3</version> </dependency>
yml基本配置:
- 連接eureka注冊中心:啟動器加@EnableDiscoveryClient 或@EnableEurekaClient注解
- 端口號,服務(wù)名,連接配置中心:本地application.yml
- 鏈路追蹤配置:git倉庫config目錄下application.yml
- rabbitmq消息接收配置:git倉庫config目錄下application.yml
- 選擇性配置feign:git倉庫config目錄下application.yml
- 熔斷,隔離,限流:git倉庫config目錄下application.yml
- 數(shù)據(jù)庫連接::git倉庫config目錄下application.yml
本地application.yml
server: port: ${port:9001} spring: application: name: pay-service cloud: config: uri: http://localhost:9007 profile: default label: master config: import: optional:configserver:http://localhost:9007
git倉庫config目錄下application.yml
spring: zipkin: base-url: http://localhost:9411 sender: type: web sleuth: sampler: probability: 1 rabbitmq: host: 127.0.0.1 port: 5672 username: guest password: guest eureka: client: service-url: defaultZone: http://peer1:9003/eureka,http://peer2:9004/eureka,http://peer3:9005/eureka feign: client: config: default: connectTimeout: 5000 #防止由于服務(wù)器處理時間長而阻塞調(diào)用者 readTimeout: 5000 #從連接建立時開始應(yīng)用,在返回響應(yīng)時間過長時觸發(fā) circuitbreaker: enabled: true compression: request: enabled: true # 請求壓縮 mime-types: text/xml,application/xml,application/json # 壓縮的類型 min-request-size: 2048 # 請求最小壓縮的閾值 response: enabled: true #響應(yīng)壓縮 useGzipDecoder: true #使用gzip解碼器解碼響應(yīng)數(shù)據(jù) logging: level: com.zhao: debug #設(shè)置自己作為斷路器 resilience4j: circuitbreaker: configs: default: failureRateThreshold: 30 #失敗請求百分比,超過這個比例,CircuitBreaker變?yōu)镺PEN狀態(tài) slidingWindowSize: 10 #滑動窗口的大小,配置COUNT_BASED,表示10個請求,配置TIME_BASED表示10秒 minimumNumberOfCalls: 5 #最小請求個數(shù),只有在滑動窗口內(nèi),請求個數(shù)達到這個個數(shù),才會觸發(fā)CircuitBreader對于斷路器的判斷 slidingWindowType: TIME_BASED #滑動窗口的類型 permittedNumberOfCallsInHalfOpenState: 3 #當CircuitBreaker處于HALF_OPEN狀態(tài)的時候,允許通過的請求個數(shù) automaticTransitionFromOpenToHalfOpenEnabled: true #設(shè)置true,表示自動從OPEN變成HALF_OPEN,即使沒有請求過來 waitDurationInOpenState: 2s #從OPEN到HALF_OPEN狀態(tài)需要等待的時間 recordExceptions: #異常名單 - java.lang.Exception instances: backendA: baseConfig: default #熔斷器backendA,繼承默認配置default backendB: failureRateThreshold: 50 slowCallDurationThreshold: 2s #慢調(diào)用時間閾值,高于這個閾值的呼叫視為慢調(diào)用,并增加慢調(diào)用比例。 slowCallRateThreshold: 30 #慢調(diào)用百分比閾值,斷路器把調(diào)用時間大于slowCallDurationThreshold,視為慢調(diào)用,當慢調(diào)用比例大于閾值,斷路器打開,并進行服務(wù)降級 slidingWindowSize: 10 slidingWindowType: TIME_BASED minimumNumberOfCalls: 2 permittedNumberOfCallsInHalfOpenState: 2 waitDurationInOpenState: 2s #從OPEN到HALF_OPEN狀態(tài)需要等待的時間 bulkhead: configs: default: maxConcurrentCalls: 5 # 隔離允許并發(fā)線程執(zhí)行的最大數(shù)量 maxWaitDuration: 20ms # 當達到并發(fā)調(diào)用數(shù)量時,新的線程的阻塞等待的最長時間 instances: backendA: baseConfig: default backendB: maxWaitDuration: 10ms maxConcurrentCalls: 20 #線程池隔離() thread-pool-bulkhead: configs: default: maxThreadPoolSize: 4 # 最大線程池大小 coreThreadPoolSize: 2 # 核心線程池大小 queueCapacity: 2 # 隊列容量 instances: backendA: baseConfig: default backendB: maxThreadPoolSize: 1 coreThreadPoolSize: 1 queueCapacity: 1 #微服務(wù)限流 ratelimiter: configs: default: timeoutDuration: 5 # 線程等待權(quán)限的默認等待時間 limitRefreshPeriod: 1s # 限流器每隔1s刷新一次,將允許處理的最大請求重置為2 limitForPeriod: 2 #在一個刷新周期內(nèi),允許執(zhí)行的最大請求數(shù) instances: backendA: baseConfig: default backendB: timeoutDuration: 5 limitRefreshPeriod: 1s limitForPeriod: 5
實現(xiàn)微服務(wù)的負載均衡(有使用resttemplate和使用openfeign兩種方式),這里直接使用restTemplate,在消費者啟動器類里引入restTemplate Bean類,加上@loadbalanced注解就可以用了
@EnableDiscoveryClient @SpringBootApplication public class OrderApplication { public static void main(String[] args) { SpringApplication.run(OrderApplication.class, args); } @Bean @LoadBalanced public RestTemplate restTemplate(){ return new RestTemplate(); } }
使用方法示例:
@Autowired private RestTemplate restTemplate; @Autowired DiscoveryClient discoveryClient; @GetMapping("/pay/{id}") @RateLimiter(name = "backendA", fallbackMethod = "fallback") public ResponseEntity<Payment> getPaymentById(@PathVariable("id") Integer id) throws InterruptedException, ExecutionException { log.info("now i enter the method!!!"); // Thread.sleep(10000L); //阻塞10秒,已測試慢調(diào)用比例熔斷 String url = "http://pay-service/pay/" + id; Payment payment = restTemplate.getForObject(url, Payment.class); log.info("now i exist the method!!!"); return ResponseEntity.ok(payment); }
6.依賴引入完畢,以上全部微服務(wù)創(chuàng)建出來后修改位置
啟動器加啟動器加@EnableDiscoveryClient 或@EnableEurekaServer
逐個修改yml文件,修改端口號和服務(wù)名
打開services,方便同時打開多個服務(wù)
配置中心加@EnableConfigServer
修改倉庫配置文件
添加本項目實體類依賴
打開rabbitmq,打開方法參考我的另一篇博客rabbitmq安裝全過程[含安裝包,可直接用
打開鏈路追蹤控制臺
開始寫邏輯代碼;
到此這篇關(guān)于springcloud項目快速開始起始模板的實現(xiàn)的文章就介紹到這了,更多相關(guān)springcloud 起始模板 內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
IntelliJ IDEA將導(dǎo)入的項目轉(zhuǎn)成maven項目
這篇文章主要介紹了IntelliJ IDEA將導(dǎo)入的項目轉(zhuǎn)成maven項目,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-09-09Java數(shù)據(jù)結(jié)構(gòu)之鏈表的增刪查改詳解
在這篇文章中,小編將帶大家了解一下Java數(shù)據(jù)結(jié)構(gòu)中鏈表的增刪查改(以下結(jié)果均在IDEA中編譯)希望在方便自己復(fù)習(xí)的同時也能幫助到大家2022-09-09SpringBoot項目接入Nacos的實現(xiàn)步驟
SpringBoot項目使用nacos作為配置中心和服務(wù)注冊中心,同時兼容dubbo的注冊中心。 本Demo項目使用的SpringBoot版本是2.3.9.RELEASE2021-05-05maven基礎(chǔ)教程——簡單了解maven的特點與功能
這篇文章主要介紹了Maven基礎(chǔ)教程的相關(guān)資料,文中講解非常細致,幫助大家開始學(xué)習(xí)maven,感興趣的朋友可以了解下2020-07-07