Spring Boot 2 發佈與調用REST服務

開發環境:IntelliJ IDEA 2019.2.2
Spring Boot版本:2.1.8java

1、發佈REST服務git

一、IDEA新建一個名稱爲rest-server的Spring Boot項目github

二、新建一個實體類User.javaweb

package com.example.restserver.domain;

public class User {
    String name;
    Integer age;

    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public Integer getAge() {
        return age;
    }
    public void setAge(Integer age) {
        this.age = age;
    }
}

三、新建一個控制器類 UserController.javaspring

package com.example.restserver.web;

import com.example.restserver.domain.User;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class UserController {

    @RequestMapping(value="/user/{name}", produces = MediaType.APPLICATION_JSON_VALUE)
    public User user(@PathVariable String name) {
        User u = new User();
        u.setName(name);
        u.setAge(30);
        return u;
    }
}

項目結構以下:app

  

 訪問 http://localhost:8080/user/lc,頁面顯示:dom

{"name":"lc","age":30}

2、使用RestTemplae調用服務單元測試

一、IDEA新建一個名稱爲rest-client的Spring Boot項目測試

二、新建一個含有main方法的普通類 RestTemplateMain.java,調用服務優化

package com.example.restclient;

import com.example.restclient.domain.User;
import org.springframework.web.client.RestTemplate;

public class RestTemplateMain {
    public static void main(String[] args){
        RestTemplate tpl = new RestTemplate();
        User u = tpl.getForObject("http://localhost:8080/user/lc", User.class);
        System.out.println(u.getName() + "," + u.getAge());
    }
}

右鍵Run 'RestTemplateMain.main()',控制檯輸出:lc,30

三、在bean裏面使用RestTemplate,可以使用RestTemplateBuilder,新建類 UserService.java

package com.example.restclient.service;

import com.example.restclient.domain.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.web.client.RestTemplateBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

@Service
public class UserService {
    @Autowired
    private RestTemplateBuilder builder;

    @Bean
    public RestTemplate restTemplate(){
        return builder.rootUri("http://localhost:8080").build();
    }

    public User userBuilder(String name){
        User u = restTemplate().getForObject("/user/" + name, User.class);
        return u;
    }

}

四、編寫一個單元測試類,來測試上面的UserService的bean。

package com.example.restclient.service;

import com.example.restclient.domain.User;
import org.junit.Assert;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.NONE)
public class UserServiceTest {
    @Autowired
    private UserService userService;

    @Test
    public void testUser(){
        User u = userService.userBuilder("lc");
        Assert.assertEquals("lc", u.getName());
    }
}

五、控制器類UserController.cs 中調用

配置在application.properties 配置端口和8080不同,如 server.port = 9001

    @Autowired
    private UserService userService;

    @RequestMapping(value="/user/{name}", produces = MediaType.APPLICATION_JSON_VALUE)
    public User user(@PathVariable String name) {
        User u = userService.userBuilder(name);
        return u;
    }

3、使用Feign調用服務

繼續在rest-client項目基礎上修改代碼。

一、pom.xml添加依賴

        <dependency>
            <groupId>io.github.openfeign</groupId>
            <artifactId>feign-core</artifactId>
            <version>9.5.0</version>
        </dependency>

        <dependency>
            <groupId>io.github.openfeign</groupId>
            <artifactId>feign-gson</artifactId>
            <version>9.5.0</version>
        </dependency>

二、新建接口 UserClient.java

package com.example.restclient.service;

import com.example.restclient.domain.User;
import feign.Param;
import feign.RequestLine;


public interface UserClient {

    @RequestLine("GET /user/{name}")
    User getUser(@Param("name")String name);

}

三、在控制器類 UserController.java 中調用

decoder(new GsonDecoder()) 表示添加了解碼器的配置,GsonDecoder會將返回的JSON字符串轉換爲接口方法返回的對象。
相反的,encoder(new GsonEncoder())則是編碼器,將對象轉換爲JSON字符串。

    @RequestMapping(value="/user2/{name}", produces = MediaType.APPLICATION_JSON_VALUE)
    public User user2(@PathVariable String name) {
        UserClient service = Feign.builder().decoder(new GsonDecoder())
                                    .target(UserClient.class, "http://localhost:8080/");
        User u = service.getUser(name);
        return u;
    }

四、優化第3步代碼,並把請求地址放到配置文件中。

(1)application.properties 添加配置

application.client.url = http://localhost:8080

(2)新建配置類ClientConfig.java

package com.example.restclient.config;

import com.example.restclient.service.UserClient;
import feign.Feign;
import feign.gson.GsonDecoder;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class ClientConfig {
    @Value("${application.client.url}")
    private String clientUrl;

    @Bean
    UserClient userClient(){
        UserClient client = Feign.builder()
                .decoder(new GsonDecoder())
                .target(UserClient.class, clientUrl);
        return client;
    }
}

(3)控制器 UserController.java  中調用

    @Autowired
    private  UserClient userClient;

    @RequestMapping(value="/user3/{name}", produces = MediaType.APPLICATION_JSON_VALUE)
    public User user3(@PathVariable String name) {
        User u = userClient.getUser(name);
        return u;
    }

 

UserController.java最終內容:

package com.example.restclient.web;

import com.example.restclient.domain.User;
import com.example.restclient.service.UserClient;
import com.example.restclient.service.UserService;
import feign.Feign;
import feign.gson.GsonDecoder;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class UserController {
    @Autowired
    private UserService userService;
    @Autowired
    private  UserClient userClient;

    @RequestMapping(value="/user/{name}", produces = MediaType.APPLICATION_JSON_VALUE)
    public User user(@PathVariable String name) {
        User u = userService.userBuilder(name);
        return u;
    }

    @RequestMapping(value="/user2/{name}", produces = MediaType.APPLICATION_JSON_VALUE)
    public User user2(@PathVariable String name) {
        UserClient service = Feign.builder().decoder(new GsonDecoder())
                                    .target(UserClient.class, "http://localhost:8080/");
        User u = service.getUser(name);
        return u;
    }

    @RequestMapping(value="/user3/{name}", produces = MediaType.APPLICATION_JSON_VALUE)
    public User user3(@PathVariable String name) {
        User u = userClient.getUser(name);
        return u;
    }
}

項目結構

 

前後訪問下面地址,可見到輸出正常結果

http://localhost:9001/user/lchttp://localhost:9001/user2/lc2http://localhost:9001/user3/lc3

相關文章
相關標籤/搜索