Add RequestSendType.ROUND_ROBIN for per-request IP round-robin

client/src/main/java/org/asynchttpclient/AsyncHttpClientConfig.java

@@ -230,6 +230,14 @@ public interface AsyncHttpClientConfig {
      */
     int getMaxRequestRetry();
 
+    /**
+     * @return how requests are dispatched to a host that resolves to several IP addresses; never {@code null}.
+     * @see RequestSendType
+     */
+    default RequestSendType getRequestSendType() {
+        return RequestSendType.DEFAULT;
+    }
+
     /**
      * @return the disableUrlEncodingForBoundRequests
      */

client/src/main/java/org/asynchttpclient/DefaultAsyncHttpClientConfig.java

@@ -80,6 +80,7 @@
 import static org.asynchttpclient.config.AsyncHttpClientConfigDefaults.defaultMaxRequestRetry;
 import static org.asynchttpclient.config.AsyncHttpClientConfigDefaults.defaultPooledConnectionIdleTimeout;
 import static org.asynchttpclient.config.AsyncHttpClientConfigDefaults.defaultReadTimeout;
+import static org.asynchttpclient.config.AsyncHttpClientConfigDefaults.defaultRequestSendType;
 import static org.asynchttpclient.config.AsyncHttpClientConfigDefaults.defaultRequestTimeout;
 import static org.asynchttpclient.config.AsyncHttpClientConfigDefaults.defaultShutdownQuietPeriod;
 import static org.asynchttpclient.config.AsyncHttpClientConfigDefaults.defaultShutdownTimeout;
@@ -131,6 +132,7 @@ public class DefaultAsyncHttpClientConfig implements AsyncHttpClientConfig {
     private final String userAgent;
     private final @Nullable Realm realm;
     private final int maxRequestRetry;
+    private final RequestSendType requestSendType;
     private final boolean disableUrlEncodingForBoundRequests;
     private final boolean useLaxCookieEncoder;
     private final boolean disableZeroCopy;
@@ -232,6 +234,7 @@ private DefaultAsyncHttpClientConfig(// http
                                          String userAgent,
                                          @Nullable Realm realm,
                                          int maxRequestRetry,
+                                         RequestSendType requestSendType,
                                          boolean disableUrlEncodingForBoundRequests,
                                          boolean useLaxCookieEncoder,
                                          boolean disableZeroCopy,
@@ -333,6 +336,7 @@ private DefaultAsyncHttpClientConfig(// http
         this.userAgent = userAgent;
         this.realm = realm;
         this.maxRequestRetry = maxRequestRetry;
+        this.requestSendType = requestSendType;
         this.disableUrlEncodingForBoundRequests = disableUrlEncodingForBoundRequests;
         this.useLaxCookieEncoder = useLaxCookieEncoder;
         this.disableZeroCopy = disableZeroCopy;
@@ -487,6 +491,11 @@ public int getMaxRequestRetry() {
         return maxRequestRetry;
     }
 
+    @Override
+    public RequestSendType getRequestSendType() {
+        return requestSendType;
+    }
+
     @Override
     public boolean isDisableUrlEncodingForBoundRequests() {
         return disableUrlEncodingForBoundRequests;
@@ -898,6 +907,7 @@ public static class Builder {
         private String userAgent = defaultUserAgent();
         private @Nullable Realm realm;
         private int maxRequestRetry = defaultMaxRequestRetry();
+        private RequestSendType requestSendType = defaultRequestSendType();
         private boolean disableUrlEncodingForBoundRequests = defaultDisableUrlEncodingForBoundRequests();
         private boolean useLaxCookieEncoder = defaultUseLaxCookieEncoder();
         private boolean disableZeroCopy = defaultDisableZeroCopy();
@@ -1002,6 +1012,7 @@ public Builder(AsyncHttpClientConfig config) {
             userAgent = config.getUserAgent();
             realm = config.getRealm();
             maxRequestRetry = config.getMaxRequestRetry();
+            requestSendType = config.getRequestSendType();
             disableUrlEncodingForBoundRequests = config.isDisableUrlEncodingForBoundRequests();
             useLaxCookieEncoder = config.isUseLaxCookieEncoder();
             disableZeroCopy = config.isDisableZeroCopy();
@@ -1158,6 +1169,21 @@ public Builder setMaxRequestRetry(int maxRequestRetry) {
             return this;
         }
 
+        /**
+         * Sets how requests are dispatched to a host that resolves to several IP addresses.
+         *
+         * <p>With {@link RequestSendType#ROUND_ROBIN}, consecutive requests to a multi-IP host are
+         * spread evenly across all of its addresses (TCP failover is preserved, both HTTP/1.1 and
+         * HTTP/2 are supported). The {@code maxConnectionsPerHost} limit remains per host.
+         *
+         * @param requestSendType the dispatch strategy; {@code null} resets to {@link RequestSendType#DEFAULT}
+         * @return this
+         */
+        public Builder setRequestSendType(RequestSendType requestSendType) {
+            this.requestSendType = requestSendType == null ? RequestSendType.DEFAULT : requestSendType;
+            return this;
+        }
+
         public Builder setDisableUrlEncodingForBoundRequests(boolean disableUrlEncodingForBoundRequests) {
             this.disableUrlEncodingForBoundRequests = disableUrlEncodingForBoundRequests;
             return this;
@@ -1633,6 +1659,7 @@ public DefaultAsyncHttpClientConfig build() {
                     userAgent,
                     realm,
                     maxRequestRetry,
+                    requestSendType,
                     disableUrlEncodingForBoundRequests,
                     useLaxCookieEncoder,
                     disableZeroCopy,

client/src/main/java/org/asynchttpclient/RequestSendType.java

@@ -0,0 +1,69 @@
+/*
+ *    Copyright (c) 2026 AsyncHttpClient Project. All rights reserved.
+ *
+ *    Licensed under the Apache License, Version 2.0 (the "License");
+ *    you may not use this file except in compliance with the License.
+ *    You may obtain a copy of the License at
+ *
+ *        http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *    Unless required by applicable law or agreed to in writing, software
+ *    distributed under the License is distributed on an "AS IS" BASIS,
+ *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *    See the License for the specific language governing permissions and
+ *    limitations under the License.
+ */
+package org.asynchttpclient;
+
+/**
+ * Controls how requests are dispatched to a host that resolves to several IP addresses.
+ *
+ * <p>Configured globally through {@link AsyncHttpClientConfig#getRequestSendType()}.
+ */
+public enum RequestSendType {
+
+    /**
+     * Default behavior. The address list returned by DNS is used in its natural order: a new
+     * connection always targets the first address and only falls back to the next one when a TCP
+     * connection attempt fails. Combined with connection pooling (keyed by host), this means that
+     * with keep-alive enabled essentially all traffic to a host stays on the first reachable IP.
+     *
+     * <p>To spread traffic across a host's IPs in this mode, configure a resolver that rotates its
+     * results, such as {@link io.netty.resolver.RoundRobinInetAddressResolver}; the client keeps
+     * targeting the first address, and the resolver is what varies which IP that is.
+     */
+    DEFAULT,
+
+    /**
+     * Strict per-request round-robin across the host's resolved IPs.
+     *
+     * <p>For each request, the client rotates which resolved IP is targeted first (TCP failover to
+     * the remaining IPs is preserved) and makes connection reuse IP-aware, so that pooled HTTP/1.1
+     * connections and multiplexed HTTP/2 connections are kept and reused per IP rather than per
+     * host. The net effect is that consecutive requests to a multi-IP host are spread evenly across
+     * all of its addresses, even when connections are kept alive.
+     *
+     * <p>Notes:
+     * <ul>
+     *   <li>Has no effect for hosts that resolve to a single address, literal-IP hosts, requests
+     *       with an explicit {@link Request#getAddress() address}, or requests routed through a
+     *       proxy (HTTP or SOCKS) — the socket is established to the proxy, not directly to the
+     *       rotated target IPs. (Round-robin still applies when the proxy is bypassed for the host.)</li>
+     *   <li>Connection limits ({@code maxConnectionsPerHost}) remain per host, not per IP.</li>
+     *   <li>The address order comes straight from the configured
+     *       {@link io.netty.resolver.InetNameResolver}; this mode does not re-sort it. For the
+     *       rotation to map consistently across requests, use a resolver that returns the addresses
+     *       in a stable order and does not deliberately reorder them between resolutions (for
+     *       example {@link io.netty.resolver.dns.DnsNameResolver}). Do not pair this mode with a
+     *       resolver that intentionally rotates its results, such as
+     *       {@link io.netty.resolver.RoundRobinInetAddressResolver} — that one is meant for
+     *       {@link #DEFAULT} mode, where it provides the spreading instead.</li>
+     *   <li>Rotation is not health-aware: it always cycles through every IP the resolver returns, so
+     *       a temporarily unreachable IP keeps receiving its share of requests — each then retried
+     *       via TCP failover to a healthy IP — until the resolver stops returning it. Which IPs are
+     *       live is expected to be governed at the DNS/resolver level, as it already is in
+     *       {@link #DEFAULT} mode.</li>
+     * </ul>
+     */
+    ROUND_ROBIN
+}

client/src/main/java/org/asynchttpclient/config/AsyncHttpClientConfigDefaults.java

@@ -15,15 +15,22 @@
  */
 package org.asynchttpclient.config;
 
+import org.asynchttpclient.RequestSendType;
 import org.jetbrains.annotations.Nullable;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.io.IOException;
 import java.io.InputStream;
 import java.time.Duration;
+import java.util.Arrays;
+import java.util.Locale;
 import java.util.Properties;
 
 public final class AsyncHttpClientConfigDefaults {
 
+    private static final Logger LOGGER = LoggerFactory.getLogger(AsyncHttpClientConfigDefaults.class);
+
     public static final String ASYNC_CLIENT_CONFIG_ROOT = "org.asynchttpclient.";
     public static final String THREAD_POOL_NAME_CONFIG = "threadPoolName";
     public static final String MAX_CONNECTIONS_CONFIG = "maxConnections";
@@ -52,6 +59,7 @@ public final class AsyncHttpClientConfigDefaults {
     public static final String STRICT_302_HANDLING_CONFIG = "strict302Handling";
     public static final String KEEP_ALIVE_CONFIG = "keepAlive";
     public static final String MAX_REQUEST_RETRY_CONFIG = "maxRequestRetry";
+    public static final String REQUEST_SEND_TYPE_CONFIG = "requestSendType";
     public static final String DISABLE_URL_ENCODING_FOR_BOUND_REQUESTS_CONFIG = "disableUrlEncodingForBoundRequests";
     public static final String USE_LAX_COOKIE_ENCODER_CONFIG = "useLaxCookieEncoder";
     public static final String USE_OPEN_SSL_CONFIG = "useOpenSsl";
@@ -373,4 +381,19 @@ public static Duration defaultHttp2PingInterval() {
     public static boolean defaultHttp2CleartextEnabled() {
         return AsyncHttpClientConfigHelper.getAsyncHttpClientConfig().getBoolean(ASYNC_CLIENT_CONFIG_ROOT + HTTP2_CLEARTEXT_ENABLED_CONFIG);
     }
+
+    public static RequestSendType defaultRequestSendType() {
+        String value = AsyncHttpClientConfigHelper.getAsyncHttpClientConfig().getString(ASYNC_CLIENT_CONFIG_ROOT + REQUEST_SEND_TYPE_CONFIG);
+        if (value == null || value.trim().isEmpty()) {
+            return RequestSendType.DEFAULT;
+        }
+        try {
+            return RequestSendType.valueOf(value.trim().toUpperCase(Locale.ROOT));
+        } catch (IllegalArgumentException e) {
+            LOGGER.warn("Invalid value '{}' for {}{}, falling back to {}. Valid values: {}",
+                    value, ASYNC_CLIENT_CONFIG_ROOT, REQUEST_SEND_TYPE_CONFIG,
+                    RequestSendType.DEFAULT, Arrays.toString(RequestSendType.values()));
+            return RequestSendType.DEFAULT;
+        }
+    }
 }

client/src/main/java/org/asynchttpclient/netty/NettyResponseFuture.java

@@ -24,6 +24,7 @@
 import org.asynchttpclient.netty.channel.ChannelState;
 import org.asynchttpclient.netty.channel.Channels;
 import org.asynchttpclient.netty.channel.ConnectionSemaphore;
+import org.asynchttpclient.netty.channel.RoundRobinPartitionKey;
 import org.asynchttpclient.netty.request.NettyRequest;
 import org.asynchttpclient.netty.timeout.TimeoutsHolder;
 import org.asynchttpclient.proxy.ProxyServer;
@@ -33,6 +34,9 @@
 import org.slf4j.LoggerFactory;
 
 import java.io.IOException;
+import java.net.InetAddress;
+import java.net.InetSocketAddress;
+import java.util.List;
 import java.util.concurrent.CancellationException;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ExecutionException;
@@ -127,6 +131,10 @@ public final class NettyResponseFuture<V> implements ListenableFuture<V> {
     private boolean allowConnect;
     private Realm realm;
     private Realm proxyRealm;
+    // RequestSendType.ROUND_ROBIN overrides; all null in DEFAULT mode
+    private volatile Object partitionKeyOverride;
+    private volatile List<InetSocketAddress> roundRobinAddresses;
+    private volatile String roundRobinHost;
     private volatile ScramContext scramContext;
 
     public NettyResponseFuture(Request originalRequest,
@@ -530,16 +538,90 @@ public long getStart() {
     }
 
     public Object getPartitionKey() {
+        Object override = partitionKeyOverride;
+        if (override != null) {
+            return override;
+        }
+        return basePartitionKey();
+    }
+
+    /**
+     * The per-host partition key, ignoring any round-robin IP-aware override. Used for the connection
+     * semaphore so {@code maxConnectionsPerHost} stays per host (not per IP): the permit is taken
+     * before the target IP is known and the connector may fail over to a different IP than the one
+     * initially selected.
+     */
+    public Object basePartitionKey() {
         return connectionPoolPartitioning.getPartitionKey(targetRequest.getUri(), targetRequest.getVirtualHost(),
                 proxyServer);
     }
 
+    /**
+     * @return the IP-aware partition key set for {@link org.asynchttpclient.RequestSendType#ROUND_ROBIN},
+     * or {@code null} when not in round-robin mode
+     */
+    public Object getPartitionKeyOverride() {
+        return partitionKeyOverride;
+    }
+
+    public void setPartitionKeyOverride(Object partitionKeyOverride) {
+        this.partitionKeyOverride = partitionKeyOverride;
+    }
+
+    /**
+     * @return the resolved addresses to connect to (round-robin-ordered), or {@code null} to resolve
+     * lazily as usual
+     */
+    public List<InetSocketAddress> getRoundRobinAddresses() {
+        return roundRobinAddresses;
+    }
+
+    public void setRoundRobinAddresses(List<InetSocketAddress> roundRobinAddresses) {
+        this.roundRobinAddresses = roundRobinAddresses;
+    }
+
+    /**
+     * @return the host the round-robin overrides were computed for, used to detect host changes on
+     * redirects
+     */
+    public String getRoundRobinHost() {
+        return roundRobinHost;
+    }
+
+    public void setRoundRobinHost(String roundRobinHost) {
+        this.roundRobinHost = roundRobinHost;
+    }
+
+    /**
+     * Drops any round-robin overrides, e.g. when this future is reused for a cross-host redirect whose
+     * target is not eligible for round-robin.
+     */
+    public void clearRoundRobinOverrides() {
+        partitionKeyOverride = null;
+        roundRobinAddresses = null;
+        roundRobinHost = null;
+    }
+
+    /**
+     * Re-pins the round-robin partition key to the IP actually connected to. The connector may have
+     * failed over from the initially selected IP to a later one; keying connection reuse by the real
+     * peer IP keeps the pool / HTTP/2 registry correct. No-op outside round-robin mode.
+     */
+    public void repinRoundRobinAddress(InetAddress actualAddress) {
+        Object override = partitionKeyOverride;
+        if (actualAddress != null && override instanceof RoundRobinPartitionKey) {
+            partitionKeyOverride = ((RoundRobinPartitionKey) override).withAddress(actualAddress);
+        }
+    }
+
     public void acquirePartitionLockLazily() throws IOException {
         if (connectionSemaphore == null || partitionKeyLock != null) {
             return;
         }
 
-        Object partitionKey = getPartitionKey();
+        // Semaphore is keyed per host (base key), not the round-robin per-IP override: the permit is
+        // taken before the target IP is known and the connector may fail over to another IP.
+        Object partitionKey = basePartitionKey();
         connectionSemaphore.acquireChannelLock(partitionKey);
         Object prevKey = PARTITION_KEY_LOCK_FIELD.getAndSet(this, partitionKey);
         if (prevKey != null) {

client/src/main/java/org/asynchttpclient/netty/channel/ChannelManager.java

@@ -453,6 +453,10 @@ public Channel poll(Uri uri, String virtualHost, ProxyServer proxy, ChannelPoolP
         return channelPool.poll(partitionKey);
     }
 
+    public Channel poll(Object partitionKey) {
+        return channelPool.poll(partitionKey);
+    }
+
     public void removeAll(Channel connection) {
         channelPool.removeAll(connection);
     }

client/src/main/java/org/asynchttpclient/netty/channel/NettyConnectListener.java

@@ -24,7 +24,6 @@
 import org.asynchttpclient.netty.NettyResponseFuture;
 import org.asynchttpclient.netty.SimpleFutureListener;
 import org.asynchttpclient.netty.future.StackTraceInspector;
-import org.asynchttpclient.channel.ChannelPoolPartitioning;
 import org.asynchttpclient.netty.request.NettyRequestSender;
 import org.asynchttpclient.netty.timeout.TimeoutsHolder;
 import org.asynchttpclient.proxy.ProxyServer;
@@ -114,6 +113,10 @@ public void onSuccess(Channel channel, InetSocketAddress remoteAddress) {
         // timeout logging and keep useful diagnostic information
         if (remoteAddress != null) {
             timeoutsHolder.setResolvedRemoteAddress(remoteAddress);
+            // In ROUND_ROBIN mode the connector may have failed over from the initially selected IP to a
+            // later one; re-pin the pool/HTTP-2 partition key to the IP we actually connected to so reuse
+            // stays correct. No-op in DEFAULT mode.
+            future.repinRoundRobinAddress(remoteAddress.getAddress());
         }
         ProxyServer proxyServer = future.getProxyServer();
 
@@ -272,12 +275,9 @@ private void releaseSemaphoreImmediately(Object partitionKeyLock) {
      * Registers the HTTP/2 connection in the channel manager's H2 registry.
      */
     private void registerHttp2AndReleaseSemaphore(Channel channel) {
-        Request request = future.getTargetRequest();
-        Uri uri = request.getUri();
-        ProxyServer proxy = future.getProxyServer();
-        ChannelPoolPartitioning partitioning = request.getChannelPoolPartitioning();
-        Object partitionKey = partitioning.getPartitionKey(uri, request.getVirtualHost(), proxy);
-        channelManager.registerHttp2Connection(partitionKey, channel);
+        // Register under the future's partition key so the H2 connection is found by the same key the
+        // pool is polled with — including the IP-aware key used by RequestSendType.ROUND_ROBIN.
+        channelManager.registerHttp2Connection(future.getPartitionKey(), channel);
     }
 
     public void onFailure(Channel channel, Throwable cause) {