add

unififi-demo-api/src/main/java/com/unififi/model/User.java

@@ -5,6 +5,7 @@ import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 
 import javax.validation.constraints.NotNull;
+import java.util.Date;
 
 @Data
 @ApiModel(value = "用户信息")
@@ -17,4 +18,5 @@ public class User {
     @ApiModelProperty(value = "年龄")
     private Integer age;
 
+    private Date birthday;
 }

unififi-demo1-service/src/main/java/com/unififi/controller/Demo1Controller.java

@@ -51,6 +51,11 @@ public class Demo1Controller {
         return userApi.get(name);
     }
 
+    @GetMapping("/user/get/v2")
+    public User userGetV2(@RequestParam("name") String name) {
+        return restTemplate.getForObject("http://unififi-demo2-service/user/get?name=demoData", User.class);
+    }
+
     @GetMapping(value = "/user/list")
     public List<User> userList() {
 //        return userApi.list();

unififi-demo1-service/src/main/resources/bootstrap.yml

@@ -36,6 +36,6 @@ spring:
           unififi.env: ${spring.profiles.active}
           
 rocketmq: 
-  name-server: 192.168.228.100:9876
+  name-server: 39.106.6.97:9876
   producer: 
     group: unififi-demo1-service          
\ No newline at end of file

unififi-demo1-service/src/test/java/com/unififi/test/TestMQ.java

@@ -22,14 +22,14 @@ public class TestMQ {
     @Test
     public void sendSimple() {
         TicketingOrder order = new TicketingOrder();
-        order.setOrderNo("ticketing");
+        order.setOrderNo("ticketing11111111111");
         rocketMQTemplate.convertAndSend("order-push:ticketing", order);
     }
 
     @Test
     public void sendSimple2() {
         RefundOrder order = new RefundOrder();
-        order.setOrderNo("refund");
+        order.setOrderNo("refund222222222222");
         Message<RefundOrder> message = MessageBuilder.withPayload(order)
                 .setHeader(MessageConst.PROPERTY_KEYS, "key")
                 .build();
@@ -39,7 +39,7 @@ public class TestMQ {
     @Test
     public void sendSimple3() {
         ChangeOrder order = new ChangeOrder();
-        order.setOrderNo("change");
+        order.setOrderNo("change333333333333");
         rocketMQTemplate.convertAndSend("order-push:change", order);
     }
 }

unififi-demo2-service/src/main/java/com/unififi/controller/Demo2Controller.java

@@ -9,6 +9,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.MediaType;
 import org.springframework.web.bind.annotation.*;
 
+import java.util.Date;
 import java.util.List;
 
 @RestController
@@ -51,7 +52,9 @@ public class Demo2Controller implements UserApi {
         } catch (InterruptedException e) {
             e.printStackTrace();
         }
-        return userService.get(name);
+        User user = userService.get(name);
+        user.setBirthday(new Date());
+        return user;
     }
 
     @GetMapping("/config/username")

unififi-demo2-service/src/main/java/com/unififi/service/impl/UserServiceImpl.java

@@ -71,7 +71,7 @@ public class UserServiceImpl implements UserService {
     public User get(String name) {
 //        return USERS.stream().filter(u -> name.equals(u.getName())).collect(Collectors.toList()).get(0);
         QueryWrapper<DemoUser> queryWrapper = new QueryWrapper<>();
-        queryWrapper.eq("name", name);
+        queryWrapper.lambda().eq(DemoUser::getName, name);
         DemoUser userEntity = demoUserMapper.selectOne(queryWrapper);
         User user = new User();
         BeanUtils.copyProperties(userEntity, user);

unififi-demo2-service/src/main/resources/bootstrap.yml

@@ -35,6 +35,6 @@ spring:
           user.home: ${user.home}
           
 rocketmq:
-  name-server: 192.168.228.100:9876
+  name-server: 39.106.6.97:9876
   producer:
     group: unififi-demo2-service
\ No newline at end of file