memcached获取失败从缓存中移除

linlong
Commit 26001be3c2d552d8dfaac33cbc05a97dd1159bcb 1 parent fdc72039
Showing 1 changed file with 3 additions and 1 deletions
monitor-service-middleware/src/main/java/com/monitor/middleware/memcached/service/MemcachedMonitorImpl.java
--- a/monitor-service-middleware/src/main/java/com/monitor/middleware/memcached/service/MemcachedMonitorImpl.java
View file @26001be
+++ b/monitor-service-middleware/src/main/java/com/monitor/middleware/memcached/service/MemcachedMonitorImpl.java
View file @26001be
@@ -82,7 +82,7 @@ public class MemcachedMonitorImpl {
      * @param monitorUrl 监控url
      */
     private void doMonitor(StringBuffer monitorUrl) {
-        Map<InetSocketAddress, Map<String, String>> result = new HashMap<>();
+         Map<InetSocketAddress, Map<String, String>> result = new HashMap<>();
         try {
             MemcachedClient client = new XMemcachedClient(AddrUtil.getAddresses(monitorUrl.toString().trim()));
             result = client.getStats();
@@ -177,6 +177,8 @@ public class MemcachedMonitorImpl {
             StringBuffer failUrl = new StringBuffer();
             for (InetSocketAddress address: monitorUrlSet) {
                 failUrl.append(address.toString()+" ");
+                //获取失败时从缓存中移除数据
+                MemConstants.MEMCACHED_INFO_MAP.remove(address.toString().substring(1,address.toString().length()));
             }
             alarmMsgService.sendSms("Memcached", "Failed to get Memcached status" + failUrl.toString() + " .", snsMobileConfig.getBaseMobile());