Spring Cloud Alibaba系列之-module间通

一、实现目标

module[user-service]和modul[order-service]通过RestTemplate进行通信

二、[user-service] 提供查询用户接口

2.1 maven配置

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>ac-mall-cloud</artifactId>
        <groupId>org.example</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <groupId>org.ac</groupId>
    <artifactId>user-service</artifactId>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
    </dependencies>

</project>

2.2 新建application.yml配置文件，并配置启动端口8010

server:
 port: 8010

spring:
 application:
   name: user-service

2.3 创建启动类UserApplication，并配置@SpringBootApplication注解

@SpringBootApplication
public class UserApplication {

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

2.4 创建实体类User,用@Data提供get、set方法

@Data
public class User {

    private String id;

    private String userName;
}

2.5 创建UserDao，模拟从数据库取数据

@Repository
public class UserDao {

    public User get(String id){
        if("1".equals(id)){
            User user = new User();
            user.setId("1");
            user.setUserName("AC");

            return user;
        }
       return null;
    }
}

2.6 创建IUserService接口和实现类

public interface IUserService {
    User getUser(String id);
}

@Service
public class UserServiceImpl implements IUserService {

    @Autowired
    UserDao userDao;

    public User getUser(String id) {
        return userDao.get(id);
    }
}

2.7 创建UserController提供服务

@RestController
@RequestMapping("/users")
public class UserController {

    @Autowired
    IUserService userService;

    @GetMapping("/{userId}")
    public User getUser(@PathVariable String userId){
        return userService.getUser(userId);
    }
}

2.8 启动module[user-service]

启动module[user-service]

2.9 测试user接口

在浏览器中输入访问地址http://127.0.0.1:8010/users/1

image.png

三、[order-service] 下单并通过RestTemplate远程调用[user-service]用户接口

3.1maven配置

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>ac-mall-cloud</artifactId>
        <groupId>org.example</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <groupId>org.ac</groupId>
    <artifactId>order-service</artifactId>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
    </dependencies>

</project>

3.2 新建application.yml配置文件，并配置启动端口8020

server:
  port: 8020

spring:
  application:
    name: order-service

3.3 创建启动类OrderApplication，并配置@SpringBootApplication注解,配置RestTemplate

@SpringBootApplication
public class OrderApplication {

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

    @Bean
    RestTemplate getRestTemplate(){
        return new RestTemplate();
    }
}

3.4 创建实体类Order,用@Data提供get、set方法

@Data
public class Order {

    private String id;

    private String orderNo;

    private Long priceFen;

    private String img;

    private Date createTime;

    private String userId;

    private String userName;

    private String productId;
}

3.5 创建OrderDao，模拟将订单数据插入数据库

@Repository
public class OrderDao {

    public void insert(Order order){
        System.out.println("订单插入数据库成功");
    }
}

3.6 创建与[user-service]对接的dto类UserDto,用@Data提供get、set方法

@Data
public class UserDto {
    private String id;
    private String userName;
}

3.7 创建IOrderService接口和实现类

public interface IOrderService {
    Order makeOrder(String productId, String userId);
}

使用RestTemplate访问[user-service]接口

import com.ac.order.dao.OrderDao;
import com.ac.order.dto.UserDto;
import com.ac.order.entity.Order;
import com.ac.order.service.IOrderService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

import java.util.Date;
import java.util.UUID;

/**
 * @author Alan Chen
 * @description
 * @date 2020/10/15
 */
@Service
public class OrderServiceImpl implements IOrderService {

    @Autowired
    OrderDao orderDao;

    @Autowired
    RestTemplate restTemplate;

    final static String USER_SERVICE_URL="http://127.0.0.1:8010/users/{userId}";

    public Order makeOrder(String productId, String userId) {

        /**
         * RestTemplate是java创造出来的，在java能够访问到网络资源的包是java.net.URLConnenction/Socket
         * RestTemplate是对URLConnenction的封装
         * apache--HttpClient 也是对URLConnenction/HttpURLConnenction的封装
         * oKHttp 也封装了URLConnenction
         * netty/rpc/grpc/thirt/tomcat
         */

        // 1、根据用户ID调用用户服务接口数据，查询用户的名字
        UserDto userDto = restTemplate.getForObject(USER_SERVICE_URL,UserDto.class,userId);
        String userName=userDto.getUserName();

        // 2、生成订单
        Order order = new Order();
        order.setId(UUID.randomUUID().toString());
        order.setCreateTime(new Date());
        order.setPriceFen(1600L);
        order.setUserId(userId);
        order.setUserName(userName);
        order.setProductId(productId);
        order.setOrderNo(UUID.randomUUID().toString());

        // 3、保存数据库
        orderDao.insert(order);

        return order;
    }
}

3.8 创建OrderController提供服务

@RestController
@RequestMapping("/orders")
public class OrderController {

    @Autowired
    IOrderService orderService;

    @GetMapping("/{productId}/{userId}")
    public Order saveOrder(@PathVariable String productId, @PathVariable String userId){
        return orderService.makeOrder(productId,userId);
    }
}

3.9 启动module[order-service]

启动module[order-service]

3.10 测试order接口

在浏览器中输入访问地址http://127.0.0.1:8020/orders/1/1

成功返回订单信息，且订单信息里获取到[user-service]的用户信息了

成功返回订单信息

控制台打印出订单插入数据库成功

订单插入数据库成功

四、附录

项目源码地址