@DubboService注解使用以及应用场景和示例代码

<!-- Dubbo核心依赖 -->
<dependency>
    <groupId>org.apache.dubbo</groupId>
    <artifactId>dubbo-spring-boot-starter</artifactId>
    <version>3.2.0</version> <!-- 推荐使用稳定版 -->
</dependency>

# 服务提供者 + 消费者 通用配置（可根据角色调整）
spring:
  application:
    name: dubbo-demo-provider # 应用名（消费者需改为dubbo-demo-consumer）
dubbo:
  protocol:
    name: dubbo # 通信协议（默认dubbo，可选http、netty等）
    port: -1 # 端口（-1表示随机端口，避免端口冲突）
  registry:
    address: nacos://127.0.0.1:8848 # Nacos注册中心地址（本地Nacos需启动）
  scan:
    base-packages: com.example.dubbo.service.impl # 服务提供者：扫描@DubboService注解的包
    # 消费者：扫描@DubboReference注解的包（如com.example.dubbo.controller）

package com.example.dubbo.service;

/**
 * 公共接口（提供者实现，消费者调用）
 */
public interface UserService {
    /**
     * 根据用户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服务，自动推断接口（仅实现一个接口）
@DubboService
@Component
public class UserServiceImpl implements UserService {

    @Override
    public String getUserNameById(Long userId) {
        // 模拟数据库查询（实际开发中替换为真实逻辑）
        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：引用远程Dubbo服务（与@DubboService对应）
    @DubboReference
    private UserService userService;

    @GetMapping("/user/{userId}")
    public String getUserName(@PathVariable Long userId) {
        // 远程调用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 版本实现（仅实现原有方法）
@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 + "）";
    }

    // 新增方法不实现（避免影响旧版本）
    @Override
    public String getUserNameByPhone(String phone) {
        throw new UnsupportedOperationException("v1.0.0 不支持该方法");
    }
}

// v2.0.0 版本实现（实现所有方法）
@DubboService(version = "2.0.0")
@Component
public class UserServiceImplV2 implements UserService {
    @Override
    public String getUserNameById(Long userId) {
        // 兼容v1.0.0逻辑，新增优化
        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 {

    // 调用v1.0.0版本
    @DubboReference(version = "1.0.0")
    private UserService userServiceV1;

    // 调用v2.0.0版本
    @DubboReference(version = "2.0.0")
    private UserService userServiceV2;

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

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

package com.example.dubbo.service;

/**
 * 支付接口（多实现：支付宝、微信支付）
 */
public interface PaymentService {
    /**
     * 支付方法
     * @param orderId 订单ID
     * @param amount 支付金额
     * @return 支付结果
     */
    String pay(Long orderId, BigDecimal amount);
}

// 支付宝支付实现（group="alipay"）
@DubboService(group = "alipay")
@Component
public class AlipayServiceImpl implements PaymentService {
    @Override
    public String pay(Long orderId, BigDecimal amount) {
        return "支付宝支付成功：订单ID=" + orderId + "，金额=" + amount + "元";
    }
}

// 微信支付实现（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 {

    // 引用支付宝分组的服务
    @DubboReference(group = "alipay")
    private PaymentService alipayService;

    // 引用微信支付分组的服务
    @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;

// 个性化配置：超时30秒、不重试、负载均衡用最小活跃数
@DubboService(
        timeout = 30000, // 超时30秒（文件上传耗时久）
        retries = 0,      // 不重试（非幂等，避免重复上传）
        loadbalance = "leastactive", // 负载均衡：最小活跃数（优先调用压力小的服务）
        version = "1.0.0"
)
@Component
public class FileServiceImpl implements FileService {

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