中互金项目支持eureka平滑下线

src/main/java/com/controller/CheckController.java

+package com.controller;
+
+import com.alibaba.fastjson.JSON;
+import com.google.common.collect.ImmutableMap;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.Map;
+import java.util.UUID;
+import java.util.concurrent.ConcurrentHashMap;
+
+/**
+ * @Author fengjunkai
+ */
+@Slf4j
+@RestController
+@RequestMapping("/")
+public class CheckController {
+
+    private static Map<String,String> map = new ConcurrentHashMap<>();
+
+    @ResponseBody
+    @RequestMapping(value="check")
+    public ResponseEntity<String> check(){
+        if(map!=null && map.size()>0){
+            return new ResponseEntity<String>(HttpStatus.NOT_FOUND);
+        }else{
+            return new ResponseEntity<String>(HttpStatus.OK);
+        }
+    }
+
+    @ResponseBody
+    @RequestMapping(value="/online")
+    public Map<String, String> online(){
+        log.info("应用上线，流量开始切入....");
+        map.clear();
+        return responseOk();
+    }
+
+    @ResponseBody
+    @RequestMapping(value="/offline")
+    public Map<String, String> offline(){
+        log.info("应用下线，流量不再切入....");
+        map.put("status", "offline");
+        return responseOk();
+    }
+
+    @ResponseBody
+    @RequestMapping(value="/test")
+    public Map<String, String> test() {
+        log.info("CheckController测试!map = {}", map);
+        return ImmutableMap.of("code", "0", "msg", JSON.toJSONString(map));
+    }
+    public static Map<String, String> responseOk() {
+        return ImmutableMap.of("code", "0", "msg", "ok");
+    }
+
+    @RequestMapping("/getuuid")
+    public String getUuid(String param){
+        return UUID.nameUUIDFromBytes(param.getBytes()).toString();
+    }
+
+
+}

src/main/java/com/controller/DiscoveryManagerController.java

+package com.controller;
+
+import com.netflix.discovery.EurekaClient;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @Author fengjunkai
+ */
+@Slf4j
+@RestController
+@RequestMapping("/")
+public class DiscoveryManagerController {
+
+    @Autowired
+    @Qualifier("eurekaClient")
+    private EurekaClient eurekaClient;
+
+    @RequestMapping("clientShutdown")
+    public void clientShutdown(){
+        try{
+            eurekaClient.shutdown();
+            log.info("百行报送项目通知eureka下线成功");
+        }catch(Exception e){
+            log.error("百行报送项目通知eureka下线异常", e);
+        }
+    }
+
+    @RequestMapping("test1")
+    public String test(){
+        try {
+            log.info("开始执行");
+            Thread.sleep(10000);
+            log.info("执行结束");
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+        return "hello world !!!";
+    }
+
+}