package com.xcong.excoin.configurations.listener;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.huobi.client.model.event.TradeEvent;
|
import com.xcong.excoin.modules.symbols.service.SymbolsService;
|
import com.xcong.excoin.rabbit.pricequeue.WebsocketPriceService;
|
import com.xcong.excoin.utils.CoinTypeConvert;
|
import com.xcong.excoin.utils.RedisUtils;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.data.redis.connection.Message;
|
import org.springframework.data.redis.connection.MessageListener;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
|
/**
|
* @author wzy
|
* @date 2021-02-25
|
**/
|
@Slf4j
|
@Component
|
public class RedisReceiver implements MessageListener {
|
|
@Resource
|
private RedisUtils redisUtils;
|
|
@Resource
|
private SymbolsService symbolsService;
|
|
@Resource
|
private WebsocketPriceService websocketPriceService;
|
|
@Override
|
public void onMessage(Message message, byte[] bytes) {
|
String data = message.toString().replaceAll("\"", "");
|
String[] dataArr = data.split("_");
|
|
String symbol = dataArr[0];
|
String price = dataArr[1];
|
|
redisUtils.set(CoinTypeConvert.convertToKey(symbol), price);
|
// 比较
|
websocketPriceService.comparePriceAsc(symbol, price);
|
websocketPriceService.comparePriceDesc(symbol, price);
|
websocketPriceService.wholeBomb();
|
}
|
}
|
