java案例如何分配不同场景的权重？

wen java案例 2026-08-06 2

本文目录导读：

java案例如何分配不同场景的权重？

策略模式 + 权重配置
基于注解的自动装配
基于配置文件的权重管理
算法驱动的权重动态调整
综合实践示例
最佳实践建议

在Java中分配不同场景的权重，通常有几种常见的设计模式和方法,我来详细讲解几种实用的方案：

策略模式 + 权重配置

这是最常用且灵活的方式,适合业务规则经常变化的场景：

// 定义策略接口
public interface SceneStrategy {
    double getWeight();
    void execute();
}
// 具体场景实现
@Component
public class HighTrafficScene implements SceneStrategy {
    @Override
    public double getWeight() {
        return 0.5; // 50%权重
    }
    @Override
    public void execute() {
        // 高流量场景逻辑
    }
}
@Component
public class EmergencyScene implements SceneStrategy {
    @Override
    public double getWeight() {
        return 0.3; // 30%权重
    }
    @Override
    public void execute() {
        // 紧急场景逻辑
    }
}
// 权重管理器
public class WeightManager {
    private final Map<String, SceneStrategy> strategies = new HashMap<>();
    public void register(String sceneId, SceneStrategy strategy) {
        strategies.put(sceneId, strategy);
    }
    // 根据权重随机选择场景
    public SceneStrategy chooseByWeight() {
        double totalWeight = strategies.values().stream()
            .mapToDouble(SceneStrategy::getWeight)
            .sum();
        double random = Math.random() * totalWeight;
        double cumulativeWeight = 0;
        for (SceneStrategy strategy : strategies.values()) {
            cumulativeWeight += strategy.getWeight();
            if (random < cumulativeWeight) {
                return strategy;
            }
        }
        return null;
    }
}

基于注解的自动装配

适合需要自动扫描和配置的场景：

@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.TYPE)
public @interface SceneWeight {
    String sceneId();
    double weight();
}
@SceneWeight(sceneId = "order", weight = 0.4)
public class OrderProcessScene implements ProcessScene {
    @Override
    public void process() {
        // 订单处理逻辑
    }
}
@SceneWeight(sceneId = "payment", weight = 0.3)
public class PaymentProcessScene implements ProcessScene {
    @Override
    public void process() {
        // 支付处理逻辑
    }
}
// 全局场景注册器
@Component
public class SceneRegistry implements ApplicationContextAware {
    private final Map<String, SceneEntry> sceneMap = new ConcurrentHashMap<>();
    @Override
    public void setApplicationContext(ApplicationContext context) {
        Map<String, Object> beans = context.getBeansWithAnnotation(SceneWeight.class);
        beans.forEach((beanName, bean) -> {
            SceneWeight annotation = bean.getClass().getAnnotation(SceneWeight.class);
            SceneEntry entry = new SceneEntry(
                annotation.sceneId(),
                annotation.weight(),
                (ProcessScene) bean
            );
            sceneMap.put(annotation.sceneId(), entry);
        });
    }
    // 动态调整权重的方法
    public void adjustWeight(String sceneId, double newWeight) {
        SceneEntry entry = sceneMap.get(sceneId);
        if (entry != null) {
            entry.setWeight(newWeight);
            log.info("场景 {} 权重调整为 {}", sceneId, newWeight);
        }
    }
}

基于配置文件的权重管理

适合需要频繁调整且不想重新部署的场景：

# application.yml
scene:
  weights:
    order-scene: 0.4
    payment-scene: 0.3
    refund-scene: 0.2
    complaint-scene: 0.1
  dynamic: true

@Configuration
@ConfigurationProperties(prefix = "scene")
public class SceneWeightConfig {
    private Map<String, Double> weights;
    private boolean dynamic;
    // 动态更新权重
    public void updateWeight(String sceneId, double newWeight) {
        weights.put(sceneId, newWeight);
        refreshWeights();
    }
    // 定时刷新权重
    @Scheduled(cron = "0 */5 * * * ?") // 每5分钟刷新
    public void refreshWeights() {
        // 从配置中心或数据库读取最新权重
        Map<String, Double> latestWeights = loadLatestWeights();
        this.weights = latestWeights;
        log.info("场景权重已更新: {}", weights);
    }
    private Map<String, Double> loadLatestWeights() {
        // 从数据库或配置中心加载
        return new HashMap<>();
    }
}

算法驱动的权重动态调整

根据实时数据进行权重调整：

public class AdaptiveWeightService {
    private final MetricsCollector metricsCollector;
    public void updateWeightsDynamically() {
        Map<String, SceneMetric> metrics = metricsCollector.getMetrics();
        metrics.forEach((sceneId, metric) -> {
            double newWeight = calculateWeight(metric);
            sceneWeightRepository.updateWeight(sceneId, newWeight);
        });
    }
    private double calculateWeight(SceneMetric metric) {
        // 考虑因素：成功率、响应时间、用户反馈、业务价值等
        double successFactor = metric.getSuccessRate() * 0.4;
        double timeFactor = 1.0 / (1 + metric.getAvgResponseTime()) * 0.2;
        double valueFactor = metric.getBusinessValue() * 0.3;
        double feedbackFactor = metric.getUserFeedback() * 0.1;
        return successFactor + timeFactor + valueFactor + feedbackFactor;
    }
}
// 实时监控数据
public class SceneMetric {
    private String sceneId;
    private double successRate;
    private double avgResponseTime;
    private double businessValue;
    private double userFeedback;
}

综合实践示例

一个完整的生产级实现：

@Service
public class SceneWeightDispatcher {
    private final List<SceneStrategy> strategies;
    private final SceneWeightRepository weightRepository;
    public Scene executeScene(String requestId) {
        // 1. 获取最新的权重配置
        Map<String, Double> weights = weightRepository.getCurrentWeights();
        // 2. 基于权重选择场景
        SceneStrategy selectedStrategy = selectByWeight(weights);
        // 3. 执行场景
        SceneResult result = selectedStrategy.execute();
        // 4. 记录执行结果，用于后续优化
        metricsCollector.record(requestId, 
            selectedStrategy.getClass().getName(), 
            result);
        return new Scene(selectedStrategy, result);
    }
    private SceneStrategy selectByWeight(Map<String, Double> weights) {
        double total = weights.values().stream()
            .mapToDouble(Double::doubleValue)
            .sum();
        double random = Math.random() * total;
        double cumulative = 0;
        for (String sceneId : weights.keySet()) {
            cumulative += weights.get(sceneId);
            if (random < cumulative) {
                return strategies.stream()
                    .filter(s -> s.supports(sceneId))
                    .findFirst()
                    .orElseThrow();
            }
        }
        // 兜底策略
        return strategies.stream()
            .filter(SceneStrategy::isFallback)
            .findFirst()
            .orElseThrow();
    }
}