您的位置：首页 > 编程语言 > Java开发

SpringCloud（四）之Ribbon（详解和搭建服务和消费端）

2018-12-19 15:29 507 查看

转载请注明出处：https://blog.csdn.net/weixin_41133233/article/details/85070323
本文出自 程熙cjp 的博客

继上一篇搭建高可用的Eureka集群之后，本篇小熙将详解Ribbon和搭建搭建服务和消费端

一. Ribbon简介

Spring Cloud Ribbon是一个基于HTTP和TCP的客户端负载均衡工具，它基于Netflix Ribbon实现。通过Spring Cloud的封装，可以让我们轻松地将面向服务的REST模版请求自动转换成客户端负载均衡的服务调用。Spring Cloud Ribbon虽然只是一个工具类框架，它不像服务注册中心、配置中心、API网关那样需要独立部署，但是它几乎存在于每一个Spring Cloud构建的微服务和基础设施中。因为微服务间的调用，API网关的请求转发等内容，实际上都是通过Ribbon来实现的，包括后续我们将要介绍的Feign，它也是基于Ribbon实现的工具。所以，对Spring Cloud Ribbon的理解和使用，对于我们使用Spring Cloud来构建微服务非常重要。

二. 搭建服务消费者

由于要展示负载均衡，所以我们还需要在上一个项目中继续搭建服务消费和服务提供者去演示。

消费端源码在GitHub上：user_consumer源代码

  1. 第一步

    在上面搭建的Eureka项目中点击File，点击New，点击Module。为了更好的展示在本项目中创建出来。

  2. 第二步

    点击SpringBoot脚手架工具，然后点击下一步。

  3. 第三步

    根据个人喜好修改Group和Artifact，之后点击下一步。

  4. 第四步

    注意这里还是看个人喜好选择，后面小熙还是会附上pom文件建议对比下。

  5. 第五步

    注意，这里需要把 eureka_test\ 删除掉，因为需要和Eureka项目同一位置展示，所以路径前缀需要一致（下面的同理）。

  6. 创建结果如图

  7. pom文件

<?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.chengxi</groupId>
<artifactId>user_consumer</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>

<name>user_consumer</name>
<description>Demo project for Spring Boot</description>

<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.1.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>

<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
</properties>

<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>

<!--配置httpclient，用于项目间调用-->
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.4</version>
</dependency>

<!--自定义配置set和get-->
<dependency>
<groupId>lombok</groupId>
<artifactId>lombok</artifactId>
<version>1.0</version>
</dependency>

<!-- Eureka客户端 ，用于注册服务与发现-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

</dependencies>

<!-- SpringCloud的依赖版本管理 -->
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Finchley.RC1</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>

<!--SpringCloud的官网仓库地址，这里是配置仓库的方法之一。在项目中配置仅作用于当前项目，在下载坐标时优先从这里配置的仓库中查找，如果没有再从本地配置的仓库查找-->
<repositories>
<repository>
<id>spring-milestones</id>
<name>Spring Milestones</name>
<url>https://repo.spring.io/milestone</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
</repository>
</repositories>

<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>

</project>

  1. 解释为什么不用引入Ribbon坐标

    如图所示，在引入的Eureka客户端的坐标中，已经整合了Ribb 4000 on的坐标

  2. yml配置文件

server:
port: 8094
spring:
application:
#   注册服务的名称，注意服务器名称不能使用下划线连接，可以使用中划线连接
name: user-consumer
cloud:
# 开启SpringCloud负载均衡中的重试功能，ribbon中整合了（默认是重试到熔断机制的时间1秒），但是zuul整合时需要指定
loadbalancer:
retry:
enabled: true # 开启Spring Cloud的重试功能
user-service:   # 注意这是提供某一服务系统的服务名称，仅对这一服务起作用，不能随意抒写
ribbon:
NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule  # 修改ribbon中默认的轮询为随机（采用spring系统提供包）
ConnectTimeout: 250 # Ribbon的连接超时时间
ReadTimeout: 1000 # Ribbon的数据读取超时时间
OkToRetryOnAllOperations: true # 是否对所有操作都进行重试
MaxAutoRetriesNextServer: 1 # 切换实例的重试次数
MaxAutoRetries: 1 # 对当前实例的重试次数
eureka:
client:
#    注册eureka的地址
service-url:
defaultZone: http://127.0.0.1:8090/eureka,http://127.0.0.1:8091/eureka,http://127.0.0.1:8092/eureka
instance:
#   当其它服务获取地址时提供ip而不是hostname
prefer-ip-address: true
#   指定自己的ip信息，不指定的话会自己寻找
ip-address: 127.0.0.1
# 日志级别下也可以指定执行的包名
logging:
level:
com.chengxi: debug
  1. 修改SpringBoot启动类
package com.chengxi;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

@SpringBootApplication
@EnableDiscoveryClient     // 开启eureka客户端（服务消费者）
public class UserConsumerApplication {

/**
*  在SpringCloud中使用Ribbon，
*  需要在httpclient配置文件中的restTemplate的返回方法上添加@LoadBalanced注解
*  在使用这个restTemplate发出请求时都会被拦截处理再发出，具体看ribbon配置和源码
* @return
*/
@Bean
@LoadBalanced
public RestTemplate restTemplate(){
return new RestTemplate();
}

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

嗯，至此关于Ribbon的服务者消费者及搭建成功了。

注册结果如图：

三. 搭建服务提供者

有消费者肯定会有提供者提供服务的，所以接下来搭建本demo案例的最后一个项目user_service

项目源码在GitHub上：user_service源码

  1. 第一步

    同样在eureka的项目位置上再创建一个服务提供项目，点击File、点击New、点击Module

  2. 第二步

    使用SpringBoot脚手架工具创建项目，点击下一步

  3. 第三步

    根据个人喜好修改Group和Artifact，然后点击下一步

  4. 第四步

    同样可以在这里选择坐标，之后小熙还会附上本项目的pom文件，建议对比下

  5. 第五步

    注意这里项目路径的前缀一定要和eureka项目路径的前缀一致，因为这样才能在一个idea窗口展示多个同级项目，而不是父子项目。

  6. 创建成功展示图

  7. pom文件

    使用mysql连接数据库，导入了相关坐标

    <?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.chengxi</groupId>
<artifactId>user_service</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>

<name>user_service</name>
<description>Demo project for Spring Boot</description>

<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.1.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>

<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
</properties>

<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>1.3.2</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<scope>runtime</scope>
<version>5.1.32</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>tk.mybatis</groupId>
<artifactId>mapper-spring-boot-starter</artifactId>
<version>2.0.2</version>
</dependency>
<!--配置druid连接池-->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.1.10</version>
</dependency>
<!--自定义配置set和get-->
<dependency>
<groupId>lombok</groupId>
<artifactId>lombok</artifactId>
<version>1.0</version>
</dependency>
<!-- Eureka客户端 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
</dependencies>

<!-- SpringCloud的版本依赖管理 -->
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Finchley.RC1</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>

<!--SpringCloud的官网仓库地址，这里是配置仓库的方法之一。在项目中配置仅作用于当前项目，在下载坐标时优先从这里配置的仓库中查找，如果没有再从本地配置的仓库查找-->
<repositories>
<repository>
<id>spring-milestones</id>
<name>Spring Milestones</name>
<url>https://repo.spring.io/milestone</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
</repository>
</repositories>

<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>

</project>

  8. yml文件

    server:
port: 8093
spring:
datasource:
driver-class-name: com.mysql.jdbc.Driver
url: jdbc:mysql://localhost:3306/vue01?useUnicode=true&characterEncoding=utf8
username: root
password: xxxxxxxxxxx
druid:
initial-size: 1
min-idle: 1
max-active: 20
test-on-borrow: true
stat-view-servlet:
allow: true
application:
#    注意服务器名称不能使用下划线连接，可以使用中划线连接
name: user-service
eureka:
client:
service-url:
#     eureka注册的地址，根据这个地址去注册
defaultZone: http://127.0.0.1:8090/eureka,http://127.0.0.1:8091/eureka,http://127.0.0.1:8092/eureka
instance:
#   其他服务获取此服务时不响应服务名称，而是响应该服务的ip
prefer-ip-address: true
#   指定自己的ip信息，不指定的话会自己寻找
ip-address: 127.0.0.1
#   服务失效时间，默认值90秒
lease-expiration-duration-in-seconds: 90
#   服务续约(renew)的间隔，默认为30秒
lease-renewal-interval-in-seconds: 30

  9. 修改SpringBoot启动配置类

    package com.chengxi;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import tk.mybatis.spring.annotation.MapperScan;

@SpringBootApplication
@EnableEurekaClient      // 启动SpringCloud客户端（提供端）
@MapperScan(basePackages = "com.chengxi.dao")     // 这是用于扫描mapper的
public class UserServiceApplication {

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

嗯，至此小熙分享的Ribbon概念和搭建服务和消费端就介绍完了。下篇将详细介绍负载均衡和剖析源码

ps：数据库表下章给哟

内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 点击这里给我发消息
标签： 
相关文章推荐
新的分享
章节导航