模拟微服务业务场景

大家好，我是讯享网，很高兴认识大家。

模拟微服务业务场景

模拟开发过程中的服务间关系。抽象出来，开发中的微服务之间的关系是生产者和消费者关系。

总目标：模拟一个最简单的服务调用场景，场景中保护微服务提供者(Producer)和微服务调用者(Consumer)，方便后面学习微服务架构

注意：实际开发中，每个微服务为一个独立的SpringBoot工程。

讯享网

1 目标

创建父工程
搭建服务提供者
搭建服务消费者
服务消费者使用RestTemplate调用服务提供者

2 讲解

创建父工程

(1)新建工程

新建一个Maven父工程springcloud-parent,创建步骤如下：

（2）引入依赖

<?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.itheima</groupId> <artifactId>springcloud-parent</artifactId> <packaging>pom</packaging> <version>1.0-SNAPSHOT</version> <modules> <module>user-provider</module> <module>user-consumer</module> </modules> <!--父工程--> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.1.6.RELEASE</version> </parent> <!--SpringCloud包依赖管理--> <dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>Greenwich.SR1</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement> </project>

讯享网

创建服务提供者(producer)工程

每个微服务工程都是独立的工程，连数据库都是独立的，所以我们一会要单独为该服务工程创建数据库。

工程创建步骤：

讯享网1.准备表结构 2.创建工程 3.引入依赖 4.创建Pojo，需要配置JPA的注解 5.创建Dao，需要继承JpaRepository<T,ID> 6.创建Service，并调用Dao 7.创建Controller，并调用Service 8.创建application.yml文件 9.创建启动类 10.测试

(1)建表

producer工程是一个独立的微服务，一般拥有独立的controller、service、dao、数据库，我们在springcloud数据库新建表结构信息，如下：

-- 使用springcloud数据库 USE springcloud; -- ---------------------------- -- Table structure for tb_user -- ---------------------------- CREATE TABLE `tb_user` ( `id` int(11) NOT NULL AUTO_INCREMENT, `username` varchar(100) DEFAULT NULL COMMENT '用户名', `password` varchar(100) DEFAULT NULL COMMENT '密码', `name` varchar(100) DEFAULT NULL COMMENT '姓名', `age` int(11) DEFAULT NULL COMMENT '年龄', `sex` int(11) DEFAULT NULL COMMENT '性别，1男，2女', `birthday` date DEFAULT NULL COMMENT '出生日期', `created` date DEFAULT NULL COMMENT '创建时间', `updated` date DEFAULT NULL COMMENT '更新时间', `note` varchar(1000) DEFAULT NULL COMMENT '备注', PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8 COMMENT='用户信息表'; -- ---------------------------- -- Records of tb_user -- ---------------------------- INSERT INTO `tb_user` VALUES ('1', 'zhangsan', '', '张三', '13', '1', '2006-08-01', '2019-05-16', '2019-05-16', '张三'); INSERT INTO `tb_user` VALUES ('2', 'lisi', '', '李四', '13', '1', '2006-08-01', '2019-05-16', '2019-05-16', '李四');

(2)新建user-provider工程

选中springcloud-parent工程->New Modul->Maven->输入坐标名字，如下步骤：

引入pom.xml依赖

讯享网<?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"> <parent> <artifactId>springcloud-parent</artifactId> <groupId>com.itheima</groupId> <version>1.0-SNAPSHOT</version> </parent> <modelVersion>4.0.0</modelVersion> <artifactId>user-provider</artifactId> <!--依赖包--> <dependencies> <!--JPA包--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-jpa</artifactId> </dependency> <!--web起步包--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <!--MySQL驱动包--> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <scope>runtime</scope> </dependency> <!--测试包--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> </dependencies> </project>

(3)User对象创建

创建com.itheima.domain.User，代码如下：

@Entity @Table(name = "tb_user") public class User { @Id @GeneratedValue(strategy = GenerationType.IDENTITY) private Integer id;//主键id private String username;//用户名 private String password;//密码 private String name;//姓名 private Integer age;//年龄 private Integer sex;//性别 1男性，2女性 private Date birthday; //出生日期 private Date created; //创建时间 private Date updated; //更新时间 private String note;//备注 //..set get toString 略 }

(4)dao
创建com.itheima.dao.UserDao，代码如下：

讯享网public interface UserDao extends JpaRepository<User,Integer> { }

(5)Service层

创建com.itheima.service.UserService接口，代码如下：

public interface UserService { /* * 根据ID查询用户信息 * @param id * @return */ User findByUserId(Integer id); }

创建com.itheima.service.impl.UserServiceImpl代码如下：

讯享网@Service public class UserServiceImpl implements UserService { @Autowired private UserDao userDao; /* * 根据ID查询用户信息 * @param id * @return */ @Override public User findByUserId(Integer id) { return userDao.findById(id).get(); } }

(6)控制层

创建com.itheima.controller.UserController，代码如下：

@RestController @RequestMapping(value = "/user") public class UserController { @Autowired private UserService userService; /* * 根据ID查询用户信息 * @param id * @return */ @RequestMapping(value = "/find/{id}") public User findById(@PathVariable(value = "id") Integer id){ return userService.findByUserId(id); } }

(7)application.yml配置

讯享网server: port: 18081 spring: datasource: driver-class-name: com.mysql.cj.jdbc.Driver username: root password: itcast url: jdbc:mysql://127.0.0.1:3306/springcloud?useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC

(8)启动类创建

创建com.itheima.UserProviderApplication启动类，并启动

@SpringBootApplication public class UserProviderApplication { public static void main(String[] args) { SpringApplication.run(UserProviderApplication.class,args); } }

测试：<http://localhost:18081/user/find/2>

创建服务消费者(consumer)工程

在该工程中使用RestTemplate来调用user-provider微服务。

实现步骤：

讯享网 1.创建工程 2.引入依赖 3.创建Pojo 4.创建启动类，同时创建RestTemplate对象，并交给SpringIOC容器管理 5.创建application.yml文件，指定端口 6.编写Controller，在Controller中通过RestTemplate调用user-provider的服务 7.启动测试

(1)工程搭建

选中springcloud-parent工程->New Modul->Maven->输入坐标名字，如下步骤：

pom.xml依赖如下：

<?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"> <parent> <artifactId>springcloud-parent</artifactId> <groupId>com.itheima</groupId> <version>1.0-SNAPSHOT</version> </parent> <modelVersion>4.0.0</modelVersion> <artifactId>user-consumer</artifactId> <!--依赖包--> <dependencies> <!--web起步依赖--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> </dependencies> </project>

(2)创建User对象

在src下创建com.itheima.domain.User,代码如下：

讯享网 public class User { private Integer id;//主键id private String username;//用户名 private String password;//密码 private String name;//姓名 private Integer age;//年龄 private Integer sex;//性别 1男性，2女性 private Date birthday; //出生日期 private Date created; //创建时间 private Date updated; //更新时间 private String note;//备注 //..set、get、toString 略 }

(3)创建启动引导类

在src下创建com.itheima.UserConsumerApplication,代码如下：

 @SpringBootApplication public class UserConsumerApplication { public static void main(String[] args) { SpringApplication.run(UserConsumerApplication.class,args); } /* * 将RestTemplate的实例放到Spring容器中 * @return */ @Bean public RestTemplate restTemplate(){ return new RestTemplate(); } }

创建application.yml,并配置端口为18082

讯享网server: port: 18082

(4)创建控制层，在控制层中调用user-provider

在src下创建com.itheima.controller.UserController，代码如下：

@RestController @RequestMapping(value = "/consumer") public class UserController { @Autowired private RestTemplate restTemplate; / * 在user-consumer服务中通过RestTemplate调用user-provider服务 * @param id * @return */ @GetMapping(value = "/{id}") public User queryById(@PathVariable(value = "id")Integer id){ String url = "http://localhost:18081/user/find/"+id; return restTemplate.getForObject(url,User.class); } }

讯享网启动测试：

请求地址：<http://localhost:18082/consumer/1>

3.2.4 思考问题

user-provider：对外提供用户查询接口

user-consumer：通过RestTemplate访问接口查询用户数据

存在的问题：

在服务消费者中，我们把url地址硬编码到代码中，不方便后期维护
在服务消费者中，不清楚服务提供者的状态(user-provider有可能没有宕机了)
服务提供者只有一个服务，即便服务提供者形成集群，服务消费者还需要自己实现负载均衡
服务提供者的如果出现故障，是否能够及时发现：

其实上面说的问题，概括一下就是微服务架构必然要面临的问题

服务管理：自动注册与发现、状态监管
服务负载均衡
熔断器

3 小结

服务消费者使用RestTemplate调用服务提供者,使用RestTemplate调用的时候，需要先创建并注入到SpringIOC容器中
在服务消费者中，我们把url地址硬编码到代码中，不方便后期维护
在服务消费者中，不清楚服务提供者的状态(user-provider有可能没有宕机了)
服务提供者只有一个服务，即便服务提供者形成集群，服务消费者还需要自己实现负载均衡
服务提供者的如果出现故障，不能及时发现。

模拟微服务业务场景