SpringBoot--多模块开发

蔚落 2022-05-22 05:57 270阅读 0赞

目录结构：

![70][]

实现步骤：

1.创建springboot项目--spring-boot-demo。

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>com.cxb</groupId>
       <artifactId>spring-boot-demo</artifactId>
       <version>0.0.1-SNAPSHOT</version>
    
       <modules>
          <module>web</module>
          <module>persistence</module>
          <module>model</module>
       </modules>
    
       
       
       <packaging>pom</packaging>
    
       <name>spring-boot-demo</name>
       <description>Demo project for Spring Boot</description>
    
       <parent>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-parent</artifactId>
          <version>2.0.3.RELEASE</version>
          <relativePath/> 
       </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>
          <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-webflux</artifactId>
          </dependency>
    
          <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-test</artifactId>
             <scope>test</scope>
          </dependency>
          <dependency>
             <groupId>io.projectreactor</groupId>
             <artifactId>reactor-test</artifactId>
             <scope>test</scope>
          </dependency>
       </dependencies>
    
    </project>

创建模块web：

![70 1][]

![70 2][]

一直next，填好模块名称即可。

web模块的目录结构：

![70 3][]

这里的web.xml文件是为了打成war时候添加的。

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">
        <parent>
            <artifactId>spring-boot-demo</artifactId>
            <groupId>com.cxb</groupId>
            <version>0.0.1-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>web</artifactId>
    
        
        <packaging>war</packaging>
    
        
        
        
        <dependencies>
            
            <dependency>
                <groupId>com.cxb</groupId>
                <version>0.0.1-SNAPSHOT</version>
                <artifactId>persistence</artifactId>
            </dependency>
        </dependencies>
    
        
        <build>
            
            <defaultGoal>compile</defaultGoal>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                    
                    <configuration>
                        <mainClass>springbootdemo.SpringBootDemoApplication</mainClass>
                    </configuration>
                </plugin>
            </plugins>
        </build>
    
    </project>

package springbootdemo.config;
    
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.web.reactive.function.server.RequestPredicates;
    import org.springframework.web.reactive.function.server.RouterFunction;
    import org.springframework.web.reactive.function.server.RouterFunctions;
    import org.springframework.web.reactive.function.server.ServerResponse;
    import reactor.core.publisher.Flux;
    import springbootdemo.model.User;
    import springbootdemo.repository.UserRepository;
    
    import java.util.Collection;
    
    /**
     *  路由器函数配置
     * Created by 81046 on 2018-06-16
     */
    @Configuration
    public class RouterFunctionConfiguration {
    
        /**
         * Servlet
         *      请求接口：ServletRequest或者HttpServletRequest
         *      响应接口：ServletResponse或者HttpServletResponse
         *  Spring 5.0 重新定义了服务请求和响应接口
         *      请求接口：ServletRequest
         *      响应接口：ServletResponse
         *  即可支持Servlet 规范，也可以支持自定义，比如 Netty （Web Server）
         *
         *  以本例：
         *      定义GET请求，并且返回所有的用户对象 URI：/user/findAll
         *      Flux 是0-N个对象集合
         *      Mono 是0-1个对象集合
         *      Reactive 中的Flux 或者 Mono 它是异步处理 （非阻塞）
         *      集合对象基本上是同步处理 （阻塞）
         *      Flux 或者 Mono 都是 Publisher
         */
        @Bean
        public RouterFunction<ServerResponse> userFindAll(UserRepository userRepository){
            return RouterFunctions.route(RequestPredicates.GET("/user/list"),
                    request -> {
                        //返回所有的用户
                        Collection<User> users = userRepository.findAll();
                        Flux<User> userFlux = Flux.fromIterable(users);
                        return ServerResponse.ok().body(userFlux,User.class);
                    });
        }
    }

package springbootdemo.controller;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.*;
    import springbootdemo.model.User;
    import springbootdemo.repository.UserRepository;
    
    import java.util.Collection;
    
    /**
     * Created by 81046 on 2018-06-16
     */
    @RestController
    @RequestMapping("/user")
    //RestController 等价于controller和responseBody
    public class UserController {
    
        private final UserRepository userRepository;
    
        /**
         *  这里是采用构造器的注入方式注入userRepository
         *  好处是提前初始化，不能修改
         *  @Autowired 可写可不写
         */
        @Autowired
        public UserController(UserRepository userRepository){
            this.userRepository=userRepository;
        }
    
        /**
         *  http://localhost:8080/user/save?name=小石潭记
         * @param name
         * @return
         */
        @PostMapping("/save")
        public User save(@RequestParam String name){
            User user = new User();
            user.setName(name);
            if (userRepository.save(user)){
                System.out.println("保存对象成功：" + user);
            }
            return user;
        }
    
        @GetMapping("/list")
        public Collection<User> list(){
            return userRepository.findAll();
        }
    
    }

package springbootdemo;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    
    @SpringBootApplication
    public class SpringBootDemoApplication {
    
       public static void main(String[] args) {
          SpringApplication.run(SpringBootDemoApplication.class, args);
       }
    }

这里web模块就完成了，注意该模块需要依赖其他模块的文件，依赖在该模块pom.xml文件中。

多模块就是为了职责分明，web模块只做web端的访问，model模块就是用来管理实体类的，persistence模块就是管理数据库打交道的。

接下来介绍model模块和persistence模块。

创建模板的方式和前面的web模块一样。

model模块目录结构：

![70 4][]

pom.xml文件：

package springbootdemo.model;
    
    /**
     * Created by 81046 on 2018-06-16
     */
    public class User {
        private int id;
        private String name;
    
        public int getId() {
            return id;
        }
    
        public void setId(int id) {
            this.id = id;
        }
    
        public String getName() {
            return name;
        }
    
        public void setName(String name) {
            this.name = name;
        }
    
        public User() {
        }
    
        @Override
        public String toString() {
            return "User{" +
                    "id=" + id +
                    ", name='" + name + '\'' +
                    '}';
        }
    }

persistence模块目录结构：

![70 5][]

pom.xml文件：

package springbootdemo.repository;
    
    import org.springframework.stereotype.Repository;
    import springbootdemo.model.User;
    
    import java.util.Collection;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentMap;
    import java.util.concurrent.atomic.AtomicInteger;
    
    /**
     * Created by 81046 on 2018-06-16
     */
    @Repository
    public class UserRepository {
    
        /**
         * 采用内存型的存储方式-->Map
         */
        private final ConcurrentMap<Integer,User> repository = new ConcurrentHashMap<>();
    
        /**
         * id生成器
         */
        private final static AtomicInteger idGennerator = new AtomicInteger();
    
        /**
         * 保存用户对象
         */
        public boolean save(User user){
            int id = idGennerator.incrementAndGet();
            user.setId(id);
            return repository.put(id,user) == null ;
        }
    
        /**
         * 查询所有的用户
         * @return
         */
        public Collection<User> findAll(){
            return repository.values();
        }
    }

**这里就完成了三个模块的实现，注意每个模块的包名保持一致，这里包名全是springbootdemo，然后在下面创建具体的包即可。**

再介绍一下打包的方式：

1.jar     在该文件的位置执行cmd     执行mvn -Dmaven.test.skip -U clean package

![70 6][]

![70 7][]

![70 8][]

这里jar的方式介绍完了，war只是将pom文件中的jar改成war

![70 9][]

![70 10][]

[70]: /images/20220522/49c742b8841e4308a11a5b9cf034c02d.png
[70 1]: /images/20220522/d76b2fa4c49a4db4a3dc698bad99b9db.png
[70 2]: /images/20220522/7ccbfbc3337144c99e4fc0ad7782543d.png
[70 3]: /images/20220522/34d80ac063ab4259b6d34967763b34f4.png
[70 4]: /images/20220522/03bdaf5db4444469a8ce4d6bb24baf02.png
[70 5]: /images/20220522/347f3d6b9b194e54b449789e167a6478.png
[70 6]: /images/20220522/08ef2df792314fef8fdbada7cf11cbfd.png
[70 7]: /images/20220522/b764479da07c4546b1eb6f067cb971d5.png
[70 8]: /images/20220522/d23637b203684dc38fdd05c7d6d36cea.png
[70 9]: /images/20220522/bf703091032f4d95a7085978ab081695.png
[70 10]: /images/20220522/604026083fff42e0973d16ad809278ca.png