Вызов Rest сервиса в Java

Рассмотрим способо обращения к Rest-сервису, на примере микросервисов. Так же в скользь будет рассмотрен способ избежения дублирования кода в микросервисах. Я использую данную статью, позже, планирую ее перевести.

Первым делом реализуем библиотечную часть, которая будет использоваться во всех частях микросервиса для обмена.

package com.example.user.dto;

import com.fasterxml.jackson.annotation.JsonIgnoreProperties;

import java.util.ArrayList;
import java.util.List;

/**
 * Created by bartoszjedrzejewski on 08/06/2016.
 */
@JsonIgnoreProperties(ignoreUnknown = true)
public class UserView {

    private long id;
    private String forename;
    private String surname;
    private String organisation;
    private List notifications;
    private long points;

    public UserView(){

    }

    public long getId() {
        return id;
    }

    public String getForename() {
        return forename;
    }

    public String getSurname() {
        return surname;
    }

    public String getOrganisation() {
        return organisation;
    }

    public List getNotifications() {
        return notifications;
    }

    public long getPoints() {
        return points;
    }
}

и pom-файл для мавена:

    4.0.0

    com.example
    user-client-libs
    0.0.1-SNAPSHOT
    
        
            com.fasterxml.jackson.core
            jackson-annotations
            2.6.6
        
    

Чтобы была возможность использовать данный класс, необходимо выполнить в консоли mvn clean install

Теперь рассмотрим микросервис, предоставляющий информацию о пользователе.

Пользователь:

package com.example;

import java.util.ArrayList;
import java.util.List;

/**
 * Created by bartoszjedrzejewski on 08/06/2016.
 */
public class User {

    private final long id;
    private final String forename;
    private final String surname;
    private final String organisation;
    private final List notifications;
    private final long points;
    //Friends are deprecated and should not be used
    private final List friends;

    public User(int id) {
        String[] forenames = {"Alice", "Manjula", "Bartosz", "Mack"};
        String[] surnames = {"Smith", "Salvatore", "Jedrzejewski", "Scott"};
        String[] organisations = {"ScottLogic", "UNICEF"};

        forename = forenames[id%3];
        surname = surnames[id%4];
        organisation = organisations[id%2];
        notifications= new ArrayList<>();
        notifications.add("You have been promoted!");
        notifications.add("Sorry, disregard the previous notifaction- wrong user");
        points = id * 31 % 1000;

        //You have no friends
        friends = new ArrayList<>();

        this.id = id;
    }

    public long getId() {
        return id;
    }

    public String getForename() {
        return forename;
    }

    public String getSurname() {
        return surname;
    }

    public String getOrganisation() {
        return organisation;
    }

    public List getNotifications() {
        return notifications;
    }

    public long getPoints() {
        return points;
    }

    public List getFriends() {
        return friends;
    }
}

Обычный Rest-контроллер:

package com.example;

import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import java.util.concurrent.atomic.AtomicLong;

/**
 * Created by bartoszjedrzejewski on 08/06/2016.
 */
@RestController
public class UserController {

    @RequestMapping("/user")
    public User getUser(@RequestParam(value="id", defaultValue="1") int id) {
        return new User(id);
    }

}

И запускалочка от SpringBoot:

package com.example;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class UserServiceApplication {

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

Для настройки порта используется файл application.properties.Укажем в нем: server.port = 9001

pom-файл:

 4.0.0

 com.example
 user-service
 0.0.1-SNAPSHOT
 jar

 user-service
 Demo user-service with Spring Boot

 
  org.springframework.boot
  spring-boot-starter-parent
  1.3.5.RELEASE
   
 

 
  UTF-8
  1.8
 

 
  
   org.springframework.boot
   spring-boot-starter-web
  
  
   org.springframework.boot
   spring-boot-starter-test
   test
  
  
   com.fasterxml.jackson.core
   jackson-databind
   2.5.0
  
 


 
  
   
    org.springframework.boot
    spring-boot-maven-plugin
   
  
 
 

Простенький Rest-контроллер, который обращается к выше описанному микросервису:

package com.example;

import com.example.user.dto.UserView;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

/**
 * Created by bartoszjedrzejewski on 09/06/2016.
 */
@RestController
public class UserDashboardController {

    @RequestMapping("/dashboard")
    public String getUser(@RequestParam(value="id", defaultValue="1") int id) {
        RestTemplate restTemplate = new RestTemplate();
        UserView user = restTemplate.getForObject("http://localhost:9001/user?id="+id, UserView.class);
        return "USER DASHBOARD 
" +
                "Welcome " + user.getForename() +" "+user.getSurname()+"
"+
                "You have " +user.getPoints() + " points! Good job!
"+
                "
"+
                "
"+user.getOrganisation();
    }

}

Запускалочка:

package com.example;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class UserDashboardApplication {

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

порт: server.port = 9002

pom-файл:

 4.0.0

 com.example
 user-dashboard
 0.0.1-SNAPSHOT
 jar

 user-dashboard
 Demo user-dashboard service with Spring Boot

 
  org.springframework.boot
  spring-boot-starter-parent
  1.3.5.RELEASE
   
 

 
  UTF-8
  1.8
 

 
  
   org.springframework.boot
   spring-boot-starter-web
  
  
   org.springframework.boot
   spring-boot-starter-test
   test
  
  
   com.example
   user-client-libs
   0.0.1-SNAPSHOT
  
 
 
 
  
   
    org.springframework.boot
    spring-boot-maven-plugin
   
  
 
 

Вот и все, что нужно для обращения к Rest сервису. Все за нас делает объект RestTemplate. Конечно же можно выполнять не только Get запросы, но и post (postForObject(URI url, Object request, Class responseType )), put, delete. Подробности здесь.