SpringCloud 中使用 Ribbon的方法詳解

更新時間：2018年10月19日 13:41:13 作者：沛昕的博客

本文重點(diǎn)給大家介紹SpringCloud 中使用 Ribbon的方法,本文通過實例文字相結(jié)合的形式給大家介紹的非常詳細(xì)，需要的朋友可以參考下

在前兩章已經(jīng)給大家講解了Ribbon負(fù)載均衡的規(guī)則以及如何搭建Ribbon并調(diào)用服務(wù)，那么在這一章呢將會給大家說一說如何在SpringCloud中去使用Ribbon。在搭建之前我們需要做一些準(zhǔn)備工作。

1. 搭建Eureka服務(wù)器：springCloud-ribbon-server（項目名稱）
2. 服務(wù)提供者：springCloud-ribbon-police（項目名稱）
3. 服務(wù)調(diào)用者：springCloud-ribbon-person（項目名稱）

搭建Eureka服務(wù)器

配置 pom.xml，加入springCloud核心依賴、配置及eureka服務(wù)器依賴

<parent>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-parent</artifactId>
  <version>1.5.13.RELEASE</version>
</parent>
<dependencyManagement>
  <dependencies>
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-dependencies</artifactId>
      <version>Dalston.SR5</version>
      <type>pom</type>
      <scope>import</scope>
    </dependency>
  </dependencies>
</dependencyManagement>
<dependencies>
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-config</artifactId>
  </dependency>
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-eureka-server</artifactId>
  </dependency>
</dependencies>

配置 application.yml（紅色部分是必須要寫的，黑色部分不寫也能正常運(yùn)行但是建議寫上，在這里筆者將官網(wǎng)的代碼貼上）

server:
 port: 8761
eureka:
 instance:
  hostname: localhost
 client:
  registerWithEureka: false 禁止向eureka注冊服務(wù)，因為它自己本身就是服務(wù)器
  fetchRegistry: false 這里不需要抓取注冊表
  serviceUrl:
   defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

創(chuàng)建啟動類：Application.java（將服務(wù)跑起來放著，稍后會用到）配置 pom.xml，加入springCloud核心依賴、配置及eureka服務(wù)依賴

@SpringBootApplication
@EnableEurekaServer
public class Application {
  
  public static void main(String[] args) {
    new SpringApplicationBuilder(Application.class).web(true).run(args);
  }
}

服務(wù)提供者

配置 pom.xml，加入springCloud核心依賴、配置及eureka客戶端依賴

<parent>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-parent</artifactId>
  <version>1.5.13.RELEASE</version>
</parent>
<dependencyManagement>
  <dependencies>
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-dependencies</artifactId>
      <version>Dalston.SR5</version>
      <type>pom</type>
      <scope>import</scope>
    </dependency>
  </dependencies>
</dependencyManagement>
<dependencies>
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-config</artifactId>
  </dependency>
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-eureka</artifactId>
  </dependency>
</dependencies>

配置 application.yml（需要使用defaultZone向服務(wù)器注冊服務(wù)，否則就算該服務(wù)運(yùn)行起來了，但沒有向服務(wù)器注冊服務(wù)，也是使用不了的）（name 這個名稱是顯示在服務(wù)列表中的名稱，養(yǎng)成好習(xí)慣，一定要起有意義的名稱）

spring:
 application:
  name: springCloud-ribbon-police
eureka:
 client:
  serviceUrl:
   defaultZone: http://localhost:8761/eureka/

因為該服務(wù)是提供服務(wù)的，所以下面會建一個實體類及Controller用來對外提供服務(wù)，創(chuàng)建實體類：Police.java

public class Police {
  private String id;// 警察編號，用來保存用戶輸入的參數(shù)
  private String url;// 處理請求的服務(wù)器url
  private String message;// 提示信息
  public String getId() {
    return id;
  }
  public void setId(String id) {
    this.id = id;
  }
  public String getUrl() {
    return url;
  }
  public void setUrl(String url) {
    this.url = url;
  }
  public String getMessage() {
    return message;
  }
  public void setMessage(String message) {
    this.message = message;
  } 
}

創(chuàng)建對外提供服務(wù)的Controller：PoliceController.java（@RestController注解中包含了@Controller+@ResponseBody）

@RestController
public class PoliceController {

  @RequestMapping(value="/getPolice", method=RequestMethod.GET, produces=MediaType.APPLICATION_JSON_VALUE)
  public Police getPolice(HttpServletRequest request){
    Police p = new Police();
    p.setUrl(request.getRequestURL().toString());
    p.setMessage("警察派出成功");
    return p;
  }
  
  @RequestMapping(value="/getPoliceById/{id}", method=RequestMethod.GET, produces=MediaType.APPLICATION_JSON_VALUE)
  public Police getPolice(HttpServletRequest request, @PathVariable("id") String id){
    Police p = new Police();
    p.setId(id);
    p.setUrl(request.getRequestURL().toString());
    p.setMessage("指定警察派出成功");
    return p;
  }
}

因為我們要測試負(fù)載均衡，所以這里的服務(wù)提供者需要開啟多個服務(wù)實例，下面我們用讀取手動輸入端口號的方法，啟動多個服務(wù)實例，筆者在這里啟動了兩個服務(wù)實例：8080、8081

@SpringBootApplication
@EnableEurekaClient
public class PoliceApplication {
  
  public static void main(String[] args) {
    Scanner scan = new Scanner(System.in);
    String port = scan.nextLine();
    new SpringApplicationBuilder(PoliceApplication.class).properties("server.port="+port).run(args);
  } 
}

如下圖，出現(xiàn)了兩個服務(wù)實例，分別是：8080、8081，紅色的信息咱們先不管他，如果實在有看著不順眼的小伙伴，可以配置心跳（簡單的來說，就是配置服務(wù)器每隔多久檢查一次服務(wù)實例狀態(tài)，如果某個服務(wù)因為某些原因停掉不能用了，那么就將該服務(wù) 從服務(wù)列表中移除掉）

服務(wù)調(diào)用者

配置 pom.xml，加入springCloud核心依賴、配置及eureka客戶端依賴、Ribbon依賴

<parent>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-parent</artifactId>
  <version>1.5.13.RELEASE</version>
</parent>
<dependencyManagement>
  <dependencies>
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-dependencies</artifactId>
      <version>Dalston.SR5</version>
      <type>pom</type>
      <scope>import</scope>
    </dependency>
  </dependencies>
</dependencyManagement>
<dependencies>
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-config</artifactId>
  </dependency>
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-eureka</artifactId>
  </dependency>
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-ribbon</artifactId>
  </dependency>
</dependencies>

配置 application.yml（這里也將該服務(wù)注冊到服務(wù)器，一定要進(jìn)行注冊）

server:
 port: 9090
spring:
 application:
  name: springCloud-ribbon-person
eureka:
 client:
  serviceUrl:
   defaultZone: http://localhost:8761/eureka/

創(chuàng)建調(diào)用服務(wù)Controller：PersonController.java

RestTemplate 是由 Spring Web 模塊提供的工具類，與 SpringCloud 無關(guān)，是獨(dú)立存在的

因 SpringCloud 對 RestTemplate 進(jìn)行了一定的擴(kuò)展，所以 RestTemplate 具備了負(fù)載均衡的功能

@RestController
@Configuration
public class PersonController {
  @Bean
  @LoadBalanced
  public RestTemplate getRestTemplate(){
    return new RestTemplate();
  }
  @RequestMapping("/getPolice")
  public String getPolice(){
    RestTemplate rt = getRestTemplate();
    String result = rt.getForObject("http://springCloud-ribbon-police/getPolice", String.class);
    return result;
  }
  @RequestMapping("/getPoliceById/{id}")
  public String getPoliceById(@PathVariable("id") String id){
    RestTemplate rt = getRestTemplate();
    String result = rt.getForObject("http://springCloud-ribbon-police/getPoliceById/"+id, String.class);
    return result;
  }
}

創(chuàng)建啟動類：PersonApplication.java

@SpringBootApplication
@EnableEurekaClient
public class PersonApplication {
  
  public static void main(String[] args) {
    new SpringApplicationBuilder(PersonApplication.class).web(true).run(args);
  } 
}