io.netty.bootstrap.Bootstrap.resolver()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(6.4k)|赞(0)|评价(0)|浏览(218)

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

Bootstrap.resolver介绍

[英]Sets the NameResolver which will resolve the address of the unresolved named address.
[中]设置名称解析程序,该程序将解析未解析的命名地址的地址。

代码示例

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

/**
 * Returns the configured {@link AddressResolverGroup} or the default if non is configured yet.
 */
public AddressResolverGroup<?> resolver() {
  return bootstrap.resolver();
}

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

/**
 * Returns the configured {@link AddressResolverGroup} or the default if non is configured yet.
 */
public AddressResolverGroup<?> resolver() {
  return bootstrap.resolver();
}

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

/**
 * Returns the configured {@link AddressResolverGroup} or the default if non is configured yet.
 */
public AddressResolverGroup<?> resolver() {
  return bootstrap.resolver();
}

代码示例来源:origin: Netflix/zuul

public AddressResolver<?> getResolver(final EventLoop eventLoop) {
    return bootstrap.resolver().getResolver(eventLoop);
  }
}

代码示例来源:origin: eclipse-vertx/vert.x

private void handleConnect(SocketAddress remoteAddress, SocketAddress peerAddress, String serverName, Handler<AsyncResult<Channel>> channelHandler) {
 VertxInternal vertx = context.owner();
 bootstrap.resolver(vertx.nettyAddressResolverGroup());
 bootstrap.handler(new ChannelInitializer<Channel>() {
  @Override
  protected void initChannel(Channel ch) {
   initSSL(peerAddress, serverName, ch, channelHandler);
  }
 });
 ChannelFuture fut = bootstrap.connect(vertx.transport().convert(remoteAddress, false));
 fut.addListener(res -> {
  if (res.isSuccess()) {
   connected(fut.channel(), channelHandler);
  } else {
   channelHandler.handle(io.vertx.core.Future.failedFuture(res.cause()));
  }
 });
}

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

private Bootstrap createBootstrap(RedisClientConfig config, Type type) {
  Bootstrap bootstrap = new Bootstrap()
          .resolver(config.getResolverGroup())
          .channel(config.getSocketChannelClass())
          .group(config.getGroup());
  bootstrap.handler(new RedisChannelInitializer(bootstrap, config, this, channels, type));
  bootstrap.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, config.getConnectTimeout());
  bootstrap.option(ChannelOption.SO_KEEPALIVE, config.isKeepAlive());
  bootstrap.option(ChannelOption.TCP_NODELAY, config.isTcpNoDelay());
  return bootstrap;
}

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

private Bootstrap createBootstrap(RedisClientConfig config, Type type) {
  Bootstrap bootstrap = new Bootstrap()
          .resolver(config.getResolverGroup())
          .channel(config.getSocketChannelClass())
          .group(config.getGroup());
  bootstrap.handler(new RedisChannelInitializer(bootstrap, config, this, channels, type));
  bootstrap.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, config.getConnectTimeout());
  bootstrap.option(ChannelOption.SO_KEEPALIVE, config.isKeepAlive());
  bootstrap.option(ChannelOption.TCP_NODELAY, config.isTcpNoDelay());
  return bootstrap;
}

代码示例来源:origin: Netflix/zuul

public AddressResolver<?> getResolver(final EventLoop eventLoop) {
    return bootstrap.resolver().getResolver(eventLoop);
  }
}

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

baseBootstrap.resolver(addressResolverGroup);

代码示例来源:origin: GlowstoneMC/Glowstone

.resolver(resolverGroup)
.channel(GlowServer.EPOLL ? EpollSocketChannel.class : GlowServer.KQUEUE
  ? KQueueSocketChannel.class : NioSocketChannel.class)

代码示例来源:origin: eclipse-vertx/vert.x

bootstrap.resolver(NoopAddressResolverGroup.INSTANCE);
java.net.SocketAddress targetAddress = vertx.transport().convert(remoteAddress, false);

代码示例来源:origin: relayrides/pushy

this.bootstrapTemplate.option(ChannelOption.TCP_NODELAY, true);
this.bootstrapTemplate.remoteAddress(apnsServerAddress);
this.bootstrapTemplate.resolver(this.addressResolverGroup);

代码示例来源:origin: eclipse-vertx/vert.x

bootstrap.channelFactory(((VertxInternal)vertx).transport().channelFactory(false));
bootstrap.group(vertx.nettyEventLoopGroup());
bootstrap.resolver(((VertxInternal) vertx).nettyAddressResolverGroup());
bootstrap.handler(new ChannelInitializer<Channel>() {
 @Override

代码示例来源:origin: io.vertx/vertx-core

private void handleConnect(SocketAddress remoteAddress, SocketAddress peerAddress, String serverName, Handler<AsyncResult<Channel>> channelHandler) {
 VertxInternal vertx = context.owner();
 bootstrap.resolver(vertx.nettyAddressResolverGroup());
 bootstrap.handler(new ChannelInitializer<Channel>() {
  @Override
  protected void initChannel(Channel ch) {
   initSSL(peerAddress, serverName, ch, channelHandler);
  }
 });
 ChannelFuture fut = bootstrap.connect(vertx.transport().convert(remoteAddress, false));
 fut.addListener(res -> {
  if (res.isSuccess()) {
   connected(fut.channel(), channelHandler);
  } else {
   channelHandler.handle(io.vertx.core.Future.failedFuture(res.cause()));
  }
 });
}

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

bootstrap.resolver(NoopAddressResolverGroup.INSTANCE);

代码示例来源:origin: io.vertx/vertx-core

bootstrap.resolver(NoopAddressResolverGroup.INSTANCE);
java.net.SocketAddress targetAddress = vertx.transport().convert(remoteAddress, false);

代码示例来源:origin: io.vertx/vertx-core

bootstrap.channelFactory(((VertxInternal)vertx).transport().channelFactory(false));
bootstrap.group(vertx.nettyEventLoopGroup());
bootstrap.resolver(((VertxInternal) vertx).nettyAddressResolverGroup());
bootstrap.handler(new ChannelInitializer<Channel>() {
 @Override

代码示例来源:origin: reactor/reactor-netty

/**
 * Assign an {@link AddressResolverGroup}.
 *
 * @param resolver the new {@link AddressResolverGroup}
 *
 * @return a new {@link TcpClient}
 */
public final TcpClient resolver(AddressResolverGroup<?> resolver) {
  Objects.requireNonNull(resolver, "resolver");
  return bootstrap(b -> b.resolver(resolver));
}

代码示例来源:origin: org.redisson/redisson

private Bootstrap createBootstrap(RedisClientConfig config, Type type) {
  Bootstrap bootstrap = new Bootstrap()
          .resolver(config.getResolverGroup())
          .channel(config.getSocketChannelClass())
          .group(config.getGroup());
  bootstrap.handler(new RedisChannelInitializer(bootstrap, config, this, channels, type));
  bootstrap.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, config.getConnectTimeout());
  bootstrap.option(ChannelOption.SO_KEEPALIVE, config.isKeepAlive());
  bootstrap.option(ChannelOption.TCP_NODELAY, config.isTcpNoDelay());
  return bootstrap;
}

代码示例来源:origin: reactor/reactor-netty

static Bootstrap updateProxySupport(Bootstrap b, ProxyProvider proxyOptions) {
  BootstrapHandlers.updateConfiguration(b,
      NettyPipeline.ProxyHandler,
      new ProxyProvider.DeferredProxySupport(proxyOptions));
  if (b.config().resolver() == DefaultAddressResolverGroup.INSTANCE) {
    return b.resolver(NoopAddressResolverGroup.INSTANCE);
  }
  return b;
}

相关文章