This is an automated email from the ASF dual-hosted git repository.
liujun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo-samples.git
The following commit(s) were added to refs/heads/master by this push:
new 46a945c2f dubbo-samples-rest-springmvc-1 (#1121)
46a945c2f is described below
commit 46a945c2f95b93c2ec7917d0944e57b76cf77585
Author: QuYao-Fighting <[email protected]>
AuthorDate: Thu Aug 15 10:57:33 2024 +0800
dubbo-samples-rest-springmvc-1 (#1121)
---
.../dubbo-samples-triple-rest-springmvc/pom.xml | 26 ++
.../org/apache/dubbo/rest/demo/DemoService.java | 89 ++++-
.../org/apache/dubbo/rest/demo/consumer/Task.java | 31 +-
.../rest/demo/expansion/filter/FilterService.java | 13 +
.../demo/expansion/filter/FilterServiceImpl.java | 12 +
.../java/org/apache/dubbo/rest/demo/pojo/User.java | 87 +++++
.../dubbo/rest/demo/provider/DemoServiceImpl.java | 135 ++++++-
.../src/main/resources/application.yml | 1 +
.../apache/dubbo/rest/demo/test/ConsumerIT.java | 424 ++++++++++++++++++++-
9 files changed, 786 insertions(+), 32 deletions(-)
diff --git
a/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/pom.xml
b/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/pom.xml
index 02afc0554..dda55bb2a 100644
---
a/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/pom.xml
+++
b/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/pom.xml
@@ -70,6 +70,19 @@
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
+
+ <!-- https://mvnrepository.com/artifact/org.json/json -->
+ <dependency>
+ <groupId>org.json</groupId>
+ <artifactId>json</artifactId>
+ <version>20231013</version>
+ </dependency>
+ <dependency>
+ <groupId>javax.ws.rs</groupId>
+ <artifactId>javax.ws.rs-api</artifactId>
+ <scope>test</scope>
+ </dependency>
+
</dependencies>
<build>
@@ -78,6 +91,19 @@
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-compiler-plugin</artifactId>
+ <configuration>
+ <compilerArgs>
+ <compilerArg>-proc:none</compilerArg>
+ </compilerArgs>
+ <!--新增-->
+ <parameters>true</parameters>
+ <source>17</source>
+ <target>17</target>
+ </configuration>
+ </plugin>
</plugins>
</build>
</project>
diff --git
a/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/main/java/org/apache/dubbo/rest/demo/DemoService.java
b/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/main/java/org/apache/dubbo/rest/demo/DemoService.java
index ee849e9c2..9c6ee7f62 100644
---
a/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/main/java/org/apache/dubbo/rest/demo/DemoService.java
+++
b/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/main/java/org/apache/dubbo/rest/demo/DemoService.java
@@ -16,15 +16,98 @@
*/
package org.apache.dubbo.rest.demo;
+import org.apache.dubbo.rest.demo.pojo.User;
+import org.springframework.http.MediaType;
+import org.springframework.util.LinkedMultiValueMap;
+import org.springframework.util.MultiValueMap;
+import org.springframework.web.bind.annotation.DeleteMapping;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PatchMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.PutMapping;
+import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
+import java.util.HashMap;
+import java.util.List;
@RequestMapping("/demo")
public interface DemoService {
- @RequestMapping(method = RequestMethod.GET, value = "/hello")
- String sayHello(@RequestParam("name") String name);
+ @GetMapping(value = "get/param")
+ public String getParam(@RequestParam(value = "id")String id);
+
+ @GetMapping(value = "get/variable/{id}")
+ public String getVariable(@PathVariable(value = "id")String id);
+
+ @GetMapping(value = "get/muchParam")
+ public String getMuchParam(@RequestParam(value = "id")String id,
@RequestParam(value = "name")String name);
+
+ @GetMapping(value = "get/muchVariable/{id}/{name}")
+ public String getMuchVariable(@PathVariable(value = "id")String id,
@PathVariable(value = "name")String name);
+
+ @GetMapping(value =
"get/reg/{name:[a-z-]+}-{version:\\d\\.\\d\\.\\d}{ext:\\.[a-z]+}")
+ public String getReg(@PathVariable(value = "name")String name,
@PathVariable(value = "version")String version, @PathVariable(value =
"ext")String ext);
+
+ @PostMapping(value = "post/body")
+ public String postBody(@RequestBody String name);
+
+ @PostMapping(value = "post/param")
+ public String postParam(@RequestParam(value = "id")String id);
+
+ @PostMapping(value = "post/variable/{id}")
+ public String postVariable(@PathVariable(value = "id")String id);
+
+ @PostMapping(value = "post/useConsumes", consumes = "application/json")
+ public String postUseConsumes(@RequestBody String id);
+
+ @RequestMapping(value = "/error", method = RequestMethod.GET, consumes =
MediaType.TEXT_PLAIN_VALUE)
+ String error();
+
+ @PostMapping(value = "post/useParams", params = "myParam=myValue")
+ public String postUseParams(@RequestBody String id);
+
+ @GetMapping(value = "get/head/{id}", headers = "myHeader=myValue")
+ public String getHead(@PathVariable(value = "id")String id);
+
+ @PostMapping(value = "post/useConsumes/formData", consumes =
"application/x-www-form-urlencoded")
+ // 使用MultiValueMap 会显示反序列化失败 ？
+ // 但是使用hashmap又不支持 因为声明为 application/x-www-form-urlencoded
+ public String postUseConsumesFormData(@RequestBody MultiValueMap<String,
String> formData);
+
+ // content
type为"application/x-www-form-urlencoded"时body的类型必须是MultiValueMap类型
+ @PostMapping(value = "post/useConsumes/user", consumes =
"application/x-www-form-urlencoded", produces = MediaType.TEXT_PLAIN_VALUE)
+ String postUseConsumesUser(@RequestBody MultiValueMap<String, List<User>>
formData);
+
+ // HashMap<String, User> -> JSON
+ @PostMapping(value = "post/map/user", consumes = "application/json")
+ public String postMapUser(@RequestBody String formData);
+
+ @PutMapping("/put/update/{id}")
+ public String putUpdateId(@PathVariable String id);
+
+ @DeleteMapping("/delete/{id}")
+ public String deleteId(@PathVariable(value = "id")String id);
+
+ @PatchMapping("patch/{id}")
+ public String patchById(@PathVariable String id, @RequestBody String
patchData);
+
+ @RequestMapping(method = RequestMethod.GET, value = "/primitive")
+ int primitiveInt(@RequestParam("a") int a, @RequestParam("b") int b);
+
+ @RequestMapping(method = RequestMethod.GET, value = "/primitiveLong")
+ long primitiveLong(@RequestParam("a") long a, @RequestParam("b") Long b);
+
+ @RequestMapping(method = RequestMethod.GET, value = "/primitiveByte")
+ long primitiveByte(@RequestParam("a") byte a, @RequestParam("b") Long b);
+
+ @RequestMapping(method = RequestMethod.POST, value = "/primitiveShort")
+ long primitiveShort(@RequestParam("a") short a, @RequestParam("b") Long b,
@RequestBody int c);
+
+ @PostMapping(value = "/post/list", consumes = MediaType.ALL_VALUE)
+ public List<User> postList(@RequestBody List<User> users);
+
- // add more methods
}
diff --git
a/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/main/java/org/apache/dubbo/rest/demo/consumer/Task.java
b/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/main/java/org/apache/dubbo/rest/demo/consumer/Task.java
index c2635fd67..1f7df8af4 100644
---
a/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/main/java/org/apache/dubbo/rest/demo/consumer/Task.java
+++
b/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/main/java/org/apache/dubbo/rest/demo/consumer/Task.java
@@ -30,22 +30,21 @@ public class Task implements CommandLineRunner {
@Override
public void run(String... args) throws Exception {
- System.out.println("Receive result ======> " + proxyHello());
- System.out.println("Receive rest result ======> " + restHello());
-
- }
-
- private String proxyHello() {
- return demoService.sayHello("world");
+// System.out.println("Receive result ======> " + proxyHello());
+// System.out.println("Receive rest result ======> " + restHello());
}
- private String restHello() {
- RestClient defaultClient = RestClient.create();
- ResponseEntity<String> result = defaultClient.get()
- .uri("http://localhost:50052/demo/hello?name=world";)
- .header("Content-type", "application/json")
- .retrieve()
- .toEntity(String.class);
- return result.getBody();
- }
+// private String proxyHello() {
+// return demoService.sayHello("world");
+// }
+//
+// private String restHello() {
+// RestClient defaultClient = RestClient.create();
+// ResponseEntity<String> result = defaultClient.get()
+// .uri("http://localhost:50052/demo/hello?name=world";)
+// .header("Content-type", "application/json")
+// .retrieve()
+// .toEntity(String.class);
+// return result.getBody();
+// }
}
diff --git
a/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/main/java/org/apache/dubbo/rest/demo/expansion/filter/FilterService.java
b/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/main/java/org/apache/dubbo/rest/demo/expansion/filter/FilterService.java
new file mode 100644
index 000000000..3dfb7c128
--- /dev/null
+++
b/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/main/java/org/apache/dubbo/rest/demo/expansion/filter/FilterService.java
@@ -0,0 +1,13 @@
+package org.apache.dubbo.rest.demo.expansion.filter;
+
+import org.springframework.http.MediaType;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+
+@RequestMapping(value = "/filter")
+public interface FilterService {
+ @GetMapping(value = "/get/{name}", consumes = "application/json", produces
= MediaType.TEXT_PLAIN_VALUE)
+ public String filterGet(@PathVariable(value = "name") String name);
+}
diff --git
a/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/main/java/org/apache/dubbo/rest/demo/expansion/filter/FilterServiceImpl.java
b/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/main/java/org/apache/dubbo/rest/demo/expansion/filter/FilterServiceImpl.java
new file mode 100644
index 000000000..01aa4a036
--- /dev/null
+++
b/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/main/java/org/apache/dubbo/rest/demo/expansion/filter/FilterServiceImpl.java
@@ -0,0 +1,12 @@
+package org.apache.dubbo.rest.demo.expansion.filter;
+import org.apache.dubbo.config.annotation.DubboService;
+
+@DubboService
+public class FilterServiceImpl implements FilterService{
+
+ @Override
+ public String filterGet(String name) {
+ return name;
+ }
+
+}
diff --git
a/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/main/java/org/apache/dubbo/rest/demo/pojo/User.java
b/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/main/java/org/apache/dubbo/rest/demo/pojo/User.java
new file mode 100644
index 000000000..9c4c2df35
--- /dev/null
+++
b/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/main/java/org/apache/dubbo/rest/demo/pojo/User.java
@@ -0,0 +1,87 @@
+package org.apache.dubbo.rest.demo.pojo;
+import java.io.Serializable;
+import java.util.Objects;
+
+// 需要 implements Serializable
+public class User implements Serializable{
+
+ private Long id;
+
+ private String name;
+
+ private Integer age;
+
+ public User(Long id, String name){
+ this.id = id;
+ this.name = name;
+ }
+
+ public User(Long id, String name, Integer age){
+ this.id = id;
+ this.name = name;
+ this.age = age;
+ }
+
+ public User(){
+
+ }
+
+ public Long getId() {
+ return id;
+ }
+
+ public void setId(Long id) {
+ this.id = id;
+ }
+
+ 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;
+ }
+
+ public static User getInstance() {
+ User user = new User();
+ user.setAge(18);
+ user.setName("dubbo");
+ user.setId(404l);
+ return user;
+ }
+
+ @Override
+ public boolean equals(Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+ User user = (User) o;
+ return Objects.equals(id, user.id) && Objects.equals(name, user.name)
&& Objects.equals(age, user.age);
+ }
+
+ @Override
+ public int hashCode() {
+ return Objects.hash(id, name, age);
+ }
+
+ @Override
+ public String toString() {
+ return "User{" + "id=" + id + ", name='" + name + '\'' + ", age=" +
age + '}';
+ }
+
+ public String stringToJson(){
+ return "{\"id\":\"" + this.id + "\", \"name\":\"" + this.name + "\"}";
+ }
+
+}
diff --git
a/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/main/java/org/apache/dubbo/rest/demo/provider/DemoServiceImpl.java
b/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/main/java/org/apache/dubbo/rest/demo/provider/DemoServiceImpl.java
index d90361577..6b6fdc210 100644
---
a/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/main/java/org/apache/dubbo/rest/demo/provider/DemoServiceImpl.java
+++
b/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/main/java/org/apache/dubbo/rest/demo/provider/DemoServiceImpl.java
@@ -16,15 +16,146 @@
*/
package org.apache.dubbo.rest.demo.provider;
+import com.alibaba.fastjson2.TypeReference;
import org.apache.dubbo.config.annotation.DubboService;
import org.apache.dubbo.rest.demo.DemoService;
+import org.apache.dubbo.rest.demo.pojo.User;
+import org.json.JSONObject;
+import org.springframework.util.MultiValueMap;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
+import java.util.HashMap;
+import java.util.List;
@DubboService
public class DemoServiceImpl implements DemoService {
+ private static final String prefix = "hello ";
@Override
- public String sayHello(String name) {
- return "Hello " + name;
+ public String getParam(String id) {
+ return prefix + id;
}
+ @Override
+ public String getVariable(String id) {
+ return prefix + id;
+ }
+
+ @Override
+ public String getMuchParam(String id, String name) {
+ return prefix + id + " " + name;
+ }
+
+ @Override
+ public String getMuchVariable(String id, String name) {
+ return prefix + id + " " + name;
+ }
+
+ @Override
+ public String getReg(String name, String version, String ext) {
+ return prefix + name + " " + version + " " + ext;
+ }
+
+ @Override
+ public String postBody(String name_json) {
+ JSONObject jsonObject = new JSONObject(name_json);
+ return prefix + jsonObject.getString("name");
+ }
+
+ @Override
+ public String postParam(String id) {
+ return prefix + id;
+ }
+
+ @Override
+ public String postVariable(String id) {
+ return prefix + id;
+ }
+
+ @Override
+ public String postUseConsumes(String id) {
+ JSONObject jsonObject = new JSONObject(id);
+ return prefix + jsonObject.getString("id");
+ }
+
+ @Override
+ public String postUseParams(String id) {
+ JSONObject jsonObject = new JSONObject(id);
+ return prefix + jsonObject.getString("id");
+ }
+
+ @Override
+ public String getHead(String id) {
+ return prefix + id;
+ }
+
+ @Override
+ public String postUseConsumesFormData(MultiValueMap<String, String>
formData) {
+ return prefix + formData.get("id").get(0) + " " +
formData.get("name").get(0);
+ }
+
+ @Override
+ public String postMapUser(String formData) {
+ HashMap<String, User> userHashMap =
com.alibaba.fastjson2.JSONObject.parseObject(formData, new
TypeReference<HashMap<String, User>>() {
+ @Override
+ public HashMap<String, User> parseObject(String text) {
+ return super.parseObject(text);
+ }
+ });
+
+ return prefix + userHashMap.get("user1").getId() + " " +
userHashMap.get("user2").getId();
+ }
+
+ @Override
+ public String putUpdateId(@PathVariable String id){
+ return prefix + id;
+ }
+
+ @Override
+ public String deleteId(@PathVariable(value = "id")String id){
+ return prefix + id;
+ }
+
+ @Override
+ public String patchById(@PathVariable String id, @RequestBody String
patchData){
+ JSONObject jsonObject = new JSONObject(patchData);
+ String name = jsonObject.getString("name");
+
+ return prefix + id + " " + name;
+ }
+
+ @Override
+ public String error() {
+ throw new RuntimeException();
+ }
+
+ @Override
+ public String postUseConsumesUser(@RequestBody MultiValueMap<String,
List<User>> formData){
+ return prefix + formData.get("user1").get(0).get(0).getName();
+ }
+
+ @Override
+ public int primitiveInt(int a, int b) {
+ return a + b;
+ }
+
+ @Override
+ public long primitiveLong(long a, Long b) {
+ return a + b;
+ }
+
+ @Override
+ public long primitiveByte(byte a, Long b) {
+ return a + b;
+ }
+
+ @Override
+ public long primitiveShort(short a, Long b, int c) {
+ return a + b;
+ }
+
+ @Override
+ public List<User> postList(List<User> users){
+ return users;
+ }
}
diff --git
a/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/main/resources/application.yml
b/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/main/resources/application.yml
index 7596034ad..2d332cda3 100644
---
a/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/main/resources/application.yml
+++
b/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/main/resources/application.yml
@@ -24,3 +24,4 @@ dubbo:
protocol:
name: tri
port: 50052
+ serialization: fastjson2
diff --git
a/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/test/java/org/apache/dubbo/rest/demo/test/ConsumerIT.java
b/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/test/java/org/apache/dubbo/rest/demo/test/ConsumerIT.java
index 38646cabc..d3a868474 100644
---
a/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/test/java/org/apache/dubbo/rest/demo/test/ConsumerIT.java
+++
b/2-advanced/dubbo-samples-triple-rest/dubbo-samples-triple-rest-springmvc/src/test/java/org/apache/dubbo/rest/demo/test/ConsumerIT.java
@@ -16,16 +16,28 @@
*/
package org.apache.dubbo.rest.demo.test;
+import com.alibaba.fastjson2.JSON;
import org.apache.dubbo.config.annotation.DubboReference;
import org.apache.dubbo.rest.demo.DemoService;
+import org.apache.dubbo.rest.demo.expansion.filter.FilterService;
+import org.apache.dubbo.rest.demo.pojo.User;
import org.junit.Assert;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.core.ParameterizedTypeReference;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.test.context.junit4.SpringRunner;
+import org.springframework.util.LinkedMultiValueMap;
+import org.springframework.util.MultiValueMap;
import org.springframework.web.client.RestClient;
-import org.springframework.web.client.RestTemplate;
+
+import java.lang.reflect.Type;
+import java.util.HashMap;
+import java.util.LinkedList;
+import java.util.List;
import static org.springframework.http.MediaType.APPLICATION_JSON;
@@ -33,25 +45,415 @@ import static
org.springframework.http.MediaType.APPLICATION_JSON;
@RunWith(SpringRunner.class)
public class ConsumerIT {
private static final String providerAddress =
System.getProperty("dubbo.address", "localhost");
+ private static final String urlPrefix = "http://"; + providerAddress +
":50052";
+ private static final String prefix = "hello ";
@DubboReference
private DemoService demoService;
+ @DubboReference
+ private FilterService filterService;
+
+ @Test
+ public void getParam(){
+ String id = "123";
+ String res = demoService.getParam(id);
+ Assert.assertEquals(prefix + id, res);
+ }
+
+ @Test
+ public void RestGetParam(){
+ String id = "123";
+ RestClient restClient = RestClient.create();
+ ResponseEntity<String> responseEntity = restClient.get()
+ .uri(urlPrefix + "/demo/get/param?id=" + id)
+ .header("Content-Type", "application/json")
+ .retrieve()
+ .toEntity(String.class);
+
+ Assert.assertEquals("\"" + prefix + id + "\"",
responseEntity.getBody());
+ }
+
+ @Test
+ public void getVariable(){
+ String id = "123";
+ String res = demoService.getVariable(id);
+ Assert.assertEquals(prefix + id, res);
+ }
+
+ @Test
+ public void RestGetVariable(){
+ String id = "123";
+ RestClient restClient = RestClient.create();
+ ResponseEntity<String> responseEntity = restClient.get()
+ .uri(urlPrefix + "/demo/get/variable/{id}", id)
+ .header("Content-Type", "application/json")
+ .retrieve()
+ .toEntity(String.class);
+
+ Assert.assertEquals("\"" + prefix + id + "\"",
responseEntity.getBody());
+ }
+
+ @Test
+ public void getMuchParam(){
+ String id = "123", name = "test";
+ String res = demoService.getMuchParam(id, name);
+ Assert.assertEquals(prefix + id + " " + name, res);
+ }
+
+ @Test
+ public void RestGetMuchParam(){
+ String id = "123", name = "test";
+ RestClient restClient = RestClient.create();
+ ResponseEntity<String> responseEntity = restClient.get()
+ .uri(urlPrefix + "/demo/get/muchParam?id=" + id + "&name=" +
name)
+ .header("Content-Type", "application/json")
+ .retrieve()
+ .toEntity(String.class);
+
+ Assert.assertEquals("\"" + prefix + id + " " + name + "\"",
responseEntity.getBody());
+ }
+
+ @Test
+ public void getMuchVariable(){
+ String id = "123", name = "test";
+ String res = demoService.getMuchVariable(id, name);
+ Assert.assertEquals(prefix + id + " " + name, res);
+ }
+
+ @Test
+ public void RestGetMuchVariable(){
+ String id = "123", name = "test";
+ RestClient restClient = RestClient.create();
+ ResponseEntity<String> responseEntity = restClient.get()
+ .uri(urlPrefix + "/demo/get/muchVariable/{id}/{name}", id,
name)
+ .header("Content-Type", "application/json")
+ .retrieve()
+ .toEntity(String.class);
+
+ Assert.assertEquals("\"" + prefix + id + " " + name + "\"",
responseEntity.getBody());
+ }
+
+ @Test
+ public void getReg(){
+ String name = "test", version = "2.2.1", ext = ".txt";
+ String res = demoService.getReg(name, version, ext);
+ Assert.assertEquals(prefix + name + " " + version + " " + ext, res);
+ }
+
+ @Test
+ public void RestGetReg(){
+ String name = "test", version = "2.2.1", ext = ".txt";
+ RestClient restClient = RestClient.create();
+ ResponseEntity<String> responseEntity = restClient.get()
+ .uri(urlPrefix + "/demo/get/reg/{name}-{version}{ext}", name,
version, ext)
+ .header("Content-Type", "application/json")
+ .retrieve()
+ .toEntity(String.class);
+
+ // 因为已经解析了json 那么不需要再变成json格式了
+ Assert.assertEquals(prefix + name + " " + version + " " + ext,
responseEntity.getBody());
+ }
+
+ @Test
+ public void postBody(){
+ String name = "123";
+ String requestBody = "{\"name\": \"" + name + "\"}";
+ String res = demoService.postBody(requestBody);
+ Assert.assertEquals(prefix + name, res);
+ }
+
+ @Test
+ public void RestPostBody(){
+ String name = "name";
+ String requestBody = "{\"name\": \"" + name + "\"}";
+ RestClient restClient = RestClient.create();
+ ResponseEntity<String> responseEntity = restClient.post()
+ .uri(urlPrefix + "/demo/post/body")
+ .header("content-type", "application/json")
+ .body(requestBody)
+ .retrieve()
+ .toEntity(String.class);
+
+ Assert.assertEquals("\"" + prefix + name + "\"",
responseEntity.getBody());
+ }
+
@Test
- public void test() {
- String result = demoService.sayHello("world");
- Assert.assertEquals("Hello world", result);
+ public void postParam(){
+ String name = "123";
+ String res = demoService.postParam(name);
+ Assert.assertEquals(prefix + name, res);
}
@Test
- public void testRest() {
- RestClient defaultClient = RestClient.create();
- ResponseEntity<String> result = defaultClient.get()
- .uri("http://"; + providerAddress +
":50052/demo/hello?name=world")
- .header("Content-type", "application/json")
+ public void RestPostParam(){
+ String id = "name";
+ RestClient restClient = RestClient.create();
+ ResponseEntity<String> responseEntity = restClient.post()
+ .uri(urlPrefix + "/demo/post/param?id=" + id)
+ .contentType(APPLICATION_JSON)
.retrieve()
.toEntity(String.class);
- // FIXME
- Assert.assertEquals("\"Hello world\"", result.getBody());
+
+ Assert.assertEquals("\"" + prefix + id + "\"",
responseEntity.getBody());
}
+
+ @Test
+ public void postVariable(){
+ String name = "123";
+ String res = demoService.postVariable(name);
+ Assert.assertEquals(prefix + name, res);
+ }
+
+ @Test
+ public void RestPostVariable(){
+ String id = "name";
+ RestClient restClient = RestClient.create();
+ ResponseEntity<String> responseEntity = restClient.post()
+ .uri(urlPrefix + "/demo/post/variable/{id}", id)
+ .contentType(APPLICATION_JSON)
+ .retrieve()
+ .toEntity(String.class);
+
+ Assert.assertEquals("\"" + prefix + id + "\"",
responseEntity.getBody());
+ }
+
+ @Test
+ public void postUseConsumes(){
+ String id = "123";
+ String requestBody = "{\"id\": \"" + id + "\"}";
+ String res = demoService.postUseConsumes(requestBody);
+ Assert.assertEquals(prefix + id, res);
+ }
+
+ @Test
+ public void RestUseConsumes(){
+ String id = "name";
+ String requestBody = "{\"id\":\"" + id + "\"}";
+ RestClient restClient = RestClient.create();
+ ResponseEntity<String> responseEntity = restClient.post()
+ .uri(urlPrefix + "/demo/post/useConsumes")
+ .header("content-type", "application/json")
+ .body(requestBody)
+ .retrieve()
+ .toEntity(String.class);
+
+ Assert.assertEquals("\"" + prefix + id + "\"",
responseEntity.getBody());
+ }
+
+ @Test
+ public void postUseParams(){
+ String id = "123";
+ String requestBody = "{\"id\":\"" + id + "\"}";
+ String res = demoService.postUseParams(requestBody);
+ Assert.assertEquals(prefix + id, res);
+ }
+
+ @Test
+ public void RestUseParams(){
+ String id = "name";
+ String requestBody = "{\"id\":\"" + id + "\"}";
+ RestClient restClient = RestClient.create();
+ ResponseEntity<String> responseEntity = restClient.post()
+ .uri(urlPrefix + "/demo/post/useParams?myParam=myValue")
+ .contentType(APPLICATION_JSON)
+ .body(requestBody)
+ .retrieve()
+ .toEntity(String.class);
+
+ Assert.assertEquals("\"" + prefix + id + "\"",
responseEntity.getBody());
+ }
+
+ @Test
+ public void getHead(){
+ String id = "123";
+ String res = demoService.getHead(id);
+ Assert.assertEquals(prefix + id, res);
+ }
+
+ @Test
+ public void RestGetHead(){
+ String id = "123";
+ RestClient restClient = RestClient.create();
+ ResponseEntity<String> responseEntity = restClient.get()
+ .uri(urlPrefix + "/demo/get/head/{id}", id)
+ .header("Content-Type", "application/json")
+ .header("myHeader", "myValue")
+ .retrieve()
+ .toEntity(String.class);
+
+ Assert.assertEquals("\"" + prefix + id + "\"",
responseEntity.getBody());
+ }
+
+
+ @Test
+ public void RestPostUseConsumesFormData(){
+ String id = "123", name = "John";
+
+ MultiValueMap<String, String> map = new LinkedMultiValueMap<>();
+ map.add("id", id);
+ map.add("name", name);
+
+ RestClient restClient = RestClient.create();
+ ResponseEntity<String> responseEntity = restClient.post()
+ .uri(urlPrefix + "/demo/post/useConsumes/formData")
+ .header("Content-Type", "application/x-www-form-urlencoded")
+ .body(map)
+ .retrieve()
+ .toEntity(String.class);
+
+ Assert.assertEquals("\"" + prefix + id + " " + name + "\"",
responseEntity.getBody());
+ }
+
+ @Test
+ public void postUser(){
+ HashMap<String, User> map = new HashMap<String, User>();
+ map.put("user1", new User(123L, "nick"));
+ map.put("user2", new User(456L, "lick"));
+
+ String json = JSON.toJSONString(map);
+
+ Assert.assertEquals(prefix + "123" + " 456",
demoService.postMapUser(json));
+ }
+
+ // 出现问题
+ @Test
+ public void RestPostUser(){
+ HashMap<String, User> map = new HashMap<String, User>();
+ map.put("user1", new User(123L, "nick"));
+ map.put("user2", new User(456L, "lick"));
+
+ String json = JSON.toJSONString(map);
+
+ RestClient restClient = RestClient.create();
+ ResponseEntity<String> responseEntity = restClient.post()
+ .uri(urlPrefix + "/demo/post/map/user")
+ .header("content-type", "application/json")
+ .body(json)
+ .retrieve()
+ .toEntity(String.class);
+
+ Assert.assertEquals("\"" + prefix + "123" + " 456" + "\"",
responseEntity.getBody());
+ }
+
+ @Test
+ public void putUpdateId(){
+ String id = "123";
+ Assert.assertEquals(prefix + id, demoService.putUpdateId(id));
+ }
+
+
+ @Test
+ public void RestPutUpdateId(){
+ String id = "123";
+ RestClient restClient = RestClient.create();
+ HttpEntity<String> response = restClient.put()
+ .uri(urlPrefix + "/demo/put/update/{id}", id)
+ .retrieve()
+ .toEntity(String.class);
+ Assert.assertEquals("\"" + prefix + id + "\"", response.getBody());
+ }
+
+ @Test
+ public void deleteId(){
+ String id = "123";
+ Assert.assertEquals(prefix + id, demoService.deleteId(id));
+ }
+
+
+ @Test
+ public void RestDeleteId(){
+ String id = "123";
+
+ RestClient restClient = RestClient.create();
+ HttpEntity<String> response = restClient.delete()
+ .uri(urlPrefix + "/demo/delete/{id}", id)
+ .retrieve()
+ .toEntity(String.class);
+ Assert.assertEquals("\"" + prefix + id + "\"", response.getBody());
+ }
+
+ @Test
+ public void patchById(){
+ String id = "123";
+ Assert.assertEquals(prefix + id + " jack", demoService.patchById(id,
new User(123L, "jack").stringToJson()));
+ }
+
+
+ @Test
+ public void RestPatchById(){
+ String id = "123";
+ String requestBody = new User(12L, "jack").stringToJson();
+
+ RestClient restClient = RestClient.create();
+ HttpEntity<String> response = restClient.patch()
+ .uri(urlPrefix + "/demo/patch/{id}", id)
+ .contentType(APPLICATION_JSON)
+ .body(requestBody)
+ .retrieve()
+ .toEntity(String.class);
+ Assert.assertEquals("\"" + prefix + id + " jack" +"\"",
response.getBody());
+ }
+
+ @Test
+ public void primitive(){
+ Assert.assertEquals(1 + 2, demoService.primitiveInt(1, 2));
+
+ Assert.assertEquals(1L + 2L, demoService.primitiveLong(1L, 2L));
+
+ Assert.assertEquals(1 + 2L, demoService.primitiveByte((byte) 1, 2L));
+
+ Assert.assertEquals(3L, demoService.primitiveShort((short) 1, 2L, 1));
+ }
+
+ @Test
+ public void filterGet(){
+ String name = "123";
+ Assert.assertEquals(name, filterService.filterGet(name));
+ }
+
+ @Test
+ public void RestFilterGet(){
+ String name = "123";
+ RestClient restClient = RestClient.create();
+ HttpEntity<String> response = restClient.get()
+ .uri(urlPrefix + "/filter/get/{name}", name)
+ .header("content-type", "application/json")
+ .retrieve()
+ .toEntity(String.class);
+
+ Assert.assertEquals(name, response.getBody());
+ }
+
+ @Test
+ public void postList(){
+ List<User> userList = new LinkedList<>();
+ userList.add(new User(123L, "jack"));
+ userList.add(new User(345L, "mack"));
+
+ Assert.assertEquals(userList, demoService.postList(userList));
+ }
+
+ @Test
+ public void RestPostList(){
+ List<User> userList = new LinkedList<>();
+ userList.add(new User(123L, "jack", 123));
+ userList.add(new User(345L, "mack", 123));
+
+ RestClient restClient = RestClient.create();
+ HttpEntity<List<User>> response = restClient.post()
+ .uri(urlPrefix + "/demo/post/list")
+ .contentType(APPLICATION_JSON)
+ .body(userList)
+ .retrieve()
+ .toEntity(new ParameterizedTypeReference<List<User>>() {
+ @Override
+ public Type getType() {
+ return super.getType();
+ }
+ });
+
+ Assert.assertEquals(userList, response.getBody());
+ }
+
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
