/**
 * //要启动定时任务记得在启动类上添加下面两个注解
 * @ComponentScan(basePackages="com.jincou.websocket")
 * @EnableScheduling
 * 功能描述：股票推送,这里只需通过定时任务向客服端发送消息
 */
@Component
public class CoinSchedule {
    @Autowired
    private WebSocketService ws;
    
    //代表每一秒执行一次任务
    @Scheduled(fixedRate=1000)
    public void coinInfo(){
        ws.sendCoinInfo();
    }
}

/**
 * 功能描述：简单消息模板，用来推送消息
 */
@Service
public class WebSocketService {

    @Autowired
    private SimpMessagingTemplate template;
 
    /**
     * 功能描述：Coin版本，虚拟币信息推送
     */
    public void sendCoinInfo() {

        //CoinService.getStockInfo()已经把json数据转为实体对象
        CoinResult coinResult = CoinService.getStockInfo();
        
  String msgTpl = "虚拟币名称: %s ;代码: %s; 现价格: %s元 ;买一价: %s ; 买一量: %s ; 买二价: %s ; 卖二量: %s;";
        CoinResult.Obj  obj=coinResult.getObj();
        if (null != obj) {
            //将 %s 替换成实际值
            String msg = String.format(msgTpl, obj.getName(), obj.getSecurityCode(), obj.getNow(),
                    obj.getBid1(), obj.getBid1Volume(), obj.getAsk1(), obj.getAsk1Volume());

            //前面参数是订阅地址，后面参数是消息信息（也就是比特币时时消息）
            template.convertAndSend("/topic/coin_info",new OutMessage(msg));
        }
    }
}

import java.util.HashMap;
import java.util.Map;
import com.jincou.websocket.model.CoinResult;
import com.jincou.websocket.utils.HttpUtils;
import com.jincou.websocket.utils.JsonUtils;
import org.apache.http.HttpResponse;
import org.apache.http.util.EntityUtils;

/**
 * 功能描述：接口服务，调用虚拟币行情接口
 */
public class CoinService {

    public static CoinResult getStockInfo(){
         String host = "http://alirm-gbdc.konpn.com";
            String path = "/query/gbdc";
            String method = "GET";
            String appcode = "056ed9cdaa674647b6c04b87fe394fcb";
            Map<String, String> headers = new HashMap<String, String>();
            //最后在header中的格式(中间是英文空格)为Authorization:APPCODE 83359fd73fe94948385f570e3c139105
            headers.put("Authorization", "APPCODE " + appcode);
            Map<String, String> querys = new HashMap<String, String>();
            //BTC代表返回比特币相关信息，如果这里传入ETH那就代表返回以太坊信息
            querys.put("symbol", "BTC");

        try {
            //返回连接信息，如果里面带有200，说明连接接口成功
            HttpResponse response = HttpUtils.doGet(host, path, method, headers, querys);

            //将response的body信息转为字符串
            String responseText=EntityUtils.toString(response.getEntity());

            //上面部分只要根据你购买的api接口说明操作就可以，下面才是你需要处理的
            
            //将json格式的字符串（根据一定规则）赋值给实体对象（JsonUtils是自己的一个工具类）
            CoinResult coinResult = JsonUtils.objectFromJson(responseText, CoinResult.class);

            System.out.println("控制台打印虚拟币当前信息=======================================");
            System.out.println(coinResult.toString());
            return coinResult;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }
}

CoinResult coinResult = JsonUtils.objectFromJson(responseText, CoinResult.class); //看这步所需要满足的规则

{"Code":0,"Msg":"",
    "Obj":{
    "B1":271.100,     --买一
    "B1V":129,        --买一量
    "B2":0,           --买二
    "B2V":0,
    "B3":0,           --买三
    "B3V":0,
    "B4":0,           --买四
    "B4V":0,        
    "B5":0,           --买五
    "B5V":0,
    "S1":271.150,    --卖一
    "S1V":20,        --卖一量
    "S2":0,          --卖二
    "S2V":0,
    "S3":0,          --卖三
    "S3V":0,
    "S4":0,          --卖四
    "S4V":0,
    "S5":0,          --卖五
    "S5V":0,
    "ZT":280.85,       --涨停价
    "DT":259.19,       --跌停价
    "O":270.39,        --今开
    "H":271.69,        --最高
    "L":270.14,        --最低
    "YC":270.55,       --昨收
    "A":35513202100.0, --交易额
    "V":130972,        --交易量
    "P":271.14,        --当前价
    "Tick":1529911046, --标准时间戳
    "N":"比特币",       --品种名
    "M":"",            --市场
    "S":"BTC",         --品种代码
    "C":""             --编号
    }
}

import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Data;

@JsonIgnoreProperties(ignoreUnknown = true)
@Data
public class CoinResult {

    //状态码，0代表成功
    @JsonProperty("Code")
    private int Code;
    //具体数据（注意这里json用{表示，所有代表对象
    @JsonProperty("Obj")
    private Obj obj;

    @Data
    @JsonIgnoreProperties(ignoreUnknown = true)

    public static class Obj {

        //虚拟币代码
        @JsonProperty("S")
        private String securityCode;

        //虚拟币名称
        @JsonProperty("N")
        private String name;

        //现在价格
        @JsonProperty("P")
        private double now;

        //最高价格
        @JsonProperty("H")
        private double high;

        //最低价格
        @JsonProperty("L")
        private double low;

        //买一价
        @JsonProperty("B1")
        private double bid1;

        //买一量
        @JsonProperty("B1V")
        private int bid1Volume;

        //卖一价
        @JsonProperty("S1")
        private double ask1;

        //卖一量
        @JsonProperty("S1V")
        private double ask1Volume;
        
        //已成交价，这个接口没有提供，只要记住{}代表是对象，【】代表是结合那就需要集合接受：如下
        //private List<Transaction> transactions;
    }
}