本文整理了Java中javax.ws.rs.core.UriBuilder.port()
方法的一些代码示例,展示了UriBuilder.port()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。UriBuilder.port()
方法的具体详情如下:
包路径:javax.ws.rs.core.UriBuilder
类名称: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;
}
内容来源于网络,如有侵权,请联系作者删除!