一.前言

近期由于公司不同平臺項目之間的業務整合,需要做到相互訪問! 每個平臺均有自己的注冊中心和服務,且注冊中心相互之間并沒有相互注冊!
　 借助spring的事件監聽,在eureka-server端監聽服務注冊,將所有服務的ip和port存放至redis庫,然后讓其他平臺服務通過redis庫獲取ip和端口號,進而進行http調用.結構圖如下:

二.事件解析

事件列表

在org.springframework.cloud.netflix.eureka.server.event包下會發現如下類:

• EurekaInstanceCanceledEvent: 服務下線事件
• EurekaInstanceRegisteredEvent: 服務注冊事件
• EurekaInstanceRenewedEvent: 服務續約事件
• EurekaRegistryAvailableEvent: eureka注冊中心啟動事件
• EurekaServerStartedEvent: eureka server啟動時間

源碼分析

打開org.springframework.cloud.netflix.eureka.server.InstanceRegistry類,會發現當eureka服務續約、注冊、取消等時,spring會publish不同的事件,對應的事件類就是上面的列表. 續約事件 @Overridepublic boolean renew(final String appName, final String serverId,boolean isReplication) {log("renew " + appName + " serverId " + serverId + ", isReplication {}"+ isReplication);List<Application> applications = getSortedApplications();for (Application input : applications) {if (input.getName().equals(appName)) {InstanceInfo instance = null;for (InstanceInfo info : input.getInstances()) {if (info.getId().equals(serverId)) {instance = info;break;}}// 發布續約事件publishEvent(new EurekaInstanceRenewedEvent(this, appName, serverId,instance, isReplication));break;}}return super.renew(appName, serverId, isReplication);} 注冊事件 @Overridepublic void register(InstanceInfo info, int leaseDuration, boolean isReplication) {handleRegistration(info, leaseDuration, isReplication);super.register(info, leaseDuration, isReplication);}private void handleRegistration(InstanceInfo info, int leaseDuration,boolean isReplication) {log("register " + info.getAppName() + ", vip " + info.getVIPAddress()+ ", leaseDuration " + leaseDuration + ", isReplication "+ isReplication);// 發布注冊事件publishEvent(new EurekaInstanceRegisteredEvent(this, info, leaseDuration,isReplication));}

事件監聽

通過上面的源碼追溯,我們已經得到對應的事件類了,所以現在要做的僅僅是監聽對應的事件即可,至此已經完成了我們所需要對事件監聽后的業務處理! @Component public class EurekaStateChangeListener {@Value("${iptable.platform}")private String platform;@Autowiredprivate RedisTemplate<String, String> redisTemplate;private static Logger logger = LoggerFactory.getLogger(EurekaStateChangeListener.class);private static final String COLON = ":";@EventListener//(condition = "#event.replication==false")public void listen(EurekaInstanceCanceledEvent eurekaInstanceCanceledEvent) {// 服務斷線事件String appName = eurekaInstanceCanceledEvent.getAppName();String serverId = eurekaInstanceCanceledEvent.getServerId();Objects.requireNonNull(appName, "服務名不能為空!");SetOperations<String, String> opsForSet = redisTemplate.opsForSet();opsForSet.remove((platform + appName).toLowerCase(), serverId);logger.info(">>>>>>> 失效服務:{},已被剔除!", serverId);}@EventListener//(condition = "#event.replication==false")public void listen(EurekaInstanceRegisteredEvent event) {// 服務注冊InstanceInfo instanceInfo = event.getInstanceInfo();String appName = instanceInfo.getAppName();Objects.requireNonNull(appName, "服務名不能為空!");SetOperations<String, String> opsForSet = redisTemplate.opsForSet();opsForSet.add((platform + appName).toLowerCase(), instanceInfo.getIPAddr() + COLON + instanceInfo.getPort());logger.info(">>>>>>> 服務名:{},端口號:{},已緩存至redis", appName, instanceInfo.getPort());}@EventListener//(condition = "#event.replication==false")public void listen(EurekaInstanceRenewedEvent event) {// 服務續約logger.info(">>>>>>>>>>>>>>>Server續約:" + event.getServerId());}@EventListenerpublic void listen(EurekaRegistryAvailableEvent event) {// 注冊中心啟動logger.info(">>>>>>>>>>>>>>>Server注冊中心:" + event);}@EventListenerpublic void listen(EurekaServerStartedEvent event) {// Server啟動logger.info(">>>>>>>>>>>>>>>Server啟動:" + event);} }

注意事項

• [ ] 版本問題:

當時項目組用的SpringCloud版本是Brixton.RELEASE,該版本有一個問題就是服務注冊和下線并不會出發對應的事件,所以導致一直監聽不到.解決的辦法也很簡單,只要升級版本即可,我已經升級到最新版本Finchley.RELEASE.
　 傳送門,點我
　

• [ ] 重復監聽:

例如,在續約的時候,eureka會發出2條EurekaInstanceRenewedEvent事件,但是2條事件的屬性卻不一樣!一個事件的屬性replication為true,另外一個為false.如果我們只想處理replication=true的事件,如下配置即可:

@EventListener(condition = "#event.replication==false")public void listen(EurekaInstanceRenewedEvent event) {// 服務續約logger.info(">>>>>>>>>>>>>>>Server續約:" + event.getServerId());}

---

GitHub代碼,點我

總結

以上是生活随笔為你收集整理的SpringCloud eureka服务状态监听的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。