springboot 注冊服務注冊中心(zk)的兩種方式詳解
在使用springboot進行開發(fā)的過程中,我們經常需要處理這樣的場景:在服務啟動的時候,需要向服務注冊中心(例如zk)注冊服務狀態(tài),以便當服務狀態(tài)改變的時候,可以故障摘除和負載均衡。
我遇到過兩種注冊的途徑:
1、在Spring的webapplication啟動完成后,直接進行注冊;
2、在servlet容器啟動完成后,通過listener進行注冊。
本文通過一個demo講述一下這兩種注冊方式,使用的是傳統(tǒng)的向zk注冊的方案。
1、Spring webapplication啟動完成后注冊
先上代碼看一下
@SpringBootApplication
public class WebApplication {
private static final Logger logger = LoggerFactory.getLogger(WebApplication.class);
private static volatile boolean IS_REGISTRY = false;
public static void main(String[] args) {
ApplicationContext context = run(WebApplication.class, args);
if (IS_REGISTRY) {
logger.info("注冊2: WebApplication啟動完成后");
ZkClient zkClient = context.getBean(ZkClient.class);
zkClient.register();
IS_REGISTRY = true;
logger.info("注冊2: 注冊成功");
}
}
}
這里,我們在WebApplication中,獲取zkClient,并進行注冊。
這里需要說明一點,我們這里通過ApplicationContext來獲取zkClient的bean,原因是在webApplication的初始化過程中你不能用Autowired的方式注入Bean,因為在webApplication啟動過程中才會讀所有的configuration并將bean初始化完成,在沒有完成初始化之前,你不能注入bean。
關于注冊的詳細代碼這里不展開了。
2、在servlet容器初始化完成后,通過listener的方式進行注冊
照樣先上代碼
@WebListener
public class RegisterListener implements ServletContextListener {
protected final Logger logger = LoggerFactory.getLogger(this.getClass());
private static volatile boolean IS_REGISTRY = false;
@Autowired
private ZkClient zkClient;
@Override
public void contextInitialized(ServletContextEvent servletContextEvent) {
try {
if (!IS_REGISTRY) {
logger.info("注冊1: Servelet容器啟動成功后");
zkClient.register();
logger.info("注冊1: 注冊成功");
}
IS_REGISTRY = true;
} catch (Exception e) {
IS_REGISTRY = false;
logger.info("注冊1: 注冊失敗");
}
}
@Override
public void contextDestroyed(ServletContextEvent servletContextEvent) {
if (IS_REGISTRY) {
zkClient.stop();
}
}
}
你需要先寫一個listener,這個listener實現ServletContextListener接口,并且用@WebListener進行注解,這是springboot注解式的listener書寫方式。
在servlet容器啟動成功之后,會調用這個監(jiān)聽器的contextInitialized方法,servlet容器如果一旦銷毀,不能提供服務了,會調用監(jiān)聽器的contextDestroyed方法。換句話說,這個監(jiān)聽器在監(jiān)聽servlet容器的狀態(tài)。
然后你只需要在application主類中打開listener配置就好。
@ServletComponentScan
@SpringBootApplication
public class WebApplication {
}
3、這兩種方式的比較
對于一個對外提供http協議的web服務,在語義上servlet容器的注冊會顯得清晰一些,但是如果你的spring容器啟動時間過長的話,可能出現servlet初始化完成,并且已經注冊,但是服務不能對外提供訪問的gap time,所以我一般還是使用第一種方式進行注冊。
這種場景是這樣的

可以看到,當servlet注冊成功之后,其實webapplication還沒有啟動完成,這個時候服務是不能正常提供訪問的。

在zk上可以看到,兩次注冊都已經成功了。
總結
以上所述是小編給大家介紹的springboot 注冊服務注冊中心(zk)的兩種方式詳解,希望對大家有所幫助,如果大家有任何疑問請給我留言,小編會及時回復大家的。在此也非常感謝大家對腳本之家網站的支持!
相關文章
詳解mybatis-plus配置找不到Mapper接口路徑的坑
這篇文章主要介紹了詳解mybatis-plus配置找不到Mapper接口路徑的坑,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2020-10-10
淺談synchronized加鎖this和class的區(qū)別
synchronized 是 Java 語言中處理并發(fā)問題的一種常用手段,本文主要介紹了synchronized加鎖this和class的區(qū)別,具有一定的參考價值,感興趣的可以了解一下2021-11-11
Mybatis-plus獲取雪花算法生成的ID并返回生成ID
本文主要介紹了Mybatis-plus獲取雪花算法生成的ID并返回生成ID,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2023-09-09
Spring Boot集成Resilience4J實現限流/重試/隔離
在Java的微服務生態(tài)中,對于服務保護組件,像springcloud的Hystrix,springcloud?alibaba的Sentinel,以及當Hystrix停更之后官方推薦使用的Resilience4j,所以本文給大家介紹了Spring Boot集成Resilience4J實現限流/重試/隔離,需要的朋友可以參考下2024-03-03

