维特。x在垂直线之间发送NetSocket

Question

我正在使用Vert创建一个简单的TCP服务器。x和数据以压缩数据包的形式在客户端和服务器之间发送。

我想使用垂直线来创建这种性质的东西（其中[something]是垂直线，箭头显示数据流）：

Buffer In -> [Decompress Packet] -> [Parse Packet] -> Reply to NetSocket

问题是，我不确定如何将NetSocket从一个版本（结果从Decompress数据包）携带到下一个版本。我当然可以发送的结果从解压包到解析包的版本，但当解析包的版本收到这个数据，它将没有任何句柄来使用引用它来回复NetSocket必须给发件人。

本质上，我需要通过事件总线携带NetSocket，这样一旦到达最终垂直点，它就可以回复数据。

Answer 1

实际上，不必在顶点之间传递NetSocket。

在垂直方向。x、 每个套接字都会自动在事件上注册一个处理程序，您可以在场景中使用它。请在此处查看文档：

每个套接字都会自动在事件总线上注册一个处理程序，当这个处理程序中接收到任何缓冲区时，它会将它们写入自己。

这使您能够将数据写入可能位于完全不同垂直方向甚至不同垂直方向的html" target="_blank">套接字。通过将缓冲区发送到该处理程序的地址。

处理程序的地址由writeHandlerID提供

由于writeHandlerID是一个普通字符串，所以从verticle1将其发送到verticle2并不是什么大问题。在verticle2，eventbus。发送（writeHandlerID[你想回复的东西]）。就这样。

我们已经在应用程序中应用了此技巧。

Answer 2

正如评论中所说的，你可能需要一组处理程序，而不是竖线。例如，看看vertx web处理程序是如何工作的。处理程序是一个简单的lambda，它执行一个小任务，可以决定将工作传递给下一个任务，或者调用失败方法中止执行。

一个非常基本的实现就是保留一个添加的lambda（Java函数接口）列表，一旦收到套接字，就迭代该列表。

如果需要在处理程序中执行异步IO，则不能使用需要异步执行的简单迭代器，基本异步迭代器包装可以是：

abstract class AsyncIterator<T> implements Handler<T> {

  private final Iterator<T> iterator;
  private boolean end = false;

  public AsyncIterator(Iterable<T> iterable) {
    this(iterable.iterator());
  }

  public AsyncIterator(Iterator<T> iterator) {
    this.iterator = iterator;
    next();
  }

  public final boolean hasNext() {
    return !end;
  }

  public final void next() {
    if (iterator.hasNext()) {
      handle(iterator.next());
    } else {
      end = true;
      handle(null);
    }
  }

  public final void remove() {
    iterator.remove();
  }
}

你只需要像这样使用它：

new AsyncIterator<Object>(keys) {
    @Override
    public void handle(Object key) {
      if (hasNext()) {
        // here your handler code...
        // once it is complete your handler need to call:
        next();
      } else {
        // no more entries to iterate...
        // close your socket?
      }
    }
  };
});