SpringCloud组件：Eureka的服务发现与消费

时间  2019-11-17
标签 springcloud 组件 eureka 服务 发现 消费 繁體版
原文   原文链接

在以前的章节咱们已经把服务注册到Eureka Server，那么咱们该怎么调用已经注册后的服务呢？ 咱们本章来简单的介绍咱们具体该怎么调用服务节点请求内容。html

本章目标

消费Eureka注册的服务节点的请求信息。java

构建项目

咱们只须要建立一个服务节点项目便可，由于服务提供者也是消费者，而后将本项目注册到以前编写的服务注册中心，下载文章SpringCloud组件：搭建Eureka服务注册中心源码运行便可。 咱们使用idea开发工具建立一个SpringBoot项目，对应的选择spring-boot-starter-web、spring-cloud-starter-netflix-ribbon、spring-cloud-starter-netflix-eureka-client三个依赖，pom.xml配置文件以下所示：git

......
<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.0.5.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>
    <spring-cloud.version>Finchley.SR1</spring-cloud.version>
</properties>

<dependencies>
    <!--Web依赖-->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <!--ribbon-->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
    </dependency>
    <!--client-->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>

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

添加完依赖后咱们须要对本项目进行配置，让本项目注册到服务中心，在以前的章节SpringCloud组件：将微服务提供者注册到Eureka服务中心有讲过，这里就不作过多的赘述。github

配置Eureka客户端

打开XxxApplication入口类，添加@EnableDiscoveryClient注解，以下所示：web

@SpringBootApplication
@EnableDiscoveryClient
public class SpringCloudEurekaConsumerApplication {
 //...
}
复制代码

修改application.yml配置文件

下面咱们修改application.yml配置文件，添加Eureka Client对应的配置信息，以下所示：spring

# 服务名称
spring:
  application:
    name: hengboy-spring-cloud-eureka-consumer
# 启动端口号
server:
  port: 20002
# Eureka 服务注册中心配置
eureka:
  client:
    service-url:
      defaultZone: http://localhost:10000/eureka/
  # 配置优先使用IP地址注册服务
  instance:
    prefer-ip-address: true
复制代码

获取服务实例信息

若是你只是将服务注册到服务注册中心也就是Eureka Server上，到如今已经彻底没有问题了，可是咱们想要经过服务名(spring.application.name)来获取服务实例列表该怎么操做呢？数据库

本章内容涉及一点有关Ribbon的知识点，咱们经过添加依赖spring-cloud-starter-netflix-ribbon就能够直接使用RestTemplate类进行发送http请求，并且RestTemnplate能够直接使用服务名进行发送请求！！！浏览器

实例化RestTemplate

spring-cloud-starter-netflix-ribbon依赖并无为咱们实例化RestTemplate，咱们须要手动进行实例化，我采用@Bean方式进行实例化，在XxxApplication类内添加以下代码：bash

/**
 * 实例化RestTemplate对象实例
 *
 * @return
 */
@Bean
@LoadBalanced
public RestTemplate restTemplate() {
    return new RestTemplate();
}
复制代码

在这里有个@LoadBalanced注解，咱们后续章节会对它详细的讲解，博客搜索关键字LoadBalanced查询文章信息，不过若是你不添加并使用这个注解，你是没有办法经过服务名直接发送请求的，会出现错误信息。微信

了解DiscoveryClient

咱们须要建立一个发送请求以及请求消费的Controller，以下所示：

/**
 * 消费者控制器
 *
 * @author：于起宇 <p>
 * ================================
 * Created with IDEA.
 * Date：2018/9/29
 * Time：5:55 PM
 * 简书：http://www.jianshu.com/u/092df3f77bca
 * 码云：https://gitee.com/hengboy
 * GitHub：https://github.com/hengyuboy
 * ================================
 * </p>
 */
@RestController
@RequestMapping(value = "/consumer")
public class ConsumerController {
    /**
     * logger instance
     */
    static Logger logger = LoggerFactory.getLogger(ConsumerController.class);
    /**
     * 注入服务客户端实例
     */
    @Autowired
    private DiscoveryClient discoveryClient;
    /**
     * 注入restTemplate模板
     */
    @Autowired
    private RestTemplate restTemplate;

    /**
     * 服务消费者业务逻辑方法
     * 该方法使用restTemplate访问获取返回数据
     *
     * @return
     */
    @RequestMapping(value = "/logic")
    public String home() {
        return "this is home page";
    }

    /**
     * 请求地址
     * 输出服务的基本信息
     */
    @RequestMapping(value = "/index")
    public void index() {
        discoveryClient.getInstances("hengboy-spring-cloud-eureka-consumer")
                .stream()
                .forEach(
                        instance -> {
                            logger.info("服务地址：{}，服务端口号：{}，服务实例编号：{}，服务地址：{}", instance.getHost(), instance.getPort(), instance.getServiceId(), instance.getUri());
                            String response = restTemplate.getForEntity("http://" + instance.getServiceId() + "/consumer/logic", String.class).getBody();
                            logger.info("响应内容：{}", response);
                        }

                );
    }
}

复制代码

在上面代码中咱们注入了DiscoveryClient，这是一个接口类，具体该接口的实现类是什么要取决你使用的是什么服务注册中心，咱们本章采用的Eureka理所固然使用的是Eureka实现类，源码能够查看org.springframework.cloud.netflix.eureka.EurekaDiscoveryClient，在EurekaDiscoveryClient内能够看到具体是怎么经过服务名获取实例的列表，部分源码以下所示：

@Override
public List<ServiceInstance> getInstances(String serviceId) {
    List<InstanceInfo> infos = this.eurekaClient.getInstancesByVipAddress(serviceId,
            false);
    List<ServiceInstance> instances = new ArrayList<>();
    for (InstanceInfo info : infos) {
        instances.add(new EurekaServiceInstance(info));
    }
    return instances;
}
复制代码

你若是对具体的源码执行流程感兴趣，可使用断点来一步一步的观察。 在获取ServiceInstance服务实例后，能够获得实例的一些基本信息如：

  • serviceId：服务名称、服务的实例编号，也就是spring.application.name配置信息
  • host：注册该实例的hostName
  • port：注册该实例的端口号，对应server.port配置信息
  • uri：服务地址
  • metadata：服务自定义的元数据map集合

请求转发流程

执行流程：咱们在访问/consumer/index请求地址时，会经过RestTemplate转发请求访问http://hengboy-spring-cloud-eureka-consumer/consumer/logic地址并返回信息this is home page。

运行测试

咱们的测试流程以下：

  1. 启动服务注册中心
  2. 启动本章项目
  3. 访问http://localhost:20002/consumer/index
  4. 查看控制台输出内容是否有this is home page

访问有多种形式，你能够浏览器直接访问地址，我经过curl命令来访问地址，打开terminal输入如下命令：

curl http://localhost:20002/consumer/index
复制代码

请求正常，查看控制台输出内容以下所示：

2018-10-04 15:23:36.333  INFO 29075 --- [io-20002-exec-5] c.y.c.h.s.e.consumer.ConsumerController  : 服务地址：192.168.1.75，服务端口号：20002，服务实例编号：HENGBOY-SPRING-CLOUD-EUREKA-CONSUMER，服务地址：http://192.168.1.75:20002
......
2018-10-04 15:23:36.748  INFO 29075 --- [io-20002-exec-5] c.y.c.h.s.e.consumer.ConsumerController  : 响应内容：this is home page
复制代码

总结

本章经过Ribbon简单的实现了服务节点的消费，经过RestTemplate发送请求来获取响应内容，须要注意的是咱们并非经过IP:Port的形式，而是经过服务名的形式发送请求，这都归功于@LoadBalanced这个注解，这个注解在讲解Ribbon时会详细的说明。

源码位置

有问题要问？

若是你有技术相关的问题想要咨询恒宇少年，请去博客首页左侧导航栏，点击知识星球微信扫码加入个人星球。

与恒宇少年面对面

若是你喜欢恒宇少年的相关文章，那么就去微信公众号（恒宇少年）关注我吧！！！ 固然你也能够去 SpringCloud码云源码 项目底部扫描微信公众号二维码关注我，感谢阅读！！！

学习目录推荐

开源信息

这段时间一直在编写开源的相关框架，致力于公司使用的框架升级以及开源计划，将公司使用到的工具以及插件进行升级重构而且开源。

  • 代码生成器（Code-Builder） code-builder代码生成器根据你提供的模板文件（目前支持freemarker）自动生成实体类，能够很大颇有效的提升开发效率。 Gitee地址：gitee.com/hengboy/cod… Github地址：github.com/hengyuboy/c…
  • 持久化框架（MyBatis-Enhance） mybatis-enhance是一个对mybatis框架的加强封装，提供一系列的内部方法来完成单表数据的操做，多表数据提供DSL方式进行操做。 Gitee地址：gitee.com/hengboy/myb… Github地址：github.com/hengyuboy/m…
  • 自动分页插件 MyBatis-Pageable是一款自动化分页的插件，基于MyBatis内部的插件Interceptor拦截器编写完成，拦截Executor.query的两个重载方法计算出分页的信息以及根据配置的数据库Dialect自动执行不一样的查询语句完成总数量的统计。 Gitee地址：gitee.com/hengboy/myb…
相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程