在使用springboot進(jìn)行開發(fā)的過程中，我們經(jīng)常需要處理這樣的場(chǎng)景：在服務(wù)啟動(dòng)的時(shí)候，需要向服務(wù)注冊(cè)中心(例如zk)注冊(cè)服務(wù)狀態(tài)，以便當(dāng)服務(wù)狀態(tài)改變的時(shí)候，可以故障摘除和負(fù)載均衡。
我遇到過兩種注冊(cè)的途徑：
1、在spring的webapplication啟動(dòng)完成后，直接進(jìn)行注冊(cè)；
2、在servlet容器啟動(dòng)完成后，通過listener進(jìn)行注冊(cè)。
本文通過一個(gè)demo講述一下這兩種注冊(cè)方式，使用的是傳統(tǒng)的向zk注冊(cè)的方案。
1、spring webapplication啟動(dòng)完成后注冊(cè)
先上代碼看一下
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
@springbootapplicationpublic 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("注冊(cè)2: webapplication啟動(dòng)完成后"); zkclient zkclient = context.getbean(zkclient.class); zkclient.register(); is_registry = true; logger.info("注冊(cè)2: 注冊(cè)成功"); } }} |
這里，我們?cè)趙ebapplication中，獲取zkclient，并進(jìn)行注冊(cè)。
這里需要說明一點(diǎn)，我們這里通過applicationcontext來獲取zkclient的bean，原因是在webapplication的初始化過程中你不能用autowired的方式注入bean，因?yàn)樵趙ebapplication啟動(dòng)過程中才會(huì)讀所有的configuration并將bean初始化完成，在沒有完成初始化之前，你不能注入bean。
關(guān)于注冊(cè)的詳細(xì)代碼這里不展開了。
2、在servlet容器初始化完成后，通過listener的方式進(jìn)行注冊(cè)
照樣先上代碼
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
@weblistenerpublic 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("注冊(cè)1: servelet容器啟動(dòng)成功后"); zkclient.register(); logger.info("注冊(cè)1: 注冊(cè)成功"); } is_registry = true; } catch (exception e) { is_registry = false; logger.info("注冊(cè)1: 注冊(cè)失敗"); } } @override public void contextdestroyed(servletcontextevent servletcontextevent) { if (is_registry) { zkclient.stop(); } }} |
你需要先寫一個(gè)listener，這個(gè)listener實(shí)現(xiàn)servletcontextlistener接口，并且用@weblistener進(jìn)行注解，這是springboot注解式的listener書寫方式。
在servlet容器啟動(dòng)成功之后，會(huì)調(diào)用這個(gè)監(jiān)聽器的contextinitialized方法，servlet容器如果一旦銷毀，不能提供服務(wù)了，會(huì)調(diào)用監(jiān)聽器的contextdestroyed方法。換句話說，這個(gè)監(jiān)聽器在監(jiān)聽servlet容器的狀態(tài)。
然后你只需要在application主類中打開listener配置就好。
|
1
2
3
4
|
@servletcomponentscan@springbootapplicationpublic class webapplication {} |
3、這兩種方式的比較
對(duì)于一個(gè)對(duì)外提供http協(xié)議的web服務(wù)，在語義上servlet容器的注冊(cè)會(huì)顯得清晰一些，但是如果你的spring容器啟動(dòng)時(shí)間過長(zhǎng)的話，可能出現(xiàn)servlet初始化完成，并且已經(jīng)注冊(cè)，但是服務(wù)不能對(duì)外提供訪問的gap time，所以我一般還是使用第一種方式進(jìn)行注冊(cè)。
這種場(chǎng)景是這樣的
可以看到，當(dāng)servlet注冊(cè)成功之后，其實(shí)webapplication還沒有啟動(dòng)完成，這個(gè)時(shí)候服務(wù)是不能正常提供訪問的。
在zk上可以看到，兩次注冊(cè)都已經(jīng)成功了。
總結(jié)
以上所述是小編給大家介紹的springboot 注冊(cè)服務(wù)注冊(cè)中心(zk)的兩種方式詳解，希望對(duì)大家有所幫助，如果大家有任何疑問請(qǐng)給我留言，小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)服務(wù)器之家網(wǎng)站的支持！
原文鏈接：http://www.cnblogs.com/kangoroo/p/8250857.html?utm_source=tuicool&utm_medium=referral
