javax.ws.rs.core.UriBuilder.port()方法的使用及代码示例

x33g5p2x  于2022-01-31 转载在 其他  
字(7.6k)|赞(0)|评价(0)|浏览(155)

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

UriBuilder.port介绍

[英]Set the URI port.
[中]设置URI端口。

代码示例

代码示例来源:origin: jersey/jersey

/**
   * Gets base {@link URI}.
   *
   * @return base {@link URI}.
   */
  public static URI getBaseURI() {
    return UriBuilder.fromUri("http://localhost/").port(getPort(8080)).build();
  }
}

代码示例来源:origin: jersey/jersey

private static URI getBaseURI() {
  return UriBuilder.fromUri("http://localhost/resources").port(getPort(defaultPort)).build();
}

代码示例来源:origin: jersey/jersey

private static URI getBaseURI() {
  return UriBuilder.fromUri("https://localhost/").port(getPort(8463)).build();
}

代码示例来源:origin: jersey/jersey

@Override
public void start() {
  if (started.compareAndSet(false, true)) {
    LOGGER.log(Level.FINE, "Starting JdkHttpServerTestContainer...");
    server.start();
    if (baseUri.getPort() == 0) {
      baseUri = UriBuilder.fromUri(baseUri)
          .port(server.getAddress().getPort())
          .build();
      LOGGER.log(Level.INFO, "Started JdkHttpServerTestContainer at the base URI " + baseUri);
    }
  } else {
    LOGGER.log(Level.WARNING, "Ignoring start request - JdkHttpServerTestContainer is already started.");
  }
}

代码示例来源:origin: jersey/jersey

@Override
public void start() {
  LOGGER.log(Level.FINE, "Starting SimpleTestContainer...");
  try {
    server = SimpleContainerFactory.create(baseUri, deploymentContext.getResourceConfig());
    if (baseUri.getPort() == 0) {
      baseUri = UriBuilder.fromUri(baseUri)
          .port(server.getPort())
          .build();
      LOGGER.log(Level.INFO, "Started SimpleTestContainer at the base URI " + baseUri);
    }
  } catch (ProcessingException e) {
    throw new TestContainerException(e);
  }
}

代码示例来源:origin: jersey/jersey

@Override
public void start() {
  if (server.isStarted()) {
    LOGGER.log(Level.WARNING, "Ignoring start request - JettyTestContainer is already started.");
  } else {
    LOGGER.log(Level.FINE, "Starting JettyTestContainer...");
    try {
      server.start();
      if (baseUri.getPort() == 0) {
        int port = 0;
        for (final Connector connector : server.getConnectors()) {
          if (connector instanceof ServerConnector) {
            port = ((ServerConnector) connector).getLocalPort();
            break;
          }
        }
        baseUri = UriBuilder.fromUri(baseUri).port(port).build();
        LOGGER.log(Level.INFO, "Started JettyTestContainer at the base URI " + baseUri);
      }
    } catch (Exception e) {
      throw new TestContainerException(e);
    }
  }
}

代码示例来源:origin: jersey/jersey

/**
 * Returns the base URI of the tested application.
 *
 * @return the base URI of the tested application.
 */
// TODO make final
protected URI getBaseUri() {
  final TestContainer container = getTestContainer();
  if (container != null) {
    // called from outside of JerseyTest constructor
    return container.getBaseUri();
  }
  // called from within JerseyTest constructor
  return UriBuilder.fromUri("http://localhost/").port(getPort()).build();
}

代码示例来源:origin: jersey/jersey

@Override
public void start() {
  if (server.isStarted()) {
    LOGGER.log(Level.WARNING, "Ignoring start request - GrizzlyTestContainer is already started.");
  } else {
    LOGGER.log(Level.FINE, "Starting GrizzlyTestContainer...");
    try {
      server.start();
      if (baseUri.getPort() == 0) {
        baseUri = UriBuilder.fromUri(baseUri)
            .port(server.getListener("grizzly").getPort())
            .build();
        LOGGER.log(Level.INFO, "Started GrizzlyTestContainer at the base URI " + baseUri);
      }
    } catch (final IOException ioe) {
      throw new TestContainerException(ioe);
    }
  }
}

代码示例来源:origin: jersey/jersey

@Override
public void start() {
  if (server.isStarted()) {
    LOGGER.log(Level.WARNING, "Ignoring start request - GrizzlyWebTestContainer is already started.");
  } else {
    LOGGER.log(Level.FINE, "Starting GrizzlyWebTestContainer...");
    try {
      server.start();
      if (baseUri.getPort() == 0) {
        baseUri = UriBuilder.fromUri(baseUri)
            .port(server.getListener("grizzly").getPort())
            .build();
        LOGGER.log(Level.INFO, "Started GrizzlyWebTestContainer at the base URI " + baseUri);
      }
    } catch (final IOException ioe) {
      throw new TestContainerException(ioe);
    }
  }
}

代码示例来源:origin: soabase/exhibitor

public Result         makeRequest(RemoteInstanceRequestClient client, String methodName, Object... values)
{
  String      remoteResponse;
  String      errorMessage;
  {
    try
    {
      URI remoteUri = UriBuilder
        .fromPath(getPath())
        .scheme(exhibitor.getRestScheme())
        .host(hostname)
        .port(exhibitor.getRestPort())
        .path(ClusterResource.class, methodName)
        .build(values);
      remoteResponse = client.getWebResource(remoteUri, MediaType.APPLICATION_JSON_TYPE, String.class);
      errorMessage = "";
    }
    catch ( Exception e )
    {
      remoteResponse = "{}";
      errorMessage = e.getMessage();
      if ( errorMessage == null )
      {
        errorMessage = "Unknown";
      }
    }
  }
  return new Result(remoteResponse, errorMessage);
}

代码示例来源:origin: neo4j/neo4j

private static URI externalUri( UriBuilder builder, String xForwardedHost, String xForwardedProto )
{
  ForwardedHost forwardedHost = new ForwardedHost( xForwardedHost );
  ForwardedProto forwardedProto = new ForwardedProto( xForwardedProto );
  if ( forwardedHost.isValid )
  {
    builder.host( forwardedHost.getHost() );
    if ( forwardedHost.hasExplicitlySpecifiedPort() )
    {
      builder.port( forwardedHost.getPort() );
    }
  }
  if ( forwardedProto.isValid() )
  {
    builder.scheme( forwardedProto.getScheme() );
  }
  return builder.build();
}

代码示例来源:origin: rakam-io/rakam

@Override
  public void shutdown() {
    URI uri = UriBuilder.fromUri(prestoAddress)
        .port(streamingPort)
        .path("connector/streamer")
        .queryParam("ticket", ticket)
        .build();
    Request request = prepareDelete().setUri(uri).build();
    httpClient.execute(request, StringResponseHandler.createStringResponseHandler());
  }
};

代码示例来源:origin: apache/opennlp

new TokenNameFinderModel(new File(args[args.length - 1])))};
URI baseUri = UriBuilder.fromUri("http://localhost/").port(serverPort).build();
ResourceConfig config = new ResourceConfig(NameFinderResource.class);
GrizzlyHttpServerFactory.createHttpServer(baseUri, config);

代码示例来源:origin: rakam-io/rakam

@Override
public synchronized void sync() {
  try {
    URI uri = UriBuilder.fromUri(prestoAddress)
        .port(streamingPort)
        .path("connector/streamer")
        .queryParam("ticket", ticket)
        .build();
    Request request = prepareGet().setUri(uri).build();
    String data = httpClient.execute(request, StringResponseHandler.createStringResponseHandler()).getBody();
    response.send("data", data);
  } catch (Exception e) {
    if (failed.incrementAndGet() > 5) {
      LOGGER.error(e, "Error while streaming records to client");
      shutdown();
    }
  }
}

代码示例来源:origin: apache/metron

public static void start(int port) throws IOException {
 // Create an HTTP server listening at port
 URI uri = UriBuilder.fromUri("http://localhost/").port(port).build();
 server = HttpServer.create(new InetSocketAddress(uri.getPort()), 0);
 HttpHandler handler = RuntimeDelegate.getInstance().createEndpoint(new ApplicationConfig(), HttpHandler.class);
 server.createContext(uri.getPath(), handler);
 server.start();
}

代码示例来源:origin: rakam-io/rakam

.port(streamingPort)
.path("connector/streamer")
.build();

代码示例来源:origin: smallnest/Jax-RS-Performance-Comparison

public static HttpServer startServer(String host, int port) {
  final ResourceConfig rc = ResourceConfig.forApplicationClass(MyApplication.class);
  URI baseUri = UriBuilder.fromUri(BASE_URI).host(host).port(port).build();
  return GrizzlyHttpServerFactory.createHttpServer(baseUri, rc);
}

代码示例来源:origin: org.keycloak/keycloak-server-spi

@Override
public URI getRequestUri() {
  if (requestURI == null) {
    requestURI = delegate.getRequestUriBuilder().scheme(scheme).host(hostname).port(port).build();
  }
  return requestURI;
}

代码示例来源:origin: org.keycloak/keycloak-server-spi

@Override
public URI getAbsolutePath() {
  if (absolutePath == null) {
    absolutePath = delegate.getAbsolutePathBuilder().scheme(scheme).host(hostname).port(port).build();
  }
  return absolutePath;
}

代码示例来源:origin: org.keycloak/keycloak-server-spi

@Override
public URI getBaseUri() {
  if (baseURI == null) {
    baseURI = delegate.getBaseUriBuilder().scheme(scheme).host(hostname).port(port).build();
  }
  return baseURI;
}

相关文章