<!-- Dubbo核心依賴 -->
<dependency>
    <groupId>org.apache.dubbo</groupId>
    <artifactId>dubbo-spring-boot-starter</artifactId>
    <version>3.2.0</version> <!-- 推薦使用穩(wěn)定版 -->
</dependency>

# 服務(wù)提供者 + 消費(fèi)者 通用配置（可根據(jù)角色調(diào)整）
spring:
  application:
    name: dubbo-demo-provider # 應(yīng)用名（消費(fèi)者需改為dubbo-demo-consumer）
dubbo:
  protocol:
    name: dubbo # 通信協(xié)議（默認(rèn)dubbo，可選http、netty等）
    port: -1 # 端口（-1表示隨機(jī)端口，避免端口沖突）
  registry:
    address: nacos://127.0.0.1:8848 # Nacos注冊(cè)中心地址（本地Nacos需啟動(dòng)）
  scan:
    base-packages: com.example.dubbo.service.impl # 服務(wù)提供者：掃描@DubboService注解的包
    # 消費(fèi)者：掃描@DubboReference注解的包（如com.example.dubbo.controller）

package com.example.dubbo.service;

/**
 * 公共接口（提供者實(shí)現(xiàn)，消費(fèi)者調(diào)用）
 */
public interface UserService {
    /**
     * 根據(jù)用戶ID查詢用戶名
     * @param userId 用戶ID
     * @return 用戶名
     */
    String getUserNameById(Long userId);
}

package com.example.dubbo.service.impl;

import com.example.dubbo.service.UserService;
import org.apache.dubbo.config.annotation.DubboService;
import org.springframework.stereotype.Component;

// @Component：交給Spring管理（Dubbo 3.x可省略，但建議加上，避免Spring掃描不到）
// @DubboService：暴露該類為Dubbo服務(wù)，自動(dòng)推斷接口（僅實(shí)現(xiàn)一個(gè)接口）
@DubboService
@Component
public class UserServiceImpl implements UserService {

    @Override
    public String getUserNameById(Long userId) {
        // 模擬數(shù)據(jù)庫(kù)查詢（實(shí)際開(kāi)發(fā)中替換為真實(shí)邏輯）
        if (userId == 1L) {
            return "張三";
        } else if (userId == 2L) {
            return "李四";
        }
        return "未知用戶";
    }
}

package com.example.dubbo.controller;

import com.example.dubbo.service.UserService;
import org.apache.dubbo.config.annotation.DubboReference;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class UserController {

    // @DubboReference：引用遠(yuǎn)程Dubbo服務(wù)（與@DubboService對(duì)應(yīng)）
    @DubboReference
    private UserService userService;

    @GetMapping("/user/{userId}")
    public String getUserName(@PathVariable Long userId) {
        // 遠(yuǎn)程調(diào)用UserService的方法
        return userService.getUserNameById(userId);
    }
}

package com.example.dubbo.service;

public interface UserService {
    // v1.0.0 原有方法
    String getUserNameById(Long userId);

    // v2.0.0 新增方法
    String getUserNameByPhone(String phone);
}

// v1.0.0 版本實(shí)現(xiàn)（僅實(shí)現(xiàn)原有方法）
@DubboService(version = "1.0.0")
@Component
public class UserServiceImplV1 implements UserService {
    @Override
    public String getUserNameById(Long userId) {
        // 模擬v1.0.0邏輯
        return "v1.0.0 - 張三（ID：" + userId + "）";
    }

    // 新增方法不實(shí)現(xiàn)（避免影響舊版本）
    @Override
    public String getUserNameByPhone(String phone) {
        throw new UnsupportedOperationException("v1.0.0 不支持該方法");
    }
}

// v2.0.0 版本實(shí)現(xiàn)（實(shí)現(xiàn)所有方法）
@DubboService(version = "2.0.0")
@Component
public class UserServiceImplV2 implements UserService {
    @Override
    public String getUserNameById(Long userId) {
        // 兼容v1.0.0邏輯，新增優(yōu)化
        return "v2.0.0 - 張三（ID：" + userId + "）";
    }

    @Override
    public String getUserNameByPhone(String phone) {
        // 新增方法邏輯
        if ("13800138000".equals(phone)) {
            return "v2.0.0 - 張三";
        }
        return "v2.0.0 - 未知用戶";
    }
}

@RestController
public class UserController {

    // 調(diào)用v1.0.0版本
    @DubboReference(version = "1.0.0")
    private UserService userServiceV1;

    // 調(diào)用v2.0.0版本
    @DubboReference(version = "2.0.0")
    private UserService userServiceV2;

    // 調(diào)用v1.0.0
    @GetMapping("/user/v1/{userId}")
    public String getUserNameV1(@PathVariable Long userId) {
        return userServiceV1.getUserNameById(userId);
    }

    // 調(diào)用v2.0.0新增方法
    @GetMapping("/user/v2/phone/{phone}")
    public String getUserNameV2(@PathVariable String phone) {
        return userServiceV2.getUserNameByPhone(phone);
    }
}

package com.example.dubbo.service;

/**
 * 支付接口（多實(shí)現(xiàn)：支付寶、微信支付）
 */
public interface PaymentService {
    /**
     * 支付方法
     * @param orderId 訂單ID
     * @param amount 支付金額
     * @return 支付結(jié)果
     */
    String pay(Long orderId, BigDecimal amount);
}

// 支付寶支付實(shí)現(xiàn)（group="alipay"）
@DubboService(group = "alipay")
@Component
public class AlipayServiceImpl implements PaymentService {
    @Override
    public String pay(Long orderId, BigDecimal amount) {
        return "支付寶支付成功：訂單ID=" + orderId + "，金額=" + amount + "元";
    }
}

// 微信支付實(shí)現(xiàn)（group="wxpay"）
@DubboService(group = "wxpay")
@Component
public class WxPayServiceImpl implements PaymentService {
    @Override
    public String pay(Long orderId, BigDecimal amount) {
        return "微信支付成功：訂單ID=" + orderId + "，金額=" + amount + "元";
    }
}

@RestController
public class PaymentController {

    // 引用支付寶分組的服務(wù)
    @DubboReference(group = "alipay")
    private PaymentService alipayService;

    // 引用微信支付分組的服務(wù)
    @DubboReference(group = "wxpay")
    private PaymentService wxPayService;

    // 支付寶支付接口
    @GetMapping("/pay/alipay/{orderId}/{amount}")
    public String alipay(@PathVariable Long orderId, @PathVariable BigDecimal amount) {
        return alipayService.pay(orderId, amount);
    }

    // 微信支付接口
    @GetMapping("/pay/wxpay/{orderId}/{amount}")
    public String wxpay(@PathVariable Long orderId, @PathVariable BigDecimal amount) {
        return wxPayService.pay(orderId, amount);
    }
}

package com.example.dubbo.service.impl;

import com.example.dubbo.service.FileService;
import org.apache.dubbo.config.annotation.DubboService;
import org.springframework.stereotype.Component;

// 個(gè)性化配置：超時(shí)30秒、不重試、負(fù)載均衡用最小活躍數(shù)
@DubboService(
        timeout = 30000, // 超時(shí)30秒（文件上傳耗時(shí)久）
        retries = 0,      // 不重試（非冪等，避免重復(fù)上傳）
        loadbalance = "leastactive", // 負(fù)載均衡：最小活躍數(shù)（優(yōu)先調(diào)用壓力小的服務(wù)）
        version = "1.0.0"
)
@Component
public class FileServiceImpl implements FileService {

    @Override
    public String uploadFile(String fileName, byte[] fileContent) {
        // 模擬文件上傳（耗時(shí)操作）
        try {
            Thread.sleep(5000); // 模擬耗時(shí)5秒
        } catch (InterruptedException e) {
            throw new RuntimeException("文件上傳失敗");
        }
        return "文件上傳成功：" + fileName;
    }
}