`

Spring cloud eureka feign ribbon

springeurekafeignribbon 
阅读更多
Ribbon提供一种客户端的负载均衡技术，实现和集群中的服务通信。包含了三种组件
  • Rule 一个逻辑组件用来确定从服务列表中获取哪一个服务
  • Ping 运行在后台的组件，用来确定服务是否可用
  • ServerList 一个后台线程，可以以特定的频率来刷新和过滤服务，可以是静态的也可以是动态的


这些组件既可以通过API方式设定，也可以在配置文件中设定在通过反射方式创建。

1.Common rules
  • RoundRobinRule 这个策略通过简单的轮询策略来选择服务，常常作为默认策略或者是高级策略的后备策略使用
  • AvailabilityFilteringRule 这个策略将跳过那些被认为路由断开的或者是高并发连接数的server instance
  • WeightedResponseTimeRule 这个策略通过利用服务的平均响应时间来得到一个权重，响应时间越长的权重越小，依据权重再随机的挑选一个策略


    • 2.ServerList
  • Adhoc static server list 利用BaseLoadBalancer.setServersList()API设定一个静态的服务列表
  • ConfigurationBasedServerList 默认的ServerList实现方式，可以通过下面的方式设定 
    • sample-client.ribbon.listOfServers=www.microsoft.com:80,www.yahoo.com:80,www.google.com:80
  • DiscoveryEnabledNIWSServerList 这中ServerList实现方式从 Eureka client中获取服务列表，在spring boot程序中，当Eureka相应的jar在classpath中存在，会默认采用这种策略

    • 3.ServerListFilter
    该组件是DynamicServerListLoadBalancer用来在ServerList过滤服务的组件，有以下两种实现方式
  • ZoneAffinityServerListFilter 过滤掉那些和client不在同一个zone的服务，除非client所在的zone中没有可用的server，通过以下方式可以启用 
    • myclient.ribbon.EnableZoneAffinity=true
  • ServerListSubsetFilter 这个过滤器确保client只能访问到服务集合中的一个特定子集，并能周期性的不好用的服务替换掉，通过以下方式可以启用 
    • myClient.ribbon.NIWSServerListClassName=com.netflix.niws.loadbalancer.DiscoveryEnabledNIWSServerList 
# the server must register itself with Eureka server with VipAddress "myservice"
myClient.ribbon.DeploymentContextBasedVipAddresses=myservice
myClient.ribbon.NIWSServerListFilterClassName=com.netflix.loadbalancer.ServerListSubsetFilter
# only show client 5 servers. default is 20.
myClient.ribbon.ServerListSubsetFilter.size=5




    例子
  • 1. Eureka server
    • 核心是在正常的Spring boot程序中加入spring-cloud-starter-eureka-server依赖，在启动类中加入@EnableEurekaServer 注解
  • 代码结构：



  • 启动类 
    • package hello;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

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

  • 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.example</groupId>
	<artifactId>eureka-service</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	<packaging>jar</packaging>

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

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

	<dependencies>
		<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-starter-eureka-server</artifactId>
		</dependency>

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

	<dependencyManagement>
		<dependencies>
			<dependency>
				<groupId>org.springframework.cloud</groupId>
				<artifactId>spring-cloud-dependencies</artifactId>
				<version>Camden.SR5</version>
				<type>pom</type>
				<scope>import</scope>
			</dependency>
		</dependencies>
	</dependencyManagement>

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

	<repositories>
		<repository>
			<id>spring-snapshots</id>
			<name>Spring Snapshots</name>
			<url>https://repo.spring.io/libs-snapshot</url>
			<snapshots>
				<enabled>true</enabled>
			</snapshots>
		</repository>
	</repositories>

</project>

  • 应用配置信息 
    • server.port=8761

eureka.client.register-with-eureka=false
eureka.client.fetch-registry=false

logging.level.com.netflix.eureka=OFF
logging.level.com.netflix.discovery=OFF

  • 2.Eureka client（即user server端）
    • 核心是在正常的Spring boot程序中加入spring-cloud-starter-eureka依赖，在启动类中加入@EnableDiscoveryClient注解
  • 代码结构：



  • 启动类 
    • package hello;

import java.util.Arrays;
import java.util.List;
import java.util.Random;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@EnableDiscoveryClient
@SpringBootApplication
public class SayHelloApplication {

  private static Logger log = LoggerFactory.getLogger(SayHelloApplication.class);

  @RequestMapping(value = "/greeting")
  public String greet() {
    log.info("Access /greeting");

    List<String> greetings = Arrays.asList("Hi there", "Greetings", "Salutations");
    Random rand = new Random();

    int randomNum = rand.nextInt(greetings.size());
    return greetings.get(randomNum);
  }

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

  • 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>hello</groupId>
	<artifactId>say-hello</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	<packaging>jar</packaging>

	<name>say-hello</name>
	<description>Demo project for Spring Boot</description>

	<parent>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-parent</artifactId>
		<version>1.5.1.RELEASE</version>
		<relativePath /> <!-- lookup parent from repository -->
	</parent>
	<dependencyManagement>
		<dependencies>
			<dependency>
				<groupId>org.springframework.cloud</groupId>
				<artifactId>spring-cloud-dependencies</artifactId>
				<version>Camden.SR5</version>
				<type>pom</type>
				<scope>import</scope>
			</dependency>
		</dependencies>
	</dependencyManagement>

	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		<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>

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

		<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-starter-eureka</artifactId>
		</dependency>
	</dependencies>

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


</project>

  • 应用配置信息（因为在一台机器上模拟server cluster 所以用了三个profile 分别对应三个port） 
    • eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/
  instance:
    leaseRenewalIntervalInSeconds: 10
    metadataMap:
      instanceId: ${vcap.application.instance_id:${spring.application.name}:${spring.application.instance_id:${server.port}}}

endpoints:
  restart:
    enabled: true
  shutdown:
    enabled: true
  health:
    sensitive: false

---
spring:
  application:
    name: say-hello
  profiles: one
server:
  port: 8090

---
spring:
  application:
    name: say-hello
  profiles: two
server:
  port: 9092

---
spring:
  application:
    name: say-hello
  profiles: three
server:
  port: 9999

  • 3.User client（调用注册到Eureka server中的Eureka client）
    • 核心是在正常的Spring boot程序中加入spring-cloud-starter-eureka、spring-cloud-starter-feign、spring-cloud-starter-ribbon依赖，在启动类中加入@EnableFeignClients、@RibbonClient(name = "say-hello")注解
  • 代码结构：




  • 启动类 
    • package hello;

import static org.springframework.web.bind.annotation.RequestMethod.GET;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.feign.EnableFeignClients;
import org.springframework.cloud.netflix.feign.FeignClient;
import org.springframework.cloud.netflix.ribbon.RibbonClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@SpringBootApplication
@RestController
@RibbonClient(name = "say-hello")
@EnableFeignClients
public class UserApplication {

	@Autowired
	HelloClient client;

	@RequestMapping("/greeting")
	public String hello() {
		return client.greet();
	}

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

	@FeignClient(name = "say-hello")
	interface HelloClient {
		@RequestMapping(value = "/greeting", method = GET)
		String greet();
	}
}


    FeignClient、RibbonClient中的service id要和Eureka client配置信息中的spring.application.name的值保持一致


  • 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>hello</groupId>
	<artifactId>user</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	<packaging>jar</packaging>

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

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

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

	<dependencies>
		<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>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-actuator</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-starter-feign</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-starter-eureka</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-test</artifactId>
			<scope>test</scope>
		</dependency>
	</dependencies>

	<dependencyManagement>
		<dependencies>
			<dependency>
				<groupId>org.springframework.cloud</groupId>
				<artifactId>spring-cloud-dependencies</artifactId>
				<version>Camden.SR5</version>
				<type>pom</type>
				<scope>import</scope>
			</dependency>
		</dependencies>
	</dependencyManagement>

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

	<repositories>
		<repository>
			<id>spring-snapshots</id>
			<name>Spring Snapshots</name>
			<url>https://repo.spring.io/snapshot</url>
			<snapshots>
				<enabled>true</enabled>
			</snapshots>
		</repository>
		<repository>
			<id>spring-milestones</id>
			<name>Spring Milestones</name>
			<url>https://repo.spring.io/milestone</url>
			<snapshots>
				<enabled>false</enabled>
			</snapshots>
		</repository>
	</repositories>

</project>

  • 应用配置信息 
    • spring:
  application:
    name: user

server:
  port: 8888

say-hello:
  ribbon:
    ServerListRefreshInterval: 15000

eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/
  instance:
    leaseRenewalIntervalInSeconds: 10
    metadataMap:
      instanceId: ${vcap.application.instance_id:${spring.application.name}:${spring.application.instance_id:${server.port}}}



    三、启动
    按下面的顺序启动
    Eureka server ->Eureka client（say-hello）-> user client(user)
    其中Eureka client 启动时分别用
    --spring.profiles.active=one
    --spring.profiles.active=two
    --spring.profiles.active=three
    启动三个服务，注册到eureka中

    等所有应用都启动后通过界面访问http://localhost:8888/greeting，可以正常访问Eureka client中的方法返回值，整个流程是 界面访问 user client 工程中的hello方法，user client通过@FeignClient中指定的service id从Eureka server中获取到注册的 say-hello instance，因为我们注册到Eureka中的say-hello实例有三个，此处会利用Ribbon的RoundRobinRule规则获取一个实例，调用对应的greet()方法，返回调用结果给 user client，最终返回界面


    • 大小: 38 KB
    • 大小: 9 KB
    • 大小: 8.5 KB
    • 大小: 8 KB
    • 大小: 6.1 KB
    分享到：
    | Spring cloud eureka feign
    评论
    发表评论

    您还没有登录,请您登录后再发表评论

    相关推荐

      spring cloud eureka zuul ribbon hystrix feign config 示例

      在给定的标题和描述中，我们看到了几个关键组件：Eureka、Zuul、Ribbon、Hystrix 和 Feign，这些都是Spring Cloud生态中的重要组成部分。下面将详细阐述这些组件及其在实际应用中的作用。 1. **Eureka**：它是...

      微服务springcloud之feign使用demo

      RS注解，SpringCloud又为Feign增加了对SpringMVC注解的支持，同时为了能够使用和Spring Web中默认使用的相同的httpMessageConverter，SpringCloud集成了Ribbon和Eureka，用来在使用Feign时能够为其提供一个负载均衡...

      SpringCloud eureka mybatis zuul feign

      在这个项目中，我们关注的是SpringCloud Eureka、Zuul、Feign以及它们在负载均衡中的应用。 1. **SpringCloud Eureka**： Eureka是SpringCloud的一个核心组件，它作为服务注册与发现的工具。每个微服务启动时，...

      springcloud+eureka+ribbon整合

      Eureka是SpringCloud中的服务发现组件，而Ribbon是客户端负载均衡器。本文将详细介绍如何将这三个组件整合在一起，以及它们在实际应用中的工作原理和配置。 **Eureka服务发现** Eureka是Netflix开源的一个基于REST...

      springboot+springcloud+eureka+ribbon/feign

      总结来说，"springboot+springcloud+eureka+ribbon/feign"的组合，为构建高可用、可伸缩的微服务架构提供了强大的支持。通过服务注册与发现、客户端负载均衡，我们可以轻松管理分布式系统中的服务，提高系统的稳定性...

      springcloud全家桶(eureka+ribbon+feign+hystrix+turbine)

      spring cloud eureka，服务注册和服务发现 spring cloud config，动态配置项 ribbon，客户端负载均衡 feign， hystrix，熔断 turbine Spring Cloud Starters 同一个服务中的多数据库支持（AOP） 全链路traceId追踪 ...

      springcloud+eureka+ribbon+feign搭建 分布式项目.zip

      本项目"springcloud+eureka+ribbon+feign搭建 分布式项目.zip"旨在利用Spring Boot、Spring Cloud Eureka、Ribbon以及Feign组件创建一个完整的微服务架构。下面将详细解释这些组件以及它们在项目中的作用。 **1. ...

      springCloud 框架，整合feign，ribbon，熔断器

      在本项目中，我们关注的是如何整合 Feign、Ribbon 和熔断器，这些都是 SpringCloud 生态系统中的关键组件。 1. **Eureka**：Eureka 是 Netflix 提供的服务注册与发现组件。在分布式系统中，服务之间需要互相调用，...

      springcloud-ribbon-feign-hystrix-zuul-config

      在Spring Cloud框架中，"springcloud-ribbon-feign-hystrix-zuul-config"这个标题涉及到四个关键组件：Ribbon、Feign、Hystrix和Zuul，以及配置管理Config。这些组件都是构建分布式系统时常用的服务发现、客户端负载...

      Spring Cloud eureka服务注册DEMO

      Spring Cloud提供了Ribbon和Feign这两个客户端负载均衡器，它们与Eureka结合使用，可以自动选择服务实例进行请求。Ribbon是低级库，适用于自定义客户端，而Feign是基于Ribbon的声明式HTTP客户端，使得服务调用更加...

      Spring Cloud微服务eureka+ribbon+feign案例代码.zip

      在Spring Cloud中，Ribbon与Eureka结合，可以在调用服务时自动从Eureka注册表中获取服务实例列表，并根据一定的策略（如轮询、随机等）选择一个实例进行请求。Ribbon提供了多种负载均衡策略，开发者可以根据需求进行...

      SpringCloud Eureka集群项目

      6. **客户端负载均衡**：服务消费者使用Ribbon或Feign等组件进行客户端负载均衡，从Eureka获取服务实例列表后，根据策略选择一个服务实例进行请求。 7. **断路器机制**：为了提高系统的容错能力，可以结合Hystrix...

      spring cloud netflix eureka ribbon 示例

      4. 在服务消费者的代码中，使用RestTemplate或Feign Client（Spring Cloud的另一种服务调用方式，也支持Ribbon）发起对服务提供者的请求，Ribbon会在幕后自动处理负载均衡。 通过这个示例，我们可以学习到如何在...

      springcloud+eureka+feign负载均衡

      在Spring Cloud Eureka和Feign的结合使用中，负载均衡主要通过Ribbon实现。Ribbon是Netflix提供的一款客户端负载均衡器，它可以与Eureka结合，动态地从Eureka Server获取服务列表，然后在调用服务时根据预设策略选择...

      spring cloud eureka ribbon实现的负载均衡balance

      在Spring Cloud的配置中，我们通常会使用Feign或RestTemplate这样的客户端库来与Eureka和Ribbon集成，它们会自动处理服务发现和负载均衡的过程。例如，使用Feign，我们只需定义一个接口，声明服务提供者的API方法，...

      解决Spring Cloud中Feign/Ribbon第一次请求失败的方法

      在Spring Cloud微服务架构中，Feign和Ribbon是两个重要的组件。Feign是一个声明式Web服务客户端，它使得编写Web服务客户端变得简单。Ribbon则是一个客户端负载均衡器，负责在众多的服务实例中选择一个进行请求。然而...

      SpringCloud案例(集成了Eureka、Ribbon、Feign)

      **SpringCloud案例(集成了Eureka、Ribbon、Feign)** 在分布式系统中，Spring Cloud作为一套微服务解决方案，提供了丰富的组件来帮助开发者构建可扩展的云原生应用。本案例聚焦于Spring Cloud的核心组件——Eureka、...

      Spring Cloud 之 Eureka集群整合Zuul、Feign-源码

      在本教程中，我们将深入探讨如何在Spring Cloud框架下实现Eureka集群，并整合Zuul和Feign。首先，我们要理解这些组件的核心功能。 **Eureka**是Spring Cloud中的服务发现组件，它允许微服务之间互相发现并进行通信...

      spring cloud 组件整合 eureka gateway feign hystrix，各个模的整合，供大家一起学习

      在Spring Cloud生态系统中，Eureka、Gateway、Feign和Hystrix是四个核心组件，它们协同工作以构建出高可用、高性能的微服务架构。让我们深入探讨这些组件以及它们如何整合。 1. **Eureka**：Eureka是Spring Cloud中...

      SpringCloud之Feign

      【SpringCloud之Feign】是Spring Cloud生态体系中一个重要的组件，主要用于服务间的调用，实现了声明式的服务调用，极大地简化了微服务之间的通信。Feign基于Netflix Hystrix进行了整合，支持服务熔断，提高了系统的...

    Magicbox
    Global site tag (gtag.js) - Google Analytics