简介

  使用SpringBoot开发单体微服务，使用SpringCloud来协调治理各个微服务。SpringCloud为各个微服务之间提供服务注册、服务发现、配置管理、断路器、路由等功能。

搭建微服务模块

  在构建项目时，一般会定义一个父工程，统一对所有的子工程进行管理，并且在父工程中定义依赖版本，提供版本仲裁。类似SpringBoot中的 spring-boot-starter-parent 工程一样。

创建父工程

创建一个工程，首先配置好 pom.xml。

 4.0.0org.examplespringcloudservice1.0-SNAPSHOTpom8.0.251.0.311.3.01.2.3org.springframework.cloudspring-cloud-dependenciesDalston.SR1pomimportorg.springframework.bootspring-boot-dependencies1.5.9.RELEASEpomimportmysqlmysql-connector-java${mysql.version}com.alibabadruid${druid.version}org.mybatis.spring.bootmybatis-spring-boot-starter${mybatis.version}ch.qos.logbacklogback-core${logback.version}log4jlog4j${log4j.version}junitjunit${junit.version}test
 

创建公共子模块

pom.xml如下

 springcloudserviceorg.example1.0-SNAPSHOT4.0.0springcloudservice-apiorg.projectlomboklombok
 

随后将该子模块 mvn clean ===> mvn install 安装到本地库，供其他模块使用。

创建服务提供者模块

pom.xml 如下：

 springcloudserviceorg.example1.0-SNAPSHOT4.0.0springcloudservice-provider-user-8001org.examplespringcloudservice-api1.0-SNAPSHOTorg.springframework.bootspring-boot-starterorg.springframework.bootspring-boot-starter-weborg.springframework.bootspring-boot-starter-testmysqlmysql-connector-javacom.alibabadruidorg.mybatis.spring.bootmybatis-spring-boot-starterjunitjunittestch.qos.logbacklogback-coreorg.springframework.bootspring-boot-starter-jetty
 

application.properties 配置如下

server.port=8001spring.datasource.url=jdbc:mysql://localhost/cloudDB01?characterEncoding=utf8&useSSL=false&serverTimezone=UTC
 spring.datasource.username=root
 spring.datasource.password=123456
 spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
 spring.datasource.type=com.alibaba.druid.pool.DruidDataSourcemybatis.config-location=classpath:/mybatis/mybatis.cfg.xml
 # 配置type-aliases-package，我们在mapper.xml映射文件中不需要写出实体类的完整路径，只需要写出类名即可
 mybatis.type-aliases-package=com.zxb.springcloud.bean
 # 一定要写上 mapper-locations 配置
 mybatis.mapper-locations=classpath:/mybatis/mapper/*.xml
 # 如果在Spring的配置文件中指定了mybatis的配置文件位置，就不能在Spring的配置文件中写入mybatis的相关配置
 #mybatis.configuration.map-underscore-to-camel-case=true
 

除了以上两个配置文件，还写了mybatis的配置文件，里面主要开启了缓存，日志输出以及驼峰命名适配的功能。

消费者接口如下：

package com.zxb.springcloud.controller;import com.zxb.springcloud.bean.User;
 import com.zxb.springcloud.service.UserService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;import java.util.List;@RestController
 public class UserController {@Autowiredprivate UserService userService;@PostMapping(path = "/user/add")public Boolean addUser(@RequestBody User user) {return userService.addUser(user);}@GetMapping(path = "/user/del/{id}")public Integer deleteUser(@PathVariable(value = "id") Integer id) {return userService.deleteUser(id);}@PostMapping(path = "/user/update")public void deleteUser(@RequestBody User user) {userService.updateUser(user);}@GetMapping(path = "/user/get/{id}")public User getUserById(@PathVariable(value = "id") Integer id) {return userService.findById(id);}@GetMapping(path = "/user/get")public List getUserById() {return userService.findAll();}}

创建消费者模块

创建好服务提供者模块，接下来要创建消费者模块了。
pom.xml 如下

 springcloudserviceorg.example1.0-SNAPSHOT4.0.0springcloudservice-provider-user-8001org.examplespringcloudservice-api${project.version}mysqlmysql-connector-javacom.alibabadruidorg.mybatis.spring.bootmybatis-spring-boot-starterjunitjunitch.qos.logbacklogback-coreorg.springframework.bootspring-boot-starter-jettyorg.springframework.bootspring-boot-starter-weborg.springframework.bootspring-boot-starter-test
 
 

application.properties 这里暂时只需要先设置端口号即可

server.port=80
 

这里，因为不再是单体架构，牵扯到了多个微服务模块之间的调用。我们可以使用 RestTemplate 来进行调用实现。使用restTemplate访问restful接口非常的简单粗暴无脑。(url, requestMap, ResponseBean.class)这三个参数分别代表REST请求地址、请求参数、HTTP响应转换被转换成的对象类型。
注入RestTemplate实例：

	@Beanpublic RestTemplate restTemplate() {return new RestTemplate();}
 

在消费者的接口中，可以这么写：

package com.zxb.springcloud.controller;import com.zxb.springcloud.bean.User;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.client.RestTemplate;import java.util.List;@RestController
 public class UserController_Consumer {private static final String REST_URL = "http://localhost:8001";@Autowiredprivate RestTemplate restTemplate;@GetMapping(path = "/user/get/{id}")public User getById(@PathVariable(value = "id") Integer id) {return restTemplate.getForObject(REST_URL + "/user/get/" + id, User.class);}@PostMapping(path = "/user/add")public boolean addUser(User user) {return restTemplate.postForObject(REST_URL + "/user/add", user, Boolean.class);}@GetMapping(path = "/user/get")public List getAll() {return restTemplate.getForObject(REST_URL + "/user/get", List.class);}@DeleteMapping(path = "/user/del/{id}")public Integer deleteUserById(@PathVariable(value = "id") Integer id) {return restTemplate.getForObject(REST_URL + "/user/del" + id, Integer.class);}
 }
 

测试

先服务提供者自测：发送 http://localhost:8001/user/get 请求

随后消费者调用服务提供者：发送 http://localhost/user/get 请求。

至此，微服务模块基本搭建完毕，后面使用 SpringCloud 来填充我们的项目。