初识SpringCloud微服务

时间  2019-11-11
标签 springcloud 微服 繁體版
原文   原文链接

微服务是一种架构方式，最终确定须要技术架构去实施。java

微服务的实现方式不少，可是最火的莫过于Spring Cloud了。为何？mysql

  • 后台硬：做为Spring家族的一员，有整个Spring全家桶靠山，背景十分强大。程序员

  • 技术强：Spring做为Java领域的前辈，能够说是功力深厚。有强力的技术团队支撑，通常人还真比不了web

  • 群众基础好：能够说大多数程序员的成长都伴随着Spring框架，试问：如今有几家公司开发不用Spring？SpringCloud与Spring的各个框架无缝整合，对你们来讲一切都是熟悉的配方，熟悉的味道。spring

  • 使用方便：相信你们都体会到了SpringBoot给咱们开发带来的便利，而SpringCloud彻底支持SpringBoot的开发，用不多的配置就能完成微服务框架的搭建sql

一:简介

SpringCloud是Spring旗下的项目之一，官网地址：http://projects.spring.io/spring-cloud/数据库

Spring最擅长的就是集成，把世界上最好的框架拿过来，集成到本身的项目中。apache

SpringCloud也是同样，它将如今很是流行的一些技术整合到一块儿，实现了诸如：配置管理，服务发现，智能路由，负载均衡，熔断器，控制总线，集群状态等等功能。其主要涉及的组件包括：mybatis

netflix架构

  • Eureka：注册中心

  • Zuul：服务网关

  • Ribbon：负载均衡

  • Feign：服务调用

  • Hystix：熔断器

以上只是其中一部分，架构图：

二:微服务场景模拟

  首先，咱们须要模拟一个服务调用的场景。方便后面学习微服务架构

 2.1.服务提供者

 咱们新建一个项目，对外提供查询用户的服务。

 2.1.1.Spring脚手架建立工程

 借助于Spring提供的快速搭建工具：

 填写项目信息：

 添加web依赖：

 

 添加mybatis依赖：

  填写项目位置：

 生成的项目结构：

 依赖也已经所有自动引入：

<?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.leyou.demo</groupId>
<artifactId>user-service-demo</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>

<name>user-service-demo</name>
<description>Demo project for Spring Boot</description>

<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.1.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>

<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
</properties>

<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>1.3.2</version>
</dependency>
<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>

<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>

 固然，由于要使用通用mapper，因此咱们须要手动加一条依赖：

<dependency>
    <groupId>tk.mybatis</groupId>
    <artifactId>mapper-spring-boot-starter</artifactId>
    <version>2.0.2</version>
</dependency>

 很是快捷啊！

 2.1.2.编写代码

 添加一个对外查询的接口：

@RestController
@RequestMapping("user")
public class UserController {
​
    @Autowired
    private UserService userService;
​
    @GetMapping("/{id}")
    public User queryById(@PathVariable("id") Long id) {
        return this.userService.queryById(id);
   }
}

 Service：

@Service
public class UserService {
​
    @Autowired
    private UserMapper userMapper;
​
    public User queryById(Long id) {
        return this.userMapper.selectByPrimaryKey(id);
   }
}

mapper:

@Mapper
public interface UserMapper extends tk.mybatis.mapper.common.Mapper<User>{
}

实体类：

@Table(name = "tb_user")
public class User implements Serializable {
​
    private static final long serialVersionUID = 1L;
​
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
​
    // 用户名
    private String userName;
​
    // 密码
    private String password;
​
    // 姓名
    private String name;
​
    // 年龄
    private Integer age;
​
    // 性别，1男性，2女性
    private Integer sex;
​
    // 出生日期
    private Date birthday;
​
    // 建立时间
    private Date created;
​
    // 更新时间
    private Date updated;
​
    // 备注
    private String note;
​
   // 。。。省略getters和setters
}
​

属性文件,这里咱们采用了yaml语法，而不是properties：

server:
 port: 8081
spring:
 datasource:
   url: jdbc:mysql://localhost:3306/mydb01
   username: root
   password: 123
   hikari:
     maximum-pool-size: 20
     minimum-idle: 10
mybatis:
 type-aliases-package: com.leyou.userservice.pojo

项目结构：

2.1.3.启动并测试：

启动项目，访问接口：http://localhost:8081/user/7

2.2.服务调用者

2.2.1.建立工程

与上面相似，这里再也不赘述，须要注意的是，咱们调用user-service的功能，所以不须要mybatis相关依赖了。

pom：

<?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.leyou.demo</groupId>
<artifactId>user-consumer-demo</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>

<name>user-consumer-demo</name>
<description>Demo project for Spring Boot</description>

<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.1.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>

<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
</properties>

<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- 添加OkHttp支持 -->
<dependency>
<groupId>com.squareup.okhttp3</groupId>
<artifactId>okhttp</artifactId>
<version>3.9.0</version>
</dependency>
</dependencies>

<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>

</project>

2.2.2.编写代码

首先在启动类中注册RestTemplate：

@SpringBootApplication
public class UserConsumerDemoApplication {

@Bean
public RestTemplate restTemplate() {
// 此次咱们使用了OkHttp客户端,只须要注入工厂便可
return new RestTemplate(new OkHttp3ClientHttpRequestFactory());
}

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

而后编写UserDao，注意，这里不是调用mapper查数据库，而是经过RestTemplate远程查询user-service-demo中的接口：

@Component
public class UserDao {

@Autowired
private RestTemplate restTemplate;

public User queryUserById(Long id){
String url = "http://localhost:8081/user/" + id;
return this.restTemplate.getForObject(url, User.class);
}
}

而后编写user-service，循环查询UserDAO信息：

@Service
public class UserService {

@Autowired
private UserDao userDao;

public List<User> querUserByIds(List<Long> ids){
List<User> users = new ArrayList<>();
for (Long id : ids) {
User user = this.userDao.queryUserById(id);
users.add(user);
}
return users;
}
}

编写controller：

@RestController
@RequestMapping("consume")
public class ConsumerController {

@Autowired
private UserService userService;

@GetMapping
public List<User> consume(@RequestParam("ids") List<Long> ids) {
return this.userService.queryUserByIds(ids);
}
}

2.2.3.启动测试：

由于咱们没有配置端口，那么默认就是8080，咱们访问：http://localhost:8080/consume?ids=6,7,8

一个简单的远程服务调用案例就实现了。

简单回顾一下，刚才咱们写了什么：

  • use-service-demo：一个提供根据id查询用户的微服务

  • consumer-demo：一个服务调用者，经过RestTemplate远程调用user-service-demo

流程以下：

存在什么问题？

  • 在consumer中，咱们把url地址硬编码到了代码中，不方便后期维护

  • consumer须要记忆user-service的地址，若是出现变动，可能得不到通知，地址将失效

  • consumer不清楚user-service的状态，服务宕机也不知道

  • user-service只有1台服务，不具有高可用性

  • 即使user-service造成集群，consumer还需本身实现负载均衡

其实上面说的问题，归纳一下就是分布式服务必然要面临的问题：

  • 服务管理

    • 如何自动注册和发现

    • 如何实现状态监管

    • 如何实现动态路由

  • 服务如何实现负载均衡--- (动态路由)

  • 服务如何解决容灾问题

  • 服务如何实现统一配置

以上的问题，咱们都将在Eureka注册中心中获得答案。

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程