使用Jboss DMR下载/保存附件

Question

我有一个Jboss CLI命令，我试图在Java中使用DMR库实现。该步骤涉及下载附件(显示/保存)，但是没有任何可用的文档。如有任何帮助，不胜感激。

CLI命令我正在尝试转换为DMR:

attachment display --operation=/deployment=app.war:read-content(path=META-INF/MANIFEST.MF)

下面是我的操作对象，但是没有办法提供命令来显示/保存附件

ModelNode request = new ModelNode();
request.get(ClientConstants.OP_ADDR).add(ClientConstants.DEPLOYMENT, "app.war");
request.get(ClientConstants.OP).set(ClientConstants.READ_CONTENT_OPERATION);
request.get(ClientConstants.PATH).set("META-INF/MANIFEST.MF");

DMR操作产生的所有结果都是

{
"outcome" => "success",
"result" => {"uuid" => "1f45b2bf-8402-4b46-a721-3e3f23db5d80"},
"response-headers" => {"attached-streams" => [{
"uuid" => "1f45b2bf-8402-4b46-a721-3e3f23db5d80",
"mime-type" => "text/plain"
}]}
}

是否有一种方法可以编辑操作或使用操作中返回的uid从流下载附件?

Answer 1

我也没有看到任何关于这方面的明确文档。然而，您需要使用的是OperationResponse来获取流。下面是一个例子。

public class ReadContent {
public static void main(final String[] args) throws Exception {
try (ModelControllerClient client = ModelControllerClient.Factory.create("localhost", 9990)) {
try (
StreamEntry entry = readContent(client, "kitchensink.war", "META-INF/MANIFEST.MF");
InputStream in = entry.getStream();
) {
int len;
final byte[] buffer = new byte[256];
while ((len = in.read(buffer)) != -1) {
System.out.write(buffer, 0, len);
}
}
}
}
private static StreamEntry readContent(final ModelControllerClient client, final String deploymentName, final String path) throws IOException {
final ModelNode address = Operations.createAddress("deployment", deploymentName);
final ModelNode op = Operations.createOperation(ClientConstants.READ_CONTENT_OPERATION, address);
op.get(ClientConstants.PATH).set(path);
// Execute the operation
final OperationResponse response = client.executeOperation(Operation.Factory.create(op), OperationMessageHandler.logging);
// Get the response node to evaluate the outcome
final ModelNode outcome = response.getResponseNode();
if (Operations.isSuccessfulOutcome(outcome)) {
// Read the result and get the UUID the stream is attached to
final String uuid = Operations.readResult(outcome).get(ClientConstants.UUID).asString();
return response.getInputStream(uuid);
}
// The operation has failed, raise and exception with the failure description
throw new RuntimeException("Failed to read the content: " + Operations.getFailureDescription(outcome).asString());
}
}