# rocketmqDemo

**Repository Path**: maxatom/rocketdemo

## Basic Information

- **Project Name**: rocketmqDemo
- **Description**: rocketmq实现分布式事务demo
- **Primary Language**: Unknown
- **License**: Apache-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 1
- **Created**: 2021-08-10
- **Last Updated**: 2023-06-26

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# rocketmqDemo

#### 介绍
rocket实现分布式事务demo
1.  两个服务， order 订单服务， stock 库存服务
2.  订单服务创建订单以后，向库存服务发送消息，库存服务收到消息后执行扣减库存操作，通过rocketmq事务消息实现

参考： https://www.jianshu.com/p/7bb56cc0946d

#### 软件架构
需要依赖rocketmq服务， mysql数据库服务
springboot
rocketmq
mysql


#### 安装教程
数据库： order 订单库
    表： t_order订单表
   ```sql    
CREATE TABLE `t_order` (
    	`id` INT(10) NOT NULL AUTO_INCREMENT,
    	`item` INT(10) NULL DEFAULT '0',
    	`item_num` INT(10) NULL DEFAULT '0',
    	PRIMARY KEY (`id`) USING BTREE
    )
    COLLATE='utf8_general_ci'
    ENGINE=InnoDB
    AUTO_INCREMENT=15
    ;
```
    stock_log 消息日志表
```sql
    CREATE TABLE `stock_log` (
    	`id` INT(10) NOT NULL AUTO_INCREMENT,
    	`order_id` INT(10) NULL DEFAULT '0',
    	`item_id` INT(10) NULL DEFAULT '0',
    	`amount` INT(10) NULL DEFAULT '0',
    	`status` INT(10) NULL DEFAULT '0' COMMENT '订单状态 0-初始 1-创建成功 2-订单失败',
    	`create_time` INT(10) NULL DEFAULT '0',
    	PRIMARY KEY (`id`) USING BTREE
    )
    COLLATE='utf8_general_ci'
    ENGINE=InnoDB
    AUTO_INCREMENT=10
    ;
```
数据库：     itemstock 库存庫
表： item 商品库存表
```sql
CREATE TABLE `item` (
	`id` INT(10) NOT NULL AUTO_INCREMENT,
	`amount` INT(10) NULL DEFAULT NULL COMMENT '剩余库存', 
	PRIMARY KEY (`id`) USING BTREE
)
COLLATE='utf8_general_ci'
ENGINE=InnoDB
AUTO_INCREMENT=4
;
```