微服务架构

Spring Cloud

Spring Cloud 是什么？

• Spring Cloud 虽然带有“Cloud”字样，但不是云计算解决方案，而是在 Spring Boot 基础上构建的，用于快速构建分布式系统的工具集，它非常适合在 Docker 或者 PaaS 上部署。
• Spring Cloud 特点：
  • 约定优于配置
  • 适用于各种环境、开发、部署
  • 隐藏了组件的复杂性，提供声明式、无 xml 配置方式
  • 开箱即用，快速启动
  • 轻量级组件，Spring Cloud 整合的组件大多比较轻量级
  • 组件丰富、功能齐全，提供了配置管理、服务发现、断路器、微服务网管等
  • 灵活、解耦

Spring Cloud 快速入门

• 编写一个电影购票系统，用户向电影微服务请求购票时，电影购票系统调用用户微服务系统的接口，查询当前余额是多少，是否符合购票标准，然后在进行购票操作

graph LR
A[用户] --> |购票|B[电影微服务] 
B--> |查询用户信息|C[用户微服务]

• 添加依赖库

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <scope>runtime</scope>
</dependency>
<dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
    <optional>true</optional>
</dependency>

• 创建数据库并插入数据

SET NAMES utf8;
SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------
--  Table structure for `user`
-- ----------------------------
DROP TABLE IF EXISTS `user`;
CREATE TABLE `user` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `username` varchar(40) DEFAULT NULL,
  `name` varchar(20) DEFAULT NULL,
  `age` int(3) DEFAULT NULL,
  `balance` decimal(10,2) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8;

-- ----------------------------
--  Records of `user`
-- ----------------------------
BEGIN;
INSERT INTO `user` VALUES ('1', 'account1', '张三', '20', '100.00'), ('2', 'account2', '李四', '28', '180.00'), ('3', 'account3', '王五', '32', '230.00');
COMMIT;

SET FOREIGN_KEY_CHECKS = 1;

用户微服务（Demo 源码 film-user）

• 实体类

@Data
@Entity(name = "user")
public class UserEntity {
    @Id
    @GeneratedValue
    private int id;
    private String username;
    private String name;
    private int age;
    private BigDecimal balance;
}

• Repository

@Repository
public interface UserRepository extends JpaRepository<UserEntity,Integer>{}

• Controller

@RestController
public class UserController {
    @Autowired
    private UserRepository userRepository;

    @GetMapping("/{id}")
    public UserEntity findById(@PathVariable int id){
        UserEntity userEntity = userRepository.findOne(id);
        return userEntity;
    }
}

• 编写配置文件

spring:
  datasource:
    url: jdbc:mysql://localhost:3306/flim?useSSL=false
    username: root
    password: 123456ly
  jpa:
    show-sql: true
    database-platform: org.hibernate.dialect.MySQL5Dialect

• 访问 http://localhost:8080/1 ，输出

{"id":1,"username":"account1","name":"张三","age":20,"balance":100.00}

消费者微服务（Demo 源码 film-consumer）

• 将 RestTemplate 注入到 IOC 容器

@SpringBootApplication
public class ConsumerApplication {
    @Bean
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }
    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class, args);
    }
}

• 创建Controller，通过 RestTemplate 访问用户微服务 API

@RestController
public class MovieController {
    @Autowired
    private RestTemplate restTemplate;

    @GetMapping("/user/{id}")
    public UserEntity findById(@PathVariable int id){
        return this.restTemplate.getForObject("http://localhost:8080/"+id,UserEntity.class);
    }
}

• 修改配置文件，修改端口

server:
  port: 8010
spring:
  datasource:
    url: jdbc:mysql://localhost:3306/flim?useSSL=false
    username: root
    password: 123456ly

• 访问 http://localhost:8010/user/1 输出

{"id":1,"username":"account1","name":"张三","age":20,"balance":100.00}

硬编码问题

• 上述例子中使用了硬编码，我们把服务提供者的网络地址、IP、端口硬编码在代码中，这样会出现以下问题：
  • 适用场景有局限，若服务提供者网络地址发生了变化，会影响服务消费者
  • 无法动态伸缩，在生产环境中，每个微服务一般都会部署多个实例，从而实现负载均衡，在微服务架构中，还需要系统具备自动伸缩的能力，例如动态增减节点
• 解决硬编码的问题是通过服务发现，如 Eureka