查看: 296|回复: 0

[Java代码] Spring-cloud 服务发现与消费(以ribbon为例)

发表于 2018-5-6 16:06:58

说明:

ribbon是spring-cloud中作为服务消费者的一种角色,客户端可以通过它来对服务提供者的服务进行消费,

比如本例中是服务提供者注册到注册中心,服务提供者提供了一个服务接口,返回一个hello字符串,我们通过ribbon将这个接口调用,再不暴露真实服务提供者的地址的同时,获取服务提供者的服务

前提:

按照之前几个教程,搭建出注册中心、服务提供者。这里可以使用分片的注册中心,也可以不使用,这里暂时定为使用之前搭好的分片注册中心,服务提供者仅提供一个即可。

准备工作:

1、启动注册中心

按照之前的教程,分别使用peer1和peer2进行启动两个分片的注册中心,如果是单节点直接启动项目即可

启动后可以查看下localhost:1111或localhost:1112,如图

2、启动服务提供者

这里为了查看负载均衡的情况,所以需要启动两个服务提供者

按照之前教程中,分别开启两个terminal进行指定端口启动(两个相同的服务也可以在各自的配置文件中配置不同的端口),两个终端指令分别如下:

  1. cd target
  2. java -jar SpringCloudDemo-0.0.1-SNAPSHOT.jar --server.port=8080
复制代码
  1. cd target
  2. java -jar SpringCloudDemo-0.0.1-SNAPSHOT.jar --server.port=8081
复制代码

启动结果:

至此,准备工作已经完成

正文:

1、ribbon服务搭建

新建一个maven项目,不使用模板即可。项目名为robbin-customer,导入依赖参考如下:

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5. <modelVersion>4.0.0</modelVersion>
  6. <groupId>com.hellxz</groupId>
  7. <artifactId>ribbon-customer</artifactId>
  8. <version>1.0-SNAPSHOT</version>
  9. <parent>
  10. <groupId>org.springframework.boot</groupId>
  11. <artifactId>spring-boot-starter-parent</artifactId>
  12. <version>1.5.9.RELEASE</version>
  13. <relativePath/>
  14. </parent>
  15. <dependencies>
  16. <dependency>
  17. <groupId>org.springframework.boot</groupId>
  18. <artifactId>spring-boot-starter-web</artifactId>
  19. </dependency>
  20. <dependency>
  21. <groupId>org.springframework.cloud</groupId>
  22. <artifactId>spring-cloud-starter-eureka</artifactId>
  23. <version>RELEASE</version>
  24. </dependency>
  25. <dependency>
  26. <groupId>org.springframework.cloud</groupId>
  27. <artifactId>spring-cloud-starter-ribbon</artifactId>
  28. <version>RELEASE</version>
  29. </dependency>
  30. </dependencies>
  31. <dependencyManagement>
  32. <dependencies>
  33. <dependency>
  34. <groupId>org.springframework.cloud</groupId>
  35. <artifactId>spring-cloud-dependencies</artifactId>
  36. <version>RELEASE</version>
  37. <scope>import</scope>
  38. <type>pom</type>
  39. </dependency>
  40. </dependencies>
  41. </dependencyManagement>
  42. </project>
复制代码

新建springboot启动类,将RestTemplate交给Spring容器进行管理

  1. package com.cnblogs.hellxz;
  2. import org.springframework.boot.SpringApplication;
  3. import org.springframework.boot.autoconfigure.SpringBootApplication;
  4. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
  5. import org.springframework.cloud.client.loadbalancer.LoadBalanced;
  6. import org.springframework.context.annotation.Bean;
  7. import org.springframework.web.client.RestTemplate;
  8. /**
  9. * @Author : Hellxz
  10. * @Description: 消费应用
  11. * @Date : 2018/4/16 15:45
  12. */
  13. @EnableDiscoveryClient
  14. @SpringBootApplication
  15. public class CustomerApplication {
  16. [url=home.php?mod=space&uid=4377]@Bean[/url] //将此Bean交给spring容器
  17. @LoadBalanced //通过此注解开启负载均衡
  18. RestTemplate restTemplate(){
  19. return new RestTemplate();
  20. }
  21. public static void main(String[] args) {
  22. SpringApplication.run(CustomerApplication.class, args);
  23. }
  24. }
复制代码

在src/resources目录下创建一个application.yml进行配置注册信息相关,本文使用了分片的注册中心,单节点请配置一个defaltZone即可

  1. server:
  2. port: 9000 #为ribbon-customer指定服务端口
  3. spring:
  4. application:
  5. name: ribbon-customer #指定应用名
  6. #指定eureka注册中心地址
  7. eureka:
  8. client:
  9. serviceUrl:
  10. defaultZone: http://peer1:1111/eureka/,http://peer2:1112/eureka/
复制代码

在启动类同级目录创建CustomerController,注入RestTemplate进行调用服务接口

  1. package com.cnblogs.hellxz;
  2. import org.springframework.beans.factory.annotation.Autowired;
  3. import org.springframework.web.bind.annotation.RequestMapping;
  4. import org.springframework.web.bind.annotation.RequestMethod;
  5. import org.springframework.web.bind.annotation.RestController;
  6. import org.springframework.web.client.RestTemplate;
  7. /**
  8. * @Author : Hellxz
  9. * @Description: 消费者应用
  10. * @Date : 2018/4/16 15:54
  11. */
  12. @RestController
  13. public class CustomerController {
  14. @Autowired
  15. //注入restTemplate
  16. private RestTemplate restTemplate;
  17. @RequestMapping(value="/ribbon-customer", method=RequestMethod.GET)
  18. public String helloCustomer(){
  19. //这里注释掉,因为之前想当然使用了直链访问服务提供者的接口,这样是不会返回结果的,而且会报错
  20. //return restTemplate.getForEntity("http://localhost:8080/hello",String.class).getBody();
  21. //使用restTemplate调用微服务接口
  22. return restTemplate.getForEntity("http://hello-service/hello", String.class).getBody();
  23. }
  24. }
复制代码

注意:上述代码第24行给出了一个错误的演示,如果出现访问ribbon接口报错,出现白色报错页面,请检查这里

至此ribbon消费者应用搭建完成,启动测试

测试:

访问http://localhost:1111/ 我们发现这个ribbon消费者应用已经注册到注册中心中了

访问http://localhost:9000/ribbon-customer

还记得服务提供者项目中的如图方法中如果有访问则会打印信息,因为启动了两个服务提供者,这里可以测试ribbon的负载均衡

查看服务提供者输出

而第二个终端没有,依旧显示到Resolving eureka endpoints via configuration这行

刷新页面查看终端,由于ribbon的默认负载均衡的实现是轮询的,所以可能出现多次访问同一服务,多刷新几次页面,一定会在另一个Termical中显示的!

结语:

Ribbon作为服务消费者,可以在用户获取到服务提供者提供的服务的同时,不向用户暴露接口地址。可以看到,这里调用服务接口的时候使用的是服务提供者的服务名代替主机名,这在服务治理框架中,这种特性很重要。

由于本人之前是先学的jhipster生成器,所以,提前预报一下,之后还会有一种名为Feign的技术可以替代Ribbon,本系列博客均为学习笔记,实际操作中,可能会存在一个应用既是服务提供者又是服务消费者的情况。

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



回复

使用道具 举报