将文件发送到vertx eventbus

Question

我正在尝试使用Vertx上传一个文件，该请求是一个包含PDF的POST请求，我的处理程序如下所示（我从github中的一个示例中获取了代码）：

...
Set<FileUpload> fileUploadSet = routingContext.fileUploads();
Iterator<FileUpload> fileUploadIterator = fileUploadSet.iterator();
while (fileUploadIterator.hasNext()) {
    FileUpload fileUpload = fileUploadIterator.next();

    // Use the Event Bus to dispatch the file now
    // Since Event Bus does not support POJOs by default so we need to create a MessageCodec implementation
    // and provide methods for encode and decode the bytes
    ...

    vertx.eventBus().<"what to use here?">send(Address.UPLOAD_FILE, "", result -> {
        if (result.succeeded()) {
            req.response()
               .setStatusCode(200)
               .write(result.result().body())
               .end();
        } else {
            logger.info(result.cause().toString());
            req.response()
               .setStatusCode(500)
               .write(result.cause().toString())
               .end();
        }
    });

根据上面的评论，我不能只尝试这样的事情（它实际上显示了一个错误）：

vertx.eventBus().<FileUpload>send(Address.UPLOAD_FILE, "", result -> {

我一直在检查MessageCodec，但我不清楚如何将其应用于这种情况。

注意：此escenario必须使用eventbus。

Answer 1

您可以使用缓冲区来实现这一点
在路由中，您迭代文件，读取临时文件并将其作为缓冲区发送：

for (FileUpload fileUpload : routingContext.fileUploads()) {
    vertx.fileSystem().readFile(fileUpload.uploadedFileName(), (f) -> {
        if (f.succeeded()) {
            vertx.eventBus().send(Address.UPLOAD_FILE, f.result());
            // Also handle response here
        }
    });
}

然后接收垂直线可能如下所示：

private static class ReceiverVerticle extends AbstractVerticle {

    @Override
    public void start() {
        vertx.eventBus().consumer(Address.UPLOAD_FILE, new Handler<Message<Buffer>>() {

            @Override
            public void handle(Message<Buffer> event) {
                System.out.println(event.body().toString());

                event.reply("OK");
            }
        });
    }
}

Answer 2

当您使用超文本传输协议post将文件上传到vertx时，该文件将存储在文件系统中。

您必须在bodyhandler中设置上载目录：http://vertx.io/docs/apidocs/io/vertx/ext/web/handler/BodyHandler.html#setUploadsDirectory-java。串-

FileUpload对象只保存FileUpload的元信息，而不保存内容本身。

如果要通过eventbus发送文件，必须首先从文件系统中读取：http://vertx.io/docs/apidocs/io/vertx/core/file/FileSystem.html#readFile-java。lang.String-io。vertx。果心处理程序-