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