SpringCloud微服务(一)——微服务入门

文章目录

一、简介1、什么是微服务2、单体集中式开发优缺点3、微服务架构4、微服务架构优点与缺点5、SpringCloud简述6、资料参考7、搭建环境8、相关功能实现<1>、创建数据<2>、创建mapper接口，实现CRUD操作<3>、Service层<4>、Controller层<5>、添加实体<6>、远程调用

一、简介

1、什么是微服务

微服务架构是⼀种架构模式，它提倡将单⼀应⽤程序划分成⼀组⼩的服务，服务之间互相协调、互相配合，为⽤户提供最终价值。每个服务运⾏在其独⽴的进程中，服务与服务间采⽤轻量级的通信机制互相协作（通常是基于HTTP协议的RESTful API）。每个服务都围绕着具体业务进⾏构建，并且能够被独⽴的部署到⽣产环境、类⽣产环境等。另外，应当尽量避免统⼀的、集中式的服务管理机制，对具体的⼀个服务⽽⾔，应根据业务上下⽂，选择合适的语⾔、⼯具对其进⾏构建。

2、单体集中式开发优缺点

优点 易于开发&测试：单个应用包含所有功能，不涉及多个应用的互联互调，便于在团队之间开发与测 试。 易于部署：只需将单个应用打成war或jar包，进行部署到Tomcat即可，运维起来比较方便。 易于整体扩展：当应用负载压力大时，将这个应用复制几份，分别部署在不同的服务器上，再通过负载 均衡即可提高应用的并发能力。缺点 复杂性高：由于是单个应用，所以整个项目文件包含的模块非常多，导致模块的边界模糊、依赖关 系不清晰、代码的质量参差不齐，混乱的堆在一起，使得整个项目非常复杂。以致每次修改代码，都非 常小心，可能添加一个简单的功能，或者修改一个Bug都会带来隐藏的缺陷。 技术债务：随着时间的推移、需求的变更和技术人员的更替，会逐渐形成应用程序的技术债务，并且越积越多。 阻碍技术创新： 对于单体应用来说，技术是在开发之前经过慎重评估后选定的，每个团队成员都必须使用相同的开发语 言、持久化存储及消息系统。

3、微服务架构

4、微服务架构优点与缺点

优点 1、易于开发和维护：一个微服务只关注一个特定的业务功能，所以它的业务清晰、代码量较少。开发和维护单个微服务相对是比较简单的。 2、单个微服务启动较快：单个微服务代码量较少，所以启动会比较快。 3、局部修改容易部署：单体应用只要是有修改，就得重新部署整个应用，微服务解决了这样的问题。一般来说，对某个微服务进行修改，只需要重新部署这个服务即可。 4、技术栈不受限：在微服务中，我们可以结合项目业务及团队的特点，合理的选择技术栈。 5、按需伸缩：我们可以根据需求，实现细粒度的扩展。 缺点 1、运维要求较高：更多的服务意味着更多的运维投入。在单体架构中，只需要保证一个应用的正常运行；而在微服务中，需要保证几十甚至几百个服务的正常运行与协作，这给项目的运维带来了很大的挑战。 2、分布式固有的复杂性：使用微服务构建的是分布式系统。对于一个分布式系统，系统容错、网络延迟、分布式事务等都给我们带来了很大的挑战。 3、接口调整成本高：微服务之间通过接口进行通信。如果修改某一个微服务的API，可能所有使用了该接口的微服务都需要做调整。

5、SpringCloud简述

SpringCloud，基于SpringBoot提供了一套微服务解决方案，包括服务注册与发现，配置中心，全链路监控，服务网关，负载均衡，熔断器等组件，除了基于NetFlix的开源组件做高度抽象封装之外，还有一些选型中立的开源组件。 官方译文：构建分布式系统不用特别的复杂且避免容易出现的错误。Spring Cloud为常见的分布式系统模式提供了一个简单和可访问的编程模型，帮助开发人员构建弹性、可靠和协调的应用程序。SpringCloud构建在 SpringBoot之上，使开发人员很容易开始工作并迅速提高生产力。

6、资料参考

1、官网:http://projects.spring.io/spring-cloud/ 2、各组件说明(中文版):https://springcloud.cc/spring-cloud-netflix.html 3、详细文档(英文版):https://cloud.spring.io/spring-cloud-static/Finchley.SR2/single/spring-cloud.html 中文版:https://springcloud.cc/spring-cloud-dalston.html 4、SpringCloud中国社区:http://springcloud.cn/ 5、SpringCloud中文网:https://springcloud.cc/ 6、Spring Cloud目前集合了21种分布式微服务架构技术

7、搭建环境

创建一个新建Maven工程，添加以下依赖

<?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>SpringCloud</groupId> <artifactId>miscroservicecloud</artifactId> <version>1.0-SNAPSHOT</version> <packaging>pom</packaging> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <java.version>1.8</java.version> <spring-cloud.version>Finchley.SR1</spring-cloud.version> <mapper.starter.version>2.0.3</mapper.starter.version> <mysql.version>5.1.47</mysql.version> <pageHelper.starter.version>1.2.5</pageHelper.starter.version> <junit.version>4.12</junit.version> <log4j.version>1.2.17</log4j.version> <lombok.version>1.16.18</lombok.version> </properties> <dependencyManagement> <dependencies> <!--springcloud--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>${spring-cloud.version}</version> <type>pom</type> <scope>import</scope> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-dependencies</artifactId> <version>2.0.4.RELEASE</version> <type>pom</type> <scope>import</scope> </dependency> <!--通用Mapper启动器--> <dependency> <groupId>tk.mybatis</groupId> <artifactId>mapper-spring-boot-starter</artifactId> <version>${mapper.starter.version}</version> </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.8</version> </dependency> <dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>1.3.4</version> </dependency> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>${junit.version}</version> <scope>test</scope> </dependency> <dependency> <groupId>log4j</groupId> <artifactId>log4j</artifactId> <version>${log4j.version}</version> </dependency> <dependency> <groupId>ch.qos.logback</groupId> <artifactId>logback-core</artifactId> <version>1.2.3</version> </dependency> </dependencies> </dependencyManagement> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> <version>2.0.4.RELEASE</version> </plugin> </plugins> </build> </project>

首先创建的工程是父工程，然后在父工程上标记我们的版本号，这样创建子工程的时候只要把模块写上就可以了，然后就来建立我们的子工程，一共是两个，首先来建立第一个，user-consumer模块 在resources里面创建一个application.yml进行相关配置

server: port: 8001 mybatis: type-aliases-package: springcloud.entities # 所有Entity别名类所在包 spring: datasource: type: com.alibaba.druid.pool.DruidDataSource # 当前数据源操作类型 driver-class-name: org.gjt.mm.mysql.Driver # mysql驱动包 url: jdbc:mysql://localhost:3306/cloudDB01 # 数据库名称 username: root password: 123456 dbcp2: min-idle: 5 # 数据库连接池的最小维持连接数 initial-size: 5 # 初始化连接数 max-total: 5 # 最大连接数 max-wait-millis: 200 # 等待连接获取的最大超时时间

和数据库进行连接，接下来创建主启动类

package springcloud; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; @SpringBootApplication public class DeptProvider8001_App { public static void main(String[] args) { SpringApplication.run(DeptProvider8001_App.class, args); } }

第一个module创建完成，接下来创建第二个module 创建一个maven工程，添加依赖

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency>

创建主启动类：

package springcloud; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; @SpringBootApplication public class DeptConsumer80_App { public static void main(String[] args) { SpringApplication.run(DeptConsumer80_App.class, args); } public RestTemplate restTemplate() { return new RestTemplate(); } }

8、相关功能实现

<1>、创建数据

创建Dept.java标明数据源的列名，主键，并且添加对应的get、set方法。

package springcloud.entities; import lombok.AllArgsConstructor; import lombok.Data; import lombok.NoArgsConstructor; import lombok.experimental.Accessors; import lombok.Getter; import lombok.Setter; import java.io.Serializable; @NoArgsConstructor //@AllArgsConstructor @Data @Accessors(chain=true) public class Dept implements Serializable// entity --orm--- db_table { private Long deptno; // 主键 private String dname; // 部门名称 private String db_source;// 来自那个数据库，因为微服务架构可以一个服务对应一个数据库，同一个信息被存储到不同数据库 public Dept(String dname) { super(); this.dname = dname; } }

添加上@NoArgsConstructor和@AllArgsConstructor之后会自动生成构造器 然后将这个maven工程打包，其他的maven工程就可以使用了

<2>、创建mapper接口，实现CRUD操作

为了方便操作数据库，我们使用和MyBatis整合 首先在resources下创建一个mapper包并在其里面创建DeptMapper.xml

<?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="springcloud.dao.DeptDao"> <select id="findById" resultType="Dept" parameterType="Long"> select deptno,dname,db_source from dept where deptno=#{deptno}; </select> <select id="finaAll" resultType="Dept"> select deptno,dname,db_source from dept; </select> <insert id="addDept" parameterType="Dept"> insert into dept(dname,db_source) values(#{dname}, DATABASE()); </insert> </mapper>

然后在resources下创建mybatis.cfg.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>

<3>、Service层

编写Service层的目的是为了能让我们先继承我们自己写的UserMapper接口后，决定究竟使用Mapper接口内的哪一个操作。

package springcloud.service.impl; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import springcloud.dao.DeptDao; import springcloud.entities.Dept; import springcloud.service.DeptService; import java.util.List; @Service public class DeptServiceImpl implements DeptService { @Autowired DeptDao deptDao; @Override public boolean add(Dept dept) { return deptDao.addDept(dept); } @Override public Dept get(Long id) { return deptDao.findById(id); } @Override public List<Dept> list() { return deptDao.findAll(); } }

<4>、Controller层

单例化Service类，并且调用要实现的业务方法

package springcloud.controller; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.cloud.client.ServiceInstance; import org.springframework.cloud.client.discovery.DiscoveryClient; import org.springframework.web.bind.annotation.*; import springcloud.entities.Dept; import springcloud.service.DeptService; import java.util.List; @RestController public class DeptController { @Autowired DeptService deptService; @Autowired DiscoveryClient client; @RequestMapping(value = "/dept/add", method = RequestMethod.POST) public boolean add(@RequestBody Dept dept){ return deptService.add(dept); } @RequestMapping(value = "/dept/get/{id}", method = RequestMethod.GET) public Dept get(@PathVariable("id")Long id){ return deptService.get(id); } @RequestMapping(value = "/dept/list", method = RequestMethod.GET) public List<Dept> get(){ return deptService.list(); } @RequestMapping(value = "/dept/discovery", method = RequestMethod.GET) public Object discovery(){ List<String> list = client.getServices(); System.out.println("******" + list); List<ServiceInstance> list1 = client.getInstances("MISCROSERVICECLOUD-DEPT"); for (ServiceInstance serviceInstance : list1){ System.out.println(serviceInstance.getHost()+"\t"+serviceInstance.getServiceId()+"\t" +serviceInstance.getPort()+"\t"+serviceInstance.getUri()); } return this.client; } }

user-consumer已经编写完成，接下来编写user-provider

<5>、添加实体

和上面的Dept一样，添加相同实例类

<6>、远程调用

控制层实现俩个模块调用

package springcloud.controller; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.client.RestTemplate; import springcloud.entities.Dept; import java.util.List; @RestController public class DeptController_Consumer { //misroservicecloud-dept // private static final String REST_URL_PREFIX = "http://localhost:8081"; private static final String REST_URL_PREFIX = "http://MISROSERVICECLOUD-DEPT"; /** * 使用RestTemplate访问restful接口 * (url,requestMap，ResponseBean.class) * REST请求地址、请求参数、HTTP响应转换被转换成的对象类型 */ @Autowired RestTemplate restTemplate; @RequestMapping(value = "/consumer/dept/add") public boolean add(Dept dept){ return restTemplate.postForObject(REST_URL_PREFIX+"/dept/add", dept, boolean.class); } @RequestMapping(value = "/consumer/dept/get/{id}") public Dept get(@PathVariable("id")Long id){ return restTemplate.getForObject(REST_URL_PREFIX+"/dept/get"+id, Dept.class); } @SuppressWarnings("unchecked") @RequestMapping(value = "/consumer/dept/list") public List<Dept> list(){ return restTemplate.getForObject(REST_URL_PREFIX+"/dept/list",List.class); } //测试@EnableDiscoveryClient，消费端可以调用服务发现 @RequestMapping(value = "/consumer/dept/discovery") public Object discovery(){ return restTemplate.getForObject(REST_URL_PREFIX+"/dept/discovery", Object.class); } }