快捷導(dǎo)航

Spring Cloud EureKa Ribbon 服務(wù)注冊(cè)發(fā)現(xiàn)與調(diào)用

更新時(shí)間：2018年02月26日 09:14:59 作者：Sam哥哥

這篇文章主要介紹了Spring Cloud EureKa Ribbon 服務(wù)注冊(cè)發(fā)現(xiàn)與調(diào)用，小編覺(jué)得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧

概述

用一個(gè)簡(jiǎn)單的例子演示Spring Cloud中EureKa和Ribbon的基本用法。

版本和環(huán)境

IDEA
Spring Boot 1.5.·0
JDK 1.8
Maven 3

構(gòu)建eureka server

在Spring Cloud,可以使用eureka來(lái)管理微服務(wù),微服務(wù)可以注冊(cè)到eureka中。

首先可以用IDEA的Spring Initialzr 來(lái)創(chuàng)建eureka server注冊(cè)中心。

修改application.properties文件，添加如下內(nèi)容

spring.application.name=eureka-server 
eureka.instance.hostname=localhost 
eureka.client.register-with-eureka=false 
eureka.client.fetch-registry=false 
server.port=8881

在Spring Boot為我們生成的啟動(dòng)類(lèi)ServerApplication 中加入@EnableEurekaServer 注解

package com.springcloud.eureka;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

@EnableEurekaServer
@SpringBootApplication
public class ServerApplication {

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

在瀏覽器中輸入http://localhost:8881/

可以看到如下界面:

可以看到暫時(shí)還沒(méi)有服務(wù)注冊(cè)上來(lái)。到此，一個(gè)簡(jiǎn)單的微服務(wù)注冊(cè)中心就構(gòu)建完了。

編寫(xiě)微服務(wù)userservice

接下來(lái)用rest構(gòu)建一個(gè)微服務(wù)接口,并注冊(cè)到注冊(cè)中心上去。依然使用Spring Initialzr 來(lái)構(gòu)建一個(gè)新的工程。使用方式跟上面的一樣。

注意這次要勾選Eureka Discovery 組件。而不是Eureka Server 。

修改application.properties文件,添加如下內(nèi)容：

spring.application.name=user 
server.port=8882 
eureka.client.service-url.defaultZone=http://localhost:8881/eureka/

在Spring Boot 為我們生成的UserApplication 類(lèi)中使用@EnableDiscoveryClient 注解。

package com.springcloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

@EnableDiscoveryClient
@SpringBootApplication
public class UserApplication {

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

創(chuàng)建一個(gè)rest full的微服務(wù)接口。

package com.springcloud;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class UserController {

  @GetMapping("/getUser")
  public String getUser() {
    return "I am user list.";
  }
}

運(yùn)行UserApplication后,再次訪問(wèn)http://localhost:8881/

會(huì)發(fā)現(xiàn)user這個(gè)服務(wù)已經(jīng)注冊(cè)上來(lái)了。

編寫(xiě)微服務(wù)order

接下來(lái),我們?cè)贅?gòu)建一個(gè)訂單的微服務(wù),并訪問(wèn)user這個(gè)微服務(wù)中的接口。

依然使用Spring Initialzr 來(lái)構(gòu)建一個(gè)新工程。user這個(gè)微服務(wù)是可以部署到多臺(tái)機(jī)器上的?？蛻舳嗽谠L問(wèn)這個(gè)服務(wù)的時(shí)候，請(qǐng)求可以路由到任何一臺(tái)部署了user服務(wù)的機(jī)器。因此客戶端需要使用一個(gè)路由算法來(lái)調(diào)度user這個(gè)服務(wù)。在Spring Cloud中，可以使用Ribbon組件來(lái)做客戶端路由。Ribbon內(nèi)部會(huì)去服務(wù)注冊(cè)中心獲取服務(wù)列表的，以便調(diào)用對(duì)應(yīng)的服務(wù)。

這次除了勾選Eureka Discovery 組件。還需要勾選Ribbon 。

修改application.properties文件，添加如下內(nèi)容：

spring.application.name=order 
server.port=8883 
eureka.client.service-url.defaultZone=http://localhost:8881/eureka/

在Spring Boot 為我們生成的OrderApplication類(lèi)中增加如下配置。

package com.springboot;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;
@EnableDiscoveryClient
@SpringBootApplication
public class OrderApplication {

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

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

由于使用了Ribbon,這里需要使用@LoadBalanced注解。

編寫(xiě)OrderController。

package com.springboot;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

@RestController
public class OrderController {
  @Autowired
  private RestTemplate restTemplate;

  @GetMapping("/getOrderUser")
  public String getOrderUser() {
    return restTemplate.getForEntity("http://user/getUser",String.class).getBody();
  }
}

運(yùn)行OrderApplication后，訪問(wèn)http://localhost:8881/

會(huì)發(fā)現(xiàn)order這個(gè)服務(wù)也被注冊(cè)到注冊(cè)中心了。