说明:
ribbon是spring-cloud中作为服务消费者的一种角色,客户端可以通过它来对服务提供者的服务进行消费,
比如本例中是服务提供者注册到注册中心,服务提供者提供了一个服务接口,返回一个hello字符串,我们通过ribbon将这个接口调用,再不暴露真实服务提供者的地址的同时,获取服务提供者的服务
前提:
按照之前几个教程,搭建出注册中心、服务提供者。这里可以使用分片的注册中心,也可以不使用,这里暂时定为使用之前搭好的分片注册中心,服务提供者仅提供一个即可。
准备工作:
1、启动注册中心
按照之前的教程,分别使用peer1和peer2进行启动两个分片的注册中心,如果是单节点直接启动项目即可
启动后可以查看下localhost:1111或localhost:1112,如图
2、启动服务提供者
这里为了查看负载均衡的情况,所以需要启动两个服务提供者
按照之前教程中,分别开启两个terminal进行指定端口启动(两个相同的服务也可以在各自的配置文件中配置不同的端口),两个终端指令分别如下:
cd target java -jar SpringCloudDemo-0.0.1-SNAPSHOT.jar --server.port=8080
cd target java -jar SpringCloudDemo-0.0.1-SNAPSHOT.jar --server.port=8081
启动结果:
至此,准备工作已经完成
正文:
1、ribbon服务搭建
新建一个maven项目,不使用模板即可。项目名为robbin-customer,导入依赖参考如下:
<?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.hellxz</groupId> <artifactId>ribbon-customer</artifactId> <version>1.0-SNAPSHOT</version> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>1.5.9.RELEASE</version> <relativePath/> </parent> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka</artifactId> <version>RELEASE</version> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-ribbon</artifactId> <version>RELEASE</version> </dependency> </dependencies> <dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>RELEASE</version> <scope>import</scope> <type>pom</type> </dependency> </dependencies> </dependencyManagement> </project>
新建springboot启动类,将RestTemplate交给Spring容器进行管理
package com.cnblogs.hellxz; 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; /** * @Author : Hellxz * @Description: 消费应用 * @Date : 2018/4/16 15:45 */ @EnableDiscoveryClient @SpringBootApplication public class CustomerApplication { @Bean //将此Bean交给spring容器 @LoadBalanced //通过此注解开启负载均衡 RestTemplate restTemplate(){ return new RestTemplate(); } public static void main(String[] args) { SpringApplication.run(CustomerApplication.class, args); } }
在src/resources目录下创建一个application.yml进行配置注册信息相关,本文使用了分片的注册中心,单节点请配置一个defaltZone即可
server: port: 9000 #为ribbon-customer指定服务端口 spring: application: name: ribbon-customer #指定应用名 #指定eureka注册中心地址 eureka: client: serviceUrl: defaultZone: http://peer1:1111/eureka/,http://peer2:1112/eureka/
在启动类同级目录创建CustomerController,注入RestTemplate进行调用服务接口
package com.cnblogs.hellxz; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.client.RestTemplate; /** * @Author : Hellxz * @Description: 消费者应用 * @Date : 2018/4/16 15:54 */ @RestController public class CustomerController { @Autowired //注入restTemplate private RestTemplate restTemplate; @RequestMapping(value="/ribbon-customer", method=RequestMethod.GET) public String helloCustomer(){ //这里注释掉,因为之前想当然使用了直链访问服务提供者的接口,这样是不会返回结果的,而且会报错 //return restTemplate.getForEntity("http://localhost:8080/hello",String.class).getBody(); //使用restTemplate调用微服务接口 return restTemplate.getForEntity("http://hello-service/hello", String.class).getBody(); } }
注意:上述代码第24行给出了一个错误的演示,如果出现访问ribbon接口报错,出现白色报错页面,请检查这里
至此ribbon消费者应用搭建完成,启动测试
测试:
访问http://localhost:1111/ 我们发现这个ribbon消费者应用已经注册到注册中心中了
访问http://localhost:9000/ribbon-customer
还记得服务提供者项目中的如图方法中如果有访问则会打印信息,因为启动了两个服务提供者,这里可以测试ribbon的负载均衡
查看服务提供者输出
而第二个终端没有,依旧显示到Resolving eureka endpoints via configuration这行
刷新页面查看终端,由于ribbon的默认负载均衡的实现是轮询的,所以可能出现多次访问同一服务,多刷新几次页面,一定会在另一个Termical中显示的!
结语:
Ribbon作为服务消费者,可以在用户获取到服务提供者提供的服务的同时,不向用户暴露接口地址。可以看到,这里调用服务接口的时候使用的是服务提供者的服务名代替主机名,这在服务治理框架中,这种特性很重要。
由于本人之前是先学的jhipster生成器,所以,提前预报一下,之后还会有一种名为Feign的技术可以替代Ribbon,本系列博客均为学习笔记,实际操作中,可能会存在一个应用既是服务提供者又是服务消费者的情况。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持小牛知识库。
本文向大家介绍Spring Cloud EureKa Ribbon 服务注册发现与调用,包括了Spring Cloud EureKa Ribbon 服务注册发现与调用的使用技巧和注意事项,需要的朋友参考一下 概述 用一个简单的例子演示Spring Cloud中EureKa和Ribbon的基本用法。 版本和环境 IDEA Spring Boot 1.5.·0 JDK 1.8 Maven 3 构建eu
Ribbon介绍 Ribbon是Netflix发布的开源项目,主要功能是提供客户端的软件负载均衡算法,将Netflix的中间层服务连接在一起。Ribbon客户端组件提供一系列完善的配置项如连接超时,重试等。简单的说,就是在配置文件中列出Load Balancer后面所有的机器,Ribbon会自动的帮助你基于某种规则(如简单轮询,随机连接等)去连接这些机器。我们也很容易使用Ribbon实现自定义的负
上文我们创建了注册中心,以及服务的提供者microservice-provider-user,并成功地将服务提供者注册到了注册中心上。 要想消费microservice-provider-user的服务是很简单的,我们只需要使用RestTemplate即可,或者例如HttpClient之类的http工具也是可以的。但是在集群环境下,我们必然是每个服务部署多个实例,那幺服务消费者消费服务提供者时的负
1、前言 本文通过创建 provider-service、consumer-service 两个微服务,并通过 feign 接口调用来演示 Spring Cloud 整合 Consul。阅读本文需要前置知识: Spring Boot Spring Cloud Spring Cloud Feign 2、搭建 provider-service 服务 2.1、创建 maven 模块 创建provider
主要内容:负载均衡,Ribbon 实现服务调用,Ribbon 实现负载均衡,切换负载均衡策略,定制负载均衡策略Spring Cloud Ribbon 是一套基于 Netflix Ribbon 实现的客户端负载均衡和服务调用工具。 Netflix Ribbon 是 Netflix 公司发布的开源组件,其主要功能是提供客户端的负载均衡算法和服务调用。Spring Cloud 将其与 Netflix 中的其他开源服务组件(例如 Eureka、Feign 以及 Hystrix 等)一起整合进 Sprin
简介 ribbon用以实现负载均衡;实现软负载均衡,核心有三点: 服务发现,发现依赖服务的列表 服务选择规则,在多个服务中如何选择一个有效服务 服务监听,检测失效的服务,高效剔除失效服务 netflix ribbon 一个简单的demo 配置文件: # Max number of retries on the same server (excluding the first try) sampl