一.前言
我們提供的服務(wù)有：網(wǎng)站制作、成都做網(wǎng)站、微信公眾號開發(fā)、網(wǎng)站優(yōu)化、網(wǎng)站認(rèn)證、南山ssl等。為近千家企事業(yè)單位解決了網(wǎng)站和推廣的問題。提供周到的售前咨詢和貼心的售后服務(wù)，是有科學(xué)管理、有技術(shù)的南山網(wǎng)站制作公司
近期由于公司不同平臺項目之間的業(yè)務(wù)整合,需要做到相互訪問! 每個平臺均有自己的注冊中心和服務(wù),且注冊中心相互之間并沒有相互注冊!
借助spring的事件監(jiān)聽,在eureka-server端監(jiān)聽服務(wù)注冊,將所有服務(wù)的ip和port存放至redis庫,然后讓其他平臺服務(wù)通過redis庫獲取ip和端口號,進(jìn)而進(jìn)行http調(diào)用.結(jié)構(gòu)圖如下:
二.事件解析
事件列表
在org.springframework.cloud.netflix.eureka.server.event包下會發(fā)現(xiàn)如下類:
重慶分公司
重慶分公司
EurekaInstanceCanceledEvent: 服務(wù)下線事件EurekaInstanceRegisteredEvent: 服務(wù)注冊事件EurekaInstanceRenewedEvent: 服務(wù)續(xù)約事件EurekaRegistryAvailableEvent: eureka注冊中心啟動事件EurekaServerStartedEvent: eureka server啟動時間源碼分析
打開org.springframework.cloud.netflix.eureka.server.InstanceRegistry類,會發(fā)現(xiàn)當(dāng)eureka服務(wù)續(xù)約、注冊、取消等時,spring會publish不同的事件,對應(yīng)的事件類就是上面的列表.
續(xù)約事件
@Override
public boolean renew(final String appName, final String serverId,
boolean isReplication) {
log("renew " + appName + " serverId " + serverId + ", isReplication {}"
+ isReplication);
List 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;
}
}
// 發(fā)布續(xù)約事件
publishEvent(new EurekaInstanceRenewedEvent(this, appName, serverId,
instance, isReplication));
break;
}
}
return super.renew(appName, serverId, isReplication);
} 注冊事件
@Override
public 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);
// 發(fā)布注冊事件
publishEvent(new EurekaInstanceRegisteredEvent(this, info, leaseDuration,
isReplication));
}事件監(jiān)聽
通過上面的源碼追溯,我們已經(jīng)得到對應(yīng)的事件類了,所以現(xiàn)在要做的僅僅是監(jiān)聽對應(yīng)的事件即可,至此已經(jīng)完成了我們所需要對事件監(jiān)聽后的業(yè)務(wù)處理!
@Component
public class EurekaStateChangeListener {
@Value("${iptable.platform}")
private String platform;
@Autowired
private RedisTemplate redisTemplate;
private static Logger logger = LoggerFactory.getLogger(EurekaStateChangeListener.class);
private static final String COLON = ":";
@EventListener//(condition = "#event.replication==false")
public void listen(EurekaInstanceCanceledEvent eurekaInstanceCanceledEvent) {
// 服務(wù)斷線事件
String appName = eurekaInstanceCanceledEvent.getAppName();
String serverId = eurekaInstanceCanceledEvent.getServerId();
Objects.requireNonNull(appName, "服務(wù)名不能為空!");
SetOperations opsForSet = redisTemplate.opsForSet();
opsForSet.remove((platform + appName).toLowerCase(), serverId);
logger.info(">>>>>>> 失效服務(wù):{},已被剔除!", serverId);
}
@EventListener//(condition = "#event.replication==false")
public void listen(EurekaInstanceRegisteredEvent event) {
// 服務(wù)注冊
InstanceInfo instanceInfo = event.getInstanceInfo();
String appName = instanceInfo.getAppName();
Objects.requireNonNull(appName, "服務(wù)名不能為空!");
SetOperations opsForSet = redisTemplate.opsForSet();
opsForSet.add((platform + appName).toLowerCase(), instanceInfo.getIPAddr() + COLON + instanceInfo.getPort());
logger.info(">>>>>>> 服務(wù)名:{},端口號:{},已緩存至redis", appName, instanceInfo.getPort());
}
@EventListener//(condition = "#event.replication==false")
public void listen(EurekaInstanceRenewedEvent event) {
// 服務(wù)續(xù)約
logger.info(">>>>>>>>>>>>>>>Server續(xù)約:" + event.getServerId());
}
@EventListener
public void listen(EurekaRegistryAvailableEvent event) {
// 注冊中心啟動
logger.info(">>>>>>>>>>>>>>>Server注冊中心:" + event);
}
@EventListener
public void listen(EurekaServerStartedEvent event) {
// Server啟動
logger.info(">>>>>>>>>>>>>>>Server啟動:" + event);
}
} 注意事項
[ ]版本問題:
當(dāng)時項目組用的SpringCloud版本是Brixton.RELEASE,該版本有一個問題就是服務(wù)注冊和下線并不會出發(fā)對應(yīng)的事件,所以導(dǎo)致一直監(jiān)聽不到.解決的辦法也很簡單,只要升級版本即可,我已經(jīng)升級到最新版本Finchley.RELEASE.
傳送門,點我
[ ] 重復(fù)監(jiān)聽:
例如,在續(xù)約的時候,eureka會發(fā)出2條EurekaInstanceRenewedEvent事件,但是2條事件的屬性卻不一樣!一個事件的屬性replication為true,另外一個為false.如果我們只想處理replication=true的事件,如下配置即可:
@EventListener(condition = "#event.replication==false")
public void listen(EurekaInstanceRenewedEvent event) {
// 服務(wù)續(xù)約
logger.info(">>>>>>>>>>>>>>>Server續(xù)約:" + event.getServerId());
}
GitHub代碼,點我
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持創(chuàng)新互聯(lián)。
