iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

BAEL-1570 (#3762)

Browse Source 
* Create pom.xml

* Update pom.xml

* Create pom.xml

* Update pom.xml

* add impl

* add app
This commit is contained in:
eelhazati 2018-03-04 10:44:05 +00:00 committed by pauljervis
parent 37223104c4
commit 09bb65a846
16 changed files with 357 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
java-spi/exchange-rate-api/pom.xml Normal file
View File

@ -0,0 +1,14 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<artifactId>exchange-rate-api</artifactId>
<packaging>jar</packaging>
<parent>
<groupId>com.baeldung</groupId>
<artifactId>java-spi</artifactId>
<version>1.0.0-SNAPSHOT</version>
</parent>
</project>

42
java-spi/exchange-rate-api/src/main/java/com/baeldung/rate/ExchangeRate.java Normal file
View File

@ -0,0 +1,42 @@
package com.baeldung.rate;
import com.baeldung.rate.exception.ProviderNotFoundException;
import com.baeldung.rate.spi.ExchangeRateProvider;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.ServiceLoader;
public final class ExchangeRate {
private static final String DEFAULT_PROVIDER = "com.baeldung.rate.spi.YahooFinanceExchangeRateProvider";
//All providers
public static List<ExchangeRateProvider> providers() {
List<ExchangeRateProvider> services = new ArrayList<>();
ServiceLoader<ExchangeRateProvider> loader = ServiceLoader.load(ExchangeRateProvider.class);
loader.forEach(exchangeRateProvider -> {
services.add(exchangeRateProvider);
});
return services;
}
//Default provider
public static ExchangeRateProvider provider() {
return provider(DEFAULT_PROVIDER);
}
//provider by name
public static ExchangeRateProvider provider(String providerName) {
ServiceLoader<ExchangeRateProvider> loader = ServiceLoader.load(ExchangeRateProvider.class);
Iterator<ExchangeRateProvider> it = loader.iterator();
while (it.hasNext()) {
ExchangeRateProvider provider = it.next();
if (providerName.equals(provider.getClass().getName())) {
return provider;
}
}
throw new ProviderNotFoundException("Exchange Rate provider " + providerName + " not found");
}
}

44
java-spi/exchange-rate-api/src/main/java/com/baeldung/rate/api/Quote.java Normal file
View File

@ -0,0 +1,44 @@
package com.baeldung.rate.api;
import java.math.BigDecimal;
import java.time.LocalDate;
public class Quote {
private String currency;
private BigDecimal ask;
private BigDecimal bid;
private LocalDate date;
//...
public String getCurrency() {
return currency;
}
public void setCurrency(String currency) {
this.currency = currency;
}
public BigDecimal getAsk() {
return ask;
}
public void setAsk(BigDecimal ask) {
this.ask = ask;
}
public BigDecimal getBid() {
return bid;
}
public void setBid(BigDecimal bid) {
this.bid = bid;
}
public LocalDate getDate() {
return date;
}
public void setDate(LocalDate date) {
this.date = date;
}
}

8
java-spi/exchange-rate-api/src/main/java/com/baeldung/rate/api/QuoteManager.java Normal file
View File

@ -0,0 +1,8 @@
package com.baeldung.rate.api;
import java.time.LocalDate;
import java.util.List;
public interface QuoteManager {
List<Quote> getQuotes(String baseCurrency, LocalDate date);
}

13
java-spi/exchange-rate-api/src/main/java/com/baeldung/rate/exception/ProviderNotFoundException.java Normal file
View File

@ -0,0 +1,13 @@
package com.baeldung.rate.exception;
public class ProviderNotFoundException extends RuntimeException {
public ProviderNotFoundException() {
super();
}
public ProviderNotFoundException(String message) {
super(message);
}
}

7
java-spi/exchange-rate-api/src/main/java/com/baeldung/rate/spi/ExchangeRateProvider.java Normal file
View File

@ -0,0 +1,7 @@
package com.baeldung.rate.spi;
import com.baeldung.rate.api.QuoteManager;
public interface ExchangeRateProvider {
QuoteManager create();
}

27
java-spi/exchange-rate-app/pom.xml Normal file
View File

@ -0,0 +1,27 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<artifactId>exchange-rate-app</artifactId>
<packaging>jar</packaging>
<parent>
<groupId>com.baeldung</groupId>
<artifactId>java-spi</artifactId>
<version>1.0.0-SNAPSHOT</version>
</parent>
<dependencies>
<dependency>
<groupId>com.baeldung</groupId>
<artifactId>exchange-rate-api</artifactId>
<version>1.0.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.baeldung</groupId>
<artifactId>exchange-rate-impl</artifactId>
<version>1.0.0-SNAPSHOT</version>
</dependency>
</dependencies>
</project>

21
java-spi/exchange-rate-app/src/main/java/com.baeldung.rate.app/MainApp.java Normal file
View File

@ -0,0 +1,21 @@
package com.baeldung.rate.app;
import com.baeldung.rate.ExchangeRate;
import com.baeldung.rate.api.Quote;
import java.time.LocalDate;
import java.util.List;
public class MainApp {
public static void main(String... args) {
ExchangeRate.providers().forEach(provider -> {
System.out.println("Retreiving USD quotes from provider :" + provider);
List<Quote> quotes = provider.create().getQuotes("USD", LocalDate.now());
System.out.println(String.format("%14s%12s|%12s", "","Ask", "Bid"));
System.out.println("----------------------------------------");
quotes.forEach(quote -> {
System.out.println("USD --> " + quote.getCurrency() + " : " + String.format("%12f|%12f", quote.getAsk(), quote.getBid()));
});
});
}
}

42
java-spi/exchange-rate-impl/pom.xml Normal file
View File

@ -0,0 +1,42 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<artifactId>exchange-rate-impl</artifactId>
<packaging>jar</packaging>
<parent>
<groupId>com.baeldung</groupId>
<artifactId>java-spi</artifactId>
<version>1.0.0-SNAPSHOT</version>
</parent>
<dependencies>
<dependency>
<groupId>com.baeldung</groupId>
<artifactId>exchange-rate-api</artifactId>
<version>1.0.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.squareup.okhttp3</groupId>
<artifactId>okhttp</artifactId>
<version>3.10.0</version>
</dependency>
<dependency>
<groupId>javax.json.bind</groupId>
<artifactId>javax.json.bind-api</artifactId>
<version>1.0</version>
</dependency>
<dependency>
<groupId>org.eclipse</groupId>
<artifactId>yasson</artifactId>
<version>1.0.1</version>
</dependency>
<dependency>
<groupId>org.glassfish</groupId>
<artifactId>javax.json</artifactId>
<version>1.1.2</version>
</dependency>
</dependencies>
</project>

26
java-spi/exchange-rate-impl/src/main/java/com/baeldung/rate/impl/QuoteResponse.java Normal file
View File

@ -0,0 +1,26 @@
package com.baeldung.rate.impl;
import com.baeldung.rate.api.Quote;
import java.util.List;
public class QuoteResponse {
private List<Quote> result;
private String error;
public List<Quote> getResult() {
return result;
}
public void setResult(List<Quote> result) {
this.result = result;
}
public String getError() {
return error;
}
public void setError(String error) {
this.error = error;
}
}

13
java-spi/exchange-rate-impl/src/main/java/com/baeldung/rate/impl/QuoteResponseWrapper.java Normal file
View File

@ -0,0 +1,13 @@
package com.baeldung.rate.impl;
public class QuoteResponseWrapper {
private QuoteResponse quoteResponse;
public QuoteResponse getQuoteResponse() {
return quoteResponse;
}
public void setQuoteResponse(QuoteResponse quoteResponse) {
this.quoteResponse = quoteResponse;
}
}

13
java-spi/exchange-rate-impl/src/main/java/com/baeldung/rate/impl/YahooFinanceExchangeRateProvider.java Normal file
View File

@ -0,0 +1,13 @@
package com.baeldung.rate.impl;
import com.baeldung.rate.api.QuoteManager;
import com.baeldung.rate.spi.ExchangeRateProvider;
public class YahooFinanceExchangeRateProvider implements ExchangeRateProvider {
@Override
public QuoteManager create() {
return new YahooQuoteManagerImpl();
}
}

65
java-spi/exchange-rate-impl/src/main/java/com/baeldung/rate/impl/YahooQuoteManagerImpl.java Normal file
View File

@ -0,0 +1,65 @@
package com.baeldung.rate.impl;
import com.baeldung.rate.api.Quote;
import com.baeldung.rate.api.QuoteManager;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import javax.json.bind.JsonbBuilder;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.time.LocalDate;
import java.util.Currency;
import java.util.List;
public class YahooQuoteManagerImpl implements QuoteManager {
static final String URL_PROVIDER = "https://query1.finance.yahoo.com/v7/finance/quote";
OkHttpClient client = new OkHttpClient();
@Override
public List<Quote> getQuotes(String baseCurrency, LocalDate date) {
StringBuilder sb = new StringBuilder();
Currency.getAvailableCurrencies().forEach(currency -> {
if (!currency.equals(currency.getCurrencyCode())) {
sb.append(baseCurrency).append(currency.getCurrencyCode()).append("=X").append(",");
}
});
String value = "";
try {
value = URLEncoder.encode(sb.toString().substring(0, sb.toString().length() - 1), "UTF-8");
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
String queryString = String.format("%s=%s", "symbols", value);
String response = doGetRequest(queryString);
System.out.println(response);
return map(response);
}
private List<Quote> map(String response) {
QuoteResponseWrapper qrw = JsonbBuilder.create().fromJson(response, QuoteResponseWrapper.class);
return qrw.getQuoteResponse().getResult();
}
String doGetRequest(String queryString) {
String fullUrl = URL_PROVIDER + "?" + queryString;
System.out.println(fullUrl);
Request request = new Request.Builder()
.url(fullUrl)
.build();
Response response = null;
try {
response = client.newCall(request).execute();
return response.body().string();
} catch (IOException e) {
e.printStackTrace();
}
return null;
}
}

1
java-spi/exchange-rate-impl/src/main/resources/META-INF/services/com.baeldung.rate.spi.ExchangeRateProvider Normal file
View File

@ -0,0 +1 @@
com.baeldung.rate.impl.YahooFinanceExchangeRateProvider

20
java-spi/pom.xml Normal file
View File

@ -0,0 +1,20 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<artifactId>java-spi</artifactId>
<packaging>pom</packaging>
<parent>
<groupId>com.baeldung</groupId>
<artifactId>parent-modules</artifactId>
<version>1.0.0-SNAPSHOT</version>
</parent>
<modules>
<module>exchange-rate-api</module>
<module>exchange-rate-impl</module>
<module>exchange-rate-app</module>
</modules>
</project>

1
pom.xml
View File

@ -278,6 +278,7 @@
<module>lucene</module>
<module>vraptor</module>
<module>persistence-modules/java-cockroachdb</module>
<module>java-spi</module>
</modules>
<dependencies>