自拍偷在线精品自拍偷,亚洲欧美中文日韩v在线观看不卡

實(shí)戰(zhàn):Nacos配置中心的Pull原理,附源碼

開發(fā) 架構(gòu)
配置中心(Configuration Center)通常用于集中管理應(yīng)用程序的配置信息。這些配置信息可以包括數(shù)據(jù)庫連接信息、外部服務(wù)地址、日志級別、超時設(shè)置等。配置中心可以提高應(yīng)用部署的靈活性和可維護(hù)性。

大家好,我是哪吒。

在單體服務(wù)時代,關(guān)于配置信息,管理一套配置文件即可。

而拆分成微服務(wù)之后,每一個系統(tǒng)都會有自己的配置,并且都各不相同,有些配置還需要動態(tài)改變,以達(dá)到動態(tài)降級、切流量、擴(kuò)縮容等目的。

一、本地配置

在Spring Boot開發(fā)中,可以把配置項(xiàng)放到config文件中,把配置當(dāng)代碼使用。比如:

public class AppConfig {
    public static final String static_SUCCESS_CODE = "0000";
    public static final String static_ERROR_CODE = "0001";
}

也可以通過@Value加載yaml配置文件中的配置。

@Component
public class HttpConfig {

    // 核心線程數(shù)
    public static String config_CORE_POOL_SIZE;

    @Value("${async.corePoolSize}")
    public void setSaveUrl(String corePoolSize) {
        HttpConfig.config_CORE_POOL_SIZE = corePoolSize;
    }
}

無論是將配置定義在代碼中,還是將配置寫在yaml配置文件中,都相當(dāng)于把配置存在應(yīng)用程序的本地。

如果想修改配置,就需要將在Linux服務(wù)器中部署的程序停止,然后手動修改其配置,再進(jìn)行重啟。

如果修改的配置項(xiàng)較多,這也是一項(xiàng)容易出錯,而且繁瑣的事情,長期運(yùn)維的小伙伴應(yīng)該深有體會。

當(dāng)時,我就在想,作為世界上使用人數(shù)最多的語言,更新一個配置,需要這么復(fù)雜嗎?

答案肯定不是的。

二、配置中心

配置中心(Configuration Center)通常用于集中管理應(yīng)用程序的配置信息。這些配置信息可以包括數(shù)據(jù)庫連接信息、外部服務(wù)地址、日志級別、超時設(shè)置等。配置中心可以提高應(yīng)用部署的靈活性和可維護(hù)性。

程序啟動時,可以自動從配置中心拉取所需要的配置項(xiàng),配置中心中配置有所改變時,同樣可以自動從配置中心拉取最新的配置信息,服務(wù)不需要重新發(fā)布。

1、以Nacos為例:

  • 配置中心的信息一般都是放在bootstrap.yml 中。
  • 初始化的時候,Bootstrap Context負(fù)責(zé)從外部源加載配置屬性并解析配置。
  • Bootstrap屬性有高優(yōu)先級,默認(rèn)情況下,它們不會被本地配置覆蓋。
  • 然后再讀取application.yml中的配置,進(jìn)行配置合并,完成項(xiàng)目的啟動。

項(xiàng)目的核心配置,需要熱更新的配置才有放到nacos管理的必要?;静粫兏囊恍┡渲眠€是保存在微服務(wù)本地比較好。

2、Pull模式

Nacos采用的是Pull模式獲取服務(wù)端數(shù)據(jù),客戶端采用長輪詢的方式定時的發(fā)起Pull請求,去檢查服務(wù)端配置信息是否發(fā)生了變化。

  • 客戶端發(fā)起長輪詢請求,監(jiān)聽變更的dataId+group。
  • 服務(wù)端收到客戶端的請求,這時會掛起客戶端的請求。
  • 如果在服務(wù)端設(shè)計(jì)的29.5s之內(nèi)都沒有發(fā)生變更,觸發(fā)自動檢查機(jī)制,此時不管是否有變化,服務(wù)端都會返回響應(yīng)到客戶端
  • 如果在29.5s之內(nèi)配置項(xiàng)發(fā)生了變更,則會觸發(fā)一個事件機(jī)制,將變更的數(shù)據(jù)推送的客戶端。

3、也可以通過Nacos實(shí)現(xiàn)注冊中心

這種是最簡單的Nacos注冊中心,有若干個服務(wù),都注冊到Nacos注冊中心,調(diào)用之前,先到Nacos獲取對應(yīng)接口,然后進(jìn)行實(shí)際的調(diào)用。

服務(wù)1和服務(wù)2和Nacos之間維護(hù)一個心跳關(guān)系,每5秒跳一次,頻率不能太快或者太慢,否者會嗝屁的。

  • 如果Nacos在5秒內(nèi)沒有收到心跳,則表示服務(wù)掛了,Nacos會下線此服務(wù)。
  • 對于超過15秒沒有收到客戶端心跳的服務(wù)實(shí)例,會將它的healthy屬性置為false,客戶端無法調(diào)用healthy為false的服務(wù)。
  • 如果超過30秒沒有收到心跳,Nacos會直接將此服務(wù)剔除。

也可以通過服務(wù)端主動注銷的方式,停止注冊。

服務(wù)1調(diào)用服務(wù)2時,服務(wù)1會通過定時任務(wù)到Nacos中獲取在線的服務(wù),保證所調(diào)用的服務(wù)一直都是健康在線的狀態(tài)。

獲取到之后,用緩存將其保存起來,然后通過負(fù)載均衡器調(diào)用服務(wù)2,此時,將不再使用服務(wù)端的負(fù)載均衡Nginx了。

三、配置中心提供了哪些功能

  • 配置項(xiàng)管理:支持添加、發(fā)布、修改配置項(xiàng)以及配置項(xiàng)的分組,可以實(shí)現(xiàn)版本管理,支持熱發(fā)布、灰度發(fā)布、環(huán)境隔離,提供API接口與可視化操作頁面。
  • 權(quán)限控制:配置項(xiàng)訪問控制,讀權(quán)限和寫權(quán)限。
  • 操作審計(jì):支持記錄用戶的操作行為。
  • 配置變更:當(dāng)有新的配置項(xiàng)或是現(xiàn)有的配置項(xiàng)發(fā)生變動時,配置中心能夠進(jìn)行實(shí)時的監(jiān)控并做出相應(yīng)的處理。
  • 配置推送:通過訂閱/發(fā)布的模式,將配置信息推送給各個服務(wù)的消費(fèi)者。
  • 歷史版本管理:保存所有的配置歷史版本,并提供查詢和對比的功能,可以輕松的回滾到任何一個版本。
  • 灰度發(fā)布:通過配置中心可以實(shí)現(xiàn)在部分環(huán)境中先發(fā)布新的配置項(xiàng),觀察一段時間沒有問題后再推送給其他所有的環(huán)境。
  • 配置變更審計(jì):記錄每次配置的修改記錄,方便追蹤和管理。

這些功能可以幫助降低分布式系統(tǒng)中管理配置信息的成本,降低因錯誤的配置信息變更帶來可用性下降甚至發(fā)生故障的風(fēng)險。

四、如何操作配置中心

1、配置注冊

配置中心的配置注冊通常包括以下步驟:

  • 服務(wù)提供者在啟動時,將自己的配置信息注冊到配置中心。這些信息可能包括服務(wù)的IP地址、端口號、數(shù)據(jù)庫連接信息等。
  • 配置中心接收并存儲這些配置信息。一般來說,配置中心會提供一個統(tǒng)一的接口或者界面,讓服務(wù)提供者能夠方便地進(jìn)行注冊。
  • 服務(wù)消費(fèi)者在需要使用某個服務(wù)時,會從配置中心獲取相應(yīng)的配置信息。這樣,即使服務(wù)提供者的地址等信息發(fā)生變化,服務(wù)消費(fèi)者也能通過配置中心獲取到最新的配置信息,而無需手動修改。

通過這種方式,配置中心實(shí)現(xiàn)了配置的統(tǒng)一管理和動態(tài)更新。服務(wù)提供者和消費(fèi)者都可以通過配置中心來進(jìn)行配置的注冊和獲取,大大提高了配置的靈活性和便利性。同時,也減少了因?yàn)槭謩优渲缅e誤而導(dǎo)致的問題,提高了系統(tǒng)的穩(wěn)定性和可用性。

要通過Java代碼實(shí)現(xiàn)配置注冊到配置中心,你可以遵循以下步驟。這里繼續(xù)提供一個通用的示例代碼,以展示基本的流程和步驟。請注意,實(shí)際的代碼可能會因所使用的具體配置中心而有所不同。

import com.configcenter.sdk.ConfigCenterClient;  
import com.configcenter.sdk.exception.ConfigCenterException;  
import com.configcenter.sdk.model.Configuration;  
  
public class ConfigurationRegistration {  
  
    public static void main(String[] args) {  
        // 配置中心的服務(wù)器URL和認(rèn)證令牌  
        String serverUrl = "configcenter_server_url";  
        String authToken = "your_auth_token";  
  
        // 創(chuàng)建配置對象  
        Configuration configuration = new Configuration();  
        configuration.setId("your_configuration_id");  
        configuration.setKey("your_configuration_key");  
        configuration.setValue("your_configuration_value");  
        // 可選:設(shè)置其他配置項(xiàng)屬性,如描述、標(biāo)簽等  
  
        try {  
            // 初始化配置中心的客戶端  
            ConfigCenterClient client = ConfigCenterClient.init(serverUrl, authToken);  
  
            // 調(diào)用配置中心的注冊API  
            boolean success = client.registerConfiguration(configuration);  
            if (success) {  
                System.out.println("配置注冊成功");  
            } else {  
                System.out.println("配置注冊失敗");  
            }  
        } catch (ConfigCenterException e) {  
            System.out.println("配置注冊出現(xiàn)異常: " + e.getMessage());  
            e.printStackTrace();  
        }  
    }  
}

在這個示例中:

  • 我們首先創(chuàng)建了一個Configuration對象,設(shè)置了配置項(xiàng)的ID、鍵(key)和值(value)。你可以根據(jù)需要設(shè)置其他屬性,如描述、標(biāo)簽等。
  • 然后,我們初始化配置中心的客戶端,并調(diào)用client.registerConfiguration()方法來執(zhí)行配置注冊操作,傳入創(chuàng)建好的Configuration對象。
  • 該方法將返回一個布爾值,表示注冊是否成功,我們根據(jù)返回結(jié)果打印相應(yīng)的消息。
  • 如果發(fā)生異常,我們進(jìn)行異常處理并打印異常信息。

2、配置反注冊

配置中心的配置反注冊是指從配置中心中移除或注銷某個配置項(xiàng)的過程。當(dāng)某個服務(wù)或應(yīng)用不再需要使用某個配置項(xiàng)時,可以進(jìn)行配置反注冊操作。這個操作通常通過配置中心提供的接口來完成,它會將指定的配置項(xiàng)從配置中心中刪除或標(biāo)記為注銷狀態(tài)。

配置反注冊可以是手動觸發(fā)的,也可以是自動觸發(fā)的。

  • 在手動觸發(fā)方式下,管理員或開發(fā)者可以通過調(diào)用配置中心提供的反注冊接口,指定需要反注冊的配置項(xiàng)。
  • 自動觸發(fā)方式下,通常會在服務(wù)或應(yīng)用停止時,自動觸發(fā)配置反注冊操作。

配置反注冊是配置中心的一個重要功能,它可以幫助管理員或開發(fā)者更好地管理配置項(xiàng)的生命周期,確保配置中心中的數(shù)據(jù)與實(shí)際應(yīng)用需求保持一致。同時,通過反注冊不再需要的配置項(xiàng),也可以減少配置中心的存儲空間和資源消耗。

要通過Java代碼實(shí)現(xiàn)配置反注冊,你需要使用配置中心提供的Java SDK或API。以下是一個示例代碼,展示了如何使用Java來實(shí)現(xiàn)配置反注冊。

import com.configcenter.sdk.ConfigCenterClient;  
import com.configcenter.sdk.exception.ConfigCenterException;  
  
public class ConfigurationDeregistration {  
  
    public static void main(String[] args) {  
        // 配置中心的服務(wù)器URL和認(rèn)證令牌  
        String serverUrl = "configcenter_server_url";  
        String authToken = "your_auth_token";  
  
        // 初始化配置中心的客戶端  
        ConfigCenterClient client = ConfigCenterClient.init(serverUrl, authToken);  
  
        // 配置項(xiàng)的ID  
        String configurationId = "your_configuration_id";  
  
        try {  
            // 調(diào)用配置中心的反注冊API  
            boolean success = client.deregisterConfiguration(configurationId);  
            if (success) {  
                System.out.println("配置反注冊成功");  
            } else {  
                System.out.println("配置反注冊失敗");  
            }  
        } catch (ConfigCenterException e) {  
            System.out.println("配置反注冊出現(xiàn)異常: " + e.getMessage());  
            e.printStackTrace();  
        }  
    }  
}

在這個示例中:

  • 我們首先通過ConfigCenterClient.init()初始化配置中心的客戶端,傳入服務(wù)器URL和認(rèn)證令牌。
  • 然后,我們調(diào)用client.deregisterConfiguration()方法來執(zhí)行配置反注冊操作,傳入配置項(xiàng)的ID。
  • 該方法將返回一個布爾值,指示反注冊是否成功。
  • 根據(jù)返回結(jié)果,我們打印相應(yīng)的消息。
  • 如果發(fā)生異常,我們捕獲并打印異常信息。

3、配置查看

通過配置中心的用戶界面和API接口,你可以方便地查看和管理配置項(xiàng)。

import com.configcenter.sdk.ConfigCenterClient;  
import com.configcenter.sdk.exception.ConfigCenterException;  
import com.configcenter.sdk.model.Configuration;  
  
public class ConfigurationViewer {  
  
    public static void main(String[] args) {  
        // 配置中心的服務(wù)器URL和認(rèn)證令牌  
        String serverUrl = "configcenter_server_url";  
        String authToken = "your_auth_token";  
  
        // 配置項(xiàng)的ID或鍵(key)  
        String configurationId = "your_configuration_id";  
        // 或者使用配置項(xiàng)的鍵(key)來獲取配置項(xiàng),根據(jù)配置中心API的要求而定  
        // String configurationKey = "your_configuration_key";  
  
        try {  
            // 初始化配置中心的客戶端  
            ConfigCenterClient client = ConfigCenterClient.init(serverUrl, authToken);  
  
            // 調(diào)用配置中心的API接口獲取配置項(xiàng)  
            Configuration configuration = client.getConfiguration(configurationId);  
            // 或者使用配置項(xiàng)的鍵(key)來獲取:  
            // Configuration configuration = client.getConfigurationByKey(configurationKey);  
  
            // 輸出配置項(xiàng)的信息  
            if (configuration != null) {  
                System.out.println("配置項(xiàng)ID: " + configuration.getId());  
                System.out.println("配置項(xiàng)鍵(key): " + configuration.getKey());  
                System.out.println("配置項(xiàng)值(value): " + configuration.getValue());  
                // 輸出其他配置項(xiàng)屬性,如描述、標(biāo)簽等  
            } else {  
                System.out.println("未找到配置項(xiàng)");  
            }  
        } catch (ConfigCenterException e) {  
            System.out.println("查看配置項(xiàng)出現(xiàn)異常: " + e.getMessage());  
            e.printStackTrace();  
        }  
    }  
}

在上面的示例代碼中:

  • 我們首先初始化配置中心的客戶端。
  • 然后調(diào)用相應(yīng)的API接口來獲取配置項(xiàng)。
  • 在獲取到配置項(xiàng)后,我們可以輸出配置項(xiàng)的各種屬性,如ID、鍵(key)、值(value)等。
  • 如果發(fā)生異常,我們進(jìn)行異常處理并打印相應(yīng)的異常信息。

4、配置變更訂閱

配置中心通常支持配置變更訂閱功能,允許應(yīng)用程序或其他服務(wù)訂閱配置項(xiàng)的變更通知。當(dāng)配置項(xiàng)發(fā)生變化時,配置中心會向訂閱者發(fā)送通知,以便訂閱者能夠及時獲取最新的配置項(xiàng)。

要通過Java代碼實(shí)現(xiàn)配置變更訂閱,你可以按照以下步驟進(jìn)行操作:

  • 首先,確保你已經(jīng)初始化了配置中心的客戶端,如上述示例代碼所示。
  • 創(chuàng)建一個訂閱者(listener)類,實(shí)現(xiàn)配置中心提供的訂閱接口。這個類將負(fù)責(zé)處理配置項(xiàng)的變更通知。
  • 在訂閱者類中,實(shí)現(xiàn)接口中定義的方法,以處理配置項(xiàng)的變更事件。該方法通常會在配置項(xiàng)發(fā)生變化時被調(diào)用,并且會接收包含變更信息的參數(shù)。
  • 在你的應(yīng)用程序或服務(wù)中,創(chuàng)建一個訂閱請求(subscription request)對象,指定你希望訂閱的配置項(xiàng)或配置項(xiàng)的過濾條件。
  • 使用配置中心的客戶端對象,調(diào)用訂閱方法,將訂閱請求對象和訂閱者對象作為參數(shù)傳遞給該方法。這將向配置中心注冊你的訂閱請求,并指定訂閱者類來處理變更通知。
  • 一旦注冊成功,當(dāng)配置項(xiàng)發(fā)生變更時,配置中心將調(diào)用訂閱者類中的方法,將變更信息傳遞給訂閱者。你可以在這個方法中編寫邏輯來處理配置項(xiàng)的變更,如更新本地緩存、重新加載配置等。

下面是一個簡單的示例代碼,展示如何實(shí)現(xiàn)配置變更訂閱:

import com.configcenter.sdk.ConfigCenterClient;  
import com.configcenter.sdk.exception.ConfigCenterException;  
import com.configcenter.sdk.listener.ConfigurationChangeListener;  
import com.configcenter.sdk.model.Configuration;  
  
public class ConfigurationSubscriber {  
  
    public static void main(String[] args) {  
        // 初始化配置中心的客戶端(省略代碼)  
  
        // 創(chuàng)建訂閱者類  
        ConfigurationChangeListener listener = new ConfigurationChangeListener() {  
            @Override  
            public void onConfigurationChanged(Configuration configuration) {  
                // 處理配置項(xiàng)變更事件  
                System.out.println("配置項(xiàng)發(fā)生變化: " + configuration.getKey() + " = " + configuration.getValue());  
                // 在這里可以更新本地緩存、重新加載配置等  
            }  
        };  
  
        try {  
            // 創(chuàng)建訂閱請求對象(根據(jù)配置中心API的要求而定)  
            // 指定你希望訂閱的配置項(xiàng)過濾條件,如配置項(xiàng)的鍵(key)或其他屬性  
  
            // 調(diào)用配置中心的訂閱方法  
            ConfigCenterClient client = ConfigCenterClient.init(serverUrl, authToken);  
            client.subscribeToConfigurationChanges(filter, listener);  
        } catch (ConfigCenterException e) {  
            System.out.println("配置變更訂閱出現(xiàn)異常: " + e.getMessage());  
            e.printStackTrace();  
        }  
    }  
}

五、主流的微服務(wù)注冊中心有哪些,如何選擇?

1、在選擇微服務(wù)注冊中心時,可以考慮以下因素:

  • 功能和特性:不同的注冊中心可能具有不同的功能和特性,需要根據(jù)自己的需求來選擇。例如,一些注冊中心可能更側(cè)重于服務(wù)發(fā)現(xiàn),而另一些可能提供更全面的配置管理功能。
  • 性能和穩(wěn)定性:注冊中心作為微服務(wù)架構(gòu)的核心組件,其性能和穩(wěn)定性至關(guān)重要。需要對候選的注冊中心進(jìn)行性能測試和穩(wěn)定性評估,確保它們能夠滿足你的業(yè)務(wù)需求。
  • 易用性和開發(fā)體驗(yàn):注冊中心的易用性和開發(fā)體驗(yàn)也是選擇的重要因素。選擇一個提供良好開發(fā)文檔、客戶端庫和工具的注冊中心,可以使開發(fā)過程更加順暢高效。
  • 社區(qū)支持和生態(tài)系統(tǒng):一個活躍和健康的社區(qū)可以為注冊中心提供持續(xù)的支持和改進(jìn)。同時,一個豐富的生態(tài)系統(tǒng)可以提供更多的集成選項(xiàng)和解決方案。因此,需要評估候選注冊中心的社區(qū)活躍度和生態(tài)系統(tǒng)成熟度。
  • 安全性和合規(guī)性:安全性和合規(guī)性對于任何系統(tǒng)都至關(guān)重要。需要確保所選的注冊中心能夠提供足夠的安全保障,并滿足你的合規(guī)性要求。

最終,選擇微服務(wù)注冊中心是一個權(quán)衡的過程,需要根據(jù)自己的實(shí)際需求、技術(shù)棧、團(tuán)隊(duì)熟悉度等因素進(jìn)行綜合考慮。

2、主流注冊中心

在Eureka、Consul、Zookeeper和Nacos這幾個微服務(wù)注冊中心中,選擇最適合的一個取決于你的具體需求和環(huán)境。

(1)Eureka

  • 是Netflix開發(fā)的服務(wù)注冊中心,與Spring Cloud集成良好。
  • 保證了高可用性和最終一致性,服務(wù)注冊相對較快。
  • 在數(shù)據(jù)不一致時,每個Eureka節(jié)點(diǎn)仍能正常對外提供服務(wù),保證了可用性。

(2)Consul

  • 使用Go語言編寫,具有較好的跨平臺性。
  • 提供了豐富的功能和強(qiáng)大的一致性保證。
  • 支持多數(shù)據(jù)中心和分布式部署,適合大規(guī)模環(huán)境。

(3)Zookeeper

  • 最初是一個分布式協(xié)調(diào)服務(wù),后來被用于服務(wù)注冊和發(fā)現(xiàn)。
  • 提供了強(qiáng)一致性和高可用性,但相對較復(fù)雜,需要自行實(shí)現(xiàn)一些服務(wù)發(fā)現(xiàn)功能。

(4)Nacos

  • 是阿里巴巴開源的項(xiàng)目,支持基于DNS和基于RPC的服務(wù)發(fā)現(xiàn)。
  • 除了服務(wù)注冊和發(fā)現(xiàn),還支持動態(tài)配置服務(wù)。
  • 在Spring Cloud中使用較為簡單,只需簡單的配置即可完成服務(wù)的注冊和發(fā)現(xiàn)。

3、如何選擇?

  • 如果你使用Spring Cloud作為微服務(wù)框架,Eureka可能是一個自然的選擇,因?yàn)樗cSpring Cloud集成良好。
  • 如果你需要強(qiáng)大的跨平臺支持和一致性保證,Consul是一個不錯的選擇。
  • 如果你已經(jīng)在使用Zookeeper或其他Apache項(xiàng)目,并且希望在同一生態(tài)系統(tǒng)中解決服務(wù)注冊和發(fā)現(xiàn)問題,那么Zookeeper可能適合你。
  • 如果你在尋找一個簡單且與阿里巴巴技術(shù)棧集成的解決方案,Nacos是一個值得考慮的選項(xiàng)。

最終的選擇應(yīng)基于你的技術(shù)需求、團(tuán)隊(duì)熟悉度和業(yè)務(wù)場景。

責(zé)任編輯:姜華 來源: 哪吒編程
相關(guān)推薦

2021-08-09 07:58:36

Nacos 服務(wù)注冊源碼分析

2021-07-02 22:23:50

Nacos配置模型

2021-08-27 07:47:07

Nacos灰度源碼

2021-06-29 07:04:38

Nacos服務(wù)配置

2021-06-10 06:57:39

Nacos配置模塊

2022-06-13 09:58:06

NacosSpring

2024-12-10 08:27:28

2022-08-29 06:27:15

Nacos微服務(wù)

2022-08-30 22:12:19

Nacos組件服務(wù)注冊

2023-08-03 08:51:07

2021-08-02 07:35:19

Nacos配置中心namespace

2021-03-15 06:24:22

Nacos集群搭建微服務(wù)

2023-05-31 19:10:31

2021-02-10 09:54:15

分布式NacosApollo

2024-10-14 12:17:17

Flutter開源項(xiàng)目

2024-12-27 12:10:58

2024-01-02 22:47:47

Nacos注冊中心節(jié)點(diǎn)

2023-03-01 08:15:10

NginxNacos

2021-07-12 08:00:21

Nacos 服務(wù)注冊源碼分析

2021-12-31 08:44:11

CSS 技巧代碼重構(gòu)
點(diǎn)贊
收藏

51CTO技術(shù)棧公眾號