Spring Cloud Ribbon实现客户端负载均衡的示例

 更新时间:2018年02月07日 16:33:55   作者:马军伟  
本篇文章主要介绍了Spring Cloud Ribbon实现客户端负载均衡的示例,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧

前面我们已经完成了注册中心和服务提供者两个基础组件。本文就介绍使用Spring Cloud Ribbon在客户端负载均衡的调用服务。

对于大型应用系统负载均衡(LB:Load Balancing)是首要被解决一个问题。在微服务之前LB方案主要是集中式负载均衡方案,在服务消费者和服务提供者之间又一个独立的LB,LB通常是专门的硬件,如F5,或者是基于软件的,如VS、HAproxy等。LB上有所有服务的地址映射表,当服务消费者调用某个目标服务时,它先向LB发起请求,由LB以某种策略(比如:Round-Robin)做负载均衡后将请求转发到目标服务。

而微服务的出现,则为LB的实现提供了另外一种思路:把LB的功能以库的方式集成到服务消费方的进程内,而不是由一个集中的设备或服务器提供。这种方案称为软负载均衡(Soft Load Balancing)或者客户端负载均衡。在Spring Cloud中配合Eureka的服务注册功能,Ribbon子项目则为REST客户端实现了负载均衡。

使用Spring Cloud Ribbon实现服务消费者

新建spring-cloud-sample-tutorial-consumer项目

在spring-cloud-sample-tutorial下新建spring-cloud-sample-tutorial-consumer子项目

添加ribbon和eureka依赖

<dependencies>
 <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>
 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
</dependencies>

配置applicatioin.properties,注册中心地址

spring.application.name=consumer
server.port=30001
eureka.client.service-url.defaultZone=http://localhost:10001/eureka/,http://localhost:10002/eureka/

编写UserController,添加@LoadBalanced注解,启用Ribbon负载均衡

@Controller
@RequestMapping("user")
public class UserController {
 
 @Bean
 @LoadBalanced
 RestTemplate initRestTemplate(){
  return new RestTemplate();
 }
 
 @Autowired
 private RestTemplate restTemplate;
 
 @RequestMapping("add")
 @ResponseBody
 public String add(String userName, String age){
  return restTemplate.getForEntity("http://PRODUCER/user/add",String.class,userName,age).getBody();
 }
}

编写ConsumerApplication,添加@EnableEurekaClient,启用服务注册

@EnableEurekaClient
@SpringBootApplication
public class ConsumerApplication {
 public static void main(String[] args) {
  SpringApplication.run(ConsumerApplication.class,args);
 }
}

集群部署Producer

为了模拟集群的Producer,在producer项目中新建application-profile1.properties和application-profile2.properties。

application-profile1.properties

spring.application.name=producer
server.port=20001
eureka.client.service-url.defaultZone=http://localhost:10001/eureka/,http://localhost:10002/eureka/

application-profile2.properties

spring.application.name=producer
server.port=20002
eureka.client.service-url.defaultZone=http://localhost:10001/eureka/,http://localhost:10002/eureka/

为了测试负载的效果,我们把被调用服务的端口打出来

@Controller
@RequestMapping("user")
public class UserController {
 private Logger logger = LoggerFactory.getLogger(getClass());
 
 @Autowired
 private DiscoveryClient client;
 @RequestMapping("add")
 @ResponseBody
 public String addUser(String userName, String age) {
  return "Success from " + client.getLocalServiceInstance().getHost() + ":" + client.getLocalServiceInstance().getPort() ;
 }
}

启动测试

启动注册中心

分别配置Active Profiles为profile1和profile2,启动两次,完成注册中心集群的服务启动。

启动服务提供者

按上面同样的方法,启动服务提供者。

启动服务消费者

服务提供者单机就可以了,正常启动ConsumerApplication即可。

验证

从浏览器输入http://localhost:30001/user/add

再次访问:

可以看到,我们的负载均衡调用服务,已经成功了,默认是按轮训的方式做负载均衡。

总结

本文介绍并完成了使用Spring Cloud Ribbon进行客户端负载均衡的调用。

接下来我们继续介绍怎么使用Spring Cloud进行服务监控。

源码下载

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

相关文章

  • Spring MVC的web.xml配置详解

    Spring MVC的web.xml配置详解

    这篇文章主要介绍了Spring MVC的web.xml配置详解,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-06-06
  • windows java -jar无法启动jar包简单的解决方法

    windows java -jar无法启动jar包简单的解决方法

    这篇文章主要介绍了windows java -jar无法启动jar包简单的解决方法,文中通过代码介绍的非常详细,对大家学习或者使用java具有一定的参考借鉴价值,需要的朋友可以参考下
    2024-12-12
  • 详解SpringMVC解决跨域的两种方案

    详解SpringMVC解决跨域的两种方案

    本篇文章主要介绍了详解SpringMVC解决跨域的两种方案,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-08-08
  • springMvc全局异常的实现

    springMvc全局异常的实现

    大家好,本篇文章主要讲的是springMvc全局异常的实现,感兴趣的同学赶紧来看一看吧,对你有帮助的话记得收藏一下
    2022-02-02
  • Java多线程编程实现socket通信示例代码

    Java多线程编程实现socket通信示例代码

    这篇文章主要介绍了Java多线程编程实现socket通信示例代码,详细介绍了tcp、udp协议,以及基于socket的Java网络编程的相关内容及代码示例,代码测试可用,供大家参考。
    2017-10-10
  • 基于java实现停车场管理系统

    基于java实现停车场管理系统

    这篇文章主要为大家详细介绍了基于java实现停车场管理系统,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2019-11-11
  • Mybatis如何传入多个参数(实体类型和基本类型)

    Mybatis如何传入多个参数(实体类型和基本类型)

    这篇文章主要介绍了Mybatis如何传入多个参数(实体类型和基本类型),具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-06-06
  • Java深入了解数据结构之哈希表篇

    Java深入了解数据结构之哈希表篇

    哈希表是一种根据关键码去寻找值的数据映射结构,该结构通过把关键码映射的位置去寻找存放值的地方,说起来可能感觉有点复杂,我想我举个例子你就会明白了,最典型的的例子就是字典
    2022-01-01
  • Java中HashMap的put过程详解

    Java中HashMap的put过程详解

    这篇文章主要介绍了Java中HashMap的put过程详解,HashMap有4个构造器,其他构造器如果用户没有传入initialCapacity 和loadFactor这两个参数,会使用默认值一般如果new HashMap()不传值,需要的朋友可以参考下
    2023-07-07
  • Spring Boot两种配置文件properties和yml区别

    Spring Boot两种配置文件properties和yml区别

    这篇文章主要为大家介绍了java面试中常见问到的Spring Boot两种配置文件properties和yml区别解答,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-07-07

最新评论