spark.Spark类的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(15.4k)|赞(0)|评价(0)|浏览(198)

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

Spark介绍

[英]The main building block of a Spark application is a set of routes. A route is made up of three simple pieces:

  • A verb (get, post, put, delete, head, trace, connect, options)
  • A path (/hello, /users/:name)
  • A callback ( handle(Request request, Response response) )

Example:

Spark.get(new Route("/hello") });}

``

``
[中]Spark应用程序的主要构建块是一组路由。路线由三个简单的部分组成：
*动词（get、post、put、delete、head、trace、connect、options）
*路径（/hello，/users/：name）
*回调（句柄（请求、响应））
例子：

Spark.get(new Route("/hello") });}

代码示例

代码示例来源：origin: gocd/gocd

@Override
public void setupRoutes() {
  path(controllerBasePath(), () -> {
    before("", this::setContentType);
    before("/*", this::setContentType);
    before("", mimeType, apiAuthenticationHelper::checkAdminUserAnd403);
    before("/*", mimeType, apiAuthenticationHelper::checkAdminUserAnd403);
    get("", this::index);
    get(Routes.ArtifactStoreConfig.ID, this::show);
    post("", this::create);
    put(Routes.ArtifactStoreConfig.ID, this::update);
    delete(Routes.ArtifactStoreConfig.ID, this::destroy);
    exception(RecordNotFoundException.class, this::notFound);
  });
}

代码示例来源：origin: gocd/gocd

@Override
public void setupRoutes() {
  path(Routes.ServerHealthMessages.BASE, () -> {
    before("", this::setContentType);
    before("/*", this::setContentType);
    before("", apiAuthenticationHelper::checkUserAnd403);
    before("/*", apiAuthenticationHelper::checkUserAnd403);
    get("", this::show);
    head("", this::show);
  });
}

代码示例来源：origin: gocd/gocd

@Override
public void setupRoutes() {
  path(controllerBasePath(), () -> {
    before("", mimeType, this::setContentType);
    before("/*", mimeType, this::setContentType);
    before("", this::verifyContentType);
    before("/*", this::verifyContentType);
    get(Routes.PipelineSelection.PIPELINES_DATA, mimeType, this::pipelinesData);
    get("", mimeType, this::show);
    put("", mimeType, this::update);
  });
}

代码示例来源：origin: gocd/gocd

@Override
public void setupRoutes() {
  path(controllerBasePath(), () -> {
    before("", mimeType, this::setContentType);
    before("/*", mimeType, this::setContentType);
    before("", this::verifyContentType);
    before("/*", this::verifyContentType);
    before(Export.PIPELINES_PATH, mimeType, apiAuthenticationHelper::checkPipelineGroupAdminUserAnd403);
    get(Export.PIPELINES_PATH, mimeType, this::exportPipeline);
    exception(RecordNotFoundException.class, this::notFound);
  });
}

代码示例来源：origin: gocd/gocd

@Override
public void setupRoutes() {
  path(controllerPath(), () -> {
    before("", mimeType, this::setContentType);
    before("", this::verifyContentType);
    before("", apiAuthenticationHelper::checkUserAnd403);
    get("", mimeType, this::index);
  });
}

代码示例来源：origin: bwssytems/ha-bridge

private void setupEndpoints() {
  log.info("HABridge device management service started.... ");
  before(API_CONTEXT + "/*", (request, response) -> {
          halt(401, "{\"message\":\"User not authenticated\"}");
  options(API_CONTEXT, "application/json", (request, response) -> {
    response.status(HttpStatus.SC_OK);
    response.header("Access-Control-Allow-Origin", request.headers("Origin"));
    return "";
  });
  post(API_CONTEXT, "application/json", (request, response) -> {
    log.debug("Create a Device(s) - request body: " + request.body());
    DeviceDescriptor devices[];
  options(API_CONTEXT + "/:id", "application/json", (request, response) -> {
    response.status(HttpStatus.SC_OK);
    response.header("Access-Control-Allow-Origin", request.headers("Origin"));
    return "";
  });
  put (API_CONTEXT + "/:id", "application/json", (request, response) -> {
    log.debug("Edit a Device - request body: " + request.body());
    DeviceDescriptor device = new Gson().fromJson(request.body(), DeviceDescriptor.class);
  get (API_CONTEXT, "application/json", (request, response) -> {
    List<DeviceDescriptor> deviceList = deviceRepository.findAll();
    log.debug("Get all devices");

代码示例来源：origin: pac4j/spark-pac4j-demo

public static void main(String[] args) {
  port(8080);
  final Config config = new DemoConfigFactory(JWT_SALT, templateEngine).build();
  get("/", SparkPac4jDemo::index, templateEngine);
  final CallbackRoute callback = new CallbackRoute(config, null, true);
  get("/callback", callback);
  post("/callback", callback);
  final SecurityFilter facebookFilter = new SecurityFilter(config, "FacebookClient", "", "excludedPath");
  before("/facebook", facebookFilter);
  before("/facebook/*", facebookFilter);
  before("/facebookadmin", new SecurityFilter(config, "FacebookClient", "admin"));
  before("/facebookcustom", new SecurityFilter(config, "FacebookClient", "custom"));
  before("/twitter", new SecurityFilter(config, "TwitterClient,FacebookClient"));
  before("/form", new SecurityFilter(config, "FormClient"));
  before("/basicauth", new SecurityFilter(config, "IndirectBasicAuthClient"));
  before("/cas", new SecurityFilter(config, "CasClient"));
  before("/saml2", new SecurityFilter(config, "SAML2Client"));
  before("/oidc", new SecurityFilter(config, "OidcClient"));
  before("/protected", new SecurityFilter(config, null));
  before("/dba", new SecurityFilter(config, "DirectBasicAuthClient,ParameterClient"));
  before("/rest-jwt", new SecurityFilter(config, "ParameterClient"));
  get("/facebook", SparkPac4jDemo::protectedIndex, templateEngine);
  get("/facebook/notprotected", SparkPac4jDemo::protectedIndex, templateEngine);
  get("/facebookadmin", SparkPac4jDemo::protectedIndex, templateEngine);
  get("/facebookcustom", SparkPac4jDemo::protectedIndex, templateEngine);
  get("/twitter", SparkPac4jDemo::protectedIndex, templateEngine);
  get("/form", SparkPac4jDemo::protectedIndex, templateEngine);
  get("/basicauth", SparkPac4jDemo::protectedIndex, templateEngine);

代码示例来源：origin: gocd/gocd

@Override
public void setupRoutes() {
  path(controllerBasePath(), () -> {
    before("", mimeType, this::setContentType);
    before("/*", mimeType, this::setContentType);
    before("", this::verifyContentType);
    before("/*", this::verifyContentType);
    before("", this.mimeType, this.apiAuthenticationHelper::checkAdminUserAnd403);
    before("/*", this.mimeType, this.apiAuthenticationHelper::checkAdminUserAnd403);
    get("", this.mimeType, this::index);
    post("", this.mimeType, this::create);
    delete("", this.mimeType, this::bulkDelete);
    get(Routes.Users.USER_NAME, this.mimeType, this::show);
    patch(Routes.Users.USER_NAME, this.mimeType, this::patchUser);
    delete(Routes.Users.USER_NAME, this.mimeType, this::deleteUser);
    patch(Routes.Users.USER_STATE, this.mimeType, this::bulkUpdateUsersState);
  });
}

代码示例来源：origin: mgtechsoftware/smockin

Spark.head("*", (request, response) -> {
  response.status(404);
  return "Mock not found";
});
Spark.get("*", (request, response) -> {
});
Spark.post("*", (request, response) -> {
  response.status(404);
  return "Mock not found";
});
Spark.put("*", (request, response) -> {
  response.status(404);
  return "Mock not found";
});
Spark.delete("*", (request, response) -> {
  response.status(404);
  return "Mock not found";
});
Spark.patch("*", (request, response) -> {
  response.status(404);
  return "Mock not found";

代码示例来源：origin: tipsy/spark-basic-structure

public static void main(String[] args) {
  // Instantiate your dependencies
  bookDao = new BookDao();
  userDao = new UserDao();
  // Configure Spark
  port(4567);
  staticFiles.location("/public");
  staticFiles.expireTime(600L);
  enableDebugScreen();
  // Set up before-filters (called before each get/post)
  before("*",                  Filters.addTrailingSlashes);
  before("*",                  Filters.handleLocaleChange);
  // Set up routes
  get(Path.Web.INDEX,          IndexController.serveIndexPage);
  get(Path.Web.BOOKS,          BookController.fetchAllBooks);
  get(Path.Web.ONE_BOOK,       BookController.fetchOneBook);
  get(Path.Web.LOGIN,          LoginController.serveLoginPage);
  post(Path.Web.LOGIN,         LoginController.handleLoginPost);
  post(Path.Web.LOGOUT,        LoginController.handleLogoutPost);
  get("*",                     ViewUtil.notFound);
  //Set up after-filters (called after each get/post)
  after("*",                   Filters.addGzipHeader);
}

代码示例来源：origin: gocd/gocd

@Override
public void setupRoutes() {
  path(controllerBasePath(), () -> {
    before("", this::setContentType);
    before("/*", this::setContentType);
    before("", mimeType, this::checkSecurityOr403);
    before("/*", mimeType, this::checkSecurityOr403);
    get("", mimeType, this::index);
    get(Routes.AgentsAPI.UUID, mimeType, this::show);
    patch(Routes.AgentsAPI.UUID, mimeType, this::update);
    patch("", mimeType, this::bulkUpdate);
    delete(Routes.AgentsAPI.UUID, mimeType, this::deleteAgent);
    delete("", mimeType, this::bulkDeleteAgents);
    exception(RecordNotFoundException.class, this::notFound);
  });
}

代码示例来源：origin: sparktutorials/BlogService_SparkExample

logger.finest("Options.servicePort = " + options.servicePort);
port(options.servicePort);
post("/posts", new PostsCreateHandler(model));
get("/posts", new PostsIndexHandler(model));
get("/posts/:uuid", new GetSinglePostHandler(model));
put("/posts/:uuid", new PostsEditHandler(model));
delete("/posts/:uuid", new PostsDeleteHandler(model));
post("/posts/:uuid/comments", new CommentsCreateHandler(model));
get("/posts/:uuid/comments", new CommentsListHandler(model));
get("/alive", new Route() {
  @Override
  public Object handle(Request request, Response response) throws Exception {

代码示例来源：origin: ikidou/Retrofit2Demo

Spark.init();
Spark.get("/blog", BlogHandler.GET, GsonTransformer.getDefault());
Spark.get("/blog/:id", BlogHandler.GET, GsonTransformer.getDefault());
Spark.post("/blog", BlogHandler.POST, GsonTransformer.getDefault());
Spark.put("/blog", BlogHandler.PUT, GsonTransformer.getDefault());
Spark.put("/blog/:id", BlogHandler.PUT, GsonTransformer.getDefault());
Spark.delete("/blog", BlogHandler.DELETE, GsonTransformer.getDefault());
Spark.delete("/blog/:id", BlogHandler.DELETE, GsonTransformer.getDefault());
Spark.head("/blog", BlogHandler.HEAD, GsonTransformer.getDefault());
Spark.head("/blog/:id", BlogHandler.HEAD, GsonTransformer.getDefault());
Spark.post("/form", new FormHandler(), GsonTransformer.getDefault());
Spark.get("/headers", new HeaderHandler(), GsonTransformer.getDefault());
Spark.after(new Filter() {
  @Override
  public void handle(Request request, Response response) throws Exception {
Spark.exception(RuntimeException.class, new ExceptionHandler() {
  @Override
  public void handle(Exception exception, Request request, Response response) {
Spark.exception(Exception.class, new ExceptionHandler() {

代码示例来源：origin: lamarios/Homedash2

@Override
public void defineEndpoints() {
  /**
   * gets all pages as json
   */
  Spark.get("/pages", (req, res) -> getAll(), gson::toJson);
  /**
   * add a pages and return the whole list of pages as json
   */
  Spark.post("/pages/add", this::addPage, gson::toJson);
  /**
   * Rename a page
   */
  Spark.post("/pages/edit/:id", this::renamePage, gson::toJson);
  /**
   * deleete a page  and return all as json
   */
  Spark.delete("/page/:id", this::deletePage, gson::toJson);
}

代码示例来源：origin: GoogleCloudPlatform/java-docs-samples

/**
 * Creates a controller that maps requests to actions.
 */
public UserController(final UserService userService) {
 Spark.staticFileLocation("/public");
 get("/api/users", (req, res) -> userService.getAllUsers(), json());
 get("/api/users/:id", (req, res) -> userService.getUser(req.params(":id")), json());
 post("/api/users",
   (req, res) -> userService.createUser(req.queryParams("name"), req.queryParams("email")),
   json());
 put("/api/users/:id", (req, res) -> userService.updateUser(
     req.params(":id"),
     req.queryParams("name"),
     req.queryParams("email")
   ), json());
 delete("/api/users/:id", (req, res) -> userService.deleteUser(req.params(":id")), json());
 after((req, res) -> {
  res.type("application/json");
 });
 exception(IllegalArgumentException.class, (error, req, res) -> {
  res.status(400);
  res.body(toJson(new ResponseError(error)));
 });
}

代码示例来源：origin: yeriomin/token-dispenser

threadPool(16, 2, 5000);
ipAddress(host);
port(port);
notFound("Not found");
before((req, res) -> {
  LOG.info(req.requestMethod() + " " + req.url());
  res.header("Access-Control-Allow-Origin", "*");
  res.header("Access-Control-Request-Method", "GET");
});
after((req, res) -> res.type("text/plain"));
Server.passwords = PasswordsDbFactory.get(config);
get("/token/email/:email", (req, res) -> new TokenResource().handle(req, res));
get("/token-ac2dm/email/:email", (req, res) -> new TokenAc2dmResource().handle(req, res));
if (config.getProperty(PROPERTY_EMAIL_RETRIEVAL, "false").equals("true")) {
  LOG.info("Exposing /email endpoint");
  get("/email", (req, res) -> new EmailResource().handle(req, res));
    get("/stats", (req, res) -> new StatsResource().get(req, res));
    delete("/stats", (req, res) -> new StatsResource().delete(req, res));

代码示例来源：origin: gocd/gocd

@Override
public void setupRoutes() {
  path(controllerBasePath(), () -> {
    before("", mimeType, this::setContentType);
    before("/*", mimeType, this::setContentType);
    before("", this::verifyConfirmHeader);
    before("/*", this::verifyConfirmHeader);
    before("", mimeType, apiAuthenticationHelper::checkAdminUserAnd403);
    before("/*", mimeType, apiAuthenticationHelper::checkAdminUserAnd403);
    post("", mimeType, this::create);
  });
}

代码示例来源：origin: awslabs/aws-serverless-java-container

public static void defineResources() {
  before((request, response) -> response.type("application/json"));
  post("/pets", (req, res) -> {
    Pet newPet = LambdaContainerHandler.getObjectMapper().readValue(req.body(), Pet.class);
    if (newPet.getName() == null || newPet.getBreed() == null) {
  }, new JsonTransformer());
  get("/pets", (req, res) -> {
    int limit = 10;
    if (req.queryParams("limit") != null) {
  }, new JsonTransformer());
  get("/pets/:petId", (req, res) -> {
    Pet newPet = new Pet();
    newPet.setId(UUID.randomUUID().toString());

代码示例来源：origin: cinchapi/concourse

Spark.get(route);
Spark.post(route);
Spark.put(route);
Spark.delete(route);
Spark.post(route);
Spark.put(route);
Spark.options(route);

代码示例来源：origin: hujiaweibujidao/Ganks-for-gank.io

/**
 * 启动服务器
 */
private void startServer() {
  CountInfo countInfo = StatTool.count();
  //设置端口
  if (System.getenv("PORT") != null) {
    port(Integer.valueOf(System.getenv("PORT")));
  }
  //web
  staticFileLocation("/public");
  //index page
  get("/", (request, response) -> {
    Map<String, Object> model = new HashMap<String, Object>();
    model.put("stat", countInfo);
    // The vm files are located under the resources directory
    return new ModelAndView(model, "public/html/index.vm");
  }, new VelocityTemplateEngine());
  //search action
  post("/search", (request, response) -> search(request.queryParams("keyword")), new JsonTransformer());
  gankHub = new GankHub();
  gankHub.startService();
  logger.info("server started");
}

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

spark

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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