From 74ca5bc0f40e3b91464c8972392271d24dd5f066 Mon Sep 17 00:00:00 2001
From: zainali5120 <512061637@qq.com>
Date: Mon, 14 Sep 2020 11:05:48 +0800
Subject: [PATCH] 撮合交易代码提交
---
src/main/java/com/xcong/excoin/websocket/TradePlateSendWebSocket.java | 12 ++++++++----
1 files changed, 8 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/websocket/TradePlateSendWebSocket.java b/src/main/java/com/xcong/excoin/websocket/TradePlateSendWebSocket.java
index b955f11..bb8bcb3 100644
--- a/src/main/java/com/xcong/excoin/websocket/TradePlateSendWebSocket.java
+++ b/src/main/java/com/xcong/excoin/websocket/TradePlateSendWebSocket.java
@@ -75,6 +75,7 @@
JSONObject jsonObject = JSON.parseObject(message);
// 盘口的判断
if (jsonObject.containsKey("sub") && jsonObject.get("sub").toString().contains("depth")) {
+ log.info("订阅盘口消息:{}", session.getId());
String sub = jsonObject.get("sub").toString();
String symbol = sub.split("\\.")[1];
symbol = CoinTypeConvert.convert(symbol);
@@ -89,6 +90,7 @@
// 取消盘口订阅
if (jsonObject.containsKey("unsub") && jsonObject.get("unsub").toString().contains("depth")) {
// `market.${symbol}.kline.${strPeriod}
+ log.info("取消订阅盘口消息:{}", session.getId());
String unsub = jsonObject.get("unsub").toString();
String[] split = unsub.split("\\.");
String symbol = split[1];
@@ -110,6 +112,7 @@
// 取消订阅 {unsub: xxx(标识)}
if (jsonObject.containsKey("sub") && jsonObject.get("sub").toString().contains("kline")) {
// 订阅
+ log.info("订阅最新K线消息:{}", session.getId());
String sub = jsonObject.get("sub").toString();
String[] split = sub.split("\\.");
String symbol = split[1];
@@ -132,6 +135,7 @@
// 取消订阅
if (jsonObject.containsKey("unsub") && jsonObject.get("unsub").toString().contains("kline")) {
// `market.${symbol}.kline.${strPeriod}
+ log.info("取消订阅最新K消息:{}", session.getId());
String unsub = jsonObject.get("unsub").toString();
String[] split = unsub.split("\\.");
String strPeriod = split[3];
@@ -173,14 +177,14 @@
*
* @param message 消息内容
*/
- public void sendMessagePlate(String message, Session fromSession) {
- if (tradeplateClients.containsKey("nekkusdt")) {
- Map<String, Session> nekk = tradeplateClients.get("nekkusdt");
+ public void sendMessagePlate(String symbol,String message, Session fromSession) {
+ if (tradeplateClients.containsKey(symbol)) {
+ Map<String, Session> nekk = tradeplateClients.get(symbol);
for (Map.Entry<String, Session> sessionEntry : nekk.entrySet()) {
Session toSession = sessionEntry.getValue();
// 排除掉自己
//if (!fromSession.getId().equals(toSession.getId())) {
- log.info("服务端给客户端[{}]发送消息{}", toSession.getId(), message);
+ log.info("服务端给客户端[{}]发送盘口消息{}", toSession.getId(), message);
boolean open = toSession.isOpen();
if (open) {
toSession.getAsyncRemote().sendText(message);
--
Gitblit v1.9.1