目录

• 1. HelloWorld
• • 1.1 Server
  • • 1.1.1 依赖
    • 1.1.2 EurekaServer
  • 1.2 Product微服务
  • • 1.2.1 依赖
    • 1.2.2 配置文件
    • 1.2.3 Controller
  • 1.3 User微服务
  • • 1.3.1 依赖
    • 1.3.2 配置文件
    • 1.3.3 RestTemplate
    • 1.3.4 Controller

1. HelloWorld

如果使用Eureka作为服务发现，则默认情况下加入spring-cloud-starter-netflix-eureka-client依赖后会自动加入LoadBalance的功能，因此本文主要是分析默认情况下SpringCloud使用的负载均衡。下面以HelloWorld进入LoadBalance的世界

1.1 Server

1.1.1 依赖

org.springframework.bootspring-boot-starter-weborg.springframework.cloudspring-cloud-starter-netflix-eureka-server   

1.1.2 EurekaServer

@SpringBootApplication
// 为了简便我们使用EurekaServer
@EnableEurekaServer
public class EurekaServeApplication {public static void main(String[] args) {SpringApplication.run(EurekaServeApplication.class, args);}}

启动server

1.2 Product微服务

1.2.1 依赖

org.springframework.bootspring-boot-starter-weborg.springframework.cloudspring-cloud-starter-netflix-eureka-client   

1.2.2 配置文件

spring:application:name: productserver:port: ${port}eureka:client:service-url:defaultZone: http://localhost:3333/eureka/

这里product我们要起两个实例，以端口不同作为区别：5001、5002。

application-peer1.yml

port: 5001

如果是Eclipse，在启动时添加-Dspring.profiles.active=peer1参数

application-peer2.yml

port: 5002

1.2.3 Controller

@RestController
@RequestMapping("/prod")
public class ProductController {@GetMappingpublic int getProduct(HttpServletRequest request) {// 直接返回端口号以示区别return request.getLocalPort();}}

1.3 User微服务

1.3.1 依赖

org.springframework.bootspring-boot-starter-weborg.springframework.cloudspring-cloud-starter-netflix-eureka-client   

1.3.2 配置文件

spring:application:name: userserver:port: 2222eureka:client:service-url:defaultZone: http://localhost:3333/eureka/

1.3.3 RestTemplate

@SpringBootApplication
public class EurekaClientApplication {public static void main(String[] args) {SpringApplication.run(EurekaClientApplication.class, args);}@LoadBalanced // 负载均衡@Beanpublic RestTemplate restTemplate() {return new RestTemplate();}
}

1.3.4 Controller

@RestController
@RequestMapping("/user")
public class UserController {@AutowiredRestTemplate restTemplate;@GetMappingpublic void getProduct() {// 调用Product微服务获取值String result = restTemplate.getForObject("http://product/prod", String.class);System.out.println(result);}
}

所有服务都启动后，在浏览器输入http://localhost:2222/user，按下回车键。为了看到负载均衡的效果，我们连续按下10次回车，再看下输出结果

5001
5002
5001
5002
5001
5002
5001
5002
5001
5002

从结果我们看到默认情况下是轮询这调用Product微服务，那么它是如何实现的呢？答案是通过intercept被@LoadBalanced的restTemplate的请求。

未完待续