Cadence工作流实战：如何为技能(Skill)添加中文丝印支持

1次阅读

共计 2683 个字符，预计需要花费 7 分钟才能阅读完成。

Cadence 是一种开源的工作流编排引擎，用于构建可靠、可扩展的分布式应用程序。在 Cadence 中，技能 (Skill) 是指可重用的工作流组件，可以封装特定业务逻辑。技能通过 Activity 定义实现，Activity 是工作流中的基本执行单元。

在实际应用中，我们经常需要为技能添加多语言支持，特别是中文丝印(即界面显示的文本)。这对于国际化应用和面向中文用户的产品至关重要。

在 Cadence 中实现多语言技能支持面临几个主要挑战：

Cadence 原生不支持动态语言切换，所有文本必须在注册时确定
工作流执行上下文不包含语言信息，难以实现运行时语言选择
多语言文本维护成本高，容易产生不一致
性能考虑：额外的语言资源会增加内存占用

我们需要创建一个基础 Activity 类，封装多语言支持功能。以下是 Java 实现示例：

public abstract class I18nActivity implements Activity {
    private Map<String, Map<String, String>> translations;
    private String defaultLanguage = "en";

    protected I18nActivity() {this.translations = new HashMap<>();
        // 初始化默认语言
        translations.put(defaultLanguage, new HashMap<>());
    }

    /**
     * 添加翻译文本
     * @param key 文本键
     * @param language 语言代码
     * @param text 翻译文本
     */
    protected void addTranslation(String key, String language, String text) {translations.computeIfAbsent(language, k -> new HashMap<>())
                   .put(key, text);
    }

    /**
     * 获取翻译文本
     * @param key 文本键
     * @param language 语言代码
     * @return 翻译后的文本
     */
    protected String getText(String key, String language) {Map<String, String> langMap = translations.get(language);
        if (langMap == null || !langMap.containsKey(key)) {
            // 回退到默认语言
            return translations.get(defaultLanguage).get(key);
        }
        return langMap.get(key);
    }
}

下面是一个具体的技能实现示例，支持中英文显示：

public class PaymentSkill extends I18nActivity {public PaymentSkill() {
        // 注册英文文本
        addTranslation("payment.success", "en", "Payment processed successfully");
        addTranslation("payment.failed", "en", "Payment failed");

        // 注册中文文本
        addTranslation("payment.success", "zh", "支付处理成功");
        addTranslation("payment.failed", "zh", "支付失败");
    }

    @Override
    public void execute(ActivityExecutionContext context) {String language = context.getInput(String.class);
        boolean success = processPayment();

        if (success) {context.complete(getText("payment.success", language));
        } else {context.fail(getText("payment.failed", language));
        }
    }

    private boolean processPayment() {
        // 实际支付处理逻辑
        return true;
    }
}

在 Cadence Worker 中注册技能：

Worker worker = new Worker(
    factory,
    TASK_LIST,
    workerOptions
);

// 注册多语言技能
worker.registerActivitiesImplementations(new PaymentSkill());

在工作流中调用：

public class PaymentWorkflowImpl implements PaymentWorkflow {
    private final PaymentSkill paymentSkill = 
        Workflow.newActivityStub(PaymentSkill.class);

    @Override
    public String processPayment(String language) {return paymentSkill.execute(language);
    }
}

多语言支持会带来一定的性能开销，主要来自：