From 1a650a4df5acf6ba55b30c003dfe59c4846f3af0 Mon Sep 17 00:00:00 2001
From: xueqingkun <xueqingkun@126.com>
Date: Wed, 6 Dec 2023 13:24:50 +0800
Subject: [PATCH] =?UTF-8?q?web=EF=BC=9A1.=20=E5=88=A0=E9=99=A4=20HeartCont?=
=?UTF-8?q?roller?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../controller/HeartController.java | 68 -------------------
1 file changed, 68 deletions(-)
delete mode 100644 virtual-patient-web/src/main/java/com/supervision/controller/HeartController.java
diff --git a/virtual-patient-web/src/main/java/com/supervision/controller/HeartController.java b/virtual-patient-web/src/main/java/com/supervision/controller/HeartController.java
deleted file mode 100644
index 78779e9a..00000000
--- a/virtual-patient-web/src/main/java/com/supervision/controller/HeartController.java
+++ /dev/null
@@ -1,68 +0,0 @@
-package com.supervision.controller;
-
-import cn.hutool.cache.CacheUtil;
-import cn.hutool.cache.impl.TimedCache;
-import cn.hutool.core.collection.CollectionUtil;
-import cn.hutool.core.util.StrUtil;
-import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiOperation;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-import javax.servlet.http.HttpServletRequest;
-import java.util.*;
-
-
-@Slf4j
-@Api(tags = "心跳检查")
-@RestController
-@RequestMapping("heart")
-@RequiredArgsConstructor
-public class HeartController {
-
-
- TimedCache<Object, Object> onlineCache = CacheUtil.newTimedCache(50*1000);
-
- {
- onlineCache.setListener((key,value)->{
- log.info(" onlineCache : remove listener key: " + key + " value: "+value);
- onlineCache.remove(key);
- });
- }
- @ApiOperation("心跳")
- @GetMapping("ping")
- public void ping (String processId, HttpServletRequest request) {
-
- String ipAddress = request.getHeader("X-Real-IPheader");
-
- if (StrUtil.isEmpty(ipAddress)){
- log.info("X-Real-IPheader is empty ....,use ip " + request.getRemoteAddr());
- ipAddress = request.getRemoteAddr();
- }
-
- if (StrUtil.isNotEmpty(ipAddress)){
- log.info("onlineCache : set cache... processId: "+ processId + " value "+ipAddress);
- onlineCache.put(processId,ipAddress);
- }
- }
-
- @ApiOperation("存活节点")
- @GetMapping("get")
- public Map<String, Object> getOnline () {
- Map<String, Object> result = new HashMap<>();
- Set<Object> objects = onlineCache.keySet();
- if (CollectionUtil.isNotEmpty(objects)){
- for (Object key : objects) {
- result.put(key.toString(),onlineCache.get(key));
- }
- }
- return result;
-
- }
-
-
-
-}