在Vertx中，通过事件总线发送对象集合的最佳方式是什么？

Question

我有一个处理程序，在给定的endpoint上处理HTTP请求。处理程序通过事件总线发送一条垂直消息，该消息发出一些外部分页的REST调用，聚合结果，并将结果返回给处理程序。分页REST调用的结果表示为自定义对象列表。如果我只是尝试发送列表本身，Vertx会抛出一个异常，抱怨它找不到java的编解码器。util。ArrayList。

我试图在Vertx中找到“最好的”——也就是最简单、最高效、最可读/可维护的——方法，通过事件总线将这些对象的列表发送回我的处理程序。这些都是我知道的，并且到目前为止已经尝试过的选项，有没有更好的方法来实现这一点？

1. 将列表序列化为JSON并存储在JsonObject中。这需要在两端进行显式序列化/反序列化，这似乎是不必要的：

// Verticle
List<CustomObject> result = method();
JsonObject data = new JsonObject();
data.put("result", Json.encode(result));
msg.reply(data);

// Handler
String serializedList = body.getString("result");
List<CustomObject> list = objectMapper.readValue(serializedList, new TypeReference<List<CustomObject>>(){});

有没有一种更简单的方法适合我的用例，而我却不知道？谢谢

Answer 1

很抱歉，这里有一个很长的例子，但你可以这样做：

public class EventBusHolder {

    public static void main(String[] args) {
        Vertx vertx = Vertx.vertx();

        vertx.eventBus().registerDefaultCodec(Holder.class, new HolderCodec());
        vertx.deployVerticle(new SomeVerticle(), (r) -> {
            vertx.eventBus().send("custom", new Holder(new CustomObject("a")));
        });
    }
}

class HolderCodec implements MessageCodec<Holder, Holder> {

    @Override
    public void encodeToWire(Buffer buffer, Holder holder) {

    }

    @Override
    public Holder decodeFromWire(int pos, Buffer buffer) {
        return null;
    }

    @Override
    public Holder transform(Holder holder) {
        return holder;
    }

    @Override
    public String name() {
        return "HolderCodec";
    }

    @Override
    public byte systemCodecID() {
        return -1;
    }
}

class SomeVerticle extends AbstractVerticle {

    @Override
    public void start() {
        vertx.eventBus().consumer("custom", (msg) -> {
           System.out.println(msg.body());
        });
    }
}

class CustomObject {
    public String name;

    public CustomObject(String name) {
        this.name = name;
    }

    @Override
    public String toString() {
        return "CustomObject{" +
                "name='" + name + '\'' +
                '}';
    }
}


final class Holder {
    @Override
    public String toString() {
        return "Holder{" +
                "data=" + data +
                '}';
    }

    private final List<CustomObject> data;

    public Holder(final CustomObject... data) {
        this.data = Arrays.asList(data);
    }

    public List<CustomObject> getData() {
        return data;
    }
}

请注意，编码ToWire和解码器FromWire没有实现。本地消息不会调用它们。

拥有此Holder对象是绕过JVM上类型擦除的一种简单方法。