SpringCloud基础之部门服务提供者

SpringCloud基础之部门服务提供者

创建一个Maven Module

• 取名为microservicecloud-provider-dept-8001 打包的方式为jar. 如下图所示

pom文件如下

  4.0.0
  
    com.thc.springcloud
    mircroservicecloud
    0.0.1-SNAPSHOT
  
  microservicecloud-provider-dept-8001
  
  
		
		
			com.thc.springcloud
		    mircroservicecloud-api
			${project.version}
		  
		
		
			org.springframework.boot
			spring-boot-starter-actuator
		
		
		
			org.springframework.cloud
			spring-cloud-starter-eureka
		
		
			org.springframework.cloud
			spring-cloud-starter-config
		
		
			junit
			junit
		
		
			mysql
			mysql-connector-java
		
		
			com.alibaba
			druid
		
		
			ch.qos.logback
			logback-core
		
		
			org.mybatis.spring.boot
			mybatis-spring-boot-starter
		
		
			org.springframework.boot
			spring-boot-starter-jetty
		
		
			org.springframework.boot
			spring-boot-starter-web
		
		
			org.springframework.boot
			spring-boot-starter-test
		
		     
		
			org.springframework
			springloaded
		
		
			org.springframework.boot
			spring-boot-devtools
		
	
  

yml文件

在Resource目录下新建application.yml配置文件. 内容如下

server:
  port: 8001 #端口为8001
  
mybatis:
  config-location: classpath:mybatis/mybatis.cfg.xml        # mybatis配置文件所在路径
  type-aliases-package: com.thc.springcloud.entities    # 所有Entity别名类所在包
  mapper-locations:
  - classpath:mybatis/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://localhost:3306/cloudDB01              # 数据库名称
    username: root
    password: 123456
    dbcp2:
      min-idle: 5                                           # 数据库连接池的最小维持连接数
      initial-size: 5                                       # 初始化连接数
      max-total: 5                                          # 最大连接数
      max-wait-millis: 200                                  # 等待连接获取的最大超时时间

其中如下的为对外暴露的微服务的名称,这个名称非常的重要

spring:
   application:
    name: microservicecloud-dept 

• 创建mybatis.cfg.xml文件 根据yml中如下的关于mybatis的内容

mybatis:
  config-location: classpath:mybatis/mybatis.cfg.xml        # mybatis配置文件所在路径
  type-aliases-package: com.thc.springcloud.entities    # 所有Entity别名类所在包
  mapper-locations:
  - classpath:mybatis/mapper/**/*.xml                       # mapper映射文件

可以知道mybatis.cfg.xml文件是放在classpath下的mybatis文件夹下的 mybatis.cfg.xml的文件中的内容如下

执行sql脚本

DROP table if EXISTS cloudDB01;
create database cloudDB01 CHARACTER SET UTF8;
use cloudDB01;
create TABLE dept(
	deptno BIGINT not NULL PRIMARY KEY AUTO_INCREMENT,
	dname VARCHAR(60),
  db_source VARCHAR(60)

);
INSERT into dept(dname,db_source) VALUES('开发部',DATABASE());
INSERT into dept(dname,db_source) VALUES('人事部',DATABASE());
INSERT into dept(dname,db_source) VALUES('财务部',DATABASE());
INSERT into dept(dname,db_source) VALUES('市场部',DATABASE());
INSERT into dept(dname,db_source) VALUES('运维部',DATABASE());

其中DATABASE()为mysql的自带函数. 可以得到当前的使用的数据库名称.

创建dao层的DeptDao接口

创建com.thc.springcloud.dao包,在此包下建立DeptDao接口

@Mapper
public interface DeptDao {

	public boolean addDept(Dept dept);

	public Dept findById(Long id);

	public List findAll();
}

注意要在接口上写@Mapper注解

• 创建DeptMapper.xml 在工程的src/main/resource/mybatis目录下新建mapper文件夹,再创建DeptMapper.xml

	
		select deptno,dname,db_source from dept where deptno=#{deptno};
	
	
		select deptno,dname,db_source from dept;
	
	
		INSERT INTO dept(dname,db_source) VALUES(#{dname},DATABASE());
	

创建DeptService服务层接口

创建Service包下写DeptService 接口

package com.thc.springcloud.service;
public interface DeptService {
	public boolean add(Dept dept);
	public Dept get(Long id);
	public List list();
}

编写Service层实现类DeptServiceImpl

@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 list()
	{
		return dao.findAll();
	}
}

编写Controller层

package com.thc.springcloud.controller;
@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);
	}
	
	@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 list()
	{
		return service.list();
	}
}

在主要的包下创建主启动类

package com.thc.springcloud;
@SpringBootApplication
public class DeptProvider8001_App {
	public static void main(String[] args) {
		SpringApplication.run(DeptProvider8001_App.class, args);
	}
}

创建启动类的时候出现了编译的错误,报错提示要配置BuildPath. 经过网上的查找,最后的解决方案是删除本地Maven仓库中springframework文件夹下的所有jar,让其全部重新下载即可 项目完整的结构如下图

运行项目,进行测试

执行上一步中创建的main方法,即可启动项目. 在启动项目的时候,遇到了奇葩的报错,依次提示很多个jar包在maven仓库中没法找到. 一开始的解决方案是挨个去找这些jar包,重新删除去下载,但发现这是条不归路,并不管用 之后发现报错的提示下,都是显示的是springboot devtools相关的包,去依赖中把devtools相关的依赖删除,就能运行项目了 控制台有打印如下 Jetty started on port(s) 8001 (http/1.1) 说明了项目开启在了8001端口. 在浏览器中输入如下的地址 http://localhost:8001/dept/list 浏览器返回了如下的json,代表该接口正常.

[
    {
        "deptno": 1,
        "dname": "开发部",
        "db_source": "clouddb01"
    },
    {
        "deptno": 2,
        "dname": "人事部",
        "db_source": "clouddb01"
    },
    {
        "deptno": 3,
        "dname": "财务部",
        "db_source": "clouddb01"
    },
    {
        "deptno": 4,
        "dname": "市场部",
        "db_source": "clouddb01"
    },
    {
        "deptno": 5,
        "dname": "运维部",
        "db_source": "clouddb01"
    }
]