Dubbo服务之间进行调用

1
<packaging>pom</packaging>
2
<modules>
3
    <module>csmall-stock-service</module>
4
</modules>

1
<?xml version="1.0" encoding="UTF-8"?>
2
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
3
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
4
    <modelVersion>4.0.0</modelVersion>
5
    <parent>
6
        <groupId>cn.tedu</groupId>
7
        <artifactId>csmall-stock</artifactId>
8
        <version>0.0.1-SNAPSHOT</version>
9
        <relativePath/> <!-- lookup parent from repository -->
10
    </parent>
11
    <groupId>cn.tedu</groupId>
12
    <artifactId>csmall-stock-service</artifactId>
13
    <version>0.0.1-SNAPSHOT</version>
14
    <name>csmall-stock-service</name>
15
    <description>Demo project for Spring Boot</description>
16
    <dependencies>
17
        <dependency>
18
            <groupId>cn.tedu</groupId>
19
            <artifactId>csmall-commons</artifactId>
20
            <version>0.0.1-SNAPSHOT</version>
21
        </dependency>
22
    </dependencies>
23
</project>

1
<?xml version="1.0" encoding="UTF-8"?>
2
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
3
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
4
    <modelVersion>4.0.0</modelVersion>
5
    <parent>
6
        <groupId>cn.tedu</groupId>
7
        <artifactId>csmall-stock</artifactId>
8
        <version>0.0.1-SNAPSHOT</version>
9
        <relativePath/> <!-- lookup parent from repository -->
10
    </parent>
11
    <groupId>cn.tedu</groupId>
12
    <artifactId>csmall-stock-webapi</artifactId>
13
    <version>0.0.1-SNAPSHOT</version>
14
    <name>csmall-stock-webapi</name>
15
    <description>Demo project for Spring Boot</description>
16
    <dependencies>
17
        <!--web实例-->
18
        <dependency>
19
            <groupId>org.springframework.boot</groupId>
20
            <artifactId>spring-boot-starter-web</artifactId>
21
        </dependency>
22
        <!--mybatis整合springboot-->
23
        <dependency>
24
            <groupId>org.mybatis.spring.boot</groupId>
25
            <artifactId>mybatis-spring-boot-starter</artifactId>
26
        </dependency>
27
        <!--alibaba 数据源德鲁伊-->
28
        <dependency>
29
            <groupId>com.alibaba</groupId>
30
            <artifactId>druid</artifactId>
31
        </dependency>
32
        <!--mysql驱动-->
33
        <dependency>
34
            <groupId>mysql</groupId>
35
            <artifactId>mysql-connector-java</artifactId>
36
        </dependency>
37
        <!--all-common依赖-->
38
        <dependency>
39
            <groupId>cn.tedu</groupId>
40
            <artifactId>csmall-commons</artifactId>
41
            <version>0.0.1-SNAPSHOT</version>
42
        </dependency>
43
        <!--在线api文档-->
44
        <dependency>
45
            <groupId>com.github.xiaoymin</groupId>
46
            <artifactId>knife4j-spring-boot-starter</artifactId>
47
        </dependency>
48
        <!--添加nacos依赖-->
49
        <dependency>
50
            <groupId>com.alibaba.cloud</groupId>
51
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
52
        </dependency>
53
        <!--添加dubbo依赖-->
54
        <dependency>
55
            <groupId>com.alibaba.cloud</groupId>
56
            <artifactId>spring-cloud-starter-dubbo</artifactId>
57
        </dependency>
58
        <!--为了实现业务逻辑层接口,要把csmall-stock-service的依赖添加进来-->
59
        <dependency>
60
            <groupId>cn.tedu</groupId>
61
            <artifactId>csmall-stock-service</artifactId>
62
            <version>0.0.1-SNAPSHOT</version>
63
        </dependency>
64
        <dependency>
65
            <groupId>org.springframework.boot</groupId>
66
            <artifactId>spring-boot-starter-test</artifactId>
67
            <scope>test</scope>
68
            <exclusions>
69
                <exclusion>
70
                    <groupId>org.junit.vintage</groupId>
71
                    <artifactId>junit-vintage-engine</artifactId>
72
                </exclusion>
73
            </exclusions>
74
        </dependency>
75
    </dependencies>
76
​
77
    <dependencyManagement>
78
        <dependencies>
79
            <dependency>
80
                <groupId>org.springframework.boot</groupId>
81
                <artifactId>spring-boot-dependencies</artifactId>
82
                <version>${spring-boot.version}</version>
83
                <type>pom</type>
84
                <scope>import</scope>
85
            </dependency>
86
        </dependencies>
87
    </dependencyManagement>
88
</project>

1
<?xml version="1.0" encoding="UTF-8"?>
2
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
3
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
4
    <modelVersion>4.0.0</modelVersion>
5
    <parent>
6
        <groupId>cn.tedu</groupId>
7
        <artifactId>csmall</artifactId>
8
        <version>0.0.1-SNAPSHOT</version>
9
        <relativePath/> <!-- lookup parent from repository -->
10
    </parent>
11
    <groupId>cn.tedu</groupId>
12
    <artifactId>csmall-stock</artifactId>
13
    <version>0.0.1-SNAPSHOT</version>
14
    <name>csmall-stock</name>
15
    <description>Demo project for Spring Boot</description>
16
    <packaging>pom</packaging>
17
    <modules>
18
        <module>csmall-stock-service</module>
19
        <module>csmall-stock-webapi</module>
20
    </modules>
21
​
22
</project>

1
       <!--添加dubbo依赖-->
2
        <dependency>
3
            <groupId>com.alibaba.cloud</groupId>
4
            <artifactId>spring-cloud-starter-dubbo</artifactId>
5
        </dependency>
6
        <!--为了实现业务逻辑层接口,要把csmall-stock-service的依赖添加进来-->
7
        <dependency>
8
            <groupId>cn.tedu</groupId>
9
            <artifactId>csmall-stock-service</artifactId>
10
            <version>0.0.1-SNAPSHOT</version>

1
#配置dubbo信息
2
dubbo:
3
  protocol:
4
    #port设置成-1是Dubbo框架支持的特殊写法,会自动动态生成可用的端口,规则是从20880开始,
5
    #如果被占用就递增使用
6
    port: -1
7
    #设置连接的名称,一般固定就叫dubbo
8
    name: dubbo
9
  registry:
10
    #声明注册中心的软件类型和ip端口号
11
    address: nacos: //localhost:8848
12
  consumer:
13
    #当项目启动时,作为消费者,是否要检查所有远程服务可用,false表示不检查
14
    check: false

1
@DubboService
2
@Service
3
@Slf4j
4
public class StockServiceImpl implements IStockService {
5
    ......
6
}

1
@SpringBootApplication
2
@EnableDubbo
3
public class CsmallStockWebapiApplication {
4
​
5
    public static void main(String[] args) {
6
        SpringApplication.run(CsmallStockWebapiApplication.class, args);
7
    }
8
​
9
}

1
       <!--添加dubbo依赖-->
2
        <dependency>
3
            <groupId>com.alibaba.cloud</groupId>
4
            <artifactId>spring-cloud-starter-dubbo</artifactId>
5
        </dependency>
6
        <!--order需要调用cart和stock模块,所以要把csmall-order-service、csmall-cart-service、csmall-stock-service的依赖添加进来-->
7
        <dependency>
8
            <groupId>cn.tedu</groupId>
9
            <artifactId>csmall-order-service</artifactId>
10
            <version>0.0.1-SNAPSHOT</version>
11
        </dependency>
12
        <dependency>
13
            <groupId>cn.tedu</groupId>
14
            <artifactId>csmall-stock-service</artifactId>
15
            <version>0.0.1-SNAPSHOT</version>
16
        </dependency>
17
        <dependency>
18
            <groupId>cn.tedu</groupId>
19
            <artifactId>csmall-cart-service</artifactId>
20
            <version>0.0.1-SNAPSHOT</version>
21
        </dependency>

1
@DubboService
2
@Service
3
@Slf4j
4
public class OrderServiceImpl implements IOrderService {
5
    @Autowired
6
    private OrderMapper orderMapper;
7
    //当前order模块消费stock模块的减少库存的方法
8
    //因为stock模块减少库存的方法已经注册到Nacos,所以当前order模块可以利用dubbo调用
9
    //要向调用必须使用@DubboReference,才能获得业务逻辑层实现类对象
10
    @DubboReference
11
    private IStockService stockService;
12
    //还需要cart模块的服务,有的公司要求dubbo的业务层变量名使用dubbo开头
13
    @DubboReference
14
    private ICartService dubboCartService;
15
​
16
    @Override
17
    public void orderAdd(OrderAddDTO orderAddDTO) {
18
        OrderTbl orderTbl = new OrderTbl();
19
        BeanUtils.copyProperties(orderAddDTO,orderTbl);
20
        //执行新增订单之前，需要先减少库存和删除购物车商品
21
        //1.减少订单商品的库存数(利用dubbo调用stock模块)
22
        //参数需要的是StockReduceCountDTO类型的参数,
23
        // 这个参数里面的属性是commodityCode和reduceCount,恰好OrderAddDTO有
24
        //,直接获取赋值即可
25
        StockReduceCountDTO stockReduceCountDTO = new StockReduceCountDTO();
26
        stockReduceCountDTO.setCommodityCode(orderAddDTO.getCommodityCode());
27
        stockReduceCountDTO.setReduceCount(orderAddDTO.getCount());
28
        stockService.reduceCommodityCount(stockReduceCountDTO);
29
        //2.删除购物车商品(利用dubbo调用cart模块)
30
        dubboCartService.deleteUserCart(orderAddDTO.getUserId(),orderAddDTO.getCommodityCode());
31
        //3.新增订单
32
        orderMapper.insertOrder(orderTbl);
33
        log.info("新增订单的信息：{}",orderTbl);
34
    }
35
}

1
        <!--添加dubbo依赖-->
2
        <dependency>
3
            <groupId>com.alibaba.cloud</groupId>
4
            <artifactId>spring-cloud-starter-dubbo</artifactId>
5
        </dependency>
6
       <!--business需要调用order模块,所以要把csmall-order-service的依赖添加进来-->
7
        <dependency>
8
            <groupId>cn.tedu</groupId>
9
            <artifactId>csmall-order-service</artifactId>
10
            <version>0.0.1-SNAPSHOT</version>
11
        </dependency>

1
@Service
2
@Slf4j //提供log对象，可以用于打印日志
3
public class BusinessServiceImpl implements IBusinessService {
4
​
5
    //需要利用dubbo调用order模块中的新增订单方法
6
    @DubboReference
7
    private IOrderService dubboOrderService;
8
    @Override
9
    public void buy() {
10
        //模拟购买业务
11
        //创建OrderAddDTO类，并赋值
12
        OrderAddDTO orderAddDTO = new OrderAddDTO();
13
        orderAddDTO.setUserId("UU100");
14
        orderAddDTO.setCommodityCode("PC100");
15
        orderAddDTO.setCount(5);
16
        orderAddDTO.setMoney(100);
17
        //调用order模块的方法
18
        dubboOrderService.orderAdd(orderAddDTO);
19
        //目前现在控制台输出
20
        log.info("新增订单的信息为：{}",orderAddDTO);
21
    }
22
}

1
@DubboService
2
@Service
3
@Slf4j
4
public class StockServiceImpl implements IStockService {
5
    @Autowired
6
    private StockMapper stockMapper;
7
​
8
    @Value("${server.port}")
9
    private int port;
10
​
11
    @Override
12
    public void reduceCommodityCount(StockReduceCountDTO stockReduceCountDTO) {
13
        //参数1：商品编号
14
        //参数2：减少的库存数
15
        stockMapper.updateStockByCommodityCode(
16
                stockReduceCountDTO.getCommodityCode(), stockReduceCountDTO.getReduceCount());
17
        log.info("库存减少完成！端口是:{}",port);
18
    }
19
}