分布式事务TX-LCN课题实验手册(三)

在 上一篇文章，我们构建了分布式事务管理器，本文将构建仓储业务服务。

新建仓储项目

在 IDEA 或 Eclipse 中构建一个简单的 maven 项目，
groupId: cn.com.hohistar.cloud
artifactId: tx-client-store

然后用以下的内容替换掉项目中原来的 pom.xml 中的内容:

<?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">
    <modelVersion>4.0.0</modelVersion>

    <groupId>cn.com.hohistar.cloud</groupId>
    <artifactId>tx-client-store</artifactId>
    <version>1.0-SNAPSHOT</version>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.5.RELEASE</version>
        <relativePath/>
    </parent>

    <properties>
        <java.version>1.8</java.version>
    </properties>

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

        <dependency>
            <groupId>com.h2database</groupId>
            <artifactId>h2</artifactId>
            <scope>runtime</scope>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>

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


    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Finchley.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

新建启动类

package: cn.com.hohistar.cloud.store
class: TxStoreApplication

代码:

@SpringBootApplication
public class TxStoreApplication {

    public static void main(String[] args) {

        SpringApplication.run(TxStoreApplication.class, args);
    }

}

新建Model

package: cn.com.hohistar.cloud.store.model
class: StoreMaster

代码:

@Data
@AllArgsConstructor
@NoArgsConstructor
@Entity
public class StoreMaster {

    @Id
    @GeneratedValue(strategy=GenerationType.AUTO)
    private Integer id;

    @NotNull
    private String product;

    private Integer allCount;

    private Integer orderId;
}

数据访问接口

package: cn.com.hohistar.cloud.store.repository
interface: StoreMasterRepos

代码:

@Repository
public interface StoreMasterRepos extends JpaRepository<StoreMaster, Integer> {
}

业务类:

package: cn.com.hohistar.cloud.store.biz
class: StoreMasterBiz

代码：

@Service
public class StoreMasterBiz {

    @Autowired
    private StoreMasterRepos storeMasterRepos;

    @Transactional
    public void handlOrder(String prod, Integer orderId, Integer allCount) {

        if ("jack".equals(prod)) {
            throw new RuntimeException("The Jack is not allowed.");
        }

        StoreMaster store = new StoreMaster();
        store.setProduct(prod);
        store.setOrderId(orderId);
        store.setAllCount(allCount);

        storeMasterRepos.save(store);
    }
}

Api接口类

package: cn.com.hohistar.cloud.store.api
class: StoreMasterApi

代码:

@RestController
public class StoreMasterApi {

    @Autowired
    private StoreMasterBiz storeMasterBiz;


    @GetMapping("/handleOrder")
    public String handleOrder(@RequestParam("prod") String prod, @RequestParam("orderId") Integer orderId, @RequestParam("count") Integer count) {

        storeMasterBiz.handlOrder(prod, orderId, count);

        return "ok";
    }
}

配置文件

application.yml

server:
  port: 8082

logging:
  level:
    com.example.demo: DEBUG


spring:
  application:
    name: cloud-store-service
  datasource:
    driverClassName: org.h2.Driver
    url: jdbc:h2:./hohistar-store
    username: sa
    password:
  jpa:
    database: H2
    generate-ddl: true
    show-sql: true
    hibernate:
      ddl-auto: create-drop
  h2:
    console:
      enabled: true
      path: /api/h2
      settings:
        web-allow-others: true

下一步

下一篇文章