| File was renamed from websocketClient/src/main/java/org/example/wsClient/MexcClient.java |
| | |
| | | package org.example.wsClient; |
| | | package org.example.mexcclient.wsClient; |
| | | |
| | | import com.fasterxml.jackson.core.JsonProcessingException; |
| | | import com.fasterxml.jackson.databind.ObjectMapper; |
| | |
| | | import com.google.gson.Gson; |
| | | import com.google.gson.JsonSyntaxException; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.example.pojo.Currency; |
| | | import org.example.util.RedisUtil; |
| | | import org.example.mexcclient.pojo.Currency; |
| | | import org.example.mexcclient.util.RedisUtil; |
| | | |
| | | import javax.websocket.*; |
| | | import java.io.IOException; |
| | |
| | | hashMap.put("asks",resultMap.get("asks")); |
| | | String key = "mexc" + map.get("s").toString(); |
| | | RedisUtil.set(key, mapper.writeValueAsString(hashMap)); |
| | | } else { |
| | | log.warn("消息不包含 's' 字段或解析失败:" + message); |
| | | } |
| | | } catch (JsonSyntaxException e) { |
| | | log.error("JSON 解析异常:" + e.getMessage(), e); |