欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

springcloud項目快速開始起始模板的實現(xiàn)

 更新時間:2021年12月06日 09:25:24   作者:探索永不止息  
本文主要介紹了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)文章

  • Java1.8中StringJoiner的使用及源碼詳析

    Java1.8中StringJoiner的使用及源碼詳析

    在看String類時,看到有使用StringJoiner類,所以順便看了下StringJoiner類,下面這篇文章主要給大家介紹了關(guān)于Java 1.8中StringJoiner的使用及源碼分析的相關(guān)資料,需要的朋友可以參考借鑒,下面來一起看看吧
    2018-08-08
  • Mybatis自定義插件Interceptor問題

    Mybatis自定義插件Interceptor問題

    這篇文章主要介紹了Mybatis自定義插件Interceptor問題,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2022-11-11
  • IntelliJ IDEA將導(dǎo)入的項目轉(zhuǎn)成maven項目

    IntelliJ IDEA將導(dǎo)入的項目轉(zhuǎn)成maven項目

    這篇文章主要介紹了IntelliJ IDEA將導(dǎo)入的項目轉(zhuǎn)成maven項目,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2020-09-09
  • Java數(shù)據(jù)結(jié)構(gòu)之鏈表的增刪查改詳解

    Java數(shù)據(jù)結(jié)構(gòu)之鏈表的增刪查改詳解

    在這篇文章中,小編將帶大家了解一下Java數(shù)據(jù)結(jié)構(gòu)中鏈表的增刪查改(以下結(jié)果均在IDEA中編譯)希望在方便自己復(fù)習(xí)的同時也能幫助到大家
    2022-09-09
  • java 中多線程生產(chǎn)者消費者問題詳細介紹

    java 中多線程生產(chǎn)者消費者問題詳細介紹

    這篇文章主要介紹了java 中多線程生產(chǎn)者消費者問題詳細介紹的相關(guān)資料,希望通過本文能幫助到大家,需要的朋友可以參考下
    2017-09-09
  • SpringBoot項目接入Nacos的實現(xiàn)步驟

    SpringBoot項目接入Nacos的實現(xiàn)步驟

    SpringBoot項目使用nacos作為配置中心和服務(wù)注冊中心,同時兼容dubbo的注冊中心。 本Demo項目使用的SpringBoot版本是2.3.9.RELEASE
    2021-05-05
  • SpringBoot中使用JWT的實戰(zhàn)

    SpringBoot中使用JWT的實戰(zhàn)

    本文主要介紹了SpringBoot中使用JWT的實戰(zhàn),文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2023-06-06
  • Spring中七種事務(wù)傳播機制詳解

    Spring中七種事務(wù)傳播機制詳解

    這篇文章主要介紹了Spring中七種事務(wù)傳播機制詳解,Spring在TransactionDefinition接口中規(guī)定了7種類型的事務(wù)傳播行為,Propagation枚舉則引用了這些類型,開發(fā)過程中我們一般直接用Propagation枚舉,需要的朋友可以參考下
    2024-01-01
  • maven基礎(chǔ)教程——簡單了解maven的特點與功能

    maven基礎(chǔ)教程——簡單了解maven的特點與功能

    這篇文章主要介紹了Maven基礎(chǔ)教程的相關(guān)資料,文中講解非常細致,幫助大家開始學(xué)習(xí)maven,感興趣的朋友可以了解下
    2020-07-07
  • Java實現(xiàn)簡易GUI貪吃蛇小游戲

    Java實現(xiàn)簡易GUI貪吃蛇小游戲

    這篇文章主要為大家詳細介紹了Java實現(xiàn)簡易GUI貪吃蛇小游戲,文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2021-09-09

最新評論