一、分布式应用

在分布式系统中,国内常用zookeeper+dubbo组合,而Spring Boot推荐使用全栈的Spring,Spring Boot+Spring Cloud。
image.png

  • 单一应用架构
    • 当网站流量很小时,只需一个应用,将所有功能都部署在一起,以减少部署节点和成本。此时,用于简化增删改查工作量的数据访问框架(ORM)是关键。
  • 垂直应用架构
    • 当访问量逐渐增大,单一应用增加机器带来的加速度越来越小,将应用拆成互不相干的几个应用,以提升效率。此时,用于加速前端页面开发的Web框架(MVC)是关键。
  • 分布式服务架构
    • 当垂直应用越来越多,应用之间交互不可避免,将核心业务抽取出来,作为独立的服务,逐渐形成稳定的服务中心,使前端应用能更快速的响应多变的市场需求。此时,用于提高业务复用及整合的分布式服务框架(RPC)是关键。
  • 流动计算架构
    • 当服务越来越多,容量的评估,小服务资源的浪费等问题逐渐显现,此时需增加一个调度中心基于访问压力实时管理集群容量,提高集群利用率。此时,用于提高机器利用率的资源调度和治理中心(SOA)是关键。

二、Zookeeper和Dubbo

ZooKeeper

ZooKeeper 是一个分布式的,开放源码的分布式应用程序协调服务。它是一个为分布式应用提供一致性服务的软件,提供的功能包括:配置维护、域名服务、分布式同步、组服务等。

Dubbo

Dubbo是Alibaba开源的分布式服务框架,它最大的特点是按照分层的方式来架构,使用这种方式可以使各个层之间解耦合(或者最大限度地松耦合)。从服务模型的角度来看,Dubbo采用的是一种非常简单的模型,要么是提供方提供服务,要么是消费方消费服务,所以基于这一点可以抽象出服务提供方(Provider)和服务消费方(Consumer)两个角色。
image.png

1.linux安装zookeeper

  1. docker pull zookeeper
  2. docker run --name myzookeeper --restart always -d -p 2181:2181 d95f03d7e491
  1. 安装 zookeeper
  2. 1.拉取软件镜像
  3. docker pull zookeeper
  4. 2.启动 zookeeper
  5. docker run --name zp01 --restart always -d -p 2181:2181 ID
  6. 1.将服务提供者注册到注册中心
  7. 1.引入依赖 dubbo zookeeper
  8. <dependency>
  9. <groupId>com.alibaba.boot</groupId>
  10. <artifactId>dubbo-spring-boot-starter</artifactId>
  11. <version>0.1.0</version>
  12. </dependency>
  13. <!--引入zookeeper的客户端工具-->
  14. <!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient -->
  15. <dependency>
  16. <groupId>com.github.sgroschupf</groupId>
  17. <artifactId>zkclient</artifactId>
  18. <version>0.1</version>
  19. </dependency>
  20. 2.配置 application.properties zookeeper相关属性
  21. #应用名称
  22. dubbo.application.name=provider-ticket
  23. #注册中心地址
  24. dubbo.registry.address=zookeeper://192.168.75.138:2181
  25. #扫描包名
  26. dubbo.scan.base-packages=com.atguigu.ticket.service
  27. 3.使用 @Service 发布服务
  28. 2、用户模块
  29. 1.引入依赖(同上)
  30. 2.配置dubbo的注册中心地址
  31. # 应用名称
  32. dubbo.application.name=consumer-user
  33. # 注册地址
  34. dubbo.registry.address=zookeeper://192.168.75.138:2181
  35. 3.引用服务
  36. 需要在提供者模块启动类上标注 @EnableDubbo @DubboComScan
  37. 在拥护者模块user同级目录下有ticket包,可以没有impl

提供者application.properties

  1. #应用名称
  2. dubbo.application.name=provider-ticket
  3. #注册中心地址
  4. dubbo.registry.address=zookeeper://192.168.75.138:2181
  5. #扫描包名
  6. dubbo.scan.base-packages=com.atguigu.ticket.service

提供者服务

  1. package com.atguigu.ticket.service;
  2. public interface TicketService {
  3. public String getTicket();
  4. }
  5. @Component//添加在容器中
  6. @Service//将服务发布出去
  7. public class TicketServiceImpl implements TicketService {
  8. @Override
  9. public String getTicket() {
  10. return "<厉害了我的国>";
  11. }
  12. }

提供者启动器

  1. @EnableDubbo//开启基于注解的dubbo
  2. @DubboComponentScan//开启自动扫描dubbo包
  3. @SpringBootApplication
  4. public class ProviderTicketApplication {

用户application.properties

  1. # 应用名称
  2. dubbo.application.name=consumer-user
  3. # 注册地址
  4. dubbo.registry.address=zookeeper://192.168.75.138:2181

用户引用提供者服务(在用户同级目录下引用ticket)

  1. @Service
  2. public class UserService {
  3. @Reference//远程引用
  4. TicketService ticketService;
  5. public void hello(){
  6. String ticket = ticketService.getTicket();
  7. System.out.println("买到票了:"+ticket);
  8. }
  9. }

用户启动器

  1. @SpringBootApplication
  2. public class ConsumerUserApplication {

三、SpringBoot 和 SpringCloud

Spring Cloud
Spring Cloud是一个分布式的整体解决方案。Spring Cloud 为开发者提供了在分布式系统(配置管理,服务发现,熔断,路由,微代理,控制总线,一次性token,全局琐,leader选举,分布式session,集群状态)中快速构建的工具,使用Spring Cloud的开发者可以快速的启动服务或构建应用、同时能够快速和云平台资源进行对接。
image.png

  1. eureka-server--->注册中心
  2. 配置信息
  3. server:
  4. port: 8761
  5. eureka:
  6. instance:
  7. hostname: eureka-server # eureka 实例主机名
  8. client:
  9. register-with-eureka: false # 不会吧 eureka 本身注册在注册中心
  10. fetch-registry: false # 不从 eureka 上获取服务的注册信息
  11. service-url:
  12. defaultZone: http://localhost:8761/eureka/
  13. 开启注解 @EnableEurekaServer

将提供者注册到注册中心

  1. server:
  2. port: 8002
  3. spring:
  4. application:
  5. name: provider-ticket
  6. eureka:
  7. instance:
  8. service-url:
  9. defaultZone: http://localhost:8761/eureka/
  10. prefer-ip-address: true # 注册服务的时候使用服务的ip进行注册

提供者提供电影票方法

  1. @Service
  2. public class TicketService {
  3. public String getTicket(){
  4. System.out.println("8002");
  5. return "电影票";
  6. }
  7. }
  8. @RestController
  9. public class TicketController {
  10. @Autowired
  11. TicketService ticketService;
  12. @GetMapping("/ticket")
  13. public String getTicket(){
  14. return ticketService.getTicket();
  15. }
  16. }

将用户注册到注册中心

  1. server:
  2. port: 8200
  3. eureka:
  4. instance:
  5. hostname: eureka-server # eureka 实例主机名
  6. client:
  7. service-url:
  8. defaultZone: http://localhost:8761/eureka/
  9. spring:
  10. application:
  11. name: consumer-user

用户开启寻找服务功能

  1. @EnableDiscoveryClient//开启发现服务功能

用户开启负载均衡

  1. @LoadBalanced//使用负载均衡机制
  2. @Bean
  3. public RestTemplate restTemplate(){
  4. return new RestTemplate();
  5. }

用户买票

  1. @RestController
  2. public class UserController {
  3. @Autowired
  4. RestTemplate restTemplate;
  5. @GetMapping("/buy")
  6. public String buyTickey(String name){
  7. String s = restTemplate.getForObject("http://PROVIDER-TICKET/ticket", String.class);
  8. return name+"购买了"+s;
  9. }
  10. }

image.png
image.png