那曲檬骨新材料有限公司

0
  • 聊天消息
  • 系統消息
  • 評論與回復
登錄后你可以
  • 下載海量資料
  • 學習在線課程
  • 觀看技術視頻
  • 寫文章/發帖/加入社區
會員中心
創作中心

完善資料讓更多小伙伴認識你,還能領取20積分哦,立即完善>

3天內不再提示

Eureka Client的創建案例

科技綠洲 ? 來源:Java技術指北 ? 作者:Java技術指北 ? 2023-10-09 17:03 ? 次閱讀

在上篇中已經講了 Eureka Server 的配置文件讀取。接下來講講 Eureka Client 的創建。每一個 eureka server 都是一個 eureka client,是用來和其他 eureka-server 節點注冊和通信的。

EurekaInstanceConfig & EurekaClientConfig

Instance 是實例的意思, EurekaInstanceConfig 就是 eureka client 的配置文件中的服務實例信息

EurekaInstanceConfig instanceConfig = isCloud(ConfigurationManager.getDeploymentContext())
                    ? new CloudInstanceConfig()
                    : new MyDataCenterInstanceConfig();

applicationInfoManager = new ApplicationInfoManager(
        instanceConfig, new EurekaConfigBasedInstanceInfoProvider(instanceConfig).get());

EurekaClientConfig eurekaClientConfig = new DefaultEurekaClientConfig();

EurekaInstanceConfig 就是將 eureka-client.properties 文件中的服務實例信息加載到 ConfigManager 中,然后基于 EurekaInstanceConfig 對外暴露接口,并且提供配置項的默認值。

圖片

ApplicationInfoManager,包含了服務實例的信息、配置,作為服務實例管理的一個組件,由 EurekaInstanceConfig 和 InstanceInfo 構建完成,InstanceInfo 的創建是在 new EurekaConfigBasedInstanceInfoProvider(instanceConfig).get() 中,用了構造器模式 LeaseInfo.Builder.newBuilder() 構造了一個復雜的代表一個服務實例的 InstanceInfo 對象。核心思想就是在 EurekaInstanceConfig 中讀取各種實例相關的配置信息,再構造了一些其他的對象,最終完成 InstanceInfo 對象的構建。

public synchronized InstanceInfo get() {
    if (instanceInfo == null) {
        // Build the lease information to be passed to the server based on config
        LeaseInfo.Builder leaseInfoBuilder = LeaseInfo.Builder.newBuilder()
                .setRenewalIntervalInSecs(config.getLeaseRenewalIntervalInSeconds())
                .setDurationInSecs(config.getLeaseExpirationDurationInSeconds());

        if (vipAddressResolver == null) {
            vipAddressResolver = new Archaius1VipAddressResolver();
        }
        //代碼太長,省略其他代碼
    }
}

DefaultEurekaClientConfig 就是和 DefaultEurekaServerConfig 一樣,讀取 erueka-client.properties 配置文件的內容。具體方法在 com.netflix.discovery.internal.util.initConfig() 中。最后都是交給 ConfigurationManager 管理。

EurekaInstanceConfig 和 EurekaClientConfig 雖然都是讀取的 erueka-client.propeties ,但是讀取的內容是不一樣的。

EurekaInstanceConfig 接口

圖片EurekaClientConfig 接口

圖片

DiscoveryClient

DiscoveryClient 是創建 Erueka Client 的類,由 ApplicationInfoManager 和 EurekaClientConfig 組成。

eurekaClient = new DiscoveryClient(applicationInfoManager, eurekaClientConfig);

DiscoveryClient 代碼很長。

  1. appPathIdentifier,服務實例的標識符, appName,代表了一個服務名稱,但是一個服務可能部署多臺機器,每臺機器上部署的就是一個服務實例,如:serviceABC/001
appPathIdentifier = instanceInfo.getAppName() + "/" + instanceInfo.getId();
  1. 是否需要注冊到別的注冊中心。eurekaServer 有個配置:eureka.client.fetchRegistry,單機情況下為 false。false 表示自己就是注冊中心。職責就是維護服務實例,并不需要去檢索服務。
if (!config.shouldRegisterWithEureka() && !config.shouldFetchRegistry()) {}
  1. 支持調度的線程池。
scheduler = Executors.newScheduledThreadPool(2,
        new ThreadFactoryBuilder()
                .setNameFormat("DiscoveryClient-%d")
                .setDaemon(true)
                .build());
  1. 支持心跳的線程池。
heartbeatExecutor = new ThreadPoolExecutor(
            1, clientConfig.getHeartbeatExecutorThreadPoolSize(), 0, TimeUnit.SECONDS,
            new SynchronousQueue< Runnable >(),
            new ThreadFactoryBuilder()
                    .setNameFormat("DiscoveryClient-HeartbeatExecutor-%d")
                    .setDaemon(true)
                    .build()
    );
  1. 支持緩存刷新的線程池。
cacheRefreshExecutor = new ThreadPoolExecutor(
            1, clientConfig.getCacheRefreshExecutorThreadPoolSize(), 0, TimeUnit.SECONDS,
            new SynchronousQueue< Runnable >(),
            new ThreadFactoryBuilder()
                    .setNameFormat("DiscoveryClient-CacheRefreshExecutor-%d")
                    .setDaemon(true)
                    .build()
    );
  1. 支持底層的 eureka client 和 eureka server 進行通信的組件。
eurekaTransport = new EurekaTransport();
  1. 初始化調度任務。
initScheduledTasks();

總結

先創建了 EurekaInstanceConfig,基于 EurekaInstanceConfig 和 InstanceInfo 創建 ApplicationInfoManager,之后才創建 DiscoveryClient。

聲明:本文內容及配圖由入駐作者撰寫或者入駐合作網站授權轉載。文章觀點僅代表作者本人,不代表電子發燒友網立場。文章及其配圖僅供工程師學習之用,如有內容侵權或者其他違規問題,請聯系本站處理。 舉報投訴
  • 接口
    +關注

    關注

    33

    文章

    8694

    瀏覽量

    151929
  • 文件
    +關注

    關注

    1

    文章

    570

    瀏覽量

    24823
  • 代碼
    +關注

    關注

    30

    文章

    4828

    瀏覽量

    69063
  • eureka
    +關注

    關注

    0

    文章

    4

    瀏覽量

    1774
收藏 人收藏

    評論

    相關推薦

    請問while循環中是怎么調用tcp_client_senddata()和tcp_client_recv()發送接收數據的?

    在這個while循環中,是怎么調用tcp_client_senddata()和tcp_client_recv()發送接收數據的?是要等到創建一個新的pcb?while(res==0){ key
    發表于 06-28 02:29

    怎樣實現創建TCP Server后連接多個Client

    版主你好,請問使用UCOS3+LWIP時,怎樣實現創建TCP Server后,連接多個Client,然后能在每個Client之間進行不同數據格式的收發?比如我有2個設備需要連接407,但是都只能通過一個網口,是否再開一個任務?謝
    發表于 09-26 00:51

    Symantec Client Security使用入門

    Symantec Client Security使用入門 Symantec Client Security 為工作站提供可調整、跨平臺的防火牆、入侵偵測,以及防毒保護,並為網路伺服器提供防毒保護。您可以建
    發表于 06-10 17:11 ?7次下載

    CLIENT99SE下載

    電子發燒友網站提供《CLIENT99SE下載.exe》資料免費下載
    發表于 10-30 13:10 ?225次下載

    CLient相關資料

    CLient,好東西,喜歡的朋友可以下載來學習。
    發表于 02-19 17:00 ?0次下載

    Eureka的集群搭建方法-保證高可用

    在微服務架構中,注冊中心是一個必不可少的組件 前面我們搭建的注冊中心只適合本地開發使用,在生產環境必須搭建一個集群來保證高可用 Eureka的集群搭建很簡單,每一臺Eureka都需要在配置中指定另外N個Eureka的地址就可以。
    發表于 11-29 10:41 ?7574次閱讀
    <b class='flag-5'>Eureka</b>的集群搭建方法-保證高可用

    ApiBoot Logging整合Spring Cloud Eureka負載均衡上報日志

    ApiBoot Logging支持整合服務注冊中心(Eureka、Consul、Nacos Discovery、Zookeeper...)進行上報請求日志,Logging Client會從服務注...
    的頭像 發表于 12-10 22:08 ?446次閱讀

    eureka優瑞家殺菌洗地機全球首發,清潔更專業、健康、高效!

    擁有112年歷史的美國百年清潔品牌eureka優瑞家2021年正式登錄中國市場,3月4日全球首發顛覆性新品——吸塵+拖地+除菌三合一的eureka優瑞家殺菌洗地機。這款洗地機也是全球首家研發出的僅僅
    的頭像 發表于 03-05 12:10 ?1404次閱讀

    danmu-client彈幕客戶端

    ./oschina_soft/danmu-client.zip
    發表于 06-01 10:24 ?1次下載
    danmu-<b class='flag-5'>client</b>彈幕客戶端

    VB6 OPC Client文件分享

    VB6 OPC Client文件分享
    發表于 08-28 10:20 ?0次下載

    LabVIEW Actor Framwork:邊學邊做server和client

    現在要做一個類似聊天的demo,一個server端,若干個client端;首先是server啟動,通過server可以打開若干個client端,然后每個client可以獨立給server發送數據。server收到數據打印出來帶有
    的頭像 發表于 06-01 15:49 ?1490次閱讀
    LabVIEW Actor Framwork:邊學邊做server和<b class='flag-5'>client</b>

    Eureka Server面向接口的方式讀取配置文件

    eureka sersver 配置環境 在上一篇中已經介紹了,spring boot 是調用 類的 方法啟動 Eureka Server 的。 public void
    的頭像 發表于 10-09 17:05 ?614次閱讀
    <b class='flag-5'>Eureka</b> Server面向接口的方式讀取配置文件

    Spring Boot啟動 Eureka流程

    在上篇中已經說過了 Eureka-Server 本質上是一個 web 應用的項目,今天就來看看 Spring Boot 是怎么啟動 Eureka 的。 Spring Boot 啟動 Eureka
    的頭像 發表于 10-10 11:40 ?930次閱讀
    Spring Boot啟動 <b class='flag-5'>Eureka</b>流程

    Eureka!NVIDIA 研究突破為機器人學習注入新動力

    AI 智能體利用 LLM 自動生成獎勵算法,訓練機器人完成復雜任務。 ? ? NVIDIA Research 開發的一款名為 Eureka 的新型 AI 智能體可以教機器人復雜的技能,它教會了機器人
    發表于 10-24 09:48 ?231次閱讀
    <b class='flag-5'>Eureka</b>!NVIDIA 研究突破為機器人學習注入新動力

    Eureka!NVIDIA 研究突破為機器人學習注入新動力

    AI 智能體利用 LLM 自動生成獎勵算法,訓練機器人完成復雜任務。 NVIDIA Research 開發的一款名為 Eureka 的新型 AI 智能體可以教機器人復雜的技能,它教會了機器人手快速轉
    的頭像 發表于 10-25 15:55 ?298次閱讀
    <b class='flag-5'>Eureka</b>!NVIDIA 研究突破為機器人學習注入新動力
    足球.百家乐官网投注网出租 | 大发888官网下载| 至富百家乐官网的玩法技巧和规则 | 百家乐视频游戏官网| 赌场百家乐官网投注公式| 威尼斯人娱乐城首选金杯娱乐城| 澳门赌场筹码| 澳门百家乐现场视频| 乐天堂百家乐官网娱乐场| 辉南县| 大发888官网www.dafa888.com| 百家乐补牌规制| 真人百家乐官网导航| 左云县| 大发娱乐城官网| 百家乐必胜方法如果你还想继续不看可能后悔一生 | 博彩优惠| 最新百家乐的玩法技巧和规则| 玩百家乐官网怎么能赢呢| 百家乐官网扫瞄光纤洗牌机扑克洗牌机扑克洗牌机| 华亭县| 拉斯维加斯娱乐城| 德州扑克学校| 百家乐游戏辅助| 富易堂百家乐娱乐城| 博彩网百家乐官网中和局| 博发百家乐官网游戏| 二连浩特市| 当阳市| 青海省| 香港六合彩挂牌| e娱乐城棋牌| bet365是否合法| bet365金融技巧| 明升 | 大发888娱乐真钱游戏 官方| 大发888全球顶级游戏平台| 大发888安装包| 大发888棋牌下载| 大发888真钱注册| 真人娱乐城开户送钱|