Mule 4模块中能否创建可访问Connection的Scope？

Mule 4的Scope确实不允许直接通过@Connection注解传入连接参数，但可以通过以下两种方式实现：

方法一：通过ConnectionProvider注入获取连接（官方推荐） #

在Scope类中注入ConnectionProvider<MyConnection>，通过它来创建和管理连接，代码示例如下：

import org.mule.runtime.api.connection.ConnectionProvider;
import org.mule.runtime.api.exception.MuleException;
import org.mule.runtime.extension.api.annotation.param.Inject;
import org.mule.runtime.extension.api.runtime.operation.Chain;
import org.mule.runtime.extension.api.runtime.operation.CompletionCallback;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class MyScopeComponent {
    private static final Logger logger = LoggerFactory.getLogger(MyScopeComponent.class);

    @Inject
    private ConnectionProvider<MyConnection> connectionProvider;

    public void logDecorator(Chain operations, CompletionCallback<Object, Object> callback) {
        MyConnection connection = null;
        try {
            // 获取连接
            connection = connectionProvider.connect();
            logger.debug("成功获取连接: {}", connection);
            
            // 执行你的业务逻辑，使用connection
            // ...
            
            // 处理子流程
            logger.debug("执行子操作");
            operations.process(
                result -> {
                    logger.debug("子操作完成: {}", result.getOutput());
                    callback.success(result);
                },
                (error, previous) -> {
                    logger.error("子操作出错: {}", error.getMessage());
                    callback.error(error);
                });
        } catch (MuleException e) {
            logger.error("获取连接失败", e);
            callback.error(e);
        } finally {
            // 确保连接被释放
            if (connection != null) {
                try {
                    connectionProvider.disconnect(connection);
                } catch (MuleException e) {
                    logger.warn("释放连接失败", e);
                }
            }
        }
    }
}

这种方式符合Mule的连接管理规范，能保证连接的正确创建和释放，避免资源泄漏。

方法二：通过ExecutionContext获取当前上下文的连接 #

如果你的Scope是在某个Connection Config的作用域内运行，可以通过ExecutionContext来获取当前的连接实例：

import org.mule.runtime.extension.api.runtime.operation.Chain;
import org.mule.runtime.extension.api.runtime.operation.CompletionCallback;
import org.mule.runtime.extension.api.runtime.operation.ExecutionContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class MyScopeComponent {
    private static final Logger logger = LoggerFactory.getLogger(MyScopeComponent.class);

    public void logDecorator(Chain operations,
                             CompletionCallback<Object, Object> callback,
                             ExecutionContext executionContext) {
        try {
            // 从执行上下文获取当前连接
            MyConnection connection = executionContext.getConnection().orElseThrow(() -> 
                new RuntimeException("当前上下文无可用连接"));
                
            logger.debug("从上下文获取连接: {}", connection);
            // 使用连接处理业务逻辑
            // ...
            
            operations.process(
                result -> callback.success(result),
                (error, previous) -> callback.error(error));
        } catch (Exception e) {
            logger.error("处理出错", e);
            callback.error(e);
        }
    }
}

注意：这种方式依赖于Scope所在的上下文有活跃的连接，如果上下文没有配置连接，会抛出异常，适用性不如第一种方法广泛。

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