本文整理了Java中com.jetdrone.vertx.yoke.Yoke类的一些代码示例，展示了Yoke类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Yoke类的具体详情如下：
包路径：com.jetdrone.vertx.yoke.Yoke
类名称：Yoke

Yoke介绍

[英]# Yoke Yoke is a chain executor of middleware for Vert.x 2.x. The goal of this library is not to provide a web application framework but the backbone that helps the creation of web applications. Yoke works in a similar way to Connect middleware. Users start by declaring which middleware components want to use and then start an http server either managed by Yoke or provided by the user (say when you need https). Yoke has no extra dependencies than Vert.x itself so it is self contained.
[中]#Yoke Yoke是Vert中间件的链执行器。x2。x、 该库的目标不是提供web应用程序框架，而是提供帮助创建web应用程序的主干。Yoke以类似的方式连接中间件。用户首先声明要使用哪些中间件组件，然后启动由Yoke管理或由用户提供的http服务器（例如，当您需要https时）。Yoke和Vert没有额外的依赖关系。所以它是独立的。

代码示例

代码示例来源：origin: pmlopes/yoke

/**
 * Starts the server listening at a given port bind to all available interfaces.
 *
 * @param port the server TCP port
 * @return {Yoke}
 */
public Yoke listen(int port) {
  return listen(port, "0.0.0.0", null);
}

代码示例来源：origin: pmlopes/yoke

/**
 * Adds a middleware to the chain with the prefix "/".
 *
 * @param middleware The middleware add to the chain
 */
public Yoke use(@NotNull IMiddleware... middleware) {
  return use("/", middleware);
}

代码示例来源：origin: pmlopes/yoke

/**
 * Get access to the security object from Yoke
 * @return security
 */
public YokeSecurity security() {
  return yoke.security();
}

代码示例来源：origin: pmlopes/yoke

@Override
 public void start() {

  new Yoke(this)
    .use(new Router()
      .get("/", new Handler<YokeRequest>() {
       @Override
       public void handle(YokeRequest request) {
        request.response().end("Hello World\n");
       }
      })
    ).listen(8080);
 }
}

代码示例来源：origin: pmlopes/yoke

@Override
public void start() {
 final Yoke app = new Yoke(this);
 app.secretSecurity("keyboard cat");
 final Mac hmac = app.security().getMac("HmacSHA256");
 app.use(new BodyParser());
 app.use(new CookieParser(hmac));
 app.use(new Session(hmac));
 app.use(formAuth);
 app.use(new Router() {{
  get("/", new Handler<YokeRequest>() {
   @Override
 }});
 app.listen(8000);

代码示例来源：origin: pmlopes/yoke

/**
 * Get access to Vert.x object
 * @return vertx
 */
public Vertx vertx() {
  return yoke.vertx();
}

代码示例来源：origin: pmlopes/yoke

/**
 * Deploys required middleware from a config json element.
 *
 * The current format for the config is either a single item or an array:
 * <pre>
 * [{
 *   module: String, // the name of the module
 *   verticle: String, // the name of the verticle (either verticle or module must be present)
 *   instances: Number, // how many instances, default 1
 *   worker: Boolean, // is it a worker verticle? default false
 *   multiThreaded: Boolean, // is it a multiThreaded verticle? default false
 *   config: JsonObject // any config you need to pass to the module/verticle
 * }]
 * </pre>
 *
 * @param config a json array.
 */
public Yoke deploy(@NotNull JsonArray config) {
  return deploy(config, null);
}

代码示例来源：origin: pmlopes/yoke

@Override
public void start() {
 final Yoke yoke = new Yoke(this);
 yoke.use(new BodyParser());
 yoke.use(new ErrorHandler(true));
 yoke.use(new JsonRestRouter(db)
   .rest("/states", "states")
 );
 yoke.use(new Static("static"));
 yoke.use(new Handler<YokeRequest>() {
  @Override
  public void handle(YokeRequest request) {
 yoke.listen(8080);

代码示例来源：origin: pmlopes/yoke

public void shutdown() {
  yoke.vertx().cancelTimer(timerID);
}

代码示例来源：origin: pmlopes/yoke

new Yoke(this)
  .use(new BodyParser())
  .use("/middleware", foo)
  .use("/middleware", foo)
  .use("/middleware", foo)
  .use("/middleware", foo)
  .use(new Router()
    .get("/", new Handler<YokeRequest>() {
     @Override
  ).listen(8080);

代码示例来源：origin: pmlopes/yoke

/**
 * Starts the server listening at a given port bind to all available interfaces.
 *
 * @param port    the server TCP port
 * @param handler for asynchronous result of the listen operation
 * @return {Yoke}
 */
public Yoke listen(int port, @NotNull Handler<Boolean> handler) {
  return listen(port, "0.0.0.0", handler);
}

代码示例来源：origin: pmlopes/yoke

/**
 * Adds a Handler to a route.
 *
 * <pre>
 * yoke.use("/login", new Handler&lt;YokeRequest&gt;() {
 *   public void handle(YokeRequest request) {
 *     request.response.end("Hello");
 *   }
 * });
 * </pre>
 * @param handler The Handler to add
 */
public Yoke use(@NotNull Handler<YokeRequest> handler) {
  return use("/", handler);
}

代码示例来源：origin: pmlopes/yoke

@Override
public Middleware init(@NotNull final Yoke yoke, @NotNull final String mount) {
  super.init(yoke, mount);
  t0 = System.nanoTime();
  dt = 500 * 1000000; // nano time
  timerID = yoke.vertx().setPeriodic(500, new Handler<Long>() {
    @Override
    public void handle(Long timerID) {
      final long t1 = System.nanoTime();
      dt = t1 - t0;
      t0 = t1;
    }
  });
  return this;
}

代码示例来源：origin: pmlopes/yoke

@Override
public Middleware init(@NotNull final Yoke yoke, @NotNull final String mount) {
  super.init(yoke, mount);
  jwt = new com.jetdrone.vertx.yoke.security.JWT(yoke.security());
  return this;
}

代码示例来源：origin: pmlopes/yoke

@Override
public void start() throws Exception {
 final Yoke yoke = new Yoke(this);
 yoke.use("/eventbus", new SockJS(vertx, new SockJSHandlerOptions()).bridge(options, event -> {
 yoke.use(new BodyParser());
 yoke.use(new ErrorHandler(true));
 yoke.use(new Static("static"));
 yoke.listen(8080);

代码示例来源：origin: pmlopes/yoke

/**
 * Starts the server listening at a given port and given address.
 *
 * @param port the server TCP port
 * @return {Yoke}
 */
public Yoke listen(int port, @NotNull String address) {
  return listen(port, address, null);
}

代码示例来源：origin: pmlopes/yoke

/**
 * Starts the server listening at a given port and given address.
 *
 * @param port    the server TCP port
 * @param handler for asynchronous result of the listen operation
 * @return {Yoke}
 */
public Yoke listen(int port, @NotNull String address, final Handler<Boolean> handler) {
  HttpServer server = vertx.createHttpServer();
  listen(server);
  if (handler != null) {
    server.listen(port, address, new Handler<AsyncResult<HttpServer>>() {
      @Override
      public void handle(AsyncResult<HttpServer> listen) {
        handler.handle(listen.succeeded());
      }
    });
  } else {
    server.listen(port, address);
  }
  return this;
}