69.SpringCloud Alibaba Dubbo使用

Dubbo-RPC通信

介绍

• Dubbo是阿里巴巴开源的基于Java的高性能RPC分布式服务框架，致力于提供高性能和透明化的RPC远程服务调用方案，以及SOA服务治理方案。

• Spring-Cloud-Alibaba-Dubbo是基于SpringCloudAlibaba技术栈对Dubbo技术的一种封装，目的在于实现基于RPC的服务调用。

  
  image

实现

提供统一的业务api

public interface ProductService {
    Product findByPid (Integer pid);
}

提供服务提供者

• 1.添加依赖

<!--dubbo-->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-dubbo</artifactId>
</dependency>

• 2.添加dubbo配置

dubbo:
  scan:
    base-packages: com.example.service.impl #开启包扫描
  protocols:
    dubbo:
      name: dubbo #服务协议
      port: -1 #服务端口
  registry:
    address: spring-cloud://192.168.110.130 #注册中心

• 3.编写并暴露服务

@Service //暴露服务：注意这里使用的是dubbo提供的注解@Service，而不是Spring的
public class ProductServiceImpl implements ProductService {

    @Autowired
    private ProductDao productDao;

    @Override
    public Product findByPid(Integer pid) {
        return productDao.findById(pid).get();
    }
}

提供者服务消费者

• 1.添加依赖

<!--dubbo-->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-dubbo</artifactId>
</dependency>

• 2.添加dubbo配置

dubbo:
  registry:
    address: spring-cloud://192.168.110.130 #注册中心
  cloud:
    subscribed-services: service-product #订阅的提供者名称

• 引用服务

@RestController
@Slf4j
public class OrderController {

    //服务引用
    @Reference
    private ProductService productService;

    /**
     * feign实现服务调用
     * @param pid
     * @return
     */
    @RequestMapping("/order/prod1/{pid}")
    public Order order(@PathVariable("pid") Integer pid) {
        log.info("接收到{}号商品的下单请求，接下来调用商品微服务查询此商品信息", pid);

        Product product = productService.findByPid(pid);

        if (product.getPid()==-100){
            Order order = new Order();
            order.setOid(-100L);
            order.setPname("下单失败");
            return order;
        }

        log.info("查询到{}号商品的信息，内容是：{}", pid, JSON.toJSONString(product));

        //下单（创建订单）
        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);
        log.info("创建订单成功，订单信息为{}", JSON.toJSONString(order));
        return order;
    }

}