Spring Boot泛型接口多实现调用问题：Sonar合规与编译错误处理

针对保留泛型前提下的调度调用问题，以下是几种可行的解决方式：

方案一：泛型方法+安全类型转换 #

利用已确认的类型匹配关系，通过泛型方法让编译器正确推断类型，配合Class.cast()完成安全转换：

修改调度组件代码：

@Autowired
private QueueMessageReceiver<?>[] queueMessageReceivers;

@Override
public boolean onMessage(QueueMessage queueMessage) {
    for (QueueMessageReceiver<?> receiver : queueMessageReceivers) {
        if (receiver.getQueueMessageType().equals(queueMessage.getClass())) {
            return handleMessage(receiver, queueMessage);
        }
    }
    return false;
}

private <T extends QueueMessage> boolean handleMessage(QueueMessageReceiver<T> receiver, QueueMessage message) {
    // 因已验证类型匹配，这里的转换绝对安全
    T typedMessage = receiver.getQueueMessageType().cast(message);
    return receiver.onMessage(typedMessage);
}

方案二：接口新增默认方法统一调用入口 #

在泛型接口中添加非泛型的默认方法，封装类型转换逻辑，实现类无需额外修改：

首先修改QueueMessageReceiver接口：

public interface QueueMessageReceiver<T extends QueueMessage> {

    boolean onMessage(T queueMessage);

    Class<T> getQueueMessageType();

    // 新增默认方法，供调度组件统一调用
    default boolean onDispatch(QueueMessage queueMessage) {
        T typedMessage = getQueueMessageType().cast(queueMessage);
        return onMessage(typedMessage);
    }
}

然后修改调度组件的调用逻辑：

@Autowired
private QueueMessageReceiver<?>[] queueMessageReceivers;

@Override
public boolean onMessage(QueueMessage queueMessage) {
    for (QueueMessageReceiver<?> receiver : queueMessageReceivers) {
        if (receiver.getQueueMessageType().equals(queueMessage.getClass())) {
            return receiver.onDispatch(queueMessage);
        }
    }
    return false;
}

方案三：预构建类型-接收器映射（优化性能） #

如果系统中接收器数量较多，循环遍历匹配会有性能损耗，可以在初始化时构建类型到接收器的映射：

修改调度组件为构造注入并初始化映射：

private final Map<Class<? extends QueueMessage>, QueueMessageReceiver<?>> receiverMap;

@Autowired
public MessageDispatcher(List<QueueMessageReceiver<?>> receivers) {
    this.receiverMap = receivers.stream()
            .collect(Collectors.toMap(QueueMessageReceiver::getQueueMessageType, receiver -> receiver));
}

@Override
public boolean onMessage(QueueMessage queueMessage) {
    QueueMessageReceiver<?> receiver = receiverMap.get(queueMessage.getClass());
    if (receiver != null) {
        return handleMessage(receiver, queueMessage);
    }
    return false;
}

private <T extends QueueMessage> boolean handleMessage(QueueMessageReceiver<T> receiver, QueueMessage message) {
    T typedMessage = receiver.getQueueMessageType().cast(message);
    return receiver.onMessage(typedMessage);
}

内容的提问来源于stack exchange，提问作者beagle