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

Spark.port介绍

[英]Retrieves the port that Spark is listening on.
[中]检索Spark正在侦听的端口。

代码示例

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

port(bridgeSettings.getBridgeSettingsDescriptor().getServerPort());
staticFileLocation("/public");
initExceptionHandler((e) -> HABridge.theExceptionHandler(e, bridgeSettings.getBridgeSettingsDescriptor().getServerPort()));

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

/**
  * Starts the webapp on localhost:8080.
  */
 public static void main(String[] args) {
  port(8080);
  String kind = "DemoUser";
  if (args != null) {
   for (String arg : args) {
    if (arg.startsWith("kind=")) {
     kind = arg.substring("kind=".length());
    }
   }
  }
  UserController userController = new UserController(new UserService(
    DatastoreOptions.getDefaultInstance().getService(), kind));
 }
}

代码示例来源：origin: beryx/text-io

@Override
public int getPort() {
  return port();
}

代码示例来源：origin: com.cldellow/manu-serve

public Server(int port, Map<String, Collection> collections) throws Exception {
  port(port);
  this.collections = collections;
}

代码示例来源：origin: beryx/text-io

@Override
public SparkDataServer withPort(int portNumber) {
  port(portNumber);
  return this;
}
@Override

代码示例来源：origin: com.rapatao.sparkjava/spark-spring-core

/**
 * Registry all Spark configuration
 *
 * @param sparkConfiguration the spark configuration
 */
@Override
public void registry(final SparkConfiguration sparkConfiguration) {
  if (sparkConfiguration != null) {
    Spark.port(sparkConfiguration.getPort());
  }
}

代码示例来源：origin: david-cao/gRPCBenchmarks

public static void main(String[] args) {
    port(50052);

    post("/postPayload", Routes.postPayload());

    System.out.println("HTTP server started...");
  }
}

代码示例来源：origin: despegar/spark-test

@Override
protected void before() throws Throwable {
  Spark.port(this.port);
  this.sparkApplication = this.sparkApplicationClass.newInstance();
  this.sparkApplication.init();
  Spark.awaitInitialization();
}

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

private void serve(SentenceRepository sentenceRepository) {
  port(PORT.get());
  get("/", (request, response) ->
      sentenceRepository.findOne()
          .map(Sentence::getContent)
          .orElseGet(() -> {
            response.status(204);
            return "";
          }));
}

代码示例来源：origin: cuba-platform/yarg

public void init() throws IOException {
  if (port != null) {
    Spark.port(port);
  }
  initPing();
  initGenerate();
}

代码示例来源：origin: mattjlewis/diozero

public static void main(String[] args) {
  port(8080);
  webSocket("/diozero", JsonWebSocket.class);
  init(); // Needed if you don't define any HTTP routes after your WebSocket routes
}

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

void initServerConfig(final MockedServerConfigDTO config) {
  logger.debug("initServerConfig called");
  if (logger.isDebugEnabled())
    logger.debug(config.toString());
  Spark.port(config.getPort());
  Spark.threadPool(config.getMaxThreads(), config.getMinThreads(), config.getTimeOutMillis());
}

代码示例来源：origin: mattjlewis/diozero

public static void main(String[] args) {
    port(PropertyUtil.getIntProperty(PORT_PROP, DEFAULT_PORT));
    
    controller = new DiozeroController();
    controller.init();
  }
}

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

@Override
public void start() {
  Spark.port(applicationConfig.port());
  configure();
  Spark.awaitInitialization();
  LOGGER.info("Spark server started on port {} for healthCheck.", applicationConfig.port());
}

代码示例来源：origin: cagataygurturk/lambadaframework

@Override
public void execute() throws MojoExecutionException {
  try {
    printLogo();
    getLog().info(LOG_SEPERATOR);
    getLog().info("Starting web server at port " + serverPort);
    port(serverPort);
    threadPool(8);
    setUpServer();
    awaitInitialization();
    while (10 != System.in.read()) {
      Thread.sleep(500);
    }
    stop();
  } catch (Exception e) {
    throw new MojoExecutionException("Exception at deployment", e);
  }
}

代码示例来源：origin: ingenieux/lambada

@Override
protected void executeInternal() throws Exception {
 setupStageVariables();
 loadPathHandlers();
 port(serverPort);
 threadPool(8);
 setupServer();
 awaitInitialization();
 getLog().info(format("Server is alive on http://%s:%d/%s/", "127.0.0.1", this.serverPort, this.stageName));
 while (10 != System.in.read()) {
  Thread.sleep(500);
 }
 stop();
}

代码示例来源：origin: xjdr/xio

private static void setupSpark(int port, String name, boolean tls) throws Exception {
 if (tls) {
  Resource keystore = new ClassPathResource("snakeoil.jks");
  URL url = keystore.getURL();
  String path = url.toString();
  secure(path, "snakeoil", path, "snakeoil");
 }
 port(port);
 get("/", (req, res) -> setupSparkResponse(name, req, res));
 post("/", (req, res) -> setupSparkResponse(name, req, res));
}

代码示例来源：origin: renatoathaydes/rawhttp

@BeforeClass
public static void startServer() throws Exception {
  Spark.port(PORT);
  Spark.get("/hello", "text/plain", (req, res) -> "Hello");
  RawHttp.waitForPortToBeTaken(PORT, Duration.ofSeconds(2));
}

代码示例来源：origin: pyloque/captain

public void start() {
  Spark.ipAddress(config.bindHost());
  Spark.port(config.bindPort());
  Spark.threadPool(config.threadNum());
  Spark.staticFileLocation("/static");
  if (!config.readonly()) {
    this.initWritableHandlers();
  }
  this.initReadonlyHandlers();
  this.initViewHandlers();
  this.initExceptionHandlers();
  Spark.awaitInitialization();
  LOG.warn("captain server started");
}

代码示例来源：origin: pengrad/java-telegram-bot-api

public static void main(String[] args) throws Exception {
  ipAddress(args[0]);
  port(Integer.parseInt(args[1]));
  get("/hello", (req, res) -> "Hello World");
  post("/test", new Test());
  get("/test", new Test());
  get("/kurs", (request, response) -> new KursBot().getAllKurs());
  post("/kursBot", new KursBot());
  BotHandler botHandler = new AqivnBot();
  post("/" + botHandler.getToken(), botHandler);
  String appSite = System.getenv("OPENSHIFT_APP_DNS");
  botHandler.getBot().execute(new SetWebhook().url(appSite + "/" + botHandler.getToken()));
}