Class RoundRobinDnsAddressResolverGroup

java.lang.Object

io.netty.resolver.AddressResolverGroup<InetSocketAddress>

io.netty.resolver.dns.DnsAddressResolverGroup

io.netty.resolver.dns.RoundRobinDnsAddressResolverGroup

All Implemented Interfaces:

Closeable, AutoCloseable

public class RoundRobinDnsAddressResolverGroup
extends DnsAddressResolverGroup

A AddressResolverGroup of DnsNameResolvers that supports random selection of destination addresses if multiple are provided by the nameserver. This is ideal for use in applications that use a pool of connections, for which connecting to a single resolved address would be inefficient.

Constructor Summary

Constructors

Constructor	Description
RoundRobinDnsAddressResolverGroup(ChannelFactory<? extends DatagramChannel> channelFactory, DnsServerAddressStreamProvider nameServerProvider)
RoundRobinDnsAddressResolverGroup(DnsNameResolverBuilder dnsResolverBuilder)
RoundRobinDnsAddressResolverGroup(Class<? extends DatagramChannel> channelType, DnsServerAddressStreamProvider nameServerProvider)

Method Summary

Modifier and Type	Method	Description
protected final AddressResolver<InetSocketAddress>	newAddressResolver(EventLoop eventLoop, NameResolver<InetAddress> resolver)	We need to override this method, not DnsAddressResolverGroup.newNameResolver(EventLoop, ChannelFactory, DnsServerAddressStreamProvider), because we need to eliminate possible caching of NameResolver.resolve(String) by InflightNameResolver created in DnsAddressResolverGroup.newResolver(EventLoop, ChannelFactory, DnsServerAddressStreamProvider).

Methods inherited from class DnsAddressResolverGroup

newNameResolver, newResolver, newResolver

Methods inherited from class AddressResolverGroup

close, getResolver

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RoundRobinDnsAddressResolverGroup

public RoundRobinDnsAddressResolverGroup(DnsNameResolverBuilder dnsResolverBuilder)

RoundRobinDnsAddressResolverGroup

public RoundRobinDnsAddressResolverGroup(Class<? extends DatagramChannel> channelType,
 DnsServerAddressStreamProvider nameServerProvider)

RoundRobinDnsAddressResolverGroup

public RoundRobinDnsAddressResolverGroup(ChannelFactory<? extends DatagramChannel> channelFactory,
 DnsServerAddressStreamProvider nameServerProvider)

Method Details

newAddressResolver

protected final AddressResolver<InetSocketAddress> newAddressResolver(EventLoop eventLoop,
 NameResolver<InetAddress> resolver)
                                                               throws Exception

We need to override this method, not DnsAddressResolverGroup.newNameResolver(EventLoop, ChannelFactory, DnsServerAddressStreamProvider), because we need to eliminate possible caching of NameResolver.resolve(String) by InflightNameResolver created in DnsAddressResolverGroup.newResolver(EventLoop, ChannelFactory, DnsServerAddressStreamProvider).

Overrides:

newAddressResolver in class DnsAddressResolverGroup

Throws:

Exception