diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/client/NifiClient.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/client/NifiClient.java index c441151f..58748595 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/client/NifiClient.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/client/NifiClient.java @@ -6,17 +6,14 @@ import okhttp3.*; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; -import javax.net.ssl.SSLContext; -import javax.net.ssl.SSLSocketFactory; -import javax.net.ssl.TrustManager; -import javax.net.ssl.X509TrustManager; import java.io.IOException; import java.nio.charset.StandardCharsets; -import java.security.SecureRandom; -import java.security.cert.X509Certificate; +import java.util.Map; import java.util.concurrent.atomic.AtomicReference; /** + * nifi客户端请求处理 + * * @Author:liuyang * @Package:com.hzya.frame.nifi.client * @Project:fw-nifi @@ -68,6 +65,27 @@ public class NifiClient { }); } + public T delete(String path, Class responseType) throws IOException { + return executeRequestWithRetry(() -> { + Request request = new Request.Builder().url(config.getApiUrl() + path).delete().header("Authorization", "Bearer " + accessToken.get()).build(); + return executeRequest(request, responseType); + }); + } + + public T delete(String path, Map queryParams, Class responseType) throws IOException { + // 构建 URL 并添加查询参数 + HttpUrl.Builder urlBuilder = HttpUrl.parse(config.getApiUrl() + path).newBuilder(); + if (queryParams != null) { + queryParams.forEach(urlBuilder::addQueryParameter); + } + String url = urlBuilder.build().toString(); + + return executeRequestWithRetry(() -> { + Request request = new Request.Builder().url(url).delete().header("Authorization", "Bearer " + accessToken.get()).build(); + return executeRequest(request, responseType); + }); + } + private T executeRequestWithRetry(IOExceptionRunnable runnable) throws IOException { int maxRetries = 2; for (int attempt = 0; attempt < maxRetries; attempt++) { @@ -78,7 +96,7 @@ public class NifiClient { if (attempt == maxRetries - 1 || !isTokenExpiredError(e)) { throw e; } - System.out.println("令牌可能已过期,请刷新并重试。。。"); + System.out.println("令牌可能已过期,请刷新并重试..."); try { accessToken.set(getAccessToken()); tokenIssueTime = System.currentTimeMillis(); diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Component.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Component3.java similarity index 79% rename from fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Component.java rename to fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Component3.java index c88f7cd2..fe8c40a1 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Component.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Component3.java @@ -11,7 +11,7 @@ import java.util.List; * @website http://www.bejson.com/java2pojo/ */ @Data -public class Component { +public class Component3 { private String name; - private List parameters; + private List parameters; } \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Parameter.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Parameter2.java similarity index 88% rename from fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Parameter.java rename to fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Parameter2.java index 3af1acf3..42762df1 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Parameter.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Parameter2.java @@ -3,7 +3,7 @@ package com.hzya.frame.nifi.model.joinparametercontexts; import lombok.Data; @Data -public class Parameter { +public class Parameter2 { private String name; private String value; private boolean sensitive; diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/ParameterContextsJoin.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/ParameterContextsJoin.java index 1516477d..558a3b0a 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/ParameterContextsJoin.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/ParameterContextsJoin.java @@ -5,5 +5,5 @@ import lombok.Data; @Data public class ParameterContextsJoin { private Revision revision; - private Component component; + private Component3 component; } \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Parameters.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Parameters2.java similarity index 66% rename from fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Parameters.java rename to fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Parameters2.java index 024b66e1..ff6167d2 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Parameters.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/joinparametercontexts/Parameters2.java @@ -6,6 +6,6 @@ package com.hzya.frame.nifi.model.joinparametercontexts; import lombok.Data; @Data -public class Parameters { - private Parameter parameter; +public class Parameters2 { + private Parameter2 parameter; } \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Component.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Component4.java similarity index 97% rename from fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Component.java rename to fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Component4.java index 5e79e2af..5ae41fa7 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Component.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Component4.java @@ -3,7 +3,7 @@ package com.hzya.frame.nifi.model.processgrouproot; import lombok.Data; @Data -public class Component { +public class Component4 { private String id; private String versionedComponentId; private String parentGroupId; diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Component2.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Component5.java similarity index 83% rename from fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Component2.java rename to fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Component5.java index 16164c5b..a9c5b8c6 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Component2.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/Component5.java @@ -3,7 +3,7 @@ package com.hzya.frame.nifi.model.processgrouproot; import lombok.Data; @Data -public class Component2 { +public class Component5 { private String id; private String name; } \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ParameterContext.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ParameterContext.java index fe77be98..ad196cf8 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ParameterContext.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ParameterContext.java @@ -14,5 +14,5 @@ import lombok.Data; public class ParameterContext { private String id; private Permissions permissions; - private Component2 component; + private Component5 component; } diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ProcessGroups.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ProcessGroups.java index ac1e25d4..fbebef08 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ProcessGroups.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/processgrouproot/ProcessGroups.java @@ -12,7 +12,7 @@ public class ProcessGroups { private Position position; private Permissions permissions; private List bulletins; - private Component component; + private Component4 component; private Status status; private String runningCount; private String stoppedCount; diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Component.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Component6.java similarity index 92% rename from fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Component.java rename to fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Component6.java index 7bd81976..ce54a623 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Component.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Component6.java @@ -5,7 +5,7 @@ import lombok.Data; import java.util.List; @Data -public class Component { +public class Component6 { private String name; private List parameters; private List boundProcessGroups; diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/ParameterContext.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/ParameterContext.java index 7b745bbf..752d243c 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/ParameterContext.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/ParameterContext.java @@ -6,5 +6,5 @@ import lombok.Data; public class ParameterContext { private String id; private Permissions permissions; - private Component component; + private Component6 component; } \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/ParameterContextsResult.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/ParameterContextsResult.java index 2611c045..0f7ae0a1 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/ParameterContextsResult.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/ParameterContextsResult.java @@ -8,5 +8,5 @@ public class ParameterContextsResult { private String id; private String uri; private Permissions permissions; - private Component component; + private Component6 component; } \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Parameters.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Parameters.java index 9c85a6b9..a26fe39b 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Parameters.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/model/resultparametercontexts/Parameters.java @@ -4,6 +4,6 @@ import lombok.Data; @Data public class Parameters { - private boolean canWrite; + private String canWrite; private Parameter parameter; } \ No newline at end of file diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifi/service/NifiApiService.java b/fw-nifi/src/main/java/com/hzya/frame/nifi/service/NifiApiService.java index 1e98eb96..5241fd01 100644 --- a/fw-nifi/src/main/java/com/hzya/frame/nifi/service/NifiApiService.java +++ b/fw-nifi/src/main/java/com/hzya/frame/nifi/service/NifiApiService.java @@ -9,6 +9,8 @@ import com.hzya.frame.nifi.model.resultparametercontexts.ParameterContextsResult import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import java.util.Map; + /** * nifi api 服务类 * @@ -58,13 +60,9 @@ public class NifiApiService { * 更新参数上下文 */ public ParameterContextsResult updateParameterContexts(ParameterContextsResult parameterContextsJoin) throws Exception { - return client.post(StrUtil.format("/parameter-contexts/{contextId}/update-requests", parameterContextsJoin.getId()), parameterContextsJoin, ParameterContextsResult.class); + return client.post(StrUtil.format("/parameter-contexts/{}/update-requests", parameterContextsJoin.getId()), parameterContextsJoin, ParameterContextsResult.class); } - /** - * 删除参数上下文 - */ - /** * 查询参数上下文 */ @@ -72,4 +70,17 @@ public class NifiApiService { return client.get(StrUtil.format("/parameter-contexts/{}", paramContextsId), ParameterContextsResult.class); } + /** + * 删除参数上下文 + */ + public void deleteParameterContexts(String paramContextsId) throws Exception { + client.delete(StrUtil.format("/parameter-contexts/{}", paramContextsId), ParameterContextsResult.class); + } + + /** + * 删除参数上下文,待query参数 + */ + public ParameterContextsResult deleteParameterContexts(String id, Map queryParams) throws Exception { + return client.delete(StrUtil.format("/parameter-contexts/{}", id), queryParams, ParameterContextsResult.class); + } } \ No newline at end of file