Camunda External Task Client (Java) 實戰(zhàn)指南遠程 Service Task 的抓取、鎖定與任務處理【免費下載鏈接】camunda-bpm-platformCamunda 7 CE is End of Life (EoL). Please check out Camunda 8 instead (https://github.com/camunda/camunda) or read about Camunda 7 Enterprise End of Life (https://camunda.com/blog/2025/02/camunda-7-enterprise-end-of-life-extension/) – Camunda 7 CE was a flexible framework for workflow and decision automation using BPMN and DMN.項目地址: https://gitcode.com/GitHub_Trending/ca/camunda-bpm-platform導讀本文以當前倉庫clients/java/README.md為骨架結合camunda-external-task-client模塊的源碼、集成測試與pom.xml系統(tǒng)講解如何用 Java 客戶端將 Camunda Platform 7 工作流中的 Service Task 以「外部任務External Task」的形式交給獨立的 Worker 進程處理。讀完本文你將掌握客戶端的 Maven 引入方式、ExternalTaskClientBuilder與TopicSubscriptionBuilder兩套流式配置 API 的全部參數(shù)、ExternalTaskService的任務操作完成、報錯、報 BPMN 錯誤、延長鎖、解鎖、設置變量以及原始類型與對象類型流程變量的序列化共享機制并能直接照搬示例接入自己的業(yè)務系統(tǒng)。說明Camunda 7 CECommunity Edition已進入 EoL 階段本倉庫clients/java/client/pom.xml中亦注明 7.24.0 是發(fā)布到 Maven Central 的最后一個社區(qū)版。本文內(nèi)容適用于倉庫當前版本7.24.0-SNAPSHOT請結合自身許可與運維策略使用。一、什么是 External Task Client把 Service Task 搬到進程外在傳統(tǒng)工作流引擎中Service Task 通常由引擎內(nèi)部的 JavaDelegate 或表達式直接執(zhí)行這意味著業(yè)務代碼必須與引擎部署在同一個進程里。Camunda 的外部任務External Task模式則反其道而行之BPMN 中的 Service Task 只聲明一個camunda:topic引擎本身不做任何業(yè)務計算而是把任務「出借」給外部 Worker。clients/java模塊正是官方提供的 Java 版外部任務客戶端它允許你為工作流設置遠程 Service Task。整體交互模型是經(jīng)典的Fetch LockWorker 通過客戶端周期性向引擎 REST API 發(fā)起fetch-and-lock請求按topic領取任務引擎將符合條件的任務鎖定給該 Worker鎖定期間其他 Worker 無法領取并把任務上下文變量、流程實例信息等返回給客戶端Worker 執(zhí)行業(yè)務邏輯然后通過complete完成任務或通過handleFailure/handleBpmnError反饋失敗與業(yè)務錯誤任務完成或失敗處理后流程實例在引擎?zhèn)壤^續(xù)推進。倉庫入口文檔位于 clients/java/README.md客戶端本體在 clients/java/client 目錄其中src/main/java/org/camunda/bpm/client/是全部核心實現(xiàn)src/it/java/org/camunda/bpm/client/下是與真實引擎聯(lián)調(diào)的集成測試。特性清單Features根據(jù) README該客戶端提供如下核心能力后續(xù)章節(jié)會逐一結合源碼展開Complete External Tasks—— 完成任務ExternalTaskService.complete(...)Extend the lock duration of External Tasks—— 延長任務鎖定時長extendLock(...)Unlock External Tasks—— 主動解鎖釋放任務供其他 Worker 領取unlock(...)Report BPMN errors as well as failures—— 上報 BPMN 錯誤handleBpmnError(...)與執(zhí)行失敗handleFailure(...)Share primitive and object typed process variables with the Workflow Engine—— 與引擎共享基本類型與對象類型的流程變量ClientValues與ValueMapper體系。若你使用 Spring BootREADME 開頭特別提示若你使用的是 Spring Boot 場景應轉(zhuǎn)向 Spring Boot External Task Client倉庫內(nèi)對應目錄為 spring-boot-starter/starter-client內(nèi)含spring與spring-boot兩個子模塊及獨立 README。本文聚焦純 Java 版客戶端。二、環(huán)境準備PrerequisitesJava使用所對應 Camunda Platform 7 版本支持的 JDK 版本當前倉庫為 7.24.x 系列Camunda Platform 7客戶端通過 REST API 與引擎通信因此需要一個運行中的 Camunda Platform 7 引擎實例含 REST API 部署網(wǎng)絡可達Worker 所在進程需能訪問引擎 REST API 的baseUrl。三、Maven 坐標與依賴引入在項目的pom.xml中加入如下依賴README 原樣給出的坐標dependency groupIdorg.camunda.bpm/groupId artifactIdcamunda-external-task-client/artifactId version${version}/version /dependency其中${version}需替換為實際使用的版本當前倉庫對應版本為7.24.0-SNAPSHOT見 clients/java/client/pom.xml 的version與parent聲明。從該pom.xml的依賴聲明可以看到客戶端的底層技術棧與直接依賴依賴用途org.apache.httpcomponents.client5:httpclient5Apache HttpClient 5負責與引擎 REST API 的 HTTP 通信com.fasterxml.jackson.core:jackson-databindJSON 序列化/反序列化ObjectMapper配置見下文org.camunda.commons:camunda-commons-logging統(tǒng)一日志框架org.camunda.commons:camunda-commons-typed-values類型化變量TypedValue/VariableMap的公共類型體系測試與集成測試階段還會用到camunda-bpmn-model構造 BPMN 模型、camunda-spin-dataformat-all、assertj-core、junit等但它們不是運行期必需依賴。四、客戶端配置ExternalTaskClientBuilder 全參數(shù)詳解客戶端通過ExternalTaskClient.create()返回流式構建器ExternalTaskClientBuilder接口定義見 ExternalTaskClientBuilder.java默認實現(xiàn)見 ExternalTaskClientBuilderImpl.java。該構建器的 JavaDoc 中明確寫著“A fluent builder to configure the Camunda client”。最小可用示例ExternalTaskClient client ExternalTaskClient.create() .baseUrl(http://localhost:8080/engine-rest) // 必填引擎 REST API 地址 .workerId(my-worker) // 可選自定義 Worker ID .maxTasks(10) // 可選單次請求最多抓取任務數(shù) .build();4.1 全部配置項一覽下表綜合接口 JavaDoc 與ExternalTaskClientBuilderImpl構造函數(shù)中的默認值見 ExternalTaskClientBuilderImpl.java全部配置項均可鏈式調(diào)用配置方法是否必填默認值說明baseUrl(String)二選一無Camunda BPM Platform REST API 的基礎 URL。調(diào)用后將創(chuàng)建PermanentUrlResolver固定使用該地址urlResolver(UrlResolver)二選一無自定義 URL 解析器。當引擎位于集群或使用 Spring Cloud 等動態(tài)服務發(fā)現(xiàn)時實現(xiàn)UrlResolver#getBaseUrl()workerId(String)可選自動生成引擎感知的 Worker ID。不傳或傳null時自動生成「hostname 128 位隨機 UUID」的組合。注意請保證 Worker ID 唯一addInterceptor(ClientRequestInterceptor)可選無請求攔截器在請求發(fā)往 HTTP 服務器前修改請求如加鑒權頭可添加多個maxTasks(int)可選10單次 fetch-and-lock 請求最多抓取的任務數(shù)usePriority(boolean)可選true是否按任務優(yōu)先級抓取任務false則任意順序useCreateTime(boolean)可選false是否按創(chuàng)建時間抓取true時按創(chuàng)建時間降序新任務優(yōu)先orderByCreateTime()asc()/desc()可選無更精細的排序控制先用orderByCreateTime()指定排序字段再用asc()/desc()指定方向?qū)狾rderingConfigdefaultSerializationFormat(String)可選application/json未顯式指定格式時對象變量的默認序列化格式BuilderImpl中取Variables.SerializationDataFormats.JSONdateFormat(String)可選yyyy-MM-ddTHH:mm:ss.SSSZ日期變量的序列化/反序列化格式asyncResponseTimeout(long)可選無同步異步響應長輪詢超時單位毫秒。設置了該值后fetch-and-lock 變?yōu)楫惒介L輪詢請求時若已有可用任務則立即返回lockDuration(long)可選2000020 秒任務默認鎖定時長毫秒必須大于 0會被主題訂閱上配置的lockDuration覆蓋disableAutoFetching()可選自動抓取開啟禁止在build()時立即啟動抓取之后必須顯式調(diào)用ExternalTaskClient#start()才開始backoffStrategy(BackoffStrategy)可選ExponentialBackoffStrategy自定義兩次請求之間的退避策略disableBackoffStrategy()可選未禁用禁用客戶端側(cè)退避。注意禁用后可能給引擎造成較重負載建議配合適當?shù)腶syncResponseTimeoutcustomizeHttpClient(ConsumerHttpClientBuilder)可選無暴露內(nèi)部 ApacheHttpClientBuilder以做自定義超時、代理等。注意通過addInterceptor添加的攔截器會在build()時最后追加build()必調(diào)—完成配置并啟動客戶端返回ExternalTaskClient4.2 build() 的校驗規(guī)則build()在以下情況下會拋出ExternalTaskClientException見 ExternalTaskClientBuilder.java 的 JavaDocbaseUrl為null或空字符串無法獲取主機名自動生成 workerId 失敗maxTasks不大于 0asyncResponseTimeout不大于 0lockDuration不大于 0。4.3 集群 / Spring Cloud 場景的 UrlResolver當引擎以集群方式部署或你使用了 Spring Cloud 的服務發(fā)現(xiàn)時baseUrl不再適用。此時實現(xiàn)UrlResolver接口見 UrlResolver.java在每次請求時動態(tài)返回可用實例地址。ExternalTaskClientBuilder的 JavaDoc 中給出了基于 Spring CloudDiscoveryClient的示例骨架從服務實例列表中隨機挑選一個實例的 URI 作為getBaseUrl()的返回值。這保證了某個引擎實例不可達時Worker 仍能通過服務發(fā)現(xiàn)路由到健康實例。4.4 認證與請求攔截器addInterceptor(ClientRequestInterceptor)允許你在請求發(fā)送前修改請求。倉庫內(nèi)置了基礎認證實現(xiàn) BasicAuthProvider.java可用于引擎開啟了 Basic Auth 的場景攔截器體系定義見 ClientRequestInterceptor.java請求上下文封裝在 ClientRequestContext.java。五、主題訂閱TopicSubscriptionBuilder 全參數(shù)詳解創(chuàng)建客戶端后通過client.subscribe(topicName)得到TopicSubscriptionBuilder接口見 TopicSubscriptionBuilder.java實現(xiàn)見 TopicSubscriptionBuilderImpl.java。一個客戶端可以訂閱多個 topic每個 topic 綁定一個ExternalTaskHandler。client.subscribe(credit-score-topic) // BPMN 模型中 camunda:topic 指定的名稱 .lockDuration(30_000) // 該主題的鎖定時間覆蓋客戶端級默認值 .variables(customerId, amount) // 僅抓取需要的變量減小負載 .handler((externalTask, externalTaskService) - { // 業(yè)務邏輯 externalTaskService.complete(externalTask); }) .open(); // 開始異步抓取5.1 全部配置項一覽配置方法說明lockDuration(long)該主題的任務鎖定時長毫秒必須大于 0默認 20 秒覆蓋客戶端級lockDurationhandler(ExternalTaskHandler)必填。每個被抓取并鎖定的任務都會回調(diào)該處理器variables(String... variableNames)指定需要隨任務抓取的變量名列表減小傳輸與反序列化開銷localVariables(boolean)false抓取外部任務作用域內(nèi)可見的全部變量含祖先作用域true僅抓取外部任務所在作用域的局部變量businessKey(String)按流程實例 business key 過濾待抓取任務processDefinitionId(String)按流程定義 ID 過濾processDefinitionIdIn(String...)按多個流程定義 ID 過濾processDefinitionKey(String)按流程定義 Key 過濾processDefinitionKeyIn(String...)按多個流程定義 Key 過濾processDefinitionVersionTag(String)按流程定義版本標簽過濾processVariablesEqualsIn(MapString, Object)按流程變量名/值匹配過濾多變量processVariableEquals(String name, Object value)按單個流程變量名/值匹配過濾多次調(diào)用時表示「任一」?jié)M足即可抓取此時建議改用processVariablesEqualsInwithoutTenantId()只抓取無租戶tenant的任務tenantIdIn(String...)按租戶 ID 列表過濾includeExtensionProperties(boolean)是否在抓取的任務中附帶自定義擴展屬性BPMN 活動上定義的camunda:extensionProperties默認false5.2 open() 的校驗規(guī)則與異步執(zhí)行open()將主題訂閱發(fā)布為異步執(zhí)行出現(xiàn)以下情況拋出ExternalTaskClientException見 TopicSubscriptionBuilder.javatopic 名稱為null或空字符串lockDuration不大于 0handler為null該 topic 名稱已被訂閱不允許重復訂閱同名 topic。5.3 ExternalTaskHandler業(yè)務代碼的入口ExternalTaskHandler是一個函數(shù)式接口ExternalTaskHandler.java只有一個方法void execute(ExternalTask externalTask, ExternalTaskService externalTaskService);它「對每個被抓取并鎖定的任務執(zhí)行一次」ExternalTask攜帶任務上下文ExternalTaskService提供對任務的后續(xù)操作。集成測試 ExternalTaskHandlerIT.java 展示了完整鏈路部署帶外部任務的 BPMN 模型 → 啟動流程實例 →client.subscribe(EXTERNAL_TASK_TOPIC_FOO).handler(handler).open()→ 斷言 handler 收到的任務攜帶正確的processDefinitionId、processDefinitionKey、businessKey、processInstanceId、activityId、topicName、lockExpirationTime等信息。這是“訂閱-抓取-回調(diào)”閉環(huán)的實測證據(jù)。六、ExternalTask任務上下文模型ExternalTask接口ExternalTask.java封裝了從引擎帶回的任務上下文主要 getter 包括標識類getId()、getActivityId()、getActivityInstanceId()、getExecutionId()、getProcessInstanceId()、getProcessDefinitionId()、getProcessDefinitionKey()、getProcessDefinitionVersionTag()業(yè)務類getBusinessKey()、getTopicName()、getTenantId()、getPriority()、getWorkerId()、getRetries()、getLockExpirationTime()、getCreateTime()錯誤類getErrorMessage()、getErrorDetails()最近一次上報失敗時的信息變量類getVariable(String)/getAllVariables()—— 未類型化untyped取值getVariableTyped(String)/getAllVariablesTyped()—— 類型化取值TypedValue/VariableMap可傳deserializeObjectValue控制是否反序列化對象getExtensionProperty(String)/getExtensionProperties()—— 擴展屬性需訂閱時開啟includeExtensionProperties(true)BPMN 活動上通過camunda:extensionProperties定義。七、任務操作ExternalTaskService 全 APIExternalTaskServiceExternalTaskService.java提供對已抓取任務的全部交互能力幾乎所有方法都支持「傳ExternalTask對象」或「傳String externalTaskId」兩種重載。7.1 完成任務// 無變量 externalTaskService.complete(externalTask); // 攜帶流程變量設置到任務的祖先執(zhí)行層級 externalTaskService.complete(externalTask, variables); // 同時攜帶流程變量與局部變量局部變量設置到外部任務實例所在執(zhí)行 externalTaskService.complete(externalTask, variables, localVariables); // 直接傳任務 ID externalTaskService.complete(externalTaskId, variables, localVariables);7.2 上報失敗handleFailureexternalTaskService.handleFailure(externalTask, error message, // 失敗原因 error details, // 詳細錯誤描述 retries, // 剩余重試次數(shù)必須 0設為 0 會創(chuàng)建 Incident 且任務不再被抓取除非重試次數(shù)被調(diào)高 retryTimeout); // 重試前等待毫秒數(shù)必須 0之后任務重新可被抓取另有重載可同時攜帶variables與localVariableshandleFailure(taskId, errorMessage, errorDetails, retries, retryTimeout, variables, localVariables)。當retries 0時引擎會為任務創(chuàng)建 IncidentIncident 消息即errorMessage對應集成測試 IncidentDto 與ExternalTaskHandlerIT中的失敗用例。7.3 上報 BPMN 錯誤handleBpmnError// 最小形式errorCode 用于匹配 BPMN 模型中的錯誤處理器 externalTaskService.handleBpmnError(externalTask, errorCode); // 附帶錯誤消息 externalTaskService.handleBpmnError(externalTask, errorCode, errorMessage); // 附帶錯誤消息與變量錯誤被捕獲時傳遞給執(zhí)行 externalTaskService.handleBpmnError(externalTask, errorCode, errorMessage, variables); // 傳任務 ID 的形式 externalTaskService.handleBpmnError(externalTaskId, errorCode, errorMessage, variables);errorCode用于識別 BPMN 錯誤處理器如邊界錯誤事件。集成測試ExternalTaskHandlerIT中通過部署含BoundaryEventErrorEventDefinition的流程驗證了上報 BPMN 錯誤后流程沿錯誤邊界繼續(xù)流轉(zhuǎn)的行為。7.4 鎖定相關lock / unlock / extendLock// 手動鎖定適用于通過非 fetch lock 途徑如 REST API獲取的任務 externalTaskService.lock(externalTaskId, lockDuration); externalTaskService.lock(externalTask, lockDuration); // 解鎖清除任務的鎖過期時間與 workerId使任務可被其他 Worker 領取 externalTaskService.unlock(externalTask); // 延長鎖為仍在執(zhí)行中的任務延長鎖定時長毫秒 externalTaskService.extendLock(externalTask, newDuration); externalTaskService.extendLock(externalTaskId, newDuration);extendLock是長耗時任務的關鍵 API默認鎖定 20 秒若業(yè)務執(zhí)行超過鎖定時長需在處理過程中持續(xù)延長鎖否則任務會被引擎判定為“鎖過期”而重新分發(fā)給其他 Worker造成重復執(zhí)行。7.5 設置變量setVariables// 按流程實例 ID 設置變量變量設置到任務的祖先執(zhí)行層級 externalTaskService.setVariables(processInstanceId, variables); // 按任務對象設置變量 externalTaskService.setVariables(externalTask, variables);變量 Map 可以同時包含類型化與非類型化變量。7.6 異常體系所有引擎交互都可能拋出以下客戶端異常見 exception 包異常觸發(fā)場景NotFoundException任務不存在或已被取消/完成BadRequestException非法操作或數(shù)據(jù)無效如未取得任務最新鎖EngineException引擎?zhèn)葓?zhí)行出錯如持久化異常ConnectionLostException無法建立連接UnknownHttpErrorExceptionHTTP 狀態(tài)碼不在客戶端已知范圍內(nèi)ValueMapperException對象無法序列化/反序列化、非空值未提供objectTypeName、值為抽象類型、找不到合適的序列化器RestException/DataFormatException/ExternalTaskClientExceptionREST 通用錯誤 / 數(shù)據(jù)格式錯誤 / 客戶端配置類錯誤八、與引擎共享流程變量primitive 與 object 類型這是 README 特性清單中的最后一項也是外部任務模式里最常踩坑的地方。客戶端通過兩層機制完成變量共享8.1 變量值映射器ValueMapper客戶端為每種變量類型注冊了專用的ValueMapper見 mapper 包注冊邏輯集中在 DefaultValueMappers.java基本類型BooleanValueMapper、ByteArrayValueMapper、DateValueMapper、DoubleValueMapper、IntegerValueMapper、LongValueMapper、ShortValueMapper、StringValueMapper、NullValueMapper、NumberValueMapper對象類型ObjectValueMapperJava 對象序列化為 JSON、FileValueMapper文件變量支持DeferredFileValue延遲下載文件內(nèi)容、JsonValueMapper、XmlValueMapper。DeferredFileValue見 DeferredFileValue.java允許先取到文件的元數(shù)據(jù)僅在真正訪問內(nèi)容時才從引擎下載避免大文件隨每個任務全量傳輸。集成測試 FileSerializationIT.java 與 PrimitiveVariableIT.java 覆蓋了這些場景。8.2 序列化格式JSON 與 XMLClientValuesClientValues.java繼承自引擎的Variables額外提供JSON與XML兩種類型化值// 類型化 JSON 變量 ClientValues.jsonValue({\key\: \value\}); ClientValues.jsonValue(jsonString, true); // 第二個參數(shù) isTransient臨時變量 // 類型化 XML 變量 ClientValues.xmlValue(roota1/a/root); ClientValues.xmlValue(xmlString, true);序列化格式通過 SPI 機制加載DataFormatProvider/DataFormatConfigurator見 spi 包JSON默認格式application/json基于 Jackson 實現(xiàn)JacksonJsonDataFormat.java并提供DefaultJsonJacksonTypeDetector/ListJacksonJsonTypeDetector進行類型探測XML基于 DOM 實現(xiàn)DomXmlDataFormat.javaJava 序列化SerializableDataFormat支持java.io.Serializable對象見 SerializableDataFormat.java?？蛻舳四J序列化格式與日期格式可通過構建器的defaultSerializationFormat(...)和dateFormat(...)調(diào)整。相關集成測試覆蓋了 JsonSerializationIT.java、XmlSerializationIT.java、JavaSerializationIT.java 與 LocalVariableIT.java 等。九、高級特性長輪詢、退避策略與運行控制9.1 長輪詢Long Polling默認情況下 fetch-and-lock 是同步請求引擎立即返回當前可用任務可能為空。通過.asyncResponseTimeout(millis)開啟長輪詢請求會在引擎?zhèn)葤炱鹱疃嘀付ê撩霐?shù)期間一旦有任務可用立即返回若超時仍無任務則返回空集。長輪詢可顯著降低 Worker 空轉(zhuǎn)請求的頻率減輕引擎壓力。9.2 退避策略Backoff Strategy兩次請求之間默認采用指數(shù)退避策略ExponentialBackoffStrategyExponentialBackoffStrategy.java默認參數(shù)為initTime 500毫秒第一次無任務后的等待時間factor 2等待時間的增長基數(shù)maxTime 60000毫秒最大等待時間封頂。其核心邏輯為reconfigure(ListExternalTask)在每次抓取后調(diào)用——若抓取結果為空則退避層級level加一否則重置為 0calculateBackoffTime()返回min(initTime * factor^(level-1), maxTime)。即連續(xù)抓不到任務時等待時間指數(shù)上升500ms → 1s → 2s → …一旦有任務則立即恢復零等待避免對空閑引擎發(fā)起高頻空轉(zhuǎn)請求。BackoffStrategy接口BackoffStrategy.java要求實現(xiàn)reconfigure(ListExternalTask)與calculateBackoffTime()兩個方法JavaDoc 特別提醒由于同一策略可能被多線程并發(fā)調(diào)用自定義實現(xiàn)必須保證線程安全。倉庫還提供了針對錯誤響應的變體ExponentialErrorBackoffStrategy與ErrorAwareBackoffStrategy見 backoff 包。若你自行實現(xiàn)了BackoffStrategy通過.backoffStrategy(myStrategy)注入若確需完全關閉退避使用.disableBackoffStrategy()但應留意引擎?zhèn)蓉撦d并建議配合asyncResponseTimeout使用。9.3 運行控制與生命周期ExternalTaskClientExternalTaskClient.java提供ExternalTaskClient client ExternalTaskClient.create().baseUrl(url).build(); client.start(); // 開始持續(xù)抓取與鎖定任務默認 build() 后即自動開始 client.stop(); // 停止持續(xù)抓取與鎖定 boolean active client.isActive(); // 是否處于活躍抓取狀態(tài)若想完全控制啟動時機可調(diào)用.disableAutoFetching()隨后手動start()。十、源碼結構與集成測試從代碼到實測對想要深入源碼或貢獻代碼的讀者建議按以下路徑閱讀核心 APIExternalTaskClient.java、ExternalTaskClientBuilder.java、TopicSubscriptionBuilder.java、ExternalTaskService.java、ExternalTask.java內(nèi)部實現(xiàn)ExternalTaskClientBuilderImpl.java默認值與校驗邏輯、ExternalTaskServiceImpl.java、TopicSubscriptionManager.java抓取調(diào)度、RequestExecutor.javaHTTP 執(zhí)行DTO 層task/impl/dto 下的CompleteRequestDto、FailureRequestDto、BpmnErrorRequestDto、ExtendLockRequestDto、LockRequestDto、SetVariablesRequestDto、ExceptionResponseDto以及 topic/impl/dto 下的FetchAndLockRequestDto、FetchAndLockResponseDto、TopicRequestDto映射引擎 REST API 的請求/響應體集成測試client/src/it/java/org/camunda/bpm/client 下按主題分類task/ExternalTaskHandlerIT、topic/TopicSubscriptionIT、variable/PrimitiveVariableIT、variable/JsonSerializationIT、variable/XmlSerializationIT、variable/LocalVariableIT等均通過與真實引擎EngineRuleClientRule見 rule 包聯(lián)調(diào)驗證端到端行為單元測試client/src/test/java/org/camunda/bpm/client 下的ExponentialBackoffStrategyTest、ExternalTaskClientBuilderImplTest、ExternalTaskImplTest、DateValueMapperTest等QA 輔助模塊clients/java/qa/engine-variable-test 提供了變量測試用的引擎應用含Application、Bean、MyExecutionListener供集成測試復用。十一、注意事項與適用前提本文所有行為描述均基于當前倉庫代碼版本7.24.0-SNAPSHOT。clients/java/client/pom.xml的description明確指出7.24.0 是發(fā)布到 Maven Central 的最后一個社區(qū)版該庫之后不再發(fā)布新版本如需延長維護可考慮 Camunda 企業(yè)版本文不作展開。客戶端僅通過 REST API 與引擎交互因此引擎必須暴露并允許訪問 REST API 端點workerId建議唯一且語義清晰便于在引擎的 External Task 列表中識別 Worker長耗時任務務必使用extendLock維持鎖并合理設計retries/retryTimeout與退避策略避免引擎?zhèn)蓉撦d與任務重復執(zhí)行。結語Camunda External Task Client (Java) 以“Fetch Lock”模式把工作流中的 Service Task 從引擎進程內(nèi)解放出來讓業(yè)務代碼以獨立 Worker 的形式水平擴展、獨立發(fā)布。本文完整覆蓋了 README 聲明的全部特性與配置入口并深入到構建器默認值、退避算法、變量映射器與集成測試等源碼細節(jié)。動手實踐時可直接以 clients/java/client/src/it/java/org/camunda/bpm/client 下的集成測試為參照搭建自己的外部任務 Worker。倉庫內(nèi)相關資源clients/java/README.md、clients/java/client/pom.xml、spring-boot-starter/starter-clientSpring Boot 版入口、CONTRIBUTING.md貢獻指南、LICENSEApache License Version 2.0?！久赓M下載鏈接】camunda-bpm-platformCamunda 7 CE is End of Life (EoL). Please check out Camunda 8 instead (https://github.com/camunda/camunda) or read about Camunda 7 Enterprise End of Life (https://camunda.com/blog/2025/02/camunda-7-enterprise-end-of-life-extension/) – Camunda 7 CE was a flexible framework for workflow and decision automation using BPMN and DMN.項目地址: https://gitcode.com/GitHub_Trending/ca/camunda-bpm-platform創(chuàng)作聲明：本文部分內(nèi)容由AI輔助生成（AIGC），僅供參考