Eureka源码分析

Eureka源码分析

Eureka server

入口:

Spring.factories

PS:

意味着如果加载EurekaServerAutoConfiguration成功,需要

@ConditionalOnBean(EurekaServerMarkerConfiguration.Marker.class)需加载成功.

通过@Bean注入了很多类

本质上, eureka-server包含很多事件:

EurekaInstanceCanceledEvent	服务下线事件
EurekaInstanceRegisteredEvent	服务注册事件
EurekaInstanceRenewedEvent	服务续约事件
EurekaRegistryAvailableEvent	Eureka注册中心启动事件
EurekaServerStartedEvent	Eureka server启动事件

Java扩展: EventObject->EventListener

包含注册\下线\续约等

事件注册之前, 需要有监听器, eureka所用的监听器是EurekaEventListener

针对上面五个事件, 我们可以自定义监听器

package com.macro.cloud;

import com.netflix.appinfo.InstanceInfo;
import org.springframework.cloud.netflix.eureka.server.event.*;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;

@Component
public class EurekaStateChangeListener {
    @EventListener
    public void listen(EurekaInstanceCanceledEvent eurekaInstanceCanceledEvent) {
        //服务断线事件
        String appName = eurekaInstanceCanceledEvent.getAppName();
        String serverId = eurekaInstanceCanceledEvent.getServerId();
        System.out.println(appName);
        System.out.println(serverId);
        System.out.println("EurekaInstanceCanceledEvent");
    }
    @EventListener
    public void listen(EurekaInstanceRegisteredEvent event) {
        InstanceInfo instanceInfo = event.getInstanceInfo();
        System.out.println(instanceInfo);
        System.out.println("EurekaInstanceRegisteredEvent");
    }
    @EventListener
    public void listen(EurekaInstanceRenewedEvent event) {
        event.getAppName();
        event.getServerId();
        System.out.println("EurekaInstanceRenewedEvent");
    }
    @EventListener
    public void listen(EurekaRegistryAvailableEvent event) {
        System.out.println("EurekaRegistryAvailableEvent");
    }
    @EventListener
    public void listen(EurekaServerStartedEvent event) {
        System.out.println("EurekaServerStartedEvent");
        //Server启动
    }
}

其中eureka-server启动时候, 会出发最后两个事件, 即:

EurekaRegistryAvailableEvent 和 EurekaServerStartedEvent.

当eureka-client启动后, 会出发EurekaInstanceRegisteredEvent事件.

Eurekaserver总结如下:

Eureka client

ApplicationListenerMethodAdapter.java

Eureka-client 底层是要了jerseyClient

Builder resourceBuilder = jerseyClient.resource(serviceUrl).path(urlPath).getRequestBuilder();
addExtraHeaders(resourceBuilder);
response = resourceBuilder
        .header("Accept-Encoding", "gzip")
        .type(MediaType.APPLICATION_JSON_TYPE)
        .accept(MediaType.APPLICATION_JSON)
        .post(ClientResponse.class, info);

欢迎关注公众号: 戏说码农职场

Eureka源码分析相关推荐

微服务发现与注册之Eureka源码分析
作者:陌北有棵树,Java人,架构师社区合伙人! [一]微服务之服务发现概述关于微服务,近年来可谓是大火,业界也吹刮着一种实践微服务的风潮.本人有幸在去年参与到一个向微服务过渡的产品,再结合自己所学 ...
【SpringClould】Spring Cloud Eureka源码分析
文章目录 1.概述 1.1 Eureka的一些概念 2.源码分析 2.1 Eureka Server源码 2.1.1 `@EnableEurekaServer`注解 2.1.2 EurekaServe ...
【SpringCloud微服务】第3章服务治理SpringCloudEureka（五）——Eureka源码分析
2.8 Eureka 源码分析首先,对于服务注册中心.服务提供者.服务消费者这三个主要元素来说,后两者(也就是Eureka客户端)在整个运行机制中是大部分通信行为的主动发起者,而注册中心主要是处 ...
【源码系列】Eureka源码分析
对于服务注册中心.服务提供者.服务消费者这个三个主要元素来说,服务提供者和服务消费者(即Eureka客户端)在整个运行机制中是大部分通信行为的主动发起者(服务注册.续约.下线等),而注册中心主要是处理 ...
Spring Cloud Eureka 源码分析(一) 服务端启动过程
2019独角兽企业重金招聘Python工程师标准>>> 一. 前言我们在使用Spring Cloud Eureka服务发现功能的时候,简单的引入maven依赖,且在项目入口类根据服 ...
eureka 源码分析三--InstanceInfo 中OverriddenStatus的作用
1. eureka server端实例存储结构 ConcurrentHashMap<String, Map<String, Lease<InstanceInfo>>> ...
深入 Eureka 服务注册源码分析（二）
说一下自己对Eureka注册的理解 Eureka注册的流程是 1.客户端在初始化或者在注册信息发生变化的时候,发送注册信息.其实在初始化的时候也是通过改变注册信息的. 客户端会开启一个定时任务,每40 ...
Spring Cloud部分源码分析Eureka，Ribbon，Feign，Zuul
Eureka SpringCloud Eureka使用NetFlix Eureka来实现的,它包括了服务端组件和客户端组件,并且都是用java 编写的. Eureka服务端就是服务注册中心, Eure ...
eureka 之前的服务如何关闭_干货分享 | 服务注册中心Spring Cloud Eureka部分源码分析...
友情提示:全文13000多文字,预计阅读时间10-15分钟 Spring Cloud Eureka作为常用的服务注册中心,我们有必要去了解其内在实现机制,这样出现问题的时候我们可以快速去定位问题.当我 ...

Eureka源码分析

Eureka源码分析相关推荐

最新文章

热门文章