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

YokeRequest.headers介绍

暂无

代码示例

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

/** Allow getting headers in a generified way.
 *
 * @param name The key to get
 * @return The found object
 */
@Override
public String getHeader(@NotNull final String name) {
  return headers().get(name);
}

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

/** Returns the content length of this request setBody or -1 if header is not present.
 */
public long contentLength() {
  String contentLengthHeader = headers().get("content-length");
  if (contentLengthHeader != null) {
    return Long.parseLong(contentLengthHeader);
  } else {
    return -1;
  }
}

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

@Override
public String getHeader(CharSequence charSequence) {
  return headers().get(charSequence);
}

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

/** Allow getting headers in a generified way.
 *
 * @param name The key to get
 * @return {List} The list of all found objects
 */
public List<String> getAllHeaders(@NotNull final String name) {
  return headers().getAll(name);
}

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

@Override
public String getRequestHeader(String name) {
  return request.headers().get(name);
}

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

/** Allow getting headers in a generified way and return defaultValue if the key does not exist.
 *
 * @param name The key to get
 * @param defaultValue value returned when the key does not exist
 * @return {String} The found object
 */
public String getHeader(@NotNull final String name, String defaultValue) {
  if (headers().contains(name)) {
    return getHeader(name);
  } else {
    return defaultValue;
  }
}

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

/** Returns true if this request has setBody
 *
 * @return {Boolean} true if content-length or transfer-encoding is present
 */
public boolean hasBody() {
  MultiMap headers = headers();
  return headers.contains("transfer-encoding") || headers.contains("content-length");
}

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

public static void setCORS(@NotNull YokeRequest request) {
 String origin = request.headers().get("origin");
 if (origin == null || "null".equals(origin)) {
  origin = "*";
 }
 request.response().headers().set("Access-Control-Allow-Origin", origin);
 request.response().headers().set("Access-Control-Allow-Credentials", "true");
 String hdr = request.headers().get("Access-Control-Request-Headers");
 if (hdr != null) {
  request.response().headers().set("Access-Control-Allow-Headers", hdr);
 }
}

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

@Override
  public String handle(YokeRequest request) {
    String token = request.formAttributes().get(key);
    if (token == null) {
      token = request.params().get(key);
      if (token == null) {
        token = request.headers().get("x-csrf-token");
      }
    }
    return token;
  }
};

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

cReq.headers().setAll(req.headers());
cReq.setChunked(true);
req.handler(new Handler<Buffer>() {

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

public EventSourceTransport(Vertx vertx, Router router, LocalMap<String, SockJSSession> sessions, SockJSHandlerOptions options,
           Handler<SockJSSocket> sockHandler) {
 super(vertx, sessions, options);
 String eventSourceRE = COMMON_PATH_ELEMENT_RE + "eventsource";
 router.get(Pattern.compile(eventSourceRE), (request, next) -> {
  if (log.isTraceEnabled()) log.trace("EventSource transport, get: " + request.uri());
  String sessionID = request.getParam("param0");
  SockJSSession session = getSession(request, options.getSessionTimeout(), options.getHeartbeatInterval(), sessionID, sockHandler);
  session.setInfo(request.localAddress(), request.remoteAddress(), request.uri(), request.headers());
  session.register(new EventSourceListener(options.getMaxBytesStreaming(), request, session));
 });
}

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

String connectionHeader = request.headers().get(io.vertx.core.http.HttpHeaders.CONNECTION);
if (connectionHeader == null || !connectionHeader.toLowerCase().contains("upgrade")) {
 request.response().setStatusCode(400);

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

private void registerHandler(Router router, Handler<SockJSSocket> sockHandler, String re, boolean streaming, SockJSHandlerOptions options) {
 router.post(Pattern.compile(re), (request, next) -> {
  if (log.isTraceEnabled()) log.trace("XHR, post, " + request.uri());
  setNoCacheHeaders(request);
  String sessionID = request.getParam("param0");
  SockJSSession session = getSession(request, options.getSessionTimeout(), options.getHeartbeatInterval(), sessionID, sockHandler);
  session.setInfo(request.localAddress(), request.remoteAddress(), request.uri(), request.headers());
  session.register(streaming? new XhrStreamingListener(options.getMaxBytesStreaming(), request, session) : new XhrPollingListener(request, session));
 });
}

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

public HtmlFileTransport(Vertx vertx, Router router, LocalMap<String, SockJSSession> sessions, SockJSHandlerOptions options,
         Handler<SockJSSocket> sockHandler) {
 super(vertx, sessions, options);
 String htmlFileRE = COMMON_PATH_ELEMENT_RE + "htmlfile.*";
 router.get(Pattern.compile(htmlFileRE), (request, next) -> {
  if (log.isTraceEnabled()) log.trace("HtmlFile, get: " + request.uri());
  String callback = request.getParam("callback");
  if (callback == null) {
   callback = request.getParam("c");
   if (callback == null) {
    request.response().setStatusCode(500).end("\"callback\" parameter required\n");
    return;
   }
  }
  String sessionID = request.params().get("param0");
  SockJSSession session = getSession(request, options.getSessionTimeout(), options.getHeartbeatInterval(), sessionID, sockHandler);
  session.setInfo(request.localAddress(), request.remoteAddress(), request.uri(), request.headers());
  session.register(new HtmlFileListener(options.getMaxBytesStreaming(), request, callback, session));
 });
}

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

session.setInfo(request.localAddress(), request.remoteAddress(), request.uri(), request.headers());
 session.register(new JsonPListener(request, session, callback));
});