import org.knowm.xchange.ExchangeFactory; //导入依赖的package包/类
public static TimeSeries loadTimeSeries(CurrencyPair pair, ExchangeSpecification spec) throws IOException {
    final long now = new Date().getTime() / 1000;
    final PoloniexExchange poloniexExchange = (PoloniexExchange) ExchangeFactory.INSTANCE.createExchange(spec);
    final PoloniexMarketDataService marketDataService = (PoloniexMarketDataService)
            poloniexExchange.getMarketDataService();

    final PoloniexChartData[] chartData = marketDataService.
            getPoloniexChartData(pair, now - TimeUnit.DAYS.toSeconds(30), now, PoloniexChartDataPeriodType.PERIOD_300);
    List<Tick> tickList = Arrays.stream(chartData).map(chart -> new Tick(new DateTime(chart.getDate()),
            chart.getOpen().doubleValue(), chart.getHigh().doubleValue(), chart.getLow().doubleValue(),
            chart.getClose().doubleValue(), chart.getVolume().doubleValue())).collect(Collectors.toList());
    return new TimeSeries(tickList);
}
 

import org.knowm.xchange.ExchangeFactory; //导入依赖的package包/类
public ExchangeRateUpdater(Currency baseCurrency, ExchangeRateStorage priceStorage) {
    this.storage = priceStorage;
    this.baseCurrencyBtcPair = new CurrencyPair(baseCurrency, Currency.BTC);

    exchanges = new HashMap<>();
    exchanges.put(baseCurrencyBtcPair, ExchangeFactory.INSTANCE.createExchange(BitfinexExchange.class.getName()));
    exchanges.put(CurrencyPair.BTC_USD, ExchangeFactory.INSTANCE.createExchange(BitfinexExchange.class.getName()));
    exchanges.put(CurrencyPair.BTC_EUR, ExchangeFactory.INSTANCE.createExchange(BitstampExchange.class.getName()));
    exchanges.put(CurrencyPair.BTC_CNY, ExchangeFactory.INSTANCE.createExchange(OkCoinExchange.class.getName()));

    // add more currencies/exchange pairs (btc/fiat) here
}
 

import org.knowm.xchange.ExchangeFactory; //导入依赖的package包/类
/**
 * Construct using an XChange Exchange class object for a set of currencies
 * @param exchangeClassName Classname of XChange exchange we are wrapping
 * @param scheduledExecutorService Executor service for running polling task
 * @param pairs pairs to monitor
 */
protected BaseXChangeExchangeRateProvider(String exchangeClassName,
                                          ScheduledExecutorService scheduledExecutorService,
                                          CurrencyUnitPair... pairs) {
    exchange = ExchangeFactory.INSTANCE.createExchange(exchangeClassName);
    stpe = (scheduledExecutorService != null) ? scheduledExecutorService : Executors.newScheduledThreadPool(1);
    name = exchange.getExchangeSpecification().getExchangeName();
    providerContext = ProviderContext.of(name, RateType.DEFERRED);
    marketDataService = exchange.getMarketDataService();
    for (CurrencyUnitPair pair : pairs) {
        MonitoredCurrency monitoredCurrency = new MonitoredCurrency(pair, xchangePair(pair));
        monitoredCurrencies.put(pair, monitoredCurrency);
    }
    start();    // starting here causes first ticker to be read before observers can be registered!!!
}
 

import org.knowm.xchange.ExchangeFactory; //导入依赖的package包/类
@Bean
public Exchange exchange() {
    return ExchangeFactory.INSTANCE.createExchangeWithApiKeys(BittrexExchange.class.getName(),
            properties.getBittrex().getKey(), properties.getBittrex().getSecret());
}
 

import org.knowm.xchange.ExchangeFactory; //导入依赖的package包/类
private void prepareAvailableExchanges() {
    for (Class<? extends Exchange> exchangeClass : ApplicationConstants.exchangeClasses) {
        Exchange exchange = ExchangeFactory.INSTANCE.createExchange(exchangeClass.getName());
        exchanges.put(exchangeClass, exchange);
    }
}
 

import org.knowm.xchange.ExchangeFactory; //导入依赖的package包/类
@Override
public ActivatedExchange call() {
    Exchange exchange = ExchangeFactory.INSTANCE.createExchange(exchangeSpecs.GetSetupedExchange());
    return new ActivatedExchange(exchange, exchangeSpecs.getTradingMode());
}