1.查询redis

———— by qlm

src/main/java/com/xc/controller/WebSocketTestController.java

@@ -1,11 +1,15 @@
 package com.xc.controller;
 
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
+import com.xc.pub.redismessage.util.RedisUtil;
 import com.xc.utils.HttpRequest;
 import com.xc.utils.websocket.WsClient;
 import com.xc.service.InitStockListService;
 import com.xc.utils.PropertiesUtil;
 import com.xc.vo.stock.StockVO;
+import org.apache.commons.lang3.StringUtils;
 import org.java_websocket.WebSocket;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -17,6 +21,7 @@ import org.springframework.web.bind.annotation.ResponseBody;
 import java.math.BigDecimal;
 import java.net.URI;
 import java.util.ArrayList;
+import java.util.Iterator;
 import java.util.List;
 import java.util.UUID;
 
@@ -78,7 +83,39 @@ public class WebSocketTestController {
         return "true";
     }
 
+    @Autowired
+    private RedisUtil redisUtil;
 
+    @RequestMapping({"showRedis.do"})
+    @ResponseBody
+    public String showRedis(String key, String code) {
+        String redisData = "";
+        try {
+            if (StringUtils.isBlank(key)) {
+                key = "data_coin";
+            }
+            String redisKey = String.format(key);
+            redisData = redisUtil.getItem(redisKey);
+            if (StringUtils.isNotBlank(code)) {
+                List<StockVO> stockRedisList = new ArrayList<>();
+                if (StringUtils.isNotEmpty(redisData) && !("[]".equals(redisData))) {
+                    stockRedisList = JSONArray.parseArray(redisData, StockVO.class);
+                    Iterator<StockVO> iteratorRedis = stockRedisList.iterator();
+                    while (iteratorRedis.hasNext()) {
+                        StockVO stockRedis = iteratorRedis.next();
+                        if (code.equals(stockRedis.getCode())) {
+                            redisData = JSON.toJSONString(stockRedis);
+                            break;
+                        }
+                    }
+                }
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+            return e.toString();
+        }
+        return redisData;
+    }
 
 
     @RequestMapping({"test.do"})