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

Endpoint.port介绍

[英]Returns the port number of this endpoint.
[中]返回此终结点的端口号。

代码示例

代码示例来源：origin: line/armeria

@Override
public byte[] encodeAll(Iterable<Endpoint> endpoints) {
  requireNonNull(endpoints, "endpoints");
  final StringBuilder nodeValue = new StringBuilder();
  endpoints.forEach(endpoint -> nodeValue.append(endpoint.host()).append(fieldDelimiter).append(
      endpoint.port()).append(fieldDelimiter).append(endpoint.weight()).append(segmentDelimiter));
  //delete the last unused segment delimiter
  if (nodeValue.length() > 0) {
    nodeValue.deleteCharAt(nodeValue.length() - 1);
  }
  return nodeValue.toString().getBytes(StandardCharsets.UTF_8);
}

代码示例来源：origin: line/armeria

@Override
  public byte[] encode(Endpoint endpoint) {
    return (endpoint.host() + fieldDelimiter + endpoint.port() + fieldDelimiter + endpoint.weight())
        .getBytes(StandardCharsets.UTF_8);
  }
}

代码示例来源：origin: line/armeria

@Override
public void serverStarted(Server server) throws Exception {
  if (endpoint == null) {
    assert server.activePort().isPresent();
    endpoint = Endpoint.of(server.defaultHostname(),
                server.activePort().get()
                   .localAddress().getPort());
  }
  client.start();
  final String key = endpoint.host() + '_' + endpoint.port();
  final byte[] value = nodeValueCodec.encode(endpoint);
  client.create()
     .creatingParentsIfNeeded()
     .withMode(CreateMode.EPHEMERAL)
     .forPath(zNodePath + '/' + key, value);
}

代码示例来源：origin: line/armeria

} else {
  final int defaultPort = cCtx.sessionProtocol().defaultPort();
  final int port = endpoint.port(defaultPort);
  if (port == defaultPort) {
    authority = endpoint.host();

代码示例来源：origin: line/armeria

endpoint -> assertExists(zNode + '/' + endpoint.host() + '_' + endpoint.port())));
  try {
    assertThat(NodeValueCodec.DEFAULT.decode(zk.getData(
        zNode + '/' + endpoint.host() + '_' + endpoint.port()).get()))
        .isEqualTo(endpoint);
  } catch (Throwable throwable) {
      final String key = zNode + '/' + endpoint.host() + '_' + endpoint.port();
      if (zk.exists(key).get()) {
        remaining++;

代码示例来源：origin: line/armeria

private void setNodeChild(Set<Endpoint> children) throws Throwable {
    try (CloseableZooKeeper zk = connection()) {
      // If the parent node does not exist, create it.
      if (!zk.exists(zNode).get()) {
        zk.create(zNode, null, Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
      }
      // Register all child nodes.
      children.forEach(endpoint -> {
        try {
          zk.create(zNode + '/' + endpoint.host() + '_' + endpoint.port(),
               NodeValueCodec.DEFAULT.encode(endpoint),
               Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
        } catch (Exception e) {
          Exceptions.throwUnsafely(e);
        }
      });
    }
    children.forEach(endpoint -> assertExists(zNode + '/' + endpoint.host() + '_' + endpoint.port()));
  }
}

代码示例来源：origin: line/armeria

private HttpEndpointHealthChecker(
    ClientFactory clientFactory, Endpoint endpoint,
    SessionProtocol protocol, String healthCheckPath, int healthCheckPort,
    Function<? super ClientOptionsBuilder, ClientOptionsBuilder> configurator) {
  final String scheme = protocol.uriText();
  final String ipAddr = endpoint.ipAddr();
  final HttpClientBuilder builder;
  if (ipAddr == null) {
    builder = new HttpClientBuilder(scheme + "://" + endpoint.authority());
  } else {
    final int port = healthCheckPort > 0 ? healthCheckPort : endpoint.port(protocol.defaultPort());
    if (endpoint.ipFamily() == StandardProtocolFamily.INET) {
      builder = new HttpClientBuilder(scheme + "://" + ipAddr + ':' + port);
    } else {
      builder = new HttpClientBuilder(scheme + "://[" + ipAddr + "]:" + port);
    }
    builder.setHttpHeader(HttpHeaderNames.AUTHORITY, endpoint.authority());
  }
  httpClient = builder.factory(clientFactory)
            .options(configurator.apply(new ClientOptionsBuilder()).build())
            .build();
  this.healthCheckPath = healthCheckPath;
}

代码示例来源：origin: line/armeria

private void acquireConnectionAndExecute(ClientRequestContext ctx, Endpoint endpoint, String ipAddr,
                     HttpRequest req, DecodedHttpResponse res) {
  final EventLoop eventLoop = ctx.eventLoop();
  if (!eventLoop.inEventLoop()) {
    eventLoop.execute(() -> acquireConnectionAndExecute(ctx, endpoint, ipAddr, req, res));
    return;
  }
  final String host = extractHost(ctx, req, endpoint);
  final int port = endpoint.port();
  final SessionProtocol protocol = ctx.sessionProtocol();
  final HttpChannelPool pool = factory.pool(ctx.eventLoop());
  final PoolKey key = new PoolKey(host, ipAddr, port);
  final PooledChannel pooledChannel = pool.acquireNow(protocol, key);
  if (pooledChannel != null) {
    doExecute(pooledChannel, ctx, req, res);
  } else {
    pool.acquireLater(protocol, key).handle((newPooledChannel, cause) -> {
      if (cause == null) {
        doExecute(newPooledChannel, ctx, req, res);
      } else {
        handleEarlyRequestException(ctx, req, cause);
        res.close(cause);
      }
      return null;
    });
  }
}

代码示例来源：origin: line/armeria

@Before
public void startServers() {
  servers = new ArrayList<>();
  for (Endpoint endpoint : sampleEndpoints) {
    final Server server = new ServerBuilder().http(endpoint.port())
                         .service("/", new EchoService())
                         .build();
    final ServerListener listener = new ZooKeeperUpdatingListenerBuilder(
        instance().connectString().get(), zNode)
        .sessionTimeoutMillis(sessionTimeoutMillis)
        .endpoint(endpoint)
        .build();
    server.addListener(listener);
    server.start().join();
    servers.add(server);
  }
}

代码示例来源：origin: line/armeria

@Override
public HttpResponse execute(ClientRequestContext ctx, HttpRequest req) throws Exception {
  if (!isValidPath(req)) {
    final IllegalArgumentException cause = new IllegalArgumentException("invalid path: " + req.path());
    handleEarlyRequestException(ctx, req, cause);
    return HttpResponse.ofFailure(cause);
  }
  final Endpoint endpoint = ctx.endpoint().resolve(ctx)
                 .withDefaultPort(ctx.sessionProtocol().defaultPort());
  final EventLoop eventLoop = ctx.eventLoop();
  final DecodedHttpResponse res = new DecodedHttpResponse(eventLoop);
  if (endpoint.hasIpAddr()) {
    // IP address has been resolved already.
    acquireConnectionAndExecute(ctx, endpoint, endpoint.ipAddr(), req, res);
  } else {
    // IP address has not been resolved yet.
    final Future<InetSocketAddress> resolveFuture =
        addressResolverGroup.getResolver(eventLoop)
                  .resolve(InetSocketAddress.createUnresolved(endpoint.host(),
                                        endpoint.port()));
    if (resolveFuture.isDone()) {
      finishResolve(ctx, endpoint, resolveFuture, req, res);
    } else {
      resolveFuture.addListener(
          (FutureListener<InetSocketAddress>) future ->
              finishResolve(ctx, endpoint, future, req, res));
    }
  }
  return res;
}

代码示例来源：origin: com.linecorp.armeria/armeria-logback-shaded

} else {
  final int defaultPort = cCtx.sessionProtocol().defaultPort();
  final int port = endpoint.port(defaultPort);
  if (port == defaultPort) {
    authority = endpoint.host();

代码示例来源：origin: com.linecorp.armeria/armeria-logback

} else {
  final int defaultPort = cCtx.sessionProtocol().defaultPort();
  final int port = endpoint.port(defaultPort);
  if (port == defaultPort) {
    authority = endpoint.host();