使用AsynRestTemplate开发服务消费者

概念阐述

AsyncRestTemplate 开发方式允许用户异步的进行服务调用。具体的业务流程和 RestTemplate 类似，只是这里以异步的形式进行服务的调用。

示例代码

AsyncRestTemplate 实例通过 new CseAsyncRestTemplate（）来创建和获取，再使用该实例通过自定义的 URL 进行服务调用。

  • Spring MVC 客户端代码示例
  2. @Component
  3. public class SpringmvcConsumerMain {
  4.   private static final Logger LOG = LoggerFactory.getLogger(SpringmvcConsumerMain.class);
  6.   public static void main(String[] args) throws Exception {
  7.     init();
  8.     Person person = new Person();
  9.     person.setName("ServiceComb/Java Chassis");
  10.     //AsyncRestTemplate Consumer
  11.     CseAsyncRestTemplate cseAsyncRestTemplate = new CseAsyncRestTemplate();
  12.     ListenableFuture<ResponseEntity<String>> responseEntityListenableFuture = cseAsyncRestTemplate
  13.         .postForEntity("cse://springmvc/springmvchello/sayhi?name=Java Chassis", null, String.class);
  14.     ResponseEntity<String> responseEntity = responseEntityListenableFuture.get();
  15.     System.out.println("AsyncRestTemplate Consumer sayHi services: " + responseEntity.getBody());
  17.     HttpEntity<Person> entity = new HttpEntity<>(person);
  18.     ListenableFuture<ResponseEntity<String>> listenableFuture = cseAsyncRestTemplate
  19.         .exchange("cse://springmvc/springmvchello/sayhello", HttpMethod.POST, entity, String.class);
  20.     //    ResponseEntity<String> responseEntity1 = listenableFuture.get();
  21.     //    System.out.println("AsyncRestTemplate Consumer sayHello services: " + responseEntity1.getBody());
  22.     //设置回调函数
  23.     listenableFuture.addCallback(
  24.         new ListenableFutureCallback<ResponseEntity<String>>() {
  25.           @Override
  26.           public void onFailure(Throwable ex) {
  27.             LOG.error("AsyncResTemplate Consumer catched exception when sayHello, ", ex);
  28.           }
  30.           @Override
  31.           public void onSuccess(ResponseEntity<String> result) {
  32.             System.out.println("AsyncRestTemplate Consumer sayHello services: " + result.getBody());
  33.           }
  34.         });
  35.   }
  37.   public static void init() throws Exception {
  38.     Log4jUtils.init();
  39.     BeanUtils.init();
  40.   }
  41. }

说明 ：

  • URL 的格式和 RestTemplate 一样，具体可以参考 restTemplate
  • 这里用自定义的 ListenableFuture 类来作为占位符，获取远程调用结束后可能获取的结果。同时也可以自定义回调函数，对可能返回的结果进行分批处理。