[BAEL-8496] - Moved articles to their own spring-resttemplate module

2018-08-26 23:24:46 +05:30
parent 5bfa6d8903
commit 39f9392a0a
26 changed files with 411 additions and 185 deletions
@@ -0,0 +1,32 @@
+package org.baeldung.resttemplate.configuration;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.http.HttpRequest;
+import org.springframework.http.client.ClientHttpRequestExecution;
+import org.springframework.http.client.ClientHttpRequestInterceptor;
+import org.springframework.http.client.ClientHttpResponse;
+
+import java.io.IOException;
+
+/**
+ * interceptor to log incoming requests
+ */
+public class CustomClientHttpRequestInterceptor implements ClientHttpRequestInterceptor {
+
+    private static final Logger LOGGER = LoggerFactory.getLogger(CustomClientHttpRequestInterceptor.class);
+
+    @Override
+    public ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution) throws IOException {
+
+        logRequestDetails(request);
+
+        return execution.execute(request, body);
+    }
+
+    private void logRequestDetails(HttpRequest request) {
+        LOGGER.info("Request Headers: {}", request.getHeaders());
+        LOGGER.info("Request Method: {}", request.getMethod());
+        LOGGER.info("Request URI: {}", request.getURI());
+    }
+}
@@ -0,0 +1,14 @@
+package org.baeldung.resttemplate.configuration;
+
+import org.springframework.boot.web.client.RestTemplateCustomizer;
+import org.springframework.web.client.RestTemplate;
+
+/**
+ * customize rest template with an interceptor
+ */
+public class CustomRestTemplateCustomizer implements RestTemplateCustomizer {
+    @Override
+    public void customize(RestTemplate restTemplate) {
+        restTemplate.getInterceptors().add(new CustomClientHttpRequestInterceptor());
+    }
+}
@@ -0,0 +1,37 @@
+package org.baeldung.resttemplate.configuration;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.web.client.RestTemplateBuilder;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.client.RestTemplate;
+
+/**
+ * Controller to test RestTemplate configuration
+ */
+@RestController
+public class HelloController {
+
+    private static final String RESOURCE_URL = "http://localhost:8082/spring-rest/baz";
+    private RestTemplate restTemplate;
+
+    @Autowired
+    public HelloController(RestTemplateBuilder builder) {
+        this.restTemplate = builder.build();
+    }
+
+    @RequestMapping("/foo")
+    public String foo() {
+
+        ResponseEntity<String> response = restTemplate.getForEntity(RESOURCE_URL, String.class);
+
+        return response.getBody();
+    }
+
+    @RequestMapping("/baz")
+    public String baz() {
+        return "Foo";
+    }
+
+}
@@ -0,0 +1,14 @@
+package org.baeldung.resttemplate.configuration;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+@EnableAutoConfiguration
+public class RestTemplateConfigurationApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(RestTemplateConfigurationApplication.class, args);
+    }
+}
@@ -0,0 +1,28 @@
+package org.baeldung.resttemplate.configuration;
+
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
+import org.springframework.boot.web.client.RestTemplateBuilder;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.DependsOn;
+
+@Configuration
+@EnableAutoConfiguration
+@ComponentScan("org.baeldung.resttemplate.configuration")
+public class SpringConfig {
+
+    @Bean
+    @Qualifier("customRestTemplateCustomizer")
+    public CustomRestTemplateCustomizer customRestTemplateCustomizer() {
+        return new CustomRestTemplateCustomizer();
+    }
+
+    @Bean
+    @DependsOn(value = {"customRestTemplateCustomizer"})
+    public RestTemplateBuilder restTemplateBuilder() {
+        return new RestTemplateBuilder(customRestTemplateCustomizer());
+    }
+
+}
@@ -0,0 +1,45 @@
+package org.baeldung.web.dto;
+
+import com.thoughtworks.xstream.annotations.XStreamAlias;
+
+@XStreamAlias("Foo")
+public class Foo {
+    private long id;
+    private String name;
+
+    public Foo() {
+        super();
+    }
+
+    public Foo(final String name) {
+        super();
+
+        this.name = name;
+    }
+
+    public Foo(final long id, final String name) {
+        super();
+
+        this.id = id;
+        this.name = name;
+    }
+
+    // API
+
+    public long getId() {
+        return id;
+    }
+
+    public void setId(final long id) {
+        this.id = id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(final String name) {
+        this.name = name;
+    }
+
+}
@@ -0,0 +1,4 @@
+package org.baeldung.web.exception;
+
+public class NotFoundException extends RuntimeException {
+}
@@ -0,0 +1,43 @@
+package org.baeldung.web.handler;
+
+import org.baeldung.web.exception.NotFoundException;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.client.ClientHttpResponse;
+import org.springframework.stereotype.Component;
+import org.springframework.web.client.ResponseErrorHandler;
+
+import java.io.IOException;
+
+@Component
+public class RestTemplateResponseErrorHandler
+    implements ResponseErrorHandler {
+
+    @Override
+    public boolean hasError(ClientHttpResponse httpResponse)
+        throws IOException {
+
+        return (httpResponse
+          .getStatusCode()
+          .series() == HttpStatus.Series.CLIENT_ERROR || httpResponse
+          .getStatusCode()
+          .series() == HttpStatus.Series.SERVER_ERROR);
+    }
+
+    @Override
+    public void handleError(ClientHttpResponse httpResponse)
+        throws IOException {
+
+        if (httpResponse
+          .getStatusCode()
+          .series() == HttpStatus.Series.SERVER_ERROR) {
+            //Handle SERVER_ERROR
+        } else if (httpResponse
+          .getStatusCode()
+          .series() == HttpStatus.Series.CLIENT_ERROR) {
+            //Handle CLIENT_ERROR
+            if (httpResponse.getStatusCode() == HttpStatus.NOT_FOUND) {
+                throw new NotFoundException();
+            }
+        }
+    }
+}
@@ -0,0 +1,22 @@
+package org.baeldung.web.model;
+
+public class Bar {
+    private String id;
+    private String name;
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+}
@@ -0,0 +1,26 @@
+package org.baeldung.web.service;
+
+import org.baeldung.web.handler.RestTemplateResponseErrorHandler;
+import org.baeldung.web.model.Bar;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.web.client.RestTemplateBuilder;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestTemplate;
+
+@Service
+public class BarConsumerService {
+
+    private RestTemplate restTemplate;
+
+    @Autowired
+    public BarConsumerService(RestTemplateBuilder restTemplateBuilder) {
+        RestTemplate restTemplate = restTemplateBuilder
+          .errorHandler(new RestTemplateResponseErrorHandler())
+          .build();
+    }
+
+    public Bar fetchBarById(String barId) {
+        return restTemplate.getForObject("/bars/4242", Bar.class);
+    }
+
+}
@@ -0,0 +1,2 @@
+server.port=8082
+server.servlet.context-path=/spring-rest
@@ -0,0 +1,23 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<configuration>
+    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder>
+            <pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n
+            </pattern>
+        </encoder>
+    </appender>
+    
+    <logger name="org.springframework.web.filter.CommonsRequestLoggingFilter">
+		<level value="DEBUG" />
+	</logger>
+
+    <logger name="org.springframework" level="WARN" />
+    <logger name="org.springframework.transaction" level="WARN" />
+
+    <!-- in order to debug some marshalling issues, this needs to be TRACE -->
+    <logger name="org.springframework.web.servlet.mvc" level="WARN" />
+
+    <root level="INFO">
+        <appender-ref ref="STDOUT" />
+    </root>
+</configuration>