如何在Spring Boot中使用@bean创建或配置Rest模板

Question

我想在Spring Boot应用程序的配置类中使用@bean注释将RestTemplate定义为应用程序bean。

我正在调用我的应用流程中不同地方的4个rest服务。当前，我在每次请求时都创建RestTemplate。是否有一种方法可以使用@bean将其定义为应用程序bean，并使用@autowired注入应用程序bean？

出现这个问题的主要原因是，我可以使用@bean定义RestTemplate，但当我用@autowired注入它时，我会丢失所有已定义的拦截器（拦截器不会被调用。）

配置类

@Bean(name = "appRestClient")
public RestTemplate getRestClient() {

    RestTemplate  restClient = new RestTemplate(
        new BufferingClientHttpRequestFactory(new SimpleClientHttpRequestFactory()));

    List<ClientHttpRequestInterceptor> interceptors = new ArrayList<ClientHttpRequestInterceptor>();
    interceptors.add(new RestServiceLoggingInterceptor());
    restClient.setInterceptors(interceptors);

    return restClient;
}

服务类别

public class MyServiceClass {

    @Autowired
    private RestTemplate appRestClient;

    public String callRestService() {
        // create uri, method response objects
        String restResp = appRestClient.getForObject(uri, method, response);
        // do something with the restResp
        // return String
    }
}

看来我的interceptors在这种配置下根本没有被调用。但是RestTemplate能够调用REST服务并获得响应。

Answer 1

从拦截器的名字来看，我猜你在做一些记录？您可能会错过日志级别配置。我使用1.3.6.release版本创建了一个小应用程序来检查您的配置是否工作。

在这个类中，我定义了RestTemplatebean和带有日志记录的拦截器。

package com.example;

// imports...

@SpringBootApplication
public class TestApplication {

    private static final Logger LOGGER = LoggerFactory.getLogger(TestApplication.class);

    public static void main(String[] args) {
        SpringApplication.run(TestApplication.class, args);
    }

    @Bean(name = "appRestClient")
    public RestTemplate getRestClient() {
        RestTemplate restClient = new RestTemplate(
                new BufferingClientHttpRequestFactory(new SimpleClientHttpRequestFactory()));

        // Add one interceptor like in your example, except using anonymous class.
        restClient.setInterceptors(Collections.singletonList((request, body, execution) -> {

            LOGGER.debug("Intercepting...");
            return execution.execute(request, body);
        }));

        return restClient;
    }
}

为了使日志记录工作，我还必须在application.properties中设置正确的调试级别。

logging.level.com.example=DEBUG

@Service
public class SomeService {

    private final RestTemplate appRestClient;

    @Autowired
    public SomeService(@Qualifier("appRestClient") RestTemplate appRestClient) {
        this.appRestClient = appRestClient;
    }

    public String callRestService() {
        return appRestClient.getForObject("http://localhost:8080", String.class);
    }
}

和一个endpoint来测试这一点。

@RestController
public class SomeController {

    private final SomeService service;

    @Autowired
    public SomeController(SomeService service) {
        this.service = service;
    }

    @RequestMapping(value = "/", method = RequestMethod.GET)
    public String testEndpoint() {
        return "hello!";
    }

    @RequestMapping(value = "/test", method = RequestMethod.GET)
    public String test() {
        return service.callRestService();
    }
}

通过对http://localhost:8080/test执行get请求，我应该希望得到正在打印的字符串Hello！（服务调用http://localhost:8080，它返回Hello！并将其发送回我）。带有记录器的拦截器还在控制台中打印出intercepting...。