使用Jboss DMR下载/保存附件

s5a0g9ez  于 2022-11-08  发布在  其他
关注(0)|答案(1)|浏览(151)

我有一个Jboss CLI命令,我正在尝试使用DMR库在Java中实现它。这个步骤涉及到下载一个附件(显示/保存),但是没有任何可用的文档。任何帮助都是感激的。
我尝试转换为DMR的CLI命令:

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"
    }]}
}

是否有办法编辑操作或使用操作中返回的uuid从流中下载附件?

zfciruhq

zfciruhq1#

我也没有看到任何明确的文档。但是你需要使用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());
    }
}

相关问题