springCloud学习笔记2(服务发现)
1、服务发现架构
服务发现架构一般具备下面 4 个概念：git
- 服务注册：服务如何使用服务发现代理进行注册？
- 服务地址的客户端查找：服务客户端查找服务信息的方法是什么？
- 信息共享：如何跨节点共享服务信息？
- 健康监测：服务如何将它的健康信息传回给服务发现代理？
下图展现了这 4 个概念的流程，以及在服务发现模式实现中一般发生的状况：github
一般服务实例都只向一个服务发现实例注册，服务发现实例之间再经过数据传输，让每一个服务实例注册到全部的服务发现实例中。
服务在向服务发现实例注册后，这个服务就能被服务消费者调用了。服务消费者可使用多种模型来"发现"服务。算法
- 每次调用服务时，经过服务发现层来获取目标服务地址并进行调用。这种用的比较少，弊端较多。首先是每次服务调用都经过服务发现层来完成，耗时会比直接调用高。最主要的是这种方法很脆弱，消费端彻底依赖于服务发现层来查找和调用服务。
- 更健壮的方法是使用所谓的客户端负载均衡。
以下图所示：spring
在这个模型中，当服务消费者须要调用一个服务时：json
(1)联系服务发现层，获取所请求服务的全部服务实例，而后放到本地缓存中。bootstrap
(2)每次调用该服务时，服务消费者从缓存中取出一个服务实例的位置，一般这个'取出'使用简单的复制均衡算法，如“轮询”，“随机",以确保服务调用分布在全部实例之间。缓存
(3)客户端将按期与服务发现层进行通讯，并刷新服务实例的缓存。服务器
(4)若是在调用服务的过程当中，服务调用失败，那么本地缓存将从服务发现层中刷新数据，再次尝试。架构
2、spring cloud 实战
使用 spring cloud 和 Netflix Eureka 搭建服务发现实例。
一、构建 Spring Eureka 服务
eurekasvr POM 主要配置以下：
<!-- 其余依赖省略 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka-server</artifactId>
</dependency>
applicaiton.yml 配置以下：
server:
port: 8761
eureka:
client:
#不注册本身
register-with-eureka: false
#不在本地缓存注册表信息
fetch-registry: false
server:
#接受请求前的等待实际，开发模式下不要开启
#wait-time-in-ms-when-sync-empty: 5
最后在启动类上加入注释@SpringBootApplication便可启动服务中心。服务中心管理页面：http://localhost:8761
二、将服务注册到服务中心
这里咱们编写一个新服务注册到服务中心,organizationservice：组织服务。并将上一篇的两个服务：confsvr:配置中心服务,licensingservice:受权服务注册到服务中心。
a、confvr 注册
首先修改 POM 文件：
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-config-server</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
而后修改配置文件 application.yml:
server:
port: 8888
eureka:
instance:
#注册服务的IP，而不是服务器名
prefer-ip-address: true
client:
#向eureka注册服务
register-with-eureka: true
#拉取注册表的本地副本
fetch-registry: true
service-url:
#Eureka服务的位置(若是有多个注册中心，使用,分隔）
defaultZone: http://localhost:8761/eureka/
spring:
profiles:
# 使用文件系统来存储配置信息，须要设置为native
active: native
application:
name: confsvr
cloud:
config:
server:
native:
# 使用文件来存放配置文件,为每一个应用程序提供用逗号分隔的文件夹列表
searchLocations: file:///D:/configFolder/licensingservice,file:///D:/configFolder/organizationservice
最后在启动类加入注解@EnableDiscoveryClient,启动便可在 eureka 管理页面发现。
b、licensingservice 注册
首先修改 POM
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-config-client</artifactId>
</dependency>
而后修改配置文件 bootstrap.yml
spring:
application:
#指定名称，以便spring cloud config客户端知道查找哪一个配置
name: licensingservice
profiles:
#指定环境
active: dev
cloud:
config:
#设为true便会自动获取从配置中心获取配置文件
enabled: true
eureka:
instance:
prefer-ip-address: true
client:
register-with-eureka: true
fetch-registry: true
service-url:
defaultZone: http://localhost:8761/eureka/
最后在启动类加入注解@EnableDiscoveryClient,启动便可在 eureka 管理页面发现本服务实例。
c、建立 organizationservice
首先在文件夹file:///D:/configFolder/organizationservice下建立两个配置文件：organizationservice.yml,organizationservice-dev.yml,内容分别为：
#organizationservice-dev.yml server: port: 10012
#organizationservice.yml
spring:
application:
name: organizationservice
主要 POM 配置以下：
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-config-client</artifactId>
</dependency>
而后修改配置文件，bootstrap.yml
spring:
application:
#指定名称，以便spring cloud config客户端知道查找哪一个配置
name: organizationservice
profiles:
#指定环境
active: dev
cloud:
config:
enabled: true
eureka:
instance:
prefer-ip-address: true
client:
register-with-eureka: true
fetch-registry: true
service-url:
defaultZone: http://localhost:8761/eureka/
最后在启动类加入注解@EnableDiscoveryClient,启动。
三、使用服务发现来查找服务
如今已经有两个注册服务了，如今来让许可证服务调用组织服务，获取组织信息。首先在 organizationservice 服务中的 controller 包中加入一个 controller 类,让它可以响应请求:
//OrganizationController.java
@RestController
public class OrganizationController {
@GetMapping(value = "/organization/{orgId}")
public Object getOrganizationInfo(@PathVariable("orgId") String orgId) {
Map<String, String> data = new HashMap<>(2);
data.put("id", orgId);
data.put("name", orgId + "公司");
return data;
}
}
接下来让许可证服务经过 Eureka 来找到组织服务的实际位置，而后调用该接口。为了达成目的，咱们将要学习使用 3 个不一样的 Spring/Netflix 客户端库，服务消费者可使用它们来和 Ribbon 进行交互。从最低级别到最高级别，这些库包含了不一样的与 Ribbon 进行交互的抽象封装层次：
- Spring DiscoveryClient
- 启用了 RestTemplate 的 Spring DiscoveryClient
- Neflix Feign 客户端
a、使用 Spring DiscoveryClient
该工具提供了对 Ribbon 和 Ribbon 中缓存的注册服务最低层次的访问，能够查询经过 Eureka 注册的全部服务以及这些服务对应的 URL。
首先在 licensingservice 的启动类中加入@EnableDiscoveryClient注解来启用 DiscoveryClient 和 Ribbon 库。
而后在 service 包下建立 OrganizationService.java
@Service
public class OrganizationService {
private static final String SERVICE_NAME = "organizationservice";
private DiscoveryClient discoveryClient;
@Autowired
public OrganizationService(DiscoveryClient discoveryClient) {
this.discoveryClient = discoveryClient;
}
/**
* 使用Spring DiscoveryClient查询
*
* @param id
* @return
*/
public Organization getOrganization(String id) {
RestTemplate restTemplate = new RestTemplate();
List<ServiceInstance> instances = discoveryClient.getInstances(SERVICE_NAME);
if (instances.size() == 0) {
throw new RuntimeException("无可用的服务");
}
String serviceUri = String.format("%s/organization/%s", instances.get(0).getUri().toString(), id);
ResponseEntity<Organization> responseEntity = restTemplate.exchange(serviceUri, HttpMethod.GET
, null, Organization.class, id);
return responseEntity.getBody();
}
}
接着在 controller 包中新建 LicensingController.java
@RestController
public class LicensingController {
private OrganizationService organizationService;
@Autowired
public LicensingController(OrganizationService organizationService) {
this.organizationService = organizationService;
}
@GetMapping("/licensing/{orgId}")
public Licensing getLicensing(@PathVariable("orgId") String orgId) {
Licensing licensing = new Licensing();
licensing.setValid(false);
licensing.setOrganization(organizationService.getOrganization(orgId));
return licensing;
}
}
启动全部项目，访问localhost:10011/licensing/12,能够看到返回以下结果：
{
"organization": {
"id": "12",
"name": "12公司"
},
"valid": false
}
在实际开发中，基本上是用不到这个的，除非是为了查询 Ribbon 以获取某个服务的全部实例信息，才会直接使用。若是直接使用它存在如下两个问题：
- 没有利用 Ribbon 的客户端负载均衡
- 和业务无关的代码写得太多
b、使用带 Ribbon 功能的 Spring RestTemplate 调用服务
这种方法是较为经常使用的微服务通讯机制之一。要启动该功能，须要使用 Spring Cloud 注解@LoadBanced 来定义 RestTemplate bean 的构造方法。方便起见直接在启动类中定义 bean:
#LicensingserviceApplication.java
@SpringBootApplication
@EnableDiscoveryClient //使用不带Ribbon功能的Spring RestTemplate,其余状况下可删除
public class LicensingserviceApplication {
/**
* 使用带有Ribbon 功能的Spring RestTemplate，其余状况可删除
*/
@LoadBalanced
@Bean
public RestTemplate getRestTemplate(){
return new RestTemplate();
}
public static void main(String[] args) {
SpringApplication.run(LicensingserviceApplication.class, args);
}
}
接着 service 包下增长一个类：OrganizationByRibbonService.java
@Component
public class OrganizationByRibbonService {
private RestTemplate restTemplate;
@Autowired
public OrganizationByRibbonService(RestTemplate restTemplate) {
this.restTemplate = restTemplate;
}
public Organization getOrganizationWithRibbon(String id) {
ResponseEntity<Organization> responseEntity = restTemplate.exchange("http://organizationservice/organization/{id}",
HttpMethod.GET, null, Organization.class, id);
return responseEntity.getBody();
}
}
最后就是在 LicensingController.js 中加一个访问路径：
//不要忘记注入OrganizationByRibbonService服务
@GetMapping("/licensingByRibbon/{orgId}")
public Licensing getLicensingByRibbon(@PathVariable("orgId") String orgId) {
Licensing licensing = new Licensing();
licensing.setValid(false);
licensing.setOrganization(organizationService.getOrganization(orgId));
return licensing;
}
}
访问localhost:10011/licensingByRibbon/113,便可看到结果。
c、使用 Netflix Feign 客户端调用
Feign 客户端是 Spring 启用 Ribbon 的 RestTemplate 类的替代方案。开发人员只需定义一个接口，而后使用 Spring 注解来标注接口，便可调用目标服务。除了编写接口定义无需编写其余辅助代码。
首先启动类上加一个@EnableFeignClients注解启用 feign 客户端。而后在 POM 中加入 Feign 的依赖
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-feign</artifactId> </dependency>
而后在 client 包下新建 OrganizationFeignClient.java
@FeignClient("organizationservice")//使用FeignClient注解指定目标服务
public interface OrganizationFeignClient {
/**
* 获取组织信息
*
* @param orgId 组织id
* @return Organization
*/
@RequestMapping(method = RequestMethod.GET, value = "/organization/{orgId}", consumes = "application/json")
Organization getOrganization(@PathVariable("orgId") String orgId);
}
最后修改LicensingController.java,加入一个路由调用 Feign。
//注入OrganizationFeignClient,使用构造注入
@GetMapping("/licensingByFeign/{orgId}")
public Licensing getLicensingByFeign(@PathVariable("orgId") String orgId) {
Licensing licensing = new Licensing();
licensing.setValid(false);
licensing.setOrganization(organizationFeignClient.getOrganization(orgId));
return licensing;
}
访问localhost:10011/licensingByFeign/11313,便可看到结果。
总结
这一节磨磨蹭蹭写了好几天，虽然例子很简单，可是相信应该是可以看懂的。因为篇幅缘由代码没有所有贴上，想要查看完整代码，能够访问这个连接：点击跳转。
- 1. springCloud学习2(服务发现)
- 2. SpringCloud学习笔记【六】：Consul实现服务注册与发现
- 3. SpringCloud学习笔记一 服务注册与发现
- 4. SpringCloud学习笔记【二】：Eureka服务注册与发现
- 5. SpringCloud学习笔记（一）Eureka——服务注册与发现
- 6. SpringCloud学习笔记（四）：Eureka服务注册与发现
- 7. SpringCloud学习笔记(2)——Ribbon
- 8. springcloud学习笔记2：eureka
- 9. SpringCloud学习笔记（2）————SpringBoot
- 10. SpringCloud微服务学习笔记
- 更多相关文章...
- • 启动MySQL服务 - MySQL教程
- • 您已经学习了 XML Schema，下一步学习什么呢？ - XML Schema 教程
- • Tomcat学习笔记（史上最全tomcat学习笔记）
- • Spring Cloud 微服务实战(三) - 服务注册与发现
-
每一个你不满意的现在，都有一个你没有努力的曾经。
- 1. 「插件」Runner更新Pro版，帮助设计师远离996
- 2. 错误 707 Could not load file or assembly ‘Newtonsoft.Json, Version=12.0.0.0, Culture=neutral, PublicKe
- 3. Jenkins 2018 报告速览，Kubernetes使用率跃升235%！
- 4. TVI-Android技术篇之注解Annotation
- 5. android studio启动项目
- 6. Android的ADIL
- 7. Android卡顿的检测及优化方法汇总（线下+线上）
- 8. 登录注册的业务逻辑流程梳理
- 9. NDK(1)创建自己的C/C++文件
- 10. 小菜的系统框架界面设计-你的评估是我的决策
- 1. springCloud学习2(服务发现)
- 2. SpringCloud学习笔记【六】：Consul实现服务注册与发现
- 3. SpringCloud学习笔记一 服务注册与发现
- 4. SpringCloud学习笔记【二】：Eureka服务注册与发现
- 5. SpringCloud学习笔记（一）Eureka——服务注册与发现
- 6. SpringCloud学习笔记（四）：Eureka服务注册与发现
- 7. SpringCloud学习笔记(2)——Ribbon
- 8. springcloud学习笔记2：eureka
- 9. SpringCloud学习笔记（2）————SpringBoot
- 10. SpringCloud微服务学习笔记