一、构建 microservicecloud-provider-dept-8001 部门微服务提供者 Module
（1）、新建microservicecloud-provider-dept-8001模块
（2）、pom.xml文件
<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>
<parent>
<groupId>cn.smilexl.springcloud</groupId>
<artifactId>microservicecloud</artifactId>
<version>0.0.1-SNAPSHOT</version>
</parent>
<artifactId>microservicecloud-provider-dept-8001</artifactId>
<dependencies>
<!-- 引入自己定义的api通用包，可以使用Dept部门Entity -->
<dependency>
<groupId>cn.smilexl.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>
</dependencies>
</project>
（3）、application.yml文件
server:
port: 8001
mybatis:
# config-location: classpath:mybatis/mybatis.cfg.xml # mybatis配置文件所在路径
type-aliases-package: cn.smilexl.springcloud.entities # 所有Entity别名类所在包
mapper-locations: classpath:mapper/**/*.xml # mapper映射文件
spring:
application:
name: microservicecloud-dept # 微服务名
datasource:
type: com.alibaba.druid.pool.DruidDataSource # 当前数据源操作类型
driver-class-name: org.gjt.mm.mysql.Driver # mysql驱动包
url: jdbc:mysql://47.99.218.123:3306/clouddb01 # 数据库名称
username: root
password: 123456
dbcp2:
min-idle: 5 # 数据库连接池的最小维持连接数
initial-size: 5 # 初始化连接数
max-total: 5 # 最大连接数
max-wait-millis: 200 # 等待连接获取的最大超时时间
（4）、Mysql创建部门数据库脚本
DROP DATABASE IF EXISTS cloudDB01;
CREATE DATABASE cloudDB01 CHARACTER SET UTF8;
USE cloudDB01;
CREATE TABLE `dept` (
`deptno` bigint(20) NOT NULL AUTO_INCREMENT,
`dname` varchar(60) DEFAULT NULL,
`db_source` varchar(60) DEFAULT NULL,
PRIMARY KEY (`deptno`)
) ENGINE=InnoDB AUTO_INCREMENT=8 DEFAULT CHARSET=utf8;
INSERT INTO `dept` VALUES ('1', '开发部', 'clouddb01');
INSERT INTO `dept` VALUES ('2', '人事部', 'clouddb01');
INSERT INTO `dept` VALUES ('3', '财务部', 'clouddb01');
INSERT INTO `dept` VALUES ('4', '市场部', 'clouddb01');
INSERT INTO `dept` VALUES ('5', '运维部', 'clouddb01');
INSERT INTO `dept` VALUES ('6', '资讯部', 'clouddb01');
（5）、DeptDao.java 部门接口
package cn.smilexl.springcloud.dao;
import java.util.List;
import org.apache.ibatis.annotations.Mapper;
import cn.smilexl.springcloud.entities.Dept;
@Mapper
public interface DeptDao {
//添加
public boolean addDept(Dept dept);
//根据id查询
public Dept findById(Long id);
//查询全部
public List<Dept> findAll();
}
（6）、工程src/main/resources/mybatis目录下新建mapper文件夹后在建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="cn.smilexl.springcloud.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>
（7）、DeptService.java 部门服务接口
package cn.smilexl.springcloud.service;
import java.util.List;
import cn.smilexl.springcloud.entities.Dept;
public interface DeptService {
//添加
public boolean addDept(Dept dept);
//根据id查询
public Dept findById(Long id);
//查询全部
public List<Dept> findAll();
}
（8）、DeptServiceImpl.java 部门服务接实现类
package cn.smilexl.springcloud.service.impl;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import cn.smilexl.springcloud.dao.DeptDao;
import cn.smilexl.springcloud.entities.Dept;
import cn.smilexl.springcloud.service.DeptService;
@Service
public class DeptServiceImpl implements DeptService{
@Autowired
private DeptDao deptDao;
@Override
public boolean addDept(Dept dept) {
return deptDao.addDept(dept);
}
@Override
public Dept findById(Long id) {
return deptDao.findById(id);
}
@Override
public List<Dept> findAll() {
return deptDao.findAll();
}
}
（9）、DeptServiceImpl.java 部门微服务提供者REST
package cn.smilexl.springcloud.controller;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;
import cn.smilexl.springcloud.entities.Dept;
import cn.smilexl.springcloud.service.DeptService;
@RestController
public class DeptController {
@Autowired
private DeptService deptService;
// 添加
@PostMapping("/dept/add")
public Boolean addDept(Dept dept) {
return deptService.addDept(dept);
}
// 根据id查询
@GetMapping("/dept/get/{id}")
public Dept findById(@PathVariable("id") Long id) {
return deptService.findById(id);
}
// 查询全部
@GetMapping("/dept/list")
public List<Dept> findAll() {
return deptService.findAll();
}
}
（10）、DeptProvider8001_App.java 主启动类
package cn.smilexl.springcloud;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class DeptProvider8001_App {
public static void main(String[] args) {
SpringApplication.run(DeptProvider8001_App.class, args);
}
}
（11）、启动测试*
（12）、最终工程展现
网友评论