MicroServices

   1 package chucknorris.bitarus.allowed.org;
   2 
   3 import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
   4 import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
   5 import org.springframework.boot.SpringApplication;
   6 import org.springframework.context.annotation.ComponentScan;
   7 import org.slf4j.Logger;
   8 import org.slf4j.LoggerFactory;
   9 
  10 @ComponentScan //scans for @Component beans 
  11 @EnableAutoConfiguration
  12 @EnableEurekaClient
  13 public class Application {
  14     private static Logger logger;
  15 
  16     public static void main(String[] args) {
  17         logger = LoggerFactory.getLogger(Application.class);
  18         logger.info("Starting application");
  19         SpringApplication.run(Application.class, args);
  20     }
  21 }

   1 package chucknorris.bitarus.allowed.org;
   2 
   3 import org.springframework.stereotype.Controller;
   4 import org.springframework.web.bind.annotation.RequestMapping;
   5 import org.slf4j.Logger;
   6 import org.slf4j.LoggerFactory;
   7 import org.springframework.web.bind.annotation.ResponseBody;
   8 import java.io.BufferedReader;
   9 import java.io.InputStreamReader;
  10 import java.net.HttpURLConnection;
  11 import java.net.URL;
  12 import org.springframework.beans.factory.annotation.Value;
  13 import org.springframework.core.env.Environment;
  14 
  15 import com.google.gson.Gson;
  16 import java.util.stream.Collectors;
  17 import java.util.List;
  18 import java.util.ArrayList;
  19 
  20 @Controller
  21 public class ChuckNorrisController {
  22     private final Logger logger = LoggerFactory.getLogger(ChuckNorrisController.class);
  23 
  24     @Value("${server.port}")
  25     private String serverPort;
  26 
  27     private Environment env;
  28 
  29     public ChuckNorrisController(Environment env) {
  30         logger.info("ChuckNorrisController created");
  31         this.env = env;
  32     }
  33 
  34     @RequestMapping("/chucknorris")
  35     @ResponseBody
  36     // http://localhost:8080/chucknorris
  37     public JokeResponse chucknorris() {
  38         String ret = "";
  39         Gson gson = new Gson();
  40 
  41         try {
  42             URL url = new URL("https://api.chucknorris.io/jokes/random");
  43             HttpURLConnection connection = (HttpURLConnection) url.openConnection();
  44             connection.connect();
  45             logger.info(Integer.toString(connection.getResponseCode()));
  46 
  47             try (BufferedReader br = new BufferedReader(new InputStreamReader(connection.getInputStream(), "utf-8"))) {
  48                 StringBuilder response = new StringBuilder();
  49                 String responseLine = null;
  50                 while ((responseLine = br.readLine()) != null) {
  51                     response.append(responseLine.trim());
  52                 }
  53 
  54                 Joke joke = gson.fromJson(response.toString(), Joke.class);
  55 
  56                 List<Joke> jokesList = new ArrayList<Joke>();
  57                 jokesList.add(joke);
  58                 List<Joke> jokesList2 = jokesList.stream().map(item -> {
  59                     item.setValue(item.getValue().toUpperCase());
  60                     return item;
  61                 }).collect(Collectors.toList());
  62                 joke = jokesList2.get(0);
  63                 ret = joke.getValue();
  64             }
  65 
  66         } catch (Exception ex) {
  67             logger.error("error", ex);
  68         }
  69 
  70         JokeResponse jr = new JokeResponse();
  71         jr.setResponse(ret);
  72         jr.setServerPort(serverPort);
  73         return jr;
  74     }
  75 }

   1 package chucknorris.bitarus.allowed.org;
   2 import com.google.gson.annotations.SerializedName;
   3 
   4 public class Joke {
   5 
   6     @SerializedName("categories")
   7     private String[] categories;
   8     @SerializedName("created_at")
   9     private String createdAt;
  10     @SerializedName("icon_url")
  11     private String iconUrl;
  12     @SerializedName("id")
  13     private String id;
  14     @SerializedName("updated_at")
  15     private String updatedAt;
  16     @SerializedName("url")
  17     private String url;
  18     @SerializedName("value")
  19     private String value;
  20 
  21     public String[] getCategories() {
  22         return this.categories;
  23     }
  24 
  25     public String getCreatedAt() {
  26         return this.createdAt;
  27     }
  28 
  29     public String getIconUrl() {
  30         return this.iconUrl;
  31     }
  32 
  33     public String getId() {
  34         return this.id;
  35     }
  36 
  37     public String getUpdatedAt() {
  38         return this.updatedAt;
  39     }
  40 
  41     public String getUrl() {
  42         return this.url;
  43     }
  44 
  45     public String getValue() {
  46         return this.value;
  47     }
  48 
  49     public void setCategories(String[] categories) {
  50         this.categories = categories;
  51     }
  52 
  53     public void setCreatedAt(String createdAt) {
  54         this.createdAt = createdAt;
  55     }
  56 
  57     public void setIconUrl(String iconUrl) {
  58         this.iconUrl = iconUrl;
  59     }
  60 
  61     public void setId(String id) {
  62         this.id = id;
  63     }
  64 
  65     public void setUpdatedAt(String updatedAt) {
  66         this.updatedAt = updatedAt;
  67     }
  68 
  69     public void setUrl(String url) {
  70         this.url = url;
  71     }
  72 
  73     public void setValue(String value) {
  74         this.value = value;
  75     }
  76 }

   1 package chucknorris.bitarus.allowed.org;
   2 
   3 import com.google.gson.annotations.SerializedName;
   4 
   5 public class JokeResponse {
   6 
   7     @SerializedName("response")
   8     private String response;
   9 
  10     @SerializedName("serverPort")
  11     private String serverPort;
  12 
  13     public String getResponse() {
  14         return this.response;
  15     }
  16 
  17     public void setResponse(String response) {
  18         this.response = response;
  19     }
  20 
  21     public String getServerPort() {
  22         return this.serverPort;
  23     }
  24 
  25     public void setServerPort(String serverPort) {
  26         this.serverPort = serverPort;
  27     }
  28 }

   1 package eurekaserver.bitarus.mooo.com;
   2 
   3 import org.springframework.boot.autoconfigure.SpringBootApplication;
   4 import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
   5 import org.springframework.boot.SpringApplication;
   6 import org.slf4j.Logger;
   7 import org.slf4j.LoggerFactory;
   8 
   9 @SpringBootApplication
  10 @EnableEurekaServer
  11 public class Application {
  12     private static Logger logger;
  13 
  14     public static void main(String[] args) {
  15         logger = LoggerFactory.getLogger(Application.class);
  16         logger.info("Starting application eureka server");
  17         SpringApplication.run(Application.class, args);
  18     }
  19 }

   1 package springcloudgwserver.bitarus.mooo.com;
   2 
   3 import org.springframework.boot.autoconfigure.SpringBootApplication;
   4 import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
   5 import org.springframework.boot.SpringApplication;
   6 import org.slf4j.Logger;
   7 import org.slf4j.LoggerFactory;
   8 
   9 @SpringBootApplication
  10 @EnableEurekaClient
  11 public class Application {
  12     private static Logger logger;
  13 
  14     public static void main(String[] args) {
  15         logger = LoggerFactory.getLogger(Application.class);
  16         logger.info("Starting application spring cloud gw server");
  17         SpringApplication.run(Application.class, args);
  18     }
  19 }