搭建微服务基础环境011.创建父工程,用于聚合其他微服务模块1.1创建父项目
说明:我们先创建一个父项目,该父项目会去管理多个微服务模块(module),如下:
(1)File-New-Project-Maven,选择如下:
(2)输入项目名称等信息,然后next
(3)选择Maven,然后Finish
1.2项目设置
(1)File-Settings-Editor-File Encodings,将编码改为UTF-8,点击Apply
(2)Settings-Build,Execution,Deployment-Compiler-Java Compiler,将项目的编译版本改为8,点击OK
(3)删除父项目的src目录
(4)配置父项目的pom.xml,配置各个依赖版本
4.0.0 com.li.springcloud E-Commerce-Center 1.0-SNAPSHOT pom E-Commerce-Center http://www.example.com UTF-8 1.8 1.8 4.12 2.17.2 1.18.20 5.1.47 1.1.17 2.2.0 org.springframework.boot spring-boot-dependencies 2.2.2.RELEASE pom import org.springframework.cloud spring-cloud-dependencies Hoxton.SR1 pom import com.alibaba.cloud spring-cloud-alibaba-dependencies 2.1.0.RELEASE pom import mysql mysql-connector-java ${mysql.version} com.alibaba druid ${druid.version} org.mybatis.spring.boot mybatis-spring-boot-starter ${mybatis.spring.boot.version} org.apache.logging.log4j log4j ${log4j.version} junit junit ${junit.version} org.projectlombok lombok ${lombok.version} <!---->
1.3dependencyManagement说明
Maven 使用 dependencyManagement 元素来提供了一种管理依赖版本号的方式。通常在packaging为pom的项目中使用该元素
使用 pom.xml 中的 dependencyManagement 元素能让所有子项目引用一个依赖 ,Maven 会沿着父子层次向 上走,直到找到一个拥有dependencyManagement元素的项目,然后它就会使用这个dependencyManagement 元素中指定的版本号。
好处∶如果有多个子项目都引用同一样依赖,则可以避免在每个使用的子项目里都声明一个版本号,当升级或切换到另一个版本时,只需要在顶层父容器里更新,而不需要分别在子项目中修改;另外如果某子项目需要另外的版本时,子项目只需要声明 version 就可。
dependencyManagement 里只是声明依赖,并不实现引入,因此子项目需要显示的声明需要用的依赖。
如果不在子项目中声明依赖,是不会从父项目中继承下来的;只有在子项目中写了该依赖项,并且没有指定具体版本时,才会从父项目中继承该项,并且version 和 scope 都读取自父 pom。作用范围一览图:
如果子项目中指定了版本号,那么会使用子项目中指定的 jar 版本
2.创建会员中心微服务模块-service provider2.1需求分析
- 通过浏览器可以获取会员信息(通过会员中心微服务模块)
- 可以通过postman进行测试查询和添加数据
2.2思路分析
- 创建Module & 完成配置
- 创建数据库 & 表
- 创建 entity-dao/mapper.xml-service-controller
- 完成测试
2.3实现步骤2.3.1创建Module&完成配置
(1)创建名为 member-service-provider-10000
的微服务模块,提供会员服务。member代表会员服务,service-provider代表这是一个提供服务的模块,10000代表端口。
依次选择:File-New-Module
(2)选择Maven,直接下一步
(3)idea会自动识别父工程,如下,然后点击Finish
(4)如果创建成功,父项目会自动聚合子模块。父项目的pom.xml文件:
(5)修改member-service-provider-10000子模块的pom.xml,加入相关依赖
E-Commerce-Center com.li.springcloud 1.0-SNAPSHOT 4.0.0 member-service-provider-10000 8 8 org.springframework.boot spring-boot-starter-web org.springframework.boot spring-boot-starter-actuator org.mybatis.spring.boot mybatis-spring-boot-starter com.alibaba druid-spring-boot-starter 1.1.17 mysql mysql-connector-java org.springframework.boot spring-boot-starter-jdbc org.projectlombok lombok org.springframework.boot spring-boot-starter-test
(6)在member-service-provider-10000
子模块中创建resources/application.yml文件
server: port: 10000spring: application: name: member-service-provider-10000 #配置应用的名称 datasource: type: com.alibaba.druid.pool.DruidDataSource #指定数据源类型 url: jdbc:mysql://localhost:3306/e_commerce_center_db?useSSL=true&useUnicode=true&characterEncoding=UTF-8 username: root password: 123456mybatis: mapper-locations: classpath:mapper/*.xml #指定mapper.xml文件位置 type-aliases-package: com.li.springcloud.entity #实体类的包,这样通过类名就可以引用
(7)启动子模块的主程序:
package com.li.springcloud;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;/** * @author 李 * @version 1.0 */@SpringBootApplicationpublic class MemberApplication { public static void main(String[] args) { SpringApplication.run(MemberApplication.class, args); }}
测试结果:运行成功。
2.3.2创建数据库&表
-- 创建数据库CREATE DATABASE e_commerce_center_dbUSE e_commerce_center_db-- 创建member表CREATE TABLE `member`(`id` BIGINT NOT NULL AUTO_INCREMENT COMMENT 'id',`name` VARCHAR(64) COMMENT '用户名',`pwd` CHAR(32) COMMENT '密码',`mobile` VARCHAR(20) COMMENT '手机号码',`email` VARCHAR(64) COMMENT '邮箱',`gender` TINYINT COMMENT '性别', PRIMARY KEY (id));-- 测试数据INSERT INTO member VALUES(NULL, 'smith', MD5('123'), '123456789000', 'smith@sohu.com', 1);SELECT * FROM member;
2.3.3业务实现2.3.3.1utils层
Result工具类,用于同一返回的数据类型
package com.li.springcloud.utils;/** * @author 李 * @version 1.0 返回结果对象,以json格式返回 */public class Result { private String code;//状态码 200-success 400-fail private String msg;//状态说明 private T data;//返回的数据,使用泛型 public Result() { } public Result(T data) { this.data = data; } //返回需要的result对象,表示成功 public static Result success() { Result result = new Result(); result.setCode("200"); result.setMsg("success"); return result; } //返回成功的result对象,表示成功,同时携带数据 //如果需要在static方法中使用泛型,需要在static关键字后添加 public static Result success(T data) { Result result = new Result(data); result.setCode("200"); result.setMsg("success"); return result; } //返回成功的result对象,表示成功,同时携带数据和自定义msg public static Result success(String msg, T data) { Result result = new Result(data); result.setCode("200"); result.setMsg(msg); return result; } //返回需要的result对象-表示失败 //因为失败的原因有很多中,因此直接将其作为参数传进来 public static Result error(String code, String msg) { Result result = new Result(); result.setCode(code); result.setMsg(msg); return result; } //返回成功的result对象,表示失败,同时携带数据 public static Result error(String code, String msg, T data) { Result result = new Result(data); result.setCode(code); result.setMsg(msg); return result; } //getter、setter方法省略}
2.3.3.2entity层
Member实体类:
package com.li.springcloud.entity;import lombok.AllArgsConstructor;import lombok.Data;import lombok.NoArgsConstructor;/** * @author 李 * @version 1.0 */@Data@AllArgsConstructor@NoArgsConstructorpublic class Member { private Long id; private String name; private String pwd; private String mobile; private String email; private Integer gender;}
2.3.3.3dao层
Member对应的Dao层接口:MemberDao.java
package com.li.springcloud.dao;import com.li.springcloud.entity.Member;/** * @author 李 * @version 1.0 */public interface MemberDao { //根据id返回member对象 public Member queryMemberById(Long id); //添加member public int save(Member member);}
如果在这里不添加@Mapper注解,则需要在主程序中添加
@MapperScan(basePackages = {"com.li.springcloud.dao"})
在 resources/mapper/MemberMapper.xml 中实现接口:
SELECT * FROM `member` WHERE `id` = #{id} INSERT INTO `member` (`name`, `pwd`, `mobile`, `email`, `gender`) VALUES (#{name}, MD5(#{pwd}), #{mobile}, #{email}, #{gender});
测试类:
注意:测试类需要和主程序在同一个路径下,否则需要手动指定class
package com.li.springcloud;import .../** * @author 李 * @version 1.0 */@SpringBootTest@Slf4jpublic class MemberApplicationTest { //装配MemberDao @Resource private MemberDao memberDao; @Test //注意:引入的是 org.junit.jupiter.api.Test; public void queryMemberById() { Member member = memberDao.queryMemberById(1L); log.info("member={}", member); } @Test //引入的是 org.junit.jupiter.api.Test; public void save() { Member member = new Member(null, "牛魔王", "123456", "18077560000", "jack@qq.com", 1); int save = memberDao.save(member); log.info("受影响的行数={}", save); }}
queryMemberById()测试结果:
member=Member(id=1, name=smith, pwd=202cb962ac59075b964b07152d234b70, mobile=123456789000, email=smith@sohu.com, gender=1)
save()测试结果:
受影响的行数=1
2.3.3.4service层
MemberService接口:
package com.li.springcloud.service;import com.li.springcloud.entity.Member;/** * @author 李 * @version 1.0 */public interface MemberService { //根据id返回member public Member queryMemberById(Long id); //添加member public int save(Member member);}
MemberServiceImpl实现类:
package com.li.springcloud.service.impl;import .../** * @author 李 * @version 1.0 */@Servicepublic class MemberServiceImpl implements MemberService { @Resource private MemberDao memberDao; @Override public Member queryMemberById(Long id) { return memberDao.queryMemberById(id); } @Override public int save(Member member) { return memberDao.save(member); }}
测试类:
package com.li.springcloud;import .../** * @author 李 * @version 1.0 */@SpringBootTest@Slf4jpublic class MemberApplicationTest { //装配MemberService @Resource private MemberService memberService; @Test public void queryMemberById() { Member member = memberService.queryMemberById(3L); log.info("member={}", member); } @Test public void save() { Member member = new Member(null, "tomas", "hahah123", "0773-2345-678", "tomas@qq.com", 0); int save = memberService.save(member); log.info("受影响的行数={}", save); }}
queryMemberById()测试结果:
member=Member(id=3, name=jack, pwd=202cb962ac59075b964b07152d234b70, mobile=123456789000, email=smith@sohu.com, gender=1)
save()测试结果:
受影响的行数=1
2.3.3.5controller层
package com.li.springcloud.controller;import .../** * @author 李 * @version 1.0 */@Controller@Slf4jpublic class MemberController { @Resource private MemberService memberService; @PostMapping("/member/save") @ResponseBody public Result save(Member member) { int affected = memberService.save(member); if (affected > 0) { return Result.success("添加会员成功", affected); } else { return Result.error("401", "添加会员失败"); } } @GetMapping("/member/get/{id}") @ResponseBody public Result getMemberById(@PathVariable("id") Long id) { Member member = memberService.queryMemberById(id); if (member != null) { return Result.success("查询成功", member); } else { return Result.error("402", "Id=" + id + "用户不存在!"); } }}
2.3.4完成测试
(1)测试controller的save()方法
使用postman进行测试
返回结果:
数据成功插入表中:
(2)测试controller的getMemberById()方法
测试成功。
2.4注意事项和细节
如果前端是以json格式来发送数据的,需要在controller层的方法参数前使用@RequestBody,来将json数据封装成对应的Javabean。同时需要保证前端发送的http请求头中,Content-Type指定的是json格式。
如果前端是以表单或者参数提交的,则不需要@RequestBody
在进行springboot应用程序测试时,引入的JUnit是 org.junit.jupiter.api.Test 包的
在运行程序时,一定要确保你的 XxxMapper.xml文件被自动放到了 target 目录的 classes 指定的目录下