基于Dubbo实现服务的远程调用
目录
前言
RPC思想
为什么使用Dubbo
Dubbo技术框架
编辑
调用关系流程
基础实现
A.提供统一业务Api
B.编辑服务提供者Product
B.a 添加依赖
B.b 添加Dubbo 配置(基于yaml配置文件)
B.c 编写并暴露服务
C.编辑服务消费者
C.a 添加依赖
C.b 添加Dubbo配置
C.c 引用服务
前言
Dubbo是基于Java的RPC分布式服务框架，主要用于提高性能和实现透明化的RPC远程服务调用以及SOA服务治理方案。简单来说，Dubbo就是一个用于分布式场景下实现远程调用的服务框架，当然Dubbo不只这个一个功能，这只是其中之一，它的核心模块还包括集群容错和自动发现等。
RPC思想
rpc全称Remote Procedure Call ，即远程过程调用，是一种进程间的通信方式，或者说是一种思想，用于解决不同服务器键的进程调用。
上图是RPC的调用流程图，具体的过程在Dubbo框架时会再介绍。对于上图中的关键点有两个，一个是建立连接，另一个是序列化和反序列化。
为什么说这两个是关键的地方呢，这是由于在分布式服务架构中，服务的调用基于网络传递，这时数据就需要进行序列化和反序列化的操作，因此服务器的性能也就取决于我们选择的RPC框架是否能够迅速的建立连接和实现序列化、反序列化。
为什么使用Dubbo
- Dubbo可以讲核心的业务抽离出来，作为独立的服务，形成稳定的服务中心，以实现代码的灵活复用和拓展。
- Dubbo的配置方式对应用没有任何侵入，做到了透明化接入应用，只需要Spring加载Dubbo配置即可
- 再分布式架构下，可以承担更大规模的流量并发
Dubbo技术框架
节点说明
| 节点 | 说明 |
| Provider | 服务提供者 |
| Consumer | 服务消费者 |
| Registry | 服务注册(发现)中心 |
| Moniter | 服务监控中心(统计调用次数和调用时间) |
| Container | 服务运行容器 |
调用关系流程
1、服务容器负责启动，加载，运行服务提供者；
2、服务提供者在启动时，向注册中心注册自己提供的服务；
3、服务消费者在启动时，向注册中心订阅自己所需的服务；
4、注册中心返回服务提供者地址列表给消费者；
5、服务消费者基于负载均衡算法，从提供者地址列表中，选择一位提供者进行调用，如果调用失败，再选另一位调用。
6、服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。
基础实现
A.提供统一业务Api
/**
实战中，会将所有服务接口设计给一个叫做api的服务，单独维护，此处就在common服务设置*/public interface IProductService {Product findByPid(Integer pid);}B.编辑服务提供者Product
B.a 添加依赖
<!--dubbo-->
<dependency><groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-dubbo</artifactId>
</dependency>B.b 添加Dubbo 配置(基于yaml配置文件)
dubbo: scan: base-packages: com.apesource.service.impl # 开启包扫描protocols: dubbo: name: dubbo # 服务协议 port: -1 # 服务端口 使用随机端口registry: address: spring-cloud://localhost # 注册中心B.c 编写并暴露服务
//暴露服务:注意这里使用的是dubbo提供的注解@Service,而不是Spring的
@Service public class ProductServiceImpl implements ProductService {@Autowired private ProductDao productDao; @Overridepublic Product findByPid(Integer pid) {return productDao.findById(pid);}}C.编辑服务消费者
C.a 添加依赖
<!--dubbo-->
<dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-dubbo</artifactId>
</dependency>C.b 添加Dubbo配置
dubbo: registry: address: spring-cloud://localhost # 注册中心cloud: subscribed-services: service-product # 订阅的提供者名称C.c 引用服务
@RestController public class OrderController {@Autowired private OrderService orderService; //引用服务 @Reference private IProductService productService; @RequestMapping("/order/prod/{pid}") public Order order(@PathVariable Integer pid) { System.out.println("接收到{}号商品的下单请求,接下来调用商品微服务查询此商品信息"+pid); //调用商品微服务,查询商品信息Product product = productService.findByPid(pid); //下单(创建订单) Order order = new Order(); order.setUid(1); order.setUsername("测试用户");order.setPid(pid);order.setPname(product.getPname()); order.setPprice(product.getPprice());order.setNumber(1);orderService.createOrder(order);System.out.println("创建订单成功,订单信息为{}"+JSON.toJSONString(order));return order;} }