SpringCloud起步 搭建父工程
1、总体介绍
- 我们会使用一个Dept部门模块做一个微服务通用案例Consurmer消费者(Client)通过REST调用Provider提供者(Server)提供的服务
- 回忆Spring、SpringMVC、Mybatis等以往学习的知识
- Maven的分包模块架构复习
一个简单的Maven模块结构是这样的
–app-aperent:一个父项目(app-parent) 聚合很多子项目(app-util、aop-dao、app-web…)|-- pom.xml | |-- app-core ||-- pom.xml | |-- app-web ||-- pom.xml ....
一个父工程带着多个子Module子模块
- microservicecloud-api [封装的整体entity/接口/公共配置等]
- microservicecloud-provider-dept-8001 [服务提供者]
- microservicecloud-consumer-dept-80 [服务消费者]
- springcloud-eureka-7001[Eureka注册中心]
- …
1.1、springboot和springcloud版本的对应
2、SpringCloud版本选择
大版本说明
实际开发版本关系
使用最后的两个版本…
3、创建父工程maven
com.lemon.springcloud
删掉src文件 (在这里可以不需要)
导入依赖
<?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.lemon</groupId>
<artifactId>springcloud</artifactId>
<version>1.0-SNAPSHOT</version>
<modules>
<module>springcloud-api</module>
<module>springcloud-provider-dept-8001</module>
</modules>
<!--打包方式 pom-->
<packaging>pom</packaging>
<!--maven依赖版本声明-->
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.source>1.8</maven.compiler.source>
<maven.compiler.target>1.8</maven.compiler.target>
<junit.version>4.12</junit.version>
<lombok.version>1.16.18</lombok.version>
<log4j.version>1.2.17</log4j.version>
<logback-core.version>1.2.3</logback-core.version>
</properties>
<!--maven的管理 需要使用直接调用即可-->
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-alibaba-dependencies</artifactId>
<version>0.2.0.RELEASE</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<!--springcloud依赖-->
<!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-dependencies -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Greenwich.SR1</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<!--SpringBoot-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-dependencies</artifactId>
<version>2.1.4.RELEASE</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<!--数据库-->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.47</version>
</dependency>
<!--数据库数据源-->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.1.10</version>
</dependency>
<!--SpringBoot启动器-->
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>1.3.2</version>
</dependency>
<!--日志测试-->
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-core</artifactId>
<version>${logback-core.version}</version>
</dependency>
<!--Junit-->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>${junit.version}</version>
</dependency>
<!--Lombok-->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>${lombok.version}</version>
</dependency>
<!--Log4j-->
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>${log4j.version}</version>
</dependency>
</dependencies>
</dependencyManagement>
</project>
4、创建maven项目公共实体
springcloud-api结构图
创建部门数据库
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 DEFAULT CHARSET=utf8 COMMENT='部门表'
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());
INSERT INTO dept(dname,db_source) VALUES ('人事部',DATABASE());
引入lombok
<!--当前的Module自己需要的依赖,如果父依赖中已经配置版本,这里不需要写依赖版本-->
<dependencies>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
</dependencies>
创建Dept实体类
@Data//get 和 set
@NoArgsConstructor//无参构造
@Accessors(chain = true)//开启链式写法 例:new Dept().setid(1).setname("test")....
public class Dept implements Serializable {//Dept实体类 orm 类表关系映射
private Long deptno;//主键
private String dname;
//存在于哪个数据库的字段 ~ 微服务,一个服务对应一个数据库,同一个信息可能存在于不同的数据库
private String db_source;
//dname的有参构造
public Dept(String dname) {
this.dname = dname;
}
}
5、创建服务的提供者maven项目
springcloud-provider-dept-8001结构图
导入maven依赖
<!--服务提供者8001端口 maven项目-->
<artifactId>springcloud-provider-dept-8001</artifactId>
<dependencies>
<!--要拿到实体类,要配置api module-->
<dependency>
<groupId>com.lemon</groupId>
<artifactId>springcloud-api</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<!--Junit-->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
</dependency>
<!--Mysql驱动-->
<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>
<!--SpringBoot启动器-->
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
</dependency>
<!--SpringBoot web启动-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!--jetty 类似于tomcat 在此无实际作用-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jetty</artifactId>
</dependency>
<!--热部署工具-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-devtools</artifactId>
</dependency>
</dependencies>
配置8001提供者的application.yml
server:
port: 8001
#mybatis配置
mybatis:
type-aliases-package: com.lemon.springcloud.pojo
config-location: classpath:mybatis/mybatis-config.xml
mapper-locations: classpath:mybatis/mapper/*.xml
#spring的配置
spring:
application:
name: springcloud-provider-dept
#数据源的配置
datasource:
type: com.alibaba.druid.pool.DruidDataSource #数据源为druid
driver-class-name: com.mysql.jdbc.Driver #数据库驱动
url: jdbc:mysql://localhost:3306/springcloud1?useUnicode=true&characterEncoding=utf-8&servetTimeZone=Asia/Shanghai
username: root
password: 123456
创建DeptDao接口
@Mapper
public interface DeptDao {
//添加一个部门
public boolean addDept(Dept dept);
//根据id查出一个部门
public Dept queryById(Long id);
//查询所有部门信息
public List<Dept> queryAll();
}
在resource包下创建mybatis包
在mybtis/mapper包下 创建DeptMapper.xml 实现DeptDao方法的sql
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<!--核心配置文件-->
<mapper namespace="com.lemon.springcloud.dao.DeptDao">
<!--增加一个部门-->
<insert id="addDept" parameterType="Dept">
insert into dept (dname,db_source) values (#{dname},DATABASE())
</insert>
<!--根据id查询部门信息-->
<select id="queryById" resultType="Dept">
select * from dept where deptno = #{depono};
</select>
<!--查询所有的部门信息-->
<select id="queryAll" resultType="Dept">
select * from dept;
</select>
</mapper>
在mybtis下创建mybatis-config.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>
创建service包
DeptService接口
public interface DeptService {
//增加一个部门
boolean addDept(Dept dept);
//根据id查询部门信息
Dept queryById(Long id);
//查询所有的部门信息
List<Dept> queryAll();
}
DeptServiceImpl实现service的接口
@Service
public class DeptServiceImpl implements DeptService{
@Autowired
private DeptDao deptDao;
@Override
public boolean addDept(Dept dept) {
return deptDao.addDept(dept);
}
@Override
public Dept queryById(Long id) {
return deptDao.queryById(id);
}
@Override
public List<Dept> queryAll() {
return deptDao.queryAll();
}
}
创建controller包
DeptController类
//提供Restful服务
@RestController
public class DeptController{
@Autowired
private DeptService deptService;
@PostMapping("/dept/add")
public boolean addDept(Dept dept) {
return deptService.addDept(dept);
}
@RequestMapping("/dept/get/{id}")
public Dept queryById(@PathVariable("id") Long id) {
return deptService.queryById(id);
}
@RequestMapping("/dept/list")
public List<Dept> queryAll() {
return deptService.queryAll();
}
}
在当前项目 目录下创建DeptProvider_8001的启动类
//启动类
@SpringBootApplication
public class DeptProvider_8001 {
public static void main(String[] args) {
SpringApplication.run(DeptProvider_8001.class);
}
}
运行启动类,根据controller的路径测试
ok 完成 服务提供者的构建
6、Rest环境搭建,服务消费者
在父类项目下 创建maven项目
springcloud-consumer-dept-80 项目结构图
导入实体类相关依赖
<!--服务消费者 80端口 maven项目。访问直接localhost/xxx/xx-->
<artifactId>springcloud-consumer-dept-80</artifactId>
<!--实体类+web-->
<dependencies>
<dependency>
<groupId>com.lemon</groupId>
<artifactId>springcloud-api</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
</dependencies>
创建application.yml,配置端口为80
server:
port: 80
创建消费者controller/DeptConsumerController控制器,去提供者中拿
@RestController
public class DeptConsumerController {
// 理解:消费者,不该有service层
// RestTemplate.. 里面有方法供我们调用即可,注册到spring中
//(String url,实体, Class<T> responseType)
//提供多种便捷访问远程http服务的方法,简单的Restful服务模板
@Autowired
private RestTemplate restTemplate;
//声明提供者的localhost路径
private static final String rest_url_prefix = "http://localhost:8001";
//调用8001提供者的控制器=>根据id查询数据
@RequestMapping("/consumer/dept/get/{id}")
public Dept get(@PathVariable("id") Long id){
// restTemplate.注意和提供者的getmapping或postmapping保持一致
return restTemplate.getForObject(rest_url_prefix+"/dept/get/"+id,Dept.class);
}
//调用8001提供者的控制器=>添加方法
@RequestMapping("/consumer/dept/add")
public Boolean add(Dept dept){
// restTemplate.注意和提供者的getmapping或postmapping保持一致
return restTemplate.postForObject(rest_url_prefix+"/dept/add",dept,Boolean.class);
}
//调用8001提供者的控制器=>查询所有
@RequestMapping("/consumer/dept/list")
public List<Dept> queryall(){
// restTemplate.注意和提供者的getmapping或postmapping保持一致
return restTemplate.getForObject(rest_url_prefix+"/dept/list",List.class);
}
}
创建config文件包
config/ConfigBean
@Configuration
public class ConfigBean {//@Configuration=spring的 application.xml
@Bean
public RestTemplate getRestTemplate(){
return new RestTemplate();
}
}
创建DeptConsumer_80启动类
//消费者 运行方式80可省略 例:localhost/consumer/dept/list
@SpringBootApplication
public class DeptConsumer_80 {
public static void main(String[] args) {
SpringApplication.run(DeptConsumer_80.class,args);
}
}
启动8001提供者 和 80消费者端口 测试.
文件包
config/ConfigBean
@Configuration
public class ConfigBean {//@Configuration=spring的 application.xml
@Bean
public RestTemplate getRestTemplate(){
return new RestTemplate();
}
}
创建DeptConsumer_80启动类
//消费者 运行方式80可省略 例:localhost/consumer/dept/list
@SpringBootApplication
public class DeptConsumer_80 {
public static void main(String[] args) {
SpringApplication.run(DeptConsumer_80.class,args);
}
}
启动8001提供者 和 80消费者端口 测试.
[外链图片转存中…(img-RLkbnzDm-1734321044265)]
至此 服务消费者 调用 提供者 项目与搭建结束。
标签:Dept,SpringCloud,class,dept,spring,80,SpringCloud03,public,搭建 From: https://blog.csdn.net/xzh202206/article/details/144503911