spring cloud学习笔记

上文 使用多个 Eureka Server
下文 使用Feign进行应用间通信

使用RestTemplate进行应用间通信

上文中我们已经准备好了 Eureka Server，在测试环境中，就不需要多个Eureka了，启动一个应用即可，为了方便我们打包运行
java -jar .\target\eureka-0.0.1-SNAPSHOT.jar

我们再创建两个 Spring Boot 项目，分别为product，consumer 并修改配置文件注册到 Eureka 中

eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/

记得在启动类添加注解 @EnableEurekaClient

product项目中

添加controller

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

import javax.servlet.http.HttpServletRequest;

@RestController
public class ServerController {
    @GetMapping("echo")
    public String echoeMessage(HttpServletRequest request){
        return "this is server "+ request.getServerName()+":"+request.getServerPort();
    }
}

consumer 项目中

添加config类，其中@LoadBalanced注解帮助提供一个负载均衡的RestTemplate Bean

import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

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

添加 controller，其中 restTemplate直接在url中用在Eureka中注册的应用名代替地址和端口,在product项目中，我们配置的应用名

spring:
  application:
    name: product

代码调用（应用名不区分大小写）
restTemplate.getForObject("http://product/echo",String.class);

import lombok.extern.slf4j.Slf4j;
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
@Slf4j
public class ClientController {

    private RestTemplate restTemplate;

    @Autowired
    public ClientController(RestTemplate restTemplate) {
        this.restTemplate = restTemplate;
    }

    @GetMapping("/product-msg")
    public String getProductMsg(){
        String resp = restTemplate.getForObject("http://product/echo",String.class);
        log.info("response={}",resp);
        return resp;
    }
}

通过-Dserver.port=xxxx设置不同的端口，启动多个product实例，idea中：

启动consumer，反复请求地址http://localhost:8180/product-msg
将会得到不同的返回：

this is server 192.168.1.107:8081
this is server 192.168.1.107:8080
this is server 192.168.1.107:8081
this is server 192.168.1.107:8080

可以发现，请求在两个服务器间轮换执行
我们可以在client的配置文件中配置负载均衡的规则，我们把负载均衡规则改为 随机

#应用名
PRODUCT:
  ribbon:
    NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

所有规则均在 com.netflix.loadbalancer包下并实现 com.netflix.loadbalancer.IRule接口，默认使用 com.netflix.loadbalancer.RoundRobinRule