springboot+mybaties+maven聚合工程

小鱼儿 2022-04-01 06:00 267阅读 0赞

项目结构：  
![在这里插入图片描述][20181229111316950.png]  
microservicecloud是父工程，下面的三个是主体子工程。  
microservicecloud-api  
主要存放实体类或者配置类，后续可以将其打成jar，在其他子工程中引用。  
microservicecloud-dept-8888  
服务方，生产者，提供数据。  
microservicecloud-consumer-dept-80  
消费者，利用http调用服务方。

## 1 maven聚合工程的创建 ##

首先选择maven object创建父工程。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1MjM3NDYzMzU4Mw_size_16_color_FFFFFF_t_70]  
创建子工程选择maven model

## 2 microservicecloud-api ##

![在这里插入图片描述][20181229135715250.png]  
这里就只是一个实体类

package com.wuk.entity;
    
    import java.io.Serializable;
    
    import lombok.AllArgsConstructor;
    import lombok.Data;
    import lombok.NoArgsConstructor;
    import lombok.experimental.Accessors;
    public class Dept implements Serializable{ 
    	private long deptno;
    	private String dName;
    	//来自那个数据库，因为微服务架构可以一个服务对应一个数据库，同一个信息被存储到不同的数据库
    	private String db_source;
    }

## 2 microservicecloud-dept-8888 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1MjM3NDYzMzU4Mw_size_16_color_FFFFFF_t_70 1]  
pom.xml  
主要要引入的有：  
子工程，mysql，数据库连接池，日志，mybatis，服务器jetty，springboot的web start，热部署jar，可能还会有前端的引擎等

<dependencies>
    		
    		<dependency>
    			<groupId>com.wuk.springcloud</groupId>
    			<artifactId>microservicecloud-api</artifactId>
    			<version>${project.version}</version>
    		</dependency>
    		<dependency>
    			<groupId>junit</groupId>
    			<artifactId>junit</artifactId>
    		</dependency>
    		
    		<dependency>
    			<groupId>mysql</groupId>
    			<artifactId>mysql-connector-java</artifactId>
    		</dependency>
    		
    		<dependency>
    			<groupId>com.alibaba</groupId>
    			<artifactId>druid</artifactId>
    		</dependency>
    		
    		<dependency>
    			<groupId>ch.qos.logback</groupId>
    			<artifactId>logback-core</artifactId>
    		</dependency>
    		
    		<dependency>
    			<groupId>org.mybatis.spring.boot</groupId>
    			<artifactId>mybatis-spring-boot-starter</artifactId>
    		</dependency>
    		
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-jetty</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-web</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    		</dependency>
    		
    		<dependency>
    			<groupId>org.springframework</groupId>
    			<artifactId>springloaded</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-devtools</artifactId>
    		</dependency>
    	</dependencies>

application.yml  
涉及到的配置：  
mybatis的配置文件位置指示，对应实体类指示，mapper文件位置指示，数据库mysql连接配置，数据库连接池配置。

server:
      port: 8888
      
    mybatis:
      config-location: classpath:mybatis/mybatis.cfg.xml        # mybatis配置文件所在路径
      type-aliases-package: com.wuk.entity    # 所有Entity别名类所在包
      mapper-locations: 
      - classpath:mybatis/mapper/**/*.xml
       
    spring:
       application:
        name: microservicecloud-dept 
       datasource:
        type: com.alibaba.druid.pool.DruidDataSource            # 当前数据源操作类型
        driver-class-name: org.gjt.mm.mysql.Driver              # mysql驱动包
        url: jdbc:mysql://127.0.0.1:3306/cloudDB01              # 数据库名称
        username: root
        password: root
        dbcp2:
          min-idle: 5 # 数据库连接池的最小维持连接数
          initial-size: 5 # 初始化连接数
          max-total: 5 # 最大连接数
          max-wait-millis: 200 # 等待连接获取的最大超时时间

mybatis.cfg.xml

<?xml version="1.0" encoding="UTF-8" ?>
    <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd">
      
    <configuration>
     
      <settings>
       <setting name="cacheEnabled" value="true"/>
      </settings>
     
    </configuration>

DeptMapper.xml

<?xml version="1.0" encoding="UTF-8" ?>
    <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
     
    <mapper namespace="com.wuk.dao.DeptDao">
     
      <select id="findById" resultType="Dept" parameterType="Long">
      
       select deptno,dname,db_source from dept where deptno=#{deptno}; 
       
      </select>
      
      <select id="findAll" resultType="Dept">
      
       select deptno,dname,db_source from dept; 
       
      </select>
      
      <insert id="addDept" parameterType="Dept">
      
       INSERT INTO dept(dname,db_source) VALUES(#{dname},DATABASE());
       
      </insert>
      
    </mapper>

DeptDao.java

package com.wuk.dao;
    
    import java.util.List;
    
    import org.apache.ibatis.annotations.Mapper;
    
    import com.wuk.entity.Dept;
    
    @Mapper
    public interface DeptDao { 
    
    	public boolean addDept(Dept dept);
    
    	public Dept findById(Long id);
    
    	public List<Dept> findAll();
    }

DeptService.java

package com.wuk.service;
    
    import java.util.List;
    
    import com.wuk.entity.Dept;
    
    public interface DeptService { 
    
    	public boolean add(Dept dept);
    
    	public Dept get(Long id);
    
    	public List<Dept> list();
    
    }

DeptServiceImpl.java

package com.wuk.service.impl;
    
    import java.util.List;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    
    import com.wuk.dao.DeptDao;
    import com.wuk.entity.Dept;
    import com.wuk.service.DeptService;
    
    @Service
    public class DeptServiceImpl implements DeptService { 
    
    	@Autowired
    	private DeptDao dao;
    
    	@Override
    	public boolean add(Dept dept) { 
    		return dao.addDept(dept);
    	}
    
    	@Override
    	public Dept get(Long id) { 
    		return dao.findById(id);
    	}
    
    	@Override
    	public List<Dept> list() { 
    		return dao.findAll();
    	}
    }

DeptController.java

package com.wuk.controller;
    
    import java.util.List;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RequestBody;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestMethod;
    import org.springframework.web.bind.annotation.RestController;
    
    import com.wuk.entity.Dept;
    import com.wuk.service.DeptService;
    
    @RestController
    public class DeptController { 
    
    	 @Autowired
    	  private DeptService service;
    	  
    	  @RequestMapping(value="/dept/add",method=RequestMethod.POST)
    	  public boolean add(@RequestBody  Dept dept)
    	  { 
    	   return service.add(dept);
    	  }
    	  
    	  //@PathVariable 表示直接从url里面取数据 
    	  //@RequestBody 表示数据json
    	  @RequestMapping(value="/dept/get/{id}",method=RequestMethod.GET)
    	  public Dept get(@PathVariable("id") Long id)
    	  { 
    	   return service.get(id);
    	  }
    	  
    	  @RequestMapping(value="/dept/list",method=RequestMethod.GET)
    	  public List<Dept> list()
    	  { 
    	   return service.list();
    	  }
    }

## 3 microservicecloud-consumer-dept-80 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1MjM3NDYzMzU4Mw_size_16_color_FFFFFF_t_70 2]  
ConfigBean.java

package com.wuk.cfgbeans;
    
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.web.client.RestTemplate;
    
    @Configuration
    public class ConfigBean { 
    	/** * RestTemplate提供了多种便捷访问远程Http服务的方法， 是一种简单便捷的访问restful服务模板类，是Spring提供的用于访问Rest服务的客户端模板工具集 * @return */
    	@Bean
    	public RestTemplate getRestTemplate() { 
    		return new RestTemplate();
    	}
    
    }

DeptController\_Consumer.java

package com.wuk.controller;
    
    import java.util.List;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    import com.wuk.entity.Dept;
    
    @RestController
    public class DeptController_Consumer { 
    
    	private static final String REST_URL_PREFIX = "http://127.0.0.1:8888";
    
    	@Autowired
    	private RestTemplate restTemplate;
    
    	@RequestMapping(value = "/consumer/dept/add")
    	public boolean add(Dept dept) { 
    		return restTemplate.postForObject(REST_URL_PREFIX + "/dept/add", dept, Boolean.class);
    	}
    	
    	@RequestMapping(value = "/consumer/dept/get/{id}")
    	public Dept get(@PathVariable("id") Long id) { 
    		return restTemplate.getForObject(REST_URL_PREFIX + "/dept/get/" + id, Dept.class);
    	}
    
    	@SuppressWarnings("unchecked")
    	@RequestMapping(value = "/consumer/dept/list")
    	public List<Dept> list() { 
    		return restTemplate.getForObject(REST_URL_PREFIX + "/dept/list", List.class);
    	}
    }

代码如下：  
[代码案例][Link 1]

[20181229111316950.png]: /images/20220401/6d9cb8eb5d1d405a8b91cafd3e1103aa.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1MjM3NDYzMzU4Mw_size_16_color_FFFFFF_t_70]: /images/20220401/37f1e62bfe1141b0ac2c9551976be478.png
[20181229135715250.png]: /images/20220401/9dc4e83d63c44ee28108ea17945a7a8a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1MjM3NDYzMzU4Mw_size_16_color_FFFFFF_t_70 1]: /images/20220401/90549073a602459da7c4606eeb9a865e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1MjM3NDYzMzU4Mw_size_16_color_FFFFFF_t_70 2]: /images/20220401/ea2cde0335fc47a3976e1fbf5a779370.png
[Link 1]: https://download.csdn.net/download/wu2374633583/10894340