父模块
1、首先新建一个普通的 maven 项目，作为父级目录，之后的服务提供者和服务消费者都放在该目录下。
2、导入相关依赖，供子模块引用
<!--集中维护依赖版本--> <properties> <junit.version>4.12</junit.version> <lombok.version>1.18.12</lombok.version> <log4j.version>1.2.17</log4j.version> <logback.version>1.2.3</logback.version> </properties> <dependencyManagement> <dependencies> <!--Cloud依赖--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>Greenwich.SR3</version> <type>pom</type> <scope>runtime</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>8.0.19</version> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>druid</artifactId> <version>1.1.21</version> </dependency> <!--Mybatis依赖--> <dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>2.1.1</version> </dependency> <!--Junit--> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>${junit.version}</version> </dependency> <!--工具类依赖--> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <version>${lombok.version}</version> </dependency> <!--日志--> <dependency> <groupId>log4j</groupId> <artifactId>log4j</artifactId> <version>${log4j.version}</version> </dependency> <dependency> <groupId>ch.qos.logback</groupId> <artifactId>logback-core</artifactId> <version>${logback.version}</version> </dependency> </dependencies> </dependencyManagement> 复制代码
一个父工程包含多个子 Module 模块：
springcloud-api：【封装的实体类接口】
springcloud-provider-dept-8001：【服务提供者】
springcloud-consumer-dept-80：【服务消费者】
服务提供者
数据库环境搭建
1、新建一个数据库
2、构建一个新表，可以通过 SQL 语句执行，也可以在 IDEA 中连接数据库建立新表，如下图所示：
其中 dbSource 字段用于存储数据库名称，在分布式环境下同一张表会存在多个数据库下，因为该字段用于区分数据。
3、新增数据
insert into dept (dpname, dbsource) values ('开发部',DATABASE()); insert into dept (dpname, dbsource) values ('人事部',DATABASE()); insert into dept (dpname, dbsource) values ('财务部',DATABASE()); insert into dept (dpname, dbsource) values ('市场部',DATABASE()); insert into dept (dpname, dbsource) values ('后勤部',DATABASE()); 复制代码
执行成功后，结果如下：
数据筹备
1、新建一个名为 springcloud-api 的普通 maven 项目
2、引用父模块的部分依赖
<dependencies> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> </dependency> </dependencies> 复制代码
3、新建 Dept 类，实现 Serializable 接口，将对象的内容进行流化，用于数据在网络中传输。
/** * chain 的中文含义是链式的，为一个布尔值， 如果为 true 生成的 set 方法返回 this， * 为 false 生成的 set 方法是 void 类型。 默认为 false，除非当 fluent 为 true时，chain 默认则为 true 。 */ @Data @NoArgsConstructor @Accessors(chain = true) public class Dept implements Serializable { private long deptId; private String dpName; private String dbSource; public Dept(String dpName) { this.dpName = dpName; } } 复制代码
服务提供
1、新建一个名为 springcloud-config-dept-8001 的普通 maven 项目
2、导入依赖
<dependencies> <!--我们需要拿到实体类，所以要配置api module--> <dependency> <groupId>com.msdn</groupId> <artifactId>springcloud-api</artifactId> <version>1.0-SNAPSHOT</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> <!--test--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-test</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <!--jetty--> <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> 复制代码
3、新建 mapper 文件，定义接口方法
@Mapper @Repository public interface DeptMapper { boolean addDept(Dept dept); Dept queryDept(long id); List<Dept> queryAll(); } 复制代码
4、在 resources 文件夹下存放 mapper 接口对应的 xml 文件
DeptMapper.xml
<?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.msdn.mapper.DeptMapper"> <select id="queryDept" resultType="Dept" parameterType="Long"> select * from springcloud.dept where deptId = #{id} </select> <insert id="addDept" parameterType="Dept"> insert into springcloud.dept (dpName,dbSource) values (#{dpName},DATABASE()) </insert> <select id="queryAll" resultType="Dept"> select * from springcloud.dept; </select> </mapper> 复制代码
5、配置数据库连接以及 mybatis 配置
server: port: 8001 spring: datasource: username: root password: mysql521695 url: jdbc:mysql://localhost:3306/springcloud?useUnicode=true&useSSL=true&serverTimezone=UTC&characterEncoding=utf-8 type: com.alibaba.druid.pool.DruidDataSource driver-class-name: com.mysql.cj.jdbc.Driver application: name: springcloud-config-dept-8001 mybatis: type-aliases-package: com.msdn.pojo mapper-locations: classpath:mybatis/mapper/*.xml 复制代码
6、定义 service 层
DeptService
public interface DeptService { boolean addDept(Dept dept); Dept queryDept(long id); List<Dept> queryAll(); } 复制代码
DeptServiceImpl
@Service public class DeptServiceImpl implements DeptService { @Autowired DeptMapper deptMapper; @Override public boolean addDept(Dept dept) { return deptMapper.addDept(dept); } @Override public Dept queryDept(long id) { return deptMapper.queryDept(id); } @Override public List<Dept> queryAll() { return deptMapper.queryAll(); } } 复制代码
7、定义 Controller 层
DeptController
@RestController public class DeptController { @Autowired DeptService deptService; @GetMapping("/dept/get/{id}") public Dept getDept(@PathVariable("id") long id){ Dept dept = deptService.queryDept(id); return dept; } @GetMapping("/dept/list") public List<Dept> queryAll(){ List<Dept> list = deptService.queryAll(); return list; } @PostMapping("/dept/add") public boolean addDept(@RequestBody Dept dept){ System.out.println(dept); return deptService.addDept(dept); } } 复制代码
8、构建执行类
@SpringBootApplication public class DeptProvider_8001 { public static void main(String[] args) { SpringApplication.run(DeptProvider_8001.class,args); } } 复制代码
整个项目的文件结构如下图所示：
启动该项目，在浏览器访问 http://localhost:8001/dept/list ，即可看到数据库表中的数据。
服务消费者
1、新建一个名为 springcloud-consumer-dept-80 的普通 maven 项目
2、导入依赖
<dependencies> <dependency> <groupId>com.msdn</groupId> <artifactId>springcloud-api</artifactId> <version>1.0-SNAPSHOT</version> </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> 复制代码
3、消费者不需要定义 service 层，可以直接定义 Controller 层来进行数据访问。由于 SpringCloud 中的 RestTemplate 需要注入到容器中，因此我们需要新建一个 config 类。
@Configuration public class MyConfig { @Bean public RestTemplate getRestTemplate(){ return new RestTemplate(); } } 复制代码
4、DeptConsumerController
@RestController public class DeptConsumerController { @Autowired RestTemplate restTemplate; private static final String REST_URL_PREFIX = "http://localhost:8001"; @RequestMapping("/consumer/dept/get/{id}") public Dept getDept(@PathVariable("id") long id) { return restTemplate.getForObject(REST_URL_PREFIX+"/dept/get/"+id,Dept.class); } @RequestMapping("/consumer/dept/list") public List<Dept> queryAll(){ return restTemplate.getForObject(REST_URL_PREFIX+"/dept/list",List.class); } @RequestMapping(name = "/consumer/dept/add") public boolean addDept(Dept dept){ return restTemplate.postForObject(REST_URL_PREFIX+"/dept/add",dept,Boolean.class); } } 复制代码
5、执行类 DeptConsumer_80
@SpringBootApplication public class DeptConsumer_80 { public static void main(String[] args) { SpringApplication.run(DeptConsumer_80.class,args); } } 复制代码
6、启动项目，在浏览器中输入 http://localhost/consumer/dept/list （80端口默认不必输入），即可查看数据。
问题记录
当访问 http://localhost/consumer/dept/add?dpName=123 报错，错误如下：
Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is org.springframework.web.client.HttpServerErrorException$InternalServerError: 500 null] with root cause 复制代码
解决方案：去 springcloud-config-dept-8001 项目中的 DeptController 类中修改 add 方法如下：
@PostMapping("/dept/add") public boolean addDept(@RequestBody Dept dept){ System.out.println(dept); return deptService.addDept(dept); } 复制代码
即在方法参数前加上 @RequestBody 注解。
