Spring Cloud的基本应用-编程知识

Spring Cloud的基本应用

上篇文章我们的eureka的集群已经搭建完毕,但是我们还没有开始使用,之前我们的page访问的方法是直接写死的,现在我们就可以改为集群的方式来写
        @Autowired//注册中心对应的客户端对象private DiscoveryClient discoveryClient;@RequestMapping("query/{id}")public Products findById(@PathVariable Integer id){//获取Eureka中注册的leq-service-product实例集合List<ServiceInstance> services = discoveryClient.getInstances("leq-service-product");//获取实例集合中的第一个对象(IP,PORT,NAME)ServiceInstance service = services.get(0);//获取ip和端口String host = service.getHost();int port = service.getPort();String url="http://"+host+":"+port+"/product/findById/"+id;System.out.println(url);return restTemplate.getForObject(url,Products.class);}
这里注意DiscoveryClient的导包
import org.springframework.cloud.client.discovery.DiscoveryClient;
写完后重启我们的page项目,重启后访问我们的查询接口,还是正在使用的

Eureka元数据详解

标准元数据:主机名,IP地址,端口号
自定义元数据:可以使用eureka.instance.metadata-map配置,符合key:value存储格式

1.在生产项目中修改核心配置文件
#自定义元数据
eureka.instance.metadata-map.username: xm
eureka.instance.metadata-map.password: 123456
eureka.instance.metadata-map.telphone: 186666666
2.在page的控制层编写获取的方法并调用
  //获取Eureka自定义的元数据信息public void getMetaDataMap(List<ServiceInstance> serviceInstances){for (ServiceInstance serviceInstance : serviceInstances) {Map<String, String> metadata = serviceInstance.getMetadata();Set<String> keys = metadata.keySet();for (String key : keys) {String value = metadata.get(key);System.out.println("key:"+key+",value:"+value);}}}
3.重启这两个项目,重新访问查询的接口,可以看到元数据信息,有的时候会全部打印,有的时候只会打印端口号
http://localhost:9100/page/query/1
4.客户端

我们也可以在核心配置文件中定义一些配置,当然我配置的这些都是默认的,如果需要可以自己进行更改,默认的是最合适的
#向Eureka服务中心集群注册服务
#租约续约时间间隔,默认为30秒,每隔30秒向注册中心汇报心跳
eureka.instance.lease-renewal-interval-in-seconds=30
#没有心跳后等待90秒,超过90秒了Eureka Server会将服务从列表移除
eureka.instance.lease-expiration-duration-in-seconds=90#向Eureka服务中心集群服务
#每隔30秒拉取一次服务列表
eureka.client.registry-fetch-interval-seconds=30
5.服务端

                服务下线:当服务正常关闭时,会发送服务下线的Resu请求给Eureka_server,服务中心接收到请求后,将该服务置为下线状态

                失效剔除:定时进行检查,发现实例在一定时间内没有收到心跳,则会注销此实例

                自我保护机制:使Eureka集群更加的健壮,稳定的运行
                 在15分钟内超过85%的客户端节点都没有正常的心跳,那么Eureka就认为客户端与注册中心出现了网络故障,Eureka Server自动进入自我保护机制

                但我们访问服务中心的时候报错是因为自我保护机制,等一会重新刷新就会消息
                   1).Eureka Server不再从注册列表中移除，因为长时间没收到心跳而应该过期的服务。
                   2).Eureka Server仍然能够接受新服务的注册和查询请求，但是不会被同步到其它节点上，保证当前节点依然可用。
                   3).当网络稳定时，当前Eureka Server新的注册信息会被同步到其它节点中。

也可以核心配置文件中关闭自我保护机制,但是不建议
#关闭自我保护机制(不建议关闭)
#eureka.server.enable-self-preservation=false