WebFlux 图书管理系统

Author: liqiangqiang

springboot-webflux-10-book-manage-sys/pom.xml

@@ -0,0 +1,60 @@
+<?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>
+    <description>WebFlux 实战图书管理系统</description>
+
+    <groupId>demo.springboot</groupId>
+    <artifactId>springboot-webflux-10-book-manage-sys</artifactId>
+    <version>1.0</version>
+    <packaging>jar</packaging>
+
+  <!-- Spring Boot 启动父依赖 -->
+  <parent>
+    <groupId>org.springframework.boot</groupId>
+    <artifactId>spring-boot-starter-parent</artifactId>
+    <version>2.0.1.RELEASE</version>
+  </parent>
+
+    <properties>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
+        <java.version>1.8</java.version>
+    </properties>
+
+  <dependencies>
+
+    <!-- Spring Boot Web Flux 依赖 -->
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter-webflux</artifactId>
+    </dependency>
+
+    <!-- Spring Boot 响应式 MongoDB 依赖 -->
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter-data-mongodb-reactive</artifactId>
+    </dependency>
+
+    <!-- 模板引擎 Thymeleaf 依赖 -->
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter-thymeleaf</artifactId>
+    </dependency>
+
+    <!-- Spring Boot Test 依赖 -->
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter-test</artifactId>
+      <scope>test</scope>
+    </dependency>
+
+    <!-- Junit -->
+    <dependency>
+      <groupId>junit</groupId>
+      <artifactId>junit</artifactId>
+      <version>4.12</version>
+    </dependency>
+  </dependencies>
+
+</project>

springboot-webflux-10-book-manage-sys/src/main/java/demo/springboot/WebApplication.java

@@ -0,0 +1,16 @@
+package demo.springboot;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+/**
+ * Spring Boot 应用启动类
+ *
+ * Created by bysocket
+ */
+@SpringBootApplication
+public class WebApplication {
+    public static void main(String[] args) {
+        SpringApplication.run(WebApplication.class, args);
+    }
+}

springboot-webflux-10-book-manage-sys/src/main/java/demo/springboot/dao/BookRepository.java

@@ -0,0 +1,10 @@
+package demo.springboot.dao;
+
+import demo.springboot.domain.Book;
+import org.springframework.data.mongodb.repository.ReactiveMongoRepository;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface BookRepository extends ReactiveMongoRepository<Book, Long> {
+
+}

springboot-webflux-10-book-manage-sys/src/main/java/demo/springboot/domain/Book.java

@@ -0,0 +1,68 @@
+package demo.springboot.domain;
+
+import org.springframework.data.annotation.Id;
+
+import java.io.Serializable;
+
+/**
+ * Book 实体类
+ *
+ * Created by bysocket
+ */
+public class Book implements Serializable {
+
+    private static final long serialVersionUID = 8033624715179323397L;
+
+    /**
+     * 编号
+     */
+    @Id
+    private Long id = 0L;
+
+    /**
+     * 书名
+     */
+    private String name;
+
+    /**
+     * 作者
+     */
+    private String writer;
+
+    /**
+     * 简介
+     */
+    private String introduction;
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getWriter() {
+        return writer;
+    }
+
+    public void setWriter(String writer) {
+        this.writer = writer;
+    }
+
+    public String getIntroduction() {
+        return introduction;
+    }
+
+    public void setIntroduction(String introduction) {
+        this.introduction = introduction;
+    }
+}

springboot-webflux-10-book-manage-sys/src/main/java/demo/springboot/service/BookService.java

@@ -0,0 +1,45 @@
+package demo.springboot.service;
+
+import demo.springboot.domain.Book;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+/**
+ * Book 业务接口层
+ *
+ * Created by bysocket
+ */
+public interface BookService {
+    /**
+     * 获取所有 Book
+     */
+    Flux<Book> findAll();
+
+    /**
+     * 新增 Book
+     *
+     * @param book {@link Book}
+     */
+    Mono<Book> insertByBook(Book book);
+
+    /**
+     * 更新 Book
+     *
+     * @param book {@link Book}
+     */
+    Mono<Book> update(Book book);
+
+    /**
+     * 删除 Book
+     *
+     * @param id 编号
+     */
+    Mono<Void> delete(Long id);
+
+    /**
+     * 获取 Book
+     *
+     * @param id 编号
+     */
+    Mono<Book> findById(Long id);
+}

springboot-webflux-10-book-manage-sys/src/main/java/demo/springboot/service/impl/BookServiceImpl.java

@@ -0,0 +1,50 @@
+package demo.springboot.service.impl;
+
+import demo.springboot.dao.BookRepository;
+import demo.springboot.domain.Book;
+import demo.springboot.service.BookService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+/**
+ * Book 业务层实现
+ *
+ * Created by bysocket
+ */
+@Component
+public class BookServiceImpl implements BookService {
+
+    private final BookRepository bookRepository;
+
+    @Autowired
+    public BookServiceImpl(BookRepository bookRepository) {
+        this.bookRepository = bookRepository;
+    }
+
+    @Override
+    public Flux<Book> findAll() {
+        return bookRepository.findAll();
+    }
+
+    @Override
+    public Mono<Book> insertByBook(Book book) {
+        return bookRepository.save(book);
+    }
+
+    @Override
+    public Mono<Book> update(Book book) {
+        return bookRepository.save(book);
+    }
+
+    @Override
+    public Mono<Void> delete(Long id) {
+        return bookRepository.deleteById(id);
+    }
+
+    @Override
+    public Mono<Book> findById(Long id) {
+        return bookRepository.findById(id);
+    }
+}

springboot-webflux-10-book-manage-sys/src/main/java/demo/springboot/web/BookController.java

@@ -0,0 +1,89 @@
+package demo.springboot.web;
+
+import demo.springboot.domain.Book;
+import demo.springboot.service.BookService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
+import org.springframework.ui.Model;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * Book 控制层
+ * <p>
+ * Created by bysocket
+ */
+@Controller
+@RequestMapping(value = "/book")
+public class BookController {
+
+    private static final String BOOK_FORM_PATH_NAME = "bookForm";
+    private static final String BOOK_LIST_PATH_NAME = "bookList";
+    private static final String REDIRECT_TO_BOOK_URL = "redirect:/book";
+
+    @Autowired
+    BookService bookService;
+
+    /**
+     * 获取 Book 列表
+     * 处理 "/book" 的 GET 请求，用来获取 Book 列表
+     */
+    @RequestMapping(method = RequestMethod.GET)
+    public String getBookList(final Model model) {
+        model.addAttribute("bookList", bookService.findAll());
+        return BOOK_LIST_PATH_NAME;
+    }
+
+    /**
+     * 获取创建 Book 表单
+     */
+    @RequestMapping(value = "/create", method = RequestMethod.GET)
+    public String createBookForm(final Model model) {
+        model.addAttribute("book", new Book());
+        model.addAttribute("action", "create");
+        return BOOK_FORM_PATH_NAME;
+    }
+
+    /**
+     * 创建 Book
+     * 处理 "/book/create" 的 POST 请求，用来新建 Book 信息
+     * 通过 @ModelAttribute 绑定表单实体参数，也通过 @RequestParam 传递参数
+     */
+    @RequestMapping(value = "/create", method = RequestMethod.POST)
+    public String postBook(@ModelAttribute Book book) {
+        bookService.insertByBook(book);
+        return REDIRECT_TO_BOOK_URL;
+    }
+
+    /**
+     * 获取更新 Book 表单
+     * 处理 "/book/update/{id}" 的 GET 请求，通过 URL 中的 id 值获取 Book 信息
+     * URL 中的 id ，通过 @PathVariable 绑定参数
+     */
+    @RequestMapping(value = "/update/{id}", method = RequestMethod.GET)
+    public String getUser(@PathVariable Long id, final Model model) {
+        model.addAttribute("book", bookService.findById(id));
+        model.addAttribute("action", "update");
+        return BOOK_FORM_PATH_NAME;
+    }
+
+    /**
+     * 更新 Book
+     * 处理 "/update" 的 PUT 请求，用来更新 Book 信息
+     */
+    @RequestMapping(value = "/update", method = RequestMethod.POST)
+    public String putBook(@ModelAttribute Book book) {
+        bookService.update(book);
+        return REDIRECT_TO_BOOK_URL;
+    }
+
+    /**
+     * 删除 Book
+     * 处理 "/book/{id}" 的 GET 请求，用来删除 Book 信息
+     */
+    @RequestMapping(value = "/delete/{id}", method = RequestMethod.GET)
+    public String deleteBook(@PathVariable Long id) {
+        bookService.delete(id);
+        return REDIRECT_TO_BOOK_URL;
+    }
+
+}

springboot-webflux-10-book-manage-sys/src/main/resources/application.properties

@@ -0,0 +1,5 @@
+spring.data.mongodb.host=localhost
+spring.data.mongodb.database=admin
+spring.data.mongodb.port=27017
+spring.data.mongodb.username=admin
+spring.data.mongodb.password=admin

springboot-webflux-10-book-manage-sys/src/main/resources/static/css/default.css

@@ -0,0 +1,2 @@
+/* contentDiv */
+.contentDiv {padding:20px 60px;}