目录
前言
什么是分布式系统?
分布式系统的出现是为了用更省钱的方式、更多的普通机器完成单个计算机无法完成的计算。
架构演变经历的4个阶段
单一应用架构
将所有功能都部署在一起,以减少部署节点和成本。但是不利于维护和升级。
垂直应用架构
将应用拆分为多个应用,通信机制一般为RESTful。但是呢?虽然拆分为多个应用,但是应用之间难免存在交互的部分,这就促使下一个架构的诞生。
分布式服务架构
将核心业务抽取出来,作为独立的服务进行部署,供多个垂直应用调用,分布式服务框架(RPC)是关键,RPC【Remote Procedure Call】是指远程过程调用,可以将共同的服务部署在服务器中,用RPC实现服务之间的调用。
流动计算架构
增加一个调度中心基于访问压力实时管理集群容量。
搭建框架
1.创建一个模块SpringBoot-Dubbo-zookeeper,使用springboot的web依赖。
2.编写一个接口:
package com.he.Service;
public interface TicketService {
public String getTicket();
}
3.编写一个实现类:
这里的@Service表示注册到zookeeper中
package com.he.Service;
import org.apache.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;
//服务注册与发现,新版是@DubboService
@Service
@Component
public class TicketServiceImpl implements TicketService {
@Override
public String getTicket() {
return "票";
}
}
4.在application.properties中配置注册中心地址,扫描指定包,被调用的方法是需要加入扫描指定包下服务的配置dubbo.scan.base-packages,需要将其注册在zookeeper中和spring中才可使用,调用时注册中心地址与被调用的配置相同方可
server.port=8081
#当前应用名字
dubbo.application.name=provider-server
#注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
#扫描指定包下服务
dubbo.scan.base-packages=com.he.Service
5.在springboot的启动文件中加入注解@EnableDubbo
6.导入依赖包
<!-- Dubbo Spring Boot Starter -->
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>2.7.3</version>
</dependency>
<dependency>
<groupId>com.github.sgroschupf</groupId>
<artifactId>zkclient</artifactId>
<version>0.1</version>
</dependency>
<!-- 引入zookeeper -->
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-framework</artifactId>
<version>2.12.0</version>
</dependency>
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-recipes</artifactId>
<version>2.12.0</version>
</dependency>
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.14</version>
<!--解决日志冲突问题-->
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
</exclusion>
</exclusions>
</dependency>
7.创建新的模块用于调用上一个模块,导入一样的包
8.配置dubbo相关属性
server.port=8082
#当前应用名字
dubbo.application.name=consumer-server
#注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
9.创建调用的类
package com.he.Service;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Service;
@Service //注入到容器中
public class Consumerservice {
@Reference //远程引用指定的服务,他会按照全类名进行匹配,看谁给注册中心注册了这个全类名
TicketService ticketService;
public void bugTicket(){
String ticket = ticketService.getTicket();
System.out.println("在注册中心买到"+ticket);
}
}
10.编写测试类
package com.he;
import com.he.Service.Consumerservice;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
@SpringBootTest
class SpringbootConsumerApplicationTests {
@Autowired
Consumerservice consumerservice;
@Test
void contextLoads() {
consumerservice.bugTicket();
}
}
11.注意,这里需要保持路径相同,且需要加入第一个的服务接口防止报错。
启动测试
开启zookeeper,开启第一个模块SpringBoot-Dubbo-zookeeper,然后启动测试方法。这里的zookeeper相当于注册中心,用于接收第一个模块的注册,并使得可以被调用。最终输出