Spring Cloud 快速入門

fuyi501 發(fā)布于2019-08-19 10:50 / 501人閱讀

摘要：服務(wù)注冊中心一個服務(wù)注冊中心，所有的服務(wù)都在注冊中心注冊，負(fù)載均衡也是通過在注冊中心注冊的服務(wù)來使用一定策略來實現(xiàn)。在客戶端實現(xiàn)了負(fù)載均衡。

文章參考于史上最簡單的 SpringCloud 教程 | 終章

Spring Cloud 是一個微服務(wù)框架，與 Spring Boot 結(jié)合，開發(fā)簡單。將一個大工程項目，分成多個小 web 服務(wù)工程，可以分別獨立擴展，又可以共同合作。

環(huán)境

spring 官網(wǎng)的 sts 3.9.2，就是有spring 相關(guān)插件的eclipse；

apache maven 3.5.4，配置阿里云鏡像

jdk1.8

Spring Cloud Finchley版本

Spring Boot 2.0.3

Spring Cloud 組件

服務(wù)注冊中心、服務(wù)、斷路器、配置中心

服務(wù)的注冊與發(fā)現(xiàn) - Eureka

使用 Eureka 來實現(xiàn)服務(wù)注冊中心、服務(wù)提供者和服務(wù)消費者。

服務(wù)注冊中心

一個服務(wù)注冊中心，所有的服務(wù)都在注冊中心注冊，負(fù)載均衡也是通過在注冊中心注冊的服務(wù)來使用一定策略來實現(xiàn)。

1.新建一個 Spring Boot 工程，用來管理服務(wù)，elipse右鍵 -> new -> Spring Starter Project :

點擊 next ，選擇 Cloud Discovery 下的 Eureka Server 組件

生成的 pom 文件：



    4.0.0

    com.beigege.cloud
    eureka-server
    0.0.1-SNAPSHOT
    jar

    eureka-server
    spring cloud學(xué)習(xí)

    
        org.springframework.boot
        spring-boot-starter-parent
        2.0.3.RELEASE
         
    

    
        UTF-8
        UTF-8
        1.8
        Finchley.RELEASE
    

    
        
            org.springframework.boot
            spring-boot-starter-test
            test
        
        
            org.springframework.cloud
            spring-cloud-starter-netflix-eureka-server
        
    
    
        
            
                org.springframework.cloud
                spring-cloud-dependencies
                ${spring-cloud.version}
                pom
                import
            
        
    
    
        
            
                org.springframework.boot
                spring-boot-maven-plugin

2.使用 @EnableEurekaServer 來說明項目是一個 Eureka：

@SpringBootApplication
@EnableEurekaServer
public class EurekaServerApplication {

    public static void main(String[] args) {
        SpringApplication.run(EurekaServerApplication.class, args);
    }
}

3.修改配置文件，配置文件，可以是 application.properties 或 application.yml，這里改后綴，使用 yml，兩種格式內(nèi)容都是一樣的只是格式不同 application.yml：

server:
  port: 8761 #服務(wù)端口

spring:
  application:
    name: eurka-server #服務(wù)應(yīng)用名稱

eureka:
  instance:
    hostname: localhost
  client:
    registerWithEureka: false #是否將自己注冊到Eureka Server，默認(rèn)為true
    fetchRegistry: false #是否從Eureka Server獲取注冊信息，默認(rèn)為true
    service-url:
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/ #服務(wù)注冊的 URL

默認(rèn) eureka server 也是一個 eureka client，registerWithEureka: false 和 fetchRegistry: false 來表明項目是一個 Eureka Server。

4.運行 EurekaServerApplication 類，啟動項目，訪問項目 http://localhost:8761/

服務(wù)提供者

1.新建項目名為 eureka-client 的 Spring Boot 項目，跟 Eureka Server 新建一樣，只是在選擇 Spring Boot 組件的時候，不選 Eureka Server ，選擇 Eureka Client，這里為了測試，再添加一個 Web 下的 Web 組件：

2.修改配置，application.yml:

server:
  port: 8762
  
spring:
  application:
    name: service-hi #服務(wù)之間的調(diào)用都是根據(jù)這個 name
    
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/

3.添加 @EnableEurekaClient 注解，并添加一個測試接口 /hi：

@SpringBootApplication
@EnableEurekaClient
@RestController
public class EurekaClientApplication {

    public static void main(String[] args) {
        SpringApplication.run(EurekaClientApplication.class, args);
    }

    @Value("${server.port}")
    String port;

    @RequestMapping("/hi")
    public String home(@RequestParam(value = "name", defaultValue = "beigege") String name) {
        return "hi " + name + " ,i am from port:" + port;
    }
}

4.啟動 Eureka Server 和 Eureka Client 項目，訪問http://localhost:8761 ，即eureka server 的網(wǎng)址：

服務(wù)消費者 - Ribbon | Feign

Spring Cloud 兩種調(diào)用服務(wù)的方式，ribbon + restTemplate，和 feign。

Ribbon

ribbon 在客戶端實現(xiàn)了負(fù)載均衡。

啟動 Eureka Server 和 Eureka Client，修改 Eureka Client 端口，再啟動一個 Eureka Client 實例，相當(dāng)于一個小的集群，訪問localhost:8761

1.新建一個 spring boot 工程，名稱為 service-ribbon，創(chuàng)建過程和 eureka-client 一樣，組件多選一個 Cloud Routing 下的 Ribbon，創(chuàng)建完成之后的 pom 文件依賴：

        
            org.springframework.cloud
            spring-cloud-starter-netflix-ribbon
        
        
            org.springframework.cloud
            spring-cloud-starter-netflix-eureka-client
        
        
            org.springframework.boot
            spring-boot-starter-web
        
        
            org.springframework.cloud
            spring-cloud-starter-netflix-hystrix
        

        
            org.springframework.boot
            spring-boot-starter-test
            test

application.yml 配置：

server:
  port: 8764
  
spring:
  application:
    name: service-ribbon
    
eureka: 
  client: 
    service-url: 
      defaultZone: http://localhost:8761/eureka/

ServiceRibbonApplication 加上 @EnableEurekaClient 注解

2.向 Spring 注入一個 bean: restTemplate，并添加 @LoadBalanced 注解，表明這個 restTemplate 開啟負(fù)載均衡功能：

@SpringBootApplication
@EnableEurekaClient
public class ServiceRibbonApplication {

    public static void main(String[] args) {
        SpringApplication.run(ServiceRibbonApplication.class, args);
    }
    
    @Bean
    @LoadBalanced
    RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

3.寫一個接口用來調(diào)用之前的 service-hi 服務(wù)的 /hi 接口：
新建 service 層，名叫 HelloService，調(diào)用 /hi 接口，這里用服務(wù)名 SERVICE-HI 代替具體的 URL：

@Service
public class HelloService {

    @Autowired
    RestTemplate restTemplate;

    public String hiService(String name) {
        return restTemplate.getForObject("http://SERVICE-HI/hi?name="+name,String.class);
    }

}

新建 controller 層，調(diào)用 service 層：

@RestController
public class HelloControler {

    @Autowired
    HelloService helloService;
    @RequestMapping(value = "/hi")
    public String hi(@RequestParam String name){
        return helloService.hiService(name);
    }
}

4.啟動 service-ribbon 工程，多次訪問該工程的 /hi 接口，即 localhost:8764/hi?name=test：

hi test ,i am from port:8762
hi test ,i am from port:8763

上面交替顯示，說明實現(xiàn)了負(fù)載均衡，ribbon 會在客戶端發(fā)送請求時做一個負(fù)載均衡。

Feign

整合了 Ribbon，具有負(fù)載均衡的能力，整合了Hystrix，具有熔斷的能力.

1.創(chuàng)建一個 spring boot工程，創(chuàng)建過程和 eureka-client 一樣，多添加一個組件 Cloud Routing 下的 Feign，項目名叫 service-feign，創(chuàng)建完后的 pom 文件依賴：

        
            org.springframework.boot
            spring-boot-starter-web
        
        
            org.springframework.cloud
            spring-cloud-starter-netflix-eureka-client
        
        
            org.springframework.cloud
            spring-cloud-starter-openfeign
        

        
            org.springframework.boot
            spring-boot-starter-test
            test

application.yml 配置文件：

server:
  port: 8765

spring:
  application:
    name: service-feign

eureka:
  client:
    serviceUrl: 
      defaultZone: http://localhost:8761/eureka/

SericeFeignApplication 上添加 @EnableEurekaClient 和 @EnableFeignClients 注解：

@SpringBootApplication
@EnableEurekaClient
@EnableFeignClients
public class SericeFeignApplication {

    public static void main(String[] args) {
        SpringApplication.run(SericeFeignApplication.class, args);
    }
}

2.寫一個 SchedualServiceHi 接口，通過@ FeignClient（“服務(wù)名”），來指定調(diào)用哪個服務(wù)，@GetMapping("接口名")，來向接口發(fā)送 Get 請求，@RequestParam 是請求參數(shù)：

@FeignClient(value = "service-hi")
public interface SchedualServiceHi {

    @GetMapping("/hi")
    String sayHiFromClientOne(@RequestParam(value = "name") String name);
    
}

寫一個 controller 層測試 SchedualServiceHi 接口：

@RestController
public class HiController {
    
    @Autowired
    SchedualServiceHi schedualServiceHi;

    @GetMapping(value = "/hi")
    public String sayHi(@RequestParam String name) {
        return schedualServiceHi.sayHiFromClientOne( name );
    }

}

3.啟動 service-feign，訪問localhost:8765/hi?name=test 測試，下面交替顯示，說明實現(xiàn)了負(fù)載均衡：

hi test ,i am from port:8762 
hi test ,i am from port:8763

斷路器 - Hystrix

鏈?zhǔn)秸{(diào)用服務(wù)，其中一個服務(wù)宕機，其他服務(wù)可能會跟著異常，發(fā)生雪崩，當(dāng)對一個服務(wù)的調(diào)用失敗次數(shù)到達一定閾值，斷路器會打開，執(zhí)行服務(wù)調(diào)用失敗時的處理，避免連鎖故障，上面已經(jīng)啟動：eureka-server、兩個 eureka-client 實例、service-ribbon 和 service-feign，下面繼續(xù)修改，分別在 service-ribbon 和 service-feign 上實現(xiàn)斷路器。

service-ribbon + Hystrix

1.在 pom 文件中加入 Hystrix 依賴：


    org.springframework.cloud
    spring-cloud-starter-netflix-hystrix

2.在程序的啟動類 ServiceRibbonApplication 加 @EnableHystrix 注解開啟Hystrix：

@SpringBootApplication
@EnableEurekaClient
@EnableHystrix
public class ServiceRibbonApplication {

    public static void main(String[] args) {
        SpringApplication.run( ServiceRibbonApplication.class, args );
    }

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

}

3.添加熔斷方法，改造 HelloService 類，在 hiService 方法上面添加 @HystrixCommand 注解，fallbackMethod 是熔斷方法，當(dāng)服務(wù)不可用時會執(zhí)行，該方法，即 hiError 方法：

@Service
public class HelloService {

    @Autowired
    RestTemplate restTemplate;

    @HystrixCommand(fallbackMethod = "hiError")
    public String hiService(String name) {
        return restTemplate.getForObject("http://SERVICE-HI/hi?name="+name,String.class);
    }

    public String hiError(String name) {
        return "hi,"+name+",sorry,error!";
    }

}

重啟 service-ribbon，訪問 localhost:8764/hi?name=test

hi test ,i am from port:8763

關(guān)閉兩個 eureka-client 實例，在訪問 localhost:8764/hi?name=test，瀏覽器顯示：

hi,test,sorry,error!

當(dāng)服務(wù)不可用時，斷路器會迅速執(zhí)行熔斷方法

service-feign + Hystrix

1.Feign 自帶斷路器，在D版本的Spring Cloud之后，它沒有默認(rèn)打開。需要在配置文件中配置打開：

feign: 
  hystrix: 
    enabled: true

2.在請求接口指定熔斷實現(xiàn)類，fallback 指定熔斷實現(xiàn)類：

@FeignClient(value ="service-hi",fallback = SchedualServiceHiHystric.class)
public interface SchedualServiceHi {
    
    @GetMapping("/hi")
    String sayHiFromClientOne(@RequestParam(value = "name") String name);

}

SchedualServiceHiHystric 類實現(xiàn) SchedualServiceHi 接口：

@Component
public class SchedualServiceHiHystric implements SchedualServiceHi{

    @Override
    public String sayHiFromClientOne(String name) {
        return "sorry "+name;
    }

}

3.訪問測試，重啟 service-feign，訪問 localhost:8765/hi?name=test:

sorry test

打開 eureka-client，再次訪問 localhost:8765/hi?name=test:

hi test ,i am from port:8762

證明斷路器起到作用，注意瀏覽器緩存。

路由網(wǎng)關(guān) - Zuul

1.創(chuàng)建一個 spring boot 工程，名稱為 service-zuul，創(chuàng)建過程和 eureka-client 一樣，組件要多添加一個 Cloud Routing 下的 Zuul，pom 文件的依賴如下：

        
            org.springframework.cloud
            spring-cloud-starter-netflix-eureka-client
        
        
            org.springframework.boot
            spring-boot-starter-web
        
        
            org.springframework.cloud
            spring-cloud-starter-netflix-zuul
        
        
            org.springframework.boot
            spring-boot-starter-test
            test

2.在入口 application 中添加 @EnableZuulProxy 注解，開啟路由：

@SpringBootApplication
@EnableEurekaClient
@EnableZuulProxy
public class ServiceZuulApplication {

    public static void main(String[] args) {
        SpringApplication.run(ServiceZuulApplication.class, args);
    }
}

application.yml 配置：

server:
  port: 8769
 
spring:
  application:
    name: service-zuul
    
eureka:
  client:
    serviceUrl: 
      defaultZone: http://localhost:8761/eureka/

添加路由

修改 application.yml 添加路由配置：

server:
  port: 8769
 
spring:
  application:
    name: service-zuul
    
eureka:
  client:
    serviceUrl: 
      defaultZone: http://localhost:8761/eureka/
      
zuul:
  routes:
    api-a: 
      path: /api-a/**
      service-id: service-ribbon
    api-b:
      path: /api-b/**
      service-id: service-feign

8769 端口的所有 api-a 請求會轉(zhuǎn)發(fā)到 service-ribbon 工程，api-b 到 service-feign

啟動 service-zuul，訪問 localhost:8769/api-a/hi?name=test，瀏覽器顯示：

hi test ,i am from port:8762

訪問 localhost:8769/api-b/hi?name=test，瀏覽器顯示：

hi test ,i am from port:8762

說明路由成功。

過濾器

新建自定義過濾器，繼承 ZuulFilter：

@Component
public class MyFilter extends ZuulFilter {

    private static Logger log = LoggerFactory.getLogger(MyFilter.class);

    /*
     * filterType：返回一個字符串代表過濾器的類型，在zuul中定義了四種不同生命周期的過濾器類型，具體如下：
     * pre：路由之前
     * routing：路由之時 
     * post： 路由之后 
     * error：發(fā)送錯誤調(diào)用 
     */
    @Override
    public String filterType() {
        return "pre";
    }

    /*
     * filterOrder：過濾的順序
     */
    @Override
    public int filterOrder() {
        return 0;
    }

    /*
     * shouldFilter：這里可以寫邏輯判斷，是否要過濾，本文true,永遠過濾。
     */
    @Override
    public boolean shouldFilter() {
        return true;
    }

    /*
     * run：過濾器的具體邏輯?？梢院軓?fù)雜，包括查sql，nosql去判斷該請求到底有沒有權(quán)限訪問，
     * 這里是判斷請求有沒有 token 參數(shù)
     */
    @Override
    public Object run() {
        RequestContext ctx = RequestContext.getCurrentContext();
        HttpServletRequest request = ctx.getRequest();
        log.info(String.format("%s >>> %s", request.getMethod(), request.getRequestURL().toString()));
        Object accessToken = request.getParameter("token");
        if(accessToken == null) {
            log.warn("token is empty");
            ctx.setSendZuulResponse(false);
            ctx.setResponseStatusCode(401);
            try {
                ctx.getResponse().getWriter().write("token is empty");
            }catch (Exception e){}

            return null;
        }
        log.info("ok");
        return null;
    }
}

重啟 service-zuul 訪問 localhost:8769/api-a/hi?name=test，瀏覽器顯示

token is empty

加上 token 參數(shù)：localhost:8769/api-a/hi?name=test&token=666

hi test ,i am from port:8762

分布式配置中心 遠程資源庫

1.這里在碼云注冊一個賬號，用來創(chuàng)建存儲配置的資源庫，在碼云上創(chuàng)建一個名叫 SpringCloudConfig 項目：

2.新建一個配置文件 config-client-dev.properties，也可以是 yml 配置文件，內(nèi)容為 test = version 1，然后提交：

2.默認(rèn)是 master 分支，新建一個分支，名字叫 aa：

修改 aa 分支中的 config-client-dev.properties 配置文件的 test 屬性為 version 2：

config-server

1.新建 spring boot 項目，組件選擇 Cloud Config 中的 Config Server，pom 中的依賴：

        
            org.springframework.cloud
            spring-cloud-config-server
        

        
            org.springframework.boot
            spring-boot-starter-test
            test

在入口程序添加 @EnableConfigServer 注解：

@SpringBootApplication
@EnableConfigServer
public class ConfigServerApplication {

    public static void main(String[] args) {
        SpringApplication.run(ConfigServerApplication.class, args);
    }
}

application.yml 配置文件，如果是公開的不需要填寫用戶名密碼：

server:
  port: 8888
  
spring:
  application:
    name: config-server
  cloud:
    config:
      server:
        git:
          uri: https://gitee.com/candy-boy/SpringCloudConfig  #配置git倉庫地址，后面的.git可有可無 
          username:  #訪問git倉庫的用戶名，碼云登陸用戶名
          password:  #訪問git倉庫的用戶密碼，碼云登陸密碼

2.訪問測試，啟動程序，訪問配置文件，可以如下訪問：

{application}/{profile}[/{label}]

如 localhost:8888/config-client/dev，即訪問 config-client-dev.properties，其中 {application} 就是最后一道橫線前面的 config-client，{profile} 是最后一道橫線后面到點，即 dev，{label} 指的是資源庫的分支，不填則為默認(rèn)分支，剛創(chuàng)建的資源庫，默認(rèn)分支是 master，訪問結(jié)果如下：

其他訪問方式如：

/{application}/{profile}[/{label}]
/{application}-{profile}.yml
/{label}/{application}-{profile}.yml
/{application}-{profile}.properties
/{label}/{application}-{profile}.properties

如果是下面這樣，可能是用戶名或密碼錯誤：

3.測試其他分支，訪問 aa 分支下的 config-client-dev.properties，localhost:8888/config-client/dev/aa

config-client

待續(xù)....

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://systransis.cn/yun/76532.html

發(fā)表評論

登陸后可評論

0條評論

fuyi501

男|高級講師

我要關(guān)注我要私信

TA的文章

淺析3種電池容量監(jiān)測方案

閱讀 2416·2021-11-11 16:54
云主機用什么系統(tǒng)好-虛擬服務(wù)器和云主機哪個好？為什么？

閱讀 1219·2021-09-22 15:23
Python爬蟲理論之cookie驗證，不回顧下歷史，套路都不知道怎么來的！

閱讀 3660·2021-09-07 09:59
Java畢設(shè)項目-航空訂票管理系統(tǒng)的設(shè)計與實現(xiàn)

閱讀 2010·2021-09-02 15:41
Limewave：$3.5/月/2核/4GB內(nèi)存/15GB SSD空間/1TB流量/1Gbps端口/

閱讀 3294·2021-08-17 10:13
帶你了解css計數(shù)器——counters

閱讀 3061·2019-08-30 15:53
javascript中你可能遇到的隱式調(diào)用

閱讀 1244·2019-08-30 13:57
自定義按鈕樣式

閱讀 1216·2019-08-29 15:16

成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

Spring Cloud 快速入門

相關(guān)文章

Spring Cloud 參考文檔（Spring Cloud Config快速入門）

springcloud(二)——spring-cloud-alibaba集成sentinel入門

Spring Cloud構(gòu)建微服務(wù)架構(gòu)：消息驅(qū)動的微服務(wù)（入門）【Dalston版】

使用maven快速入門

發(fā)表評論

0條評論

fuyi501

男|高級講師

TA的文章

淺析3種電池容量監(jiān)測方案

云主機用什么系統(tǒng)好-虛擬服務(wù)器和云主機哪個好？為什么？

Python爬蟲理論之cookie驗證，不回顧下歷史，套路都不知道怎么來的！

Java畢設(shè)項目-航空訂票管理系統(tǒng)的設(shè)計與實現(xiàn)

Limewave：$3.5/月/2核/4GB內(nèi)存/15GB SSD空間/1TB流量/1Gbps端口/

帶你了解css計數(shù)器——counters

javascript中你可能遇到的隱式調(diào)用

自定義按鈕樣式

最新活動

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

Spring Cloud 快速入門

相關(guān)文章

發(fā)表評論

0條評論

男|高級講師

TA的文章

最新活動

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！