SpringCloud組件——Eureka

一.背景

1.問題提出

我們在一個父項目下寫了兩個子項目,需要兩個子項目之間相互調用。我們可以發送HTTP請求來獲取我們想要的資源,具體實現的方法有很多,可以用HttpURLConnectionHttpClientOkhttpRestTemplate等。

舉個例子,我們想要通過訂單表中的商品Id來查詢商品的詳細信息,我們需要向商品所在的模塊發送HTTP請求,通過請求獲取商品的詳細信息:

@Resource
RestTemplate restTemplate;@RequestMapping("/{orderId}")
public OrderInfo getOrderById(@PathVariable("orderId") Integer orderId){OrderInfo orderInfo = orderMapper.selectByOrderId(orderId);String url="http://127.0.0.1:9090/product/"+orderInfo.getProductId();ProductInfo productInfo = restTemplate.getForObject(url, ProductInfo.class);orderInfo.setProductInfo(productInfo);return orderInfo;
}

上面的實現有一個問題:如果機器發生變故,url會跟著變更。url變來變去,我們寫的代碼就要進行修改,因此我們要想辦法解決這個問題。

2.解決思路

注冊中心可以解決這個問題。

服務啟動或變更的時候,向注冊中心報道,注冊中心就存儲著應用和IP的關系。

當我們想要調用方法的時候,只需要向注冊中心去獲取服務方的IP就行了。

那什么是注冊中心?

注冊中心(Service Registry)?是分布式系統(尤其是微服務架構)中的核心組件,主要用于解決服務實例的?自動發現、動態管理和路由調度?問題。它就像一個 “電話簿”,記錄著所有服務實例的網絡地址(IP、端口等信息),并實時更新這些信息,確保服務之間可以快速、可靠地通信。

注冊中心有三種角色:服務提供者(Server)服務消費者(Client)服務注冊中心(Registry)

它們之間的關系可以通過兩個概念來描述:

服務注冊服務提供者在啟動的時候向服務注冊中心(Registry)注冊自身服務,并向服務注冊中心(Registry)定期發送心跳匯報存好情況。

服務發現服務消費者注冊中心查詢服務提供者的地址,并通過該地址調用服務提供者的接口。

3.CAP理論

Consistency,一致性:這里的一致性指的是強一致性,所有結點在同一時間具有相同的數據;

Availability,可用性:保證每個請求都有響應;

Partition Tolerance,分區容錯性:分布式系統中的節點之間出現網絡分區(即部分節點無法通信)時,系統仍能繼續運行。

這個CAP是一個“不可能三角”,即這三個要求不能同時實現,要想實現CA就不能實現P,要實現AP就不能實現C。

在微服務系統中,P這一點是必須保證的,所有A和C只能實現一個。

二.Eureka

Eureka(尤里卡)曾是SpringCloud官方默認的注冊中心,其符合CAP理論中的AP,即保證分布式系統的可用性。

1.搭建服務中心

1)創建項目;

2)pom加入Eureka的依賴:

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>

3)配置文件,加入相關配置:

server:port: 10010
spring:application:name: eureka-server
eureka:instance:hostname: localhostclient:fetch-registry: false # 表示是否從Eureka Server獲取注冊信息,默認為true.因為這是一個單點的Eureka Server,不需要同步其他的Eureka Server節點的數據,這里設置為falseregister-with-eureka: false # 表示是否將自己注冊到Eureka Server,默認為true.由于當前應用就是Eureka Server,故而設置為false.service-url:# 設置Eureka Server的地址,查詢服務和注冊服務都需要依賴這個地址defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
logging:pattern:console: '%d{MM-dd HH:mm:ss.SSS} %c %M %L [%thread] %m%n'

4)啟動類,開啟Eureka的功能:

@EnableEurekaServer
@SpringBootApplication
public class EurekaServerApplication {public static void main(String[] args) {SpringApplication.run(EurekaServerApplication.class,args);}
}

此時我們啟動項目,在瀏覽器上輸入:127.0.0.1:10010,如果出現以下頁面說明成功了:

2.服務注冊

1)加入Eureka依賴:

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

2)修改配置信息:

配置服務的名稱和eureka地址

spring:application:name: product-service
eureka:client:service-url:defaultZone: http://127.0.0.1:10010/eureka

3)啟動程序

啟動程序后出現下面的界面說明注冊成功了:

注意紅線圈出的部分,這個Application的名字與剛剛配置的名字是一樣的:product-service。

3.服務發現

1)加入Eureka依賴:

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

2)修改配置信息:

spring:application:name: order-service
eureka:client:service-url:defaultZone: http://127.0.0.1:10010/eureka

3)修改遠程調用的代碼

修改本篇文章一開始提出的問題代碼:

@Resource
RestTemplate restTemplate;@Resource
DiscoveryClient discoveryClient;@RequestMapping("/{orderId}")
public OrderInfo getOrderById(@PathVariable("orderId") Integer orderId){OrderInfo orderInfo = orderMapper.selectByOrderId(orderId);//從eureka中獲取服務列表List<ServiceInstance> instances = discoveryClient.getInstances("product-service");//寫法一:EurekaServiceInstance instance=(EurekaServiceInstance)instances.get(0);String url=instance.getUri()+"/product/"+orderInfo.getProductId();//寫法二://String uri = instances.get(0).getUri().toString();//String url=uri+"/product/"+orderInfo.getProductId();ProductInfo productInfo = restTemplate.getForObject(url, ProductInfo.class);orderInfo.setProductInfo(productInfo);return orderInfo;
}

兩種寫法都可以。?

4)啟動程序

如果出現下面界面就說明成功了:

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/bicheng/77982.shtml
繁體地址,請注明出處:http://hk.pswp.cn/bicheng/77982.shtml
英文地址,請注明出處:http://en.pswp.cn/bicheng/77982.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

EAL4+與等保2.0:解讀中國網絡安全雙標準

EAL4與等保2.0&#xff1a;解讀中國網絡安全雙標準 在當今數字化時代&#xff0c;網絡安全已成為各個行業不可忽視的重要議題。特別是在金融、政府、醫療等領域&#xff0c;保護信息的安全性和隱私性顯得尤為關鍵。在中國&#xff0c;EAL4和等級保護2.0&#xff08;簡稱“等保…

FFmpeg+Nginx+VLC打造M3U8直播

一、視頻直播的技術原理和架構方案 直播模型一般包括三個模塊&#xff1a;主播方、服務器端和播放端 主播放創造視頻&#xff0c;加美顏、水印、特效、采集后推送給直播服務器 播放端&#xff1a; 直播服務器端&#xff1a;收集主播端的視頻推流&#xff0c;將其放大后推送給…

【Redis】緩存三劍客問題實踐(上)

本篇對緩存三劍客問題進行介紹和解決方案說明&#xff0c;下篇將進行實踐&#xff0c;有需要的同學可以跳轉下篇查看實踐篇&#xff1a;&#xff08;待發布&#xff09; 緩存三劍客是什么&#xff1f; 緩存三劍客指的是在分布式系統下使用緩存技術最常見的三類典型問題。它們分…

Flink 2.0 編譯

文章目錄 Flink 2.0 編譯第一個問題 java 版本太低maven 版本太低maven 版本太高開始編譯擴展多版本jdk 配置 Flink 2.0 編譯 看到Flink2.0 出來了&#xff0c;想去玩玩&#xff0c;看看怎么樣&#xff0c;當然第一件事&#xff0c;就是編譯代碼&#xff0c;但是沒想到這么多問…

獲取印度股票市場列表、查詢IPO信息以及通過WebSocket實時接收數據

為了對接印度股票市場&#xff0c;獲取市場列表、查詢IPO信息、查看漲跌排行榜以及通過WebSocket實時接收數據等步驟。 1. 獲取市場列表 首先&#xff0c;您需要獲取支持的市場列表&#xff0c;這有助于了解哪些市場可以交易或監控。 請求方法&#xff1a;GETURL&#xff1a…

云原生--CNCF-1-云原生計算基金會介紹(云原生生態的發展目標和未來)

1、CNCF定義與背景 云原生計算基金會&#xff08;Cloud Native Computing Foundation&#xff0c;CNCF&#xff09;是由Linux基金會于2015年12月發起成立的非營利組織&#xff0c;旨在推動云原生技術的標準化、開源生態建設和行業協作。其核心目標是通過開源項目和社區協作&am…

【Rust 精進之路之第5篇-數據基石·下】復合類型:元組 (Tuple) 與數組 (Array) 的定長世界

系列&#xff1a; Rust 精進之路&#xff1a;構建可靠、高效軟件的底層邏輯 作者&#xff1a; 碼覺客 發布日期&#xff1a; 2025-04-20 引言&#xff1a;從原子到分子——組合的力量 在上一篇【數據基石上】中&#xff0c;我們仔細研究了 Rust 的四種基本標量類型&#xff1…

MongoDB 集合名稱映射問題

項目場景 在使用 Spring Data MongoDB 進行開發時&#xff0c;定義了一個名為 CompetitionSignUpLog 的實體類&#xff0c;并創建了對應的 Repository 接口。需要明確該實體類在 MongoDB 中實際對應的集合名稱是 CompetitionSignUpLog 還是 competitionSignUpLog。 問題描述 …

物聯網 (IoT) 安全簡介

什么是物聯網安全&#xff1f; 物聯網安全是網絡安全的一個分支領域&#xff0c;專注于保護、監控和修復與物聯網&#xff08;IoT&#xff09;相關的威脅。物聯網是指由配備傳感器、軟件或其他技術的互聯設備組成的網絡&#xff0c;這些設備能夠通過互聯網收集、存儲和共享數據…

PCB原理圖解析(炸雞派為例)

晶振 這是外部晶振的原理圖。 32.768kHz 的晶振&#xff0c;常用于實時時鐘&#xff08;RTC&#xff09;電路&#xff0c;因為它的頻率恰好是一天的分數&#xff08;32768 秒&#xff09;&#xff0c;便于實現秒計數。 C25 和 C24&#xff1a;兩個 12pF 的電容&#xff0c;用于…

Jupyter Notebook 中切換/使用 conda 虛擬環境的方式(解決jupyter notebook 環境默認在base下面的問題)

使用 nb_conda_kernels 添加所有環境 一鍵添加所有 conda 環境 conda activate my-conda-env # this is the environment for your project and code conda install ipykernel conda deactivateconda activate base # could be also some other environment conda in…

【JAVA】十三、基礎知識“接口”精細講解!(二)(新手友好版~)

哈嘍大家好呀qvq&#xff0c;這里是乎里陳&#xff0c;接口這一知識點博主分為三篇博客為大家進行講解&#xff0c;今天為大家講解第二篇java中實現多個接口&#xff0c;接口間的繼承&#xff0c;抽象類和接口的區別知識點&#xff0c;更適合新手寶寶們閱讀~更多內容持續更新中…

基于MuJoCo物理引擎的機器人學習仿真框架robosuite

Robosuite 基于 MuJoCo 物理引擎&#xff0c;能支持多種機器人模型&#xff0c;提供豐富多樣的任務場景&#xff0c;像基礎的抓取、推物&#xff0c;精細的開門、擰瓶蓋等操作。它可靈活配置多種傳感器&#xff0c;提供本體、視覺、力 / 觸覺等感知數據。因其對強化學習友好&am…

企業微信自建應用開發回調事件實現方案

目錄 1. 前言 2. 正文 2.1 技術方案 2.2 策略上下文 2.2 添加客戶策略實現類 2.3 修改客戶信息策略實現類 2.4 默認策略實現類 2.5 接收事件的實體類&#xff08;可以根據事件格式的參數做修改&#xff09; 2.6 實際接收回調結果的接口 近日在開發企業微信的自建應用時…

Linux將多個塊設備掛載到一個掛載點

在 Linux 系統中&#xff0c;直接將多個塊設備掛載到同一個掛載點是不可能的。這是因為 Linux 的文件系統掛載機制設計為一個掛載點一次只能關聯一個文件系統。如果嘗試將多個塊設備掛載到同一個掛載點&#xff0c;后一次掛載會覆蓋前一次的掛載&#xff0c;導致只有最后掛載的…

Spark-SQL(四)

本節課學習了spark連接hive數據&#xff0c;在 spark-shell 中&#xff0c;可以看到連接成功 將依賴放進pom.xml中 運行代碼 創建文件夾 spark-warehouse 為了使在 node01:50070 中查看到數據庫&#xff0c;需要添加如下代碼&#xff0c;就可以看到新創建的數據庫 spark-sql_1…

野外價值觀:在真實世界的語言模型互動中發現并分析價值觀

每周跟蹤AI熱點新聞動向和震撼發展 想要探索生成式人工智能的前沿進展嗎&#xff1f;訂閱我們的簡報&#xff0c;深入解析最新的技術突破、實際應用案例和未來的趨勢。與全球數同行一同&#xff0c;從行業內部的深度分析和實用指南中受益。不要錯過這個機會&#xff0c;成為AI領…

el-select+vue-virtual-scroller解決數據量大卡頓問題

解決el-select中數據量過大時&#xff0c;顯示及搜索卡頓問題&#xff0c;及正確的回顯默認選中數據 粗略的封裝了組件&#xff0c;有需要各種屬性自定義的&#xff0c;自己添加設置下 環境 node 16.20.1 npm 8.19.4 vue2、element-ui "vue-virtual-scroller"…

Sqlite3交叉編譯全過程

Sqlite3交叉編譯全過程 一、概述二、下載三、解壓四、配置五、編譯六、安裝七、驗證文件類型八、移植8.1、頭文件sqlite3.h8.2、動態鏈接庫移植8.3、靜態態鏈接庫移植 九、驗證使用9.1. 關鍵函數說明 十、觸發器使用十一、sqlite表清空且恢復id值十二、全文總結 一、概述 SQLi…

軟考軟件設計師考試情況與大綱概述

文章目錄 **一、考試科目與形式****二、考試大綱與核心知識點****科目1&#xff1a;計算機與軟件工程知識****科目2&#xff1a;軟件設計** **三、備考建議****四、參考資料** 這是一個系列文章的開篇 本文對2025年軟考軟件設計師考試的大綱及核心內容進行了整理&#xff0c;并…