io.vertx.ext.web.Router.postWithRegex()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(8.4k)|赞(0)|评价(0)|浏览(162)

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

Router.postWithRegex介绍

[英]Add a route that matches a HTTP POST request and the specified path regex
[中]添加与HTTP POST请求和指定路径regex匹配的路由

代码示例

代码示例来源：origin: org.zalando/vertx-swagger

@Override
public Route postWithRegex(String regex) {
  return router.postWithRegex(regex);
}

代码示例来源：origin: vert-x3/vertx-web

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

代码示例来源：origin: vert-x3/vertx-web

@Test
public void testPostWithRegex() throws Exception {
 router.postWithRegex("\\/somepath\\/.*").handler(rc -> rc.response().setStatusMessage("foo").end());
 testRequest(HttpMethod.POST, "/somepath/whatever", 200, "foo");
 testRequest(HttpMethod.POST, "/otherpath/whatever", 404, "Not Found");
 testRequest(HttpMethod.GET, "/somepath/whatever", 404, "Not Found");
 testRequest(HttpMethod.PUT, "/somepath/whatever", 404, "Not Found");
 testRequest(HttpMethod.DELETE, "/somepath/whatever", 404, "Not Found");
 testRequest(HttpMethod.OPTIONS, "/somepath/whatever", 404, "Not Found");
 testRequest(HttpMethod.HEAD, "/somepath/whatever", 404, "Not Found");
}

代码示例来源：origin: vert-x3/vertx-web

router.postWithRegex(jsonpSendRE).handler(rc -> {
 if (log.isTraceEnabled()) log.trace("JsonP, post: " + rc.request().uri());
 String sessionID = rc.request().getParam("param0");

代码示例来源：origin: io.vertx/vertx-rx-java

/**
 * Add a route that matches a HTTP POST request and the specified path regex
 * @param regex URI paths that begin with a match for this regex will match
 * @return the route
 */
public io.vertx.rxjava.ext.web.Route postWithRegex(String regex) { 
 io.vertx.rxjava.ext.web.Route ret = io.vertx.rxjava.ext.web.Route.newInstance(delegate.postWithRegex(regex));
 return ret;
}

代码示例来源：origin: vert-x3/vertx-rx

/**
 * Add a route that matches a HTTP POST request and the specified path regex
 * @param regex URI paths that begin with a match for this regex will match
 * @return the route
 */
public io.vertx.rxjava.ext.web.Route postWithRegex(String regex) { 
 io.vertx.rxjava.ext.web.Route ret = io.vertx.rxjava.ext.web.Route.newInstance(delegate.postWithRegex(regex));
 return ret;
}

代码示例来源：origin: wang007/vertx-start

@Override
public io.vertx.ext.web.Route postWithRegex(String regex) {
  return delegate.postWithRegex(getFullPath(regex));
}

代码示例来源：origin: vert-x3/vertx-web

XhrTransport(Vertx vertx, Router router, LocalMap<String, SockJSSession> sessions, SockJSHandlerOptions options,
       Handler<SockJSSocket> sockHandler) {
 super(vertx, sessions, options);
 String xhrBase = COMMON_PATH_ELEMENT_RE;
 String xhrRE = xhrBase + "xhr";
 String xhrStreamRE = xhrBase + "xhr_streaming";
 Handler<RoutingContext> xhrOptionsHandler = createCORSOptionsHandler(options, "OPTIONS, POST");
 router.optionsWithRegex(xhrRE).handler(xhrOptionsHandler);
 router.optionsWithRegex(xhrStreamRE).handler(xhrOptionsHandler);
 registerHandler(router, sockHandler, xhrRE, false, options);
 registerHandler(router, sockHandler, xhrStreamRE, true, options);
 String xhrSendRE = COMMON_PATH_ELEMENT_RE + "xhr_send";
 router.optionsWithRegex(xhrSendRE).handler(xhrOptionsHandler);
 router.postWithRegex(xhrSendRE).handler(rc -> {
  if (log.isTraceEnabled()) log.trace("XHR send, post, " + rc.request().uri());
  String sessionID = rc.request().getParam("param0");
  final SockJSSession session = sessions.get(sessionID);
  if (session != null && !session.isClosed()) {
   handleSend(rc, session);
  } else {
   rc.response().setStatusCode(404);
   setJSESSIONID(options, rc);
   rc.response().end();
  }
 });
}

代码示例来源：origin: org.swisspush.gateleen/gateleen-routing

private void installMethodForwarder(io.vertx.ext.web.Router newRouter, Rule rule, Handler<RoutingContext> forwarder) {
  for (String method : rule.getMethods()) {
    log.info("Installing " + rule.getScheme().toUpperCase() + " forwarder for methods " + method + " to " + rule.getUrlPattern());
    switch (method) {
      case "GET":
        newRouter.getWithRegex(rule.getUrlPattern()).handler(forwarder);
        break;
      case "PUT":
        newRouter.putWithRegex(rule.getUrlPattern()).handler(forwarder);
        break;
      case "POST":
        newRouter.postWithRegex(rule.getUrlPattern()).handler(forwarder);
        break;
      case "DELETE":
        newRouter.deleteWithRegex(rule.getUrlPattern()).handler(forwarder);
        break;
    }
  }
}

代码示例来源：origin: io.vertx/vertx-web

@Test
public void testPostWithRegex() throws Exception {
 router.postWithRegex("\\/somepath\\/.*").handler(rc -> rc.response().setStatusMessage("foo").end());
 testRequest(HttpMethod.POST, "/somepath/whatever", 200, "foo");
 testRequest(HttpMethod.POST, "/otherpath/whatever", 404, "Not Found");
 testRequest(HttpMethod.GET, "/somepath/whatever", 404, "Not Found");
 testRequest(HttpMethod.PUT, "/somepath/whatever", 404, "Not Found");
 testRequest(HttpMethod.DELETE, "/somepath/whatever", 404, "Not Found");
 testRequest(HttpMethod.OPTIONS, "/somepath/whatever", 404, "Not Found");
 testRequest(HttpMethod.HEAD, "/somepath/whatever", 404, "Not Found");
}

代码示例来源：origin: io.vertx/vertx-web

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

代码示例来源：origin: io.vertx/vertx-web

router.postWithRegex(jsonpSendRE).handler(rc -> {
 if (log.isTraceEnabled()) log.trace("JsonP, post: " + rc.request().uri());
 String sessionID = rc.request().getParam("param0");

代码示例来源：origin: io.vertx/vertx-web

XhrTransport(Vertx vertx, Router router, LocalMap<String, SockJSSession> sessions, SockJSHandlerOptions options,
       Handler<SockJSSocket> sockHandler) {
 super(vertx, sessions, options);
 String xhrBase = COMMON_PATH_ELEMENT_RE;
 String xhrRE = xhrBase + "xhr";
 String xhrStreamRE = xhrBase + "xhr_streaming";
 Handler<RoutingContext> xhrOptionsHandler = createCORSOptionsHandler(options, "OPTIONS, POST");
 router.optionsWithRegex(xhrRE).handler(xhrOptionsHandler);
 router.optionsWithRegex(xhrStreamRE).handler(xhrOptionsHandler);
 registerHandler(router, sockHandler, xhrRE, false, options);
 registerHandler(router, sockHandler, xhrStreamRE, true, options);
 String xhrSendRE = COMMON_PATH_ELEMENT_RE + "xhr_send";
 router.optionsWithRegex(xhrSendRE).handler(xhrOptionsHandler);
 router.postWithRegex(xhrSendRE).handler(rc -> {
  if (log.isTraceEnabled()) log.trace("XHR send, post, " + rc.request().uri());
  String sessionID = rc.request().getParam("param0");
  final SockJSSession session = sessions.get(sessionID);
  if (session != null && !session.isClosed()) {
   handleSend(rc, session);
  } else {
   rc.response().setStatusCode(404);
   setJSESSIONID(options, rc);
   rc.response().end();
  }
 });
}

代码示例来源：origin: org.swisspush.gateleen/gateleen-queue

router.postWithRegex(prefix + "/queues/([^/]+)/").handler(ctx -> {
  final String queue = part(ctx.request().path(), "/", 1);
  ctx.request().bodyHandler(buffer -> {

代码示例来源：origin: org.swisspush/gateleen-queue

router.postWithRegex(prefix + "/queues/([^/]+)/").handler(ctx -> {
  final String queue = part(ctx.request().path(), "/", 1);
  ctx.request().bodyHandler(buffer -> {

代码示例来源：origin: org.swisspush/redisques

router.postWithRegex(prefix + "/queues/([^/]+)/").handler(this::addQueueItem);

内容来源于网络，如有侵权，请联系作者删除！

router

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com