1. 程式人生 > >spring-cloud(二)服務消費者(rest+ribbon)(Finchley版本)

spring-cloud(二)服務消費者(rest+ribbon)(Finchley版本)

在微服務架構中,業務都會被拆分成一個獨立的服務,服務與服務的通訊是基於http restful的。Spring cloud有兩種服務呼叫方式,一種是ribbon+restTemplate,另一種是feign

ribbon是一個負載均衡客戶端,可以很好的控制http和tcp的一些行為。Feign預設集成了ribbon。

ribbon 已經預設實現了這些配置bean:

  • IClientConfig ribbonClientConfig: DefaultClientConfigImpl
  • IRule ribbonRule: ZoneAvoidanceRule
  • IPing ribbonPing: NoOpPing
  • ServerList ribbonServerList: ConfigurationBasedServerList
  • ServerListFilter ribbonServerListFilter: ZonePreferenceServerListFilter
  • ILoadBalancer ribbonLoadBalancer: ZoneAwareLoadBalancer

啟動 eureka-server 埠8761  啟動eureka-client 埠8762  啟動eureka-client  埠8763

這樣eureka-client 在eureka-server中註冊了兩個例項 埠分別為8762 8763

新建服務消費者 ribbon-server

在主工程下新建module ribbon-server

在它的pom.xml繼承了父pom檔案,並引入了以下依賴

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.xuxu</groupId>
    <artifactId>ribbon-server</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>ribbon-server</name>
    <description>Demo project for Spring Boot</description>

    <parent>
        <groupId>com.xuxu</groupId>
        <artifactId>springcloud01</artifactId>
        <version>1.0-SNAPSHOT</version>
    </parent>

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
    </dependencies>
</project>

配置檔案application.yml如下

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

啟動類上加入註解@EnableEurekaClient   @EnableDiscoveryClient  並且通過@Bean注入RestTemplate,通過@LoadBalanced開啟負載均衡

@SpringBootApplication
@EnableEurekaClient
@EnableDiscoveryClient
public class RibbonServerApplication {

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

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

通過之前注入ioc容器的restTemplate來消費rureka-client服務的“/hi”介面,在這裡我們直接用的程式名替代了具體的url地址,在ribbon中它會根據服務名來選擇具體的服務例項,根據服務例項在請求的時候會用具體的url替換掉服務名

@Service
public class HelloService {
    @Autowired
    private RestTemplate restTemplate;

    public String hello(String name){
        return restTemplate.getForObject("http://eureka-client/hi?name="+name,String.class);
    }
}

restTemplate.getForObject("http://eureka-client/hi?name="+name,String.class);

代表以GET形式請求指定URL,返回string型別 這裡由ribbon通過服務名稱選擇例項,然後替換成對應的url

建立controller

@RestController
public class HelloController {
    @Autowired
    private HelloService helloService;

    @GetMapping(value = "/hi")
    public String hello(@RequestParam(value = "name") String name){
        return helloService.hello(name);
    }
}

啟動服務

檢視eureka-server中的例項

通過瀏覽器訪問http://localhost:8764/hi?name=123

發現該請求交替訪問8762 和 8763的服務

這說明當我們通過呼叫restTemplate.getForObject("http://eureka-client/hi?name="+name,String.class)方法時,已經做了負載均衡,訪問了不同的埠的服務例項

此時架構圖