Class SharedHttpClientSessionManager

java.lang.Object

org.eclipse.rdf4j.http.client.SharedHttpClientSessionManager

All Implemented Interfaces:

HttpClientDependent, HttpClientSessionManager

public class SharedHttpClientSessionManager
extends Object
implements HttpClientSessionManager, HttpClientDependent

A Manager for HTTP sessions that uses a shared RDF4JHttpClient to manage HTTP connections.

Author:

James Leigh

Field Summary

Fields

Modifier and Type	Field	Description
static final int	CONNECTION_REQUEST_TIMEOUT	HTTP connection request timeout in milliseconds for general use.
static final String	CONNECTION_REQUEST_TIMEOUT_PROPERTY	Configurable system property org.eclipse.rdf4j.client.http.connectionRequestTimeout for specifying the HTTP connection request timeout in milliseconds for general use.
static final int	CONNECTION_TIMEOUT	HTTP connection timeout in milliseconds for general use.
static final String	CONNECTION_TIMEOUT_PROPERTY	Configurable system property org.eclipse.rdf4j.client.http.connectionTimeout for specifying the HTTP connection timeout in milliseconds for general use.
static final int	CORE_POOL_SIZE	Core pool size for the executor service, as read from system properties or defaults.
static final String	CORE_POOL_SIZE_PROPERTY	Configurable system property org.eclipse.rdf4j.client.executors.corePoolSize for specifying the background executor core thread pool size.
static final int	DEFAULT_CONNECTION_REQUEST_TIMEOUT	Default HTTP connection request timeout in milliseconds for general use.
static final int	DEFAULT_CONNECTION_TIMEOUT	Default HTTP connection timeout in milliseconds for general use.
static final int	DEFAULT_CORE_POOL_SIZE	Default core pool size for the executor service.
static final int	DEFAULT_MAX_CONN_PER_ROUTE	Default maximum number of connections per route (per host).
static final int	DEFAULT_MAX_CONN_TOTAL	Default maximum total number of connections.
static final int	DEFAULT_SOCKET_TIMEOUT	Default HTTP socket timeout in milliseconds for general use.
static final int	DEFAULT_SPARQL_CONNECTION_REQUEST_TIMEOUT	Default HTTP connection request timeout in milliseconds for SPARQL SERVICE calls.
static final int	DEFAULT_SPARQL_CONNECTION_TIMEOUT	Default HTTP connection timeout in milliseconds for SPARQL SERVICE calls.
static final int	DEFAULT_SPARQL_SOCKET_TIMEOUT	Default HTTP socket timeout in milliseconds for SPARQL SERVICE calls.
static final int	MAX_CONN_PER_ROUTE	Maximum number of connections per route (per host), as read from system properties or defaults.
static final String	MAX_CONN_PER_ROUTE_PROPERTY	Configurable system property org.eclipse.rdf4j.client.http.maxConnPerRoute for specifying the maximum number of connections per route (per host).
static final int	MAX_CONN_TOTAL	Maximum total number of connections, as read from system properties or defaults.
static final String	MAX_CONN_TOTAL_PROPERTY	Configurable system property org.eclipse.rdf4j.client.http.maxConnTotal for specifying the maximum total number of connections.
static final int	SOCKET_TIMEOUT	HTTP socket timeout in milliseconds for general use.
static final String	SOCKET_TIMEOUT_PROPERTY	Configurable system property org.eclipse.rdf4j.client.http.socketTimeout for specifying the HTTP socket timeout in milliseconds for general use.
static final int	SPARQL_CONNECTION_REQUEST_TIMEOUT	HTTP connection request timeout in milliseconds for SPARQL SERVICE calls.
static final String	SPARQL_CONNECTION_REQUEST_TIMEOUT_PROPERTY	Configurable system property org.eclipse.rdf4j.client.sparql.http.connectionRequestTimeout for specifying the HTTP connection request timeout in milliseconds when used in SPARQL SERVICE calls.
static final int	SPARQL_CONNECTION_TIMEOUT	HTTP connection timeout in milliseconds for SPARQL SERVICE calls.
static final String	SPARQL_CONNECTION_TIMEOUT_PROPERTY	Configurable system property org.eclipse.rdf4j.client.sparql.http.connectionTimeout for specifying the HTTP connection timeout in milliseconds when used in SPARQL SERVICE calls.
static final int	SPARQL_SOCKET_TIMEOUT	HTTP socket timeout in milliseconds for SPARQL SERVICE calls.
static final String	SPARQL_SOCKET_TIMEOUT_PROPERTY	Configurable system property org.eclipse.rdf4j.client.sparql.http.socketTimeout for specifying the HTTP socket timeout in milliseconds when used in SPARQL SERVICE calls.

Constructor Summary

Constructors

Constructor	Description
SharedHttpClientSessionManager()
SharedHttpClientSessionManager(RDF4JHttpClient dependentClient, ExecutorService dependentExecutorService)

Method Summary

Modifier and Type	Method	Description
RDF4JProtocolSession	createRDF4JProtocolSession(String serverURL)	Creates a new session to the remote RDF4J REST API.
SPARQLProtocolSession	createSPARQLProtocolSession(String queryEndpointUrl, String updateEndpointUrl)	Creates a new SPARQL Protocol session to the remote SPARQL endpoint.
RDF4JHttpClientConfig	getDefaultHttpClientConfig()	Returns the RDF4JHttpClientConfig that will be used when lazily creating the internal HTTP client.
protected final ExecutorService	getExecutorService()	Get the ExecutorService used by this session manager.
RDF4JHttpClient	getHttpClient()	RDF4JHttpClient that has been assigned or has been used by this object.
void	initialize()	Deprecated. Create a new instance instead of trying to reactivate an old instance.
void	setDefaultSparqlServiceTimeouts()	Switches the current timeout settings to use the SPARQL-specific timeouts.
void	setDefaultTimeouts()	Resets the current timeout settings to the general timeouts.
void	setHttpClient(RDF4JHttpClient httpClient)	Assign an RDF4JHttpClient that this session manager should use.
void	setHttpClientConfig(RDF4JHttpClientConfig config)	Sets the RDF4JHttpClientConfig to be used when creating the internal HTTP client (if not provided externally via setHttpClient(RDF4JHttpClient)).
void	shutDown()	Closes any remaining connections and threads used by the sessions created by this object.

Methods inherited from class Object

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

Field Details

CORE_POOL_SIZE_PROPERTY

public static final String CORE_POOL_SIZE_PROPERTY

Configurable system property org.eclipse.rdf4j.client.executors.corePoolSize for specifying the background executor core thread pool size.

See Also:

• Constant Field Values

MAX_CONN_PER_ROUTE_PROPERTY

public static final String MAX_CONN_PER_ROUTE_PROPERTY

Configurable system property org.eclipse.rdf4j.client.http.maxConnPerRoute for specifying the maximum number of connections per route (per host). Default is 25.

This property determines the maximum number of concurrent connections to a single host (route). Adjusting this value can improve performance when communicating with a server that supports multiple concurrent connections.

See Also:

• Constant Field Values

MAX_CONN_TOTAL_PROPERTY

public static final String MAX_CONN_TOTAL_PROPERTY

Configurable system property org.eclipse.rdf4j.client.http.maxConnTotal for specifying the maximum total number of connections. Default is 50.

This property sets the maximum total number of concurrent connections that can be open at the same time. Increasing this value allows more simultaneous connections to different hosts, which can improve throughput in multi-threaded environments.

See Also:

• Constant Field Values

CONNECTION_TIMEOUT_PROPERTY

public static final String CONNECTION_TIMEOUT_PROPERTY

Configurable system property org.eclipse.rdf4j.client.http.connectionTimeout for specifying the HTTP connection timeout in milliseconds for general use. Default is 30 seconds.

The connection timeout determines the maximum time the client will wait to establish a TCP connection to the server. A default of 30 seconds is set to allow for potential network delays without causing unnecessary timeouts.

See Also:

• Constant Field Values

CONNECTION_REQUEST_TIMEOUT_PROPERTY

public static final String CONNECTION_REQUEST_TIMEOUT_PROPERTY

Configurable system property org.eclipse.rdf4j.client.http.connectionRequestTimeout for specifying the HTTP connection request timeout in milliseconds for general use. Default is 1 hour.

The connection request timeout defines how long the client will wait for a connection from the connection pool.

See Also:

• Constant Field Values

SOCKET_TIMEOUT_PROPERTY

public static final String SOCKET_TIMEOUT_PROPERTY

Configurable system property org.eclipse.rdf4j.client.http.socketTimeout for specifying the HTTP socket timeout in milliseconds for general use. Default is 10 days.

The socket timeout controls the maximum period of inactivity between data packets during data transfer. A longer timeout is appropriate for large data transfers, ensuring that operations are not interrupted prematurely.

See Also:

• Constant Field Values

SPARQL_CONNECTION_TIMEOUT_PROPERTY

public static final String SPARQL_CONNECTION_TIMEOUT_PROPERTY

Configurable system property org.eclipse.rdf4j.client.sparql.http.connectionTimeout for specifying the HTTP connection timeout in milliseconds when used in SPARQL SERVICE calls. Default is 5 seconds.

A shorter connection timeout is set for SPARQL SERVICE calls to quickly detect unresponsive endpoints in federated queries, improving overall query performance by avoiding long waits for unreachable servers.

See Also:

• Constant Field Values

SPARQL_CONNECTION_REQUEST_TIMEOUT_PROPERTY

public static final String SPARQL_CONNECTION_REQUEST_TIMEOUT_PROPERTY

Configurable system property org.eclipse.rdf4j.client.sparql.http.connectionRequestTimeout for specifying the HTTP connection request timeout in milliseconds when used in SPARQL SERVICE calls. Default is 10 minutes.

This timeout controls how long the client waits for a connection from the pool when making SPARQL SERVICE calls. A shorter timeout than general use ensures that queries fail fast if resources are constrained, maintaining responsiveness.

See Also:

• Constant Field Values

SPARQL_SOCKET_TIMEOUT_PROPERTY

public static final String SPARQL_SOCKET_TIMEOUT_PROPERTY

Configurable system property org.eclipse.rdf4j.client.sparql.http.socketTimeout for specifying the HTTP socket timeout in milliseconds when used in SPARQL SERVICE calls. Default is 1 hour.

The socket timeout for SPARQL SERVICE calls is set to a shorter duration to detect unresponsive servers during data transfer, ensuring that the client does not wait indefinitely for data that may never arrive.

See Also:

• Constant Field Values

DEFAULT_CORE_POOL_SIZE

public static final int DEFAULT_CORE_POOL_SIZE

Default core pool size for the executor service. Set to 5.

This value determines the number of threads to keep in the pool, even if they are idle. Adjusting this value can help manage resource utilization in high-load scenarios.

See Also:

• Constant Field Values

DEFAULT_MAX_CONN_PER_ROUTE

public static final int DEFAULT_MAX_CONN_PER_ROUTE

Default maximum number of connections per route (per host). Set to 25.

This value limits the number of concurrent connections to a single host. Increasing it can improve performance when communicating with a server that can handle multiple connections.

See Also:

• Constant Field Values

DEFAULT_MAX_CONN_TOTAL

public static final int DEFAULT_MAX_CONN_TOTAL

Default maximum total number of connections. Set to 50.

This value limits the total number of concurrent connections that can be open at the same time. Increasing it allows for more simultaneous connections to different hosts.

See Also:

• Constant Field Values

DEFAULT_CONNECTION_TIMEOUT

public static final int DEFAULT_CONNECTION_TIMEOUT

Default HTTP connection timeout in milliseconds for general use. Set to 30 seconds.

The connection timeout determines the maximum time the client will wait to establish a TCP connection to the server.

See Also:

• Constant Field Values

DEFAULT_CONNECTION_REQUEST_TIMEOUT

public static final int DEFAULT_CONNECTION_REQUEST_TIMEOUT

Default HTTP connection request timeout in milliseconds for general use. Set to 1 hour.

The connection request timeout defines how long the client will wait for a connection from the connection pool.

See Also:

• Constant Field Values

DEFAULT_SOCKET_TIMEOUT

public static final int DEFAULT_SOCKET_TIMEOUT

Default HTTP socket timeout in milliseconds for general use. Set to 10 days.

The socket timeout controls the maximum period of inactivity between data packets during data transfer. A longer timeout is appropriate for large data transfers.

See Also:

• Constant Field Values

DEFAULT_SPARQL_CONNECTION_TIMEOUT

public static final int DEFAULT_SPARQL_CONNECTION_TIMEOUT

Default HTTP connection timeout in milliseconds for SPARQL SERVICE calls. Set to 5 seconds.

A shorter connection timeout is set for SPARQL SERVICE calls to quickly detect unresponsive endpoints in federated queries.

See Also:

• Constant Field Values

DEFAULT_SPARQL_CONNECTION_REQUEST_TIMEOUT

public static final int DEFAULT_SPARQL_CONNECTION_REQUEST_TIMEOUT

Default HTTP connection request timeout in milliseconds for SPARQL SERVICE calls. Set to 10 minutes.

This timeout controls how long the client waits for a connection from the pool when making SPARQL SERVICE calls.

See Also:

• Constant Field Values

DEFAULT_SPARQL_SOCKET_TIMEOUT

public static final int DEFAULT_SPARQL_SOCKET_TIMEOUT

Default HTTP socket timeout in milliseconds for SPARQL SERVICE calls. Set to 1 hour.

The socket timeout for SPARQL SERVICE calls is set to a shorter duration to detect unresponsive servers during data transfer.

See Also:

• Constant Field Values

CORE_POOL_SIZE

public static final int CORE_POOL_SIZE

Core pool size for the executor service, as read from system properties or defaults.

MAX_CONN_PER_ROUTE

public static final int MAX_CONN_PER_ROUTE

Maximum number of connections per route (per host), as read from system properties or defaults.

MAX_CONN_TOTAL

public static final int MAX_CONN_TOTAL

Maximum total number of connections, as read from system properties or defaults.

CONNECTION_TIMEOUT

public static final int CONNECTION_TIMEOUT

HTTP connection timeout in milliseconds for general use.

CONNECTION_REQUEST_TIMEOUT

public static final int CONNECTION_REQUEST_TIMEOUT

HTTP connection request timeout in milliseconds for general use.

SOCKET_TIMEOUT

public static final int SOCKET_TIMEOUT

HTTP socket timeout in milliseconds for general use.

SPARQL_CONNECTION_TIMEOUT

public static final int SPARQL_CONNECTION_TIMEOUT

HTTP connection timeout in milliseconds for SPARQL SERVICE calls.

SPARQL_CONNECTION_REQUEST_TIMEOUT

public static final int SPARQL_CONNECTION_REQUEST_TIMEOUT

HTTP connection request timeout in milliseconds for SPARQL SERVICE calls.

SPARQL_SOCKET_TIMEOUT

public static final int SPARQL_SOCKET_TIMEOUT

HTTP socket timeout in milliseconds for SPARQL SERVICE calls.

Constructor Details

SharedHttpClientSessionManager

public SharedHttpClientSessionManager()

SharedHttpClientSessionManager

public SharedHttpClientSessionManager(RDF4JHttpClient dependentClient,
 ExecutorService dependentExecutorService)

Method Details

getHttpClient

public RDF4JHttpClient getHttpClient()

Description copied from interface: HttpClientDependent

RDF4JHttpClient that has been assigned or has been used by this object. The life cycle might not be or might be tied to this object, depending on whether RDF4JHttpClient was passed to or created by this object respectively.

Specified by:

getHttpClient in interface HttpClientDependent

Specified by:

getHttpClient in interface HttpClientSessionManager

Returns:

Returns the httpClient.

setHttpClient

public void setHttpClient(RDF4JHttpClient httpClient)

Description copied from interface: HttpClientSessionManager

Assign an RDF4JHttpClient that this session manager should use.

Specified by:

setHttpClient in interface HttpClientDependent

Specified by:

setHttpClient in interface HttpClientSessionManager

Parameters:

httpClient - the client to use.

setHttpClientConfig

public void setHttpClientConfig(RDF4JHttpClientConfig config)

Sets the RDF4JHttpClientConfig to be used when creating the internal HTTP client (if not provided externally via setHttpClient(RDF4JHttpClient)). The full configuration is applied, including timeouts, connection limits, SSL context, default headers, and redirect policy.

This method always updates the stored configuration. However, if an external HTTP client has already been assigned via setHttpClient(RDF4JHttpClient), or if the internal client has already been lazily initialised, the new configuration will not be applied to the already-created client. In that case getDefaultHttpClientConfig() will return the updated config even though it is not in use.

Parameters:

config - the configuration for the managed HTTP client; must not be null

createSPARQLProtocolSession

public SPARQLProtocolSession createSPARQLProtocolSession(String queryEndpointUrl,
 String updateEndpointUrl)

Description copied from interface: HttpClientSessionManager

Creates a new SPARQL Protocol session to the remote SPARQL endpoint.

Specified by:

createSPARQLProtocolSession in interface HttpClientSessionManager

createRDF4JProtocolSession

public RDF4JProtocolSession createRDF4JProtocolSession(String serverURL)

Description copied from interface: HttpClientSessionManager

Creates a new session to the remote RDF4J REST API.

Specified by:

createRDF4JProtocolSession in interface HttpClientSessionManager

shutDown

public void shutDown()

Description copied from interface: HttpClientSessionManager

Closes any remaining connections and threads used by the sessions created by this object.

Specified by:

shutDown in interface HttpClientSessionManager

initialize

@Deprecated
public void initialize()

Deprecated.

Create a new instance instead of trying to reactivate an old instance.

No-op

getExecutorService

protected final ExecutorService getExecutorService()

Get the ExecutorService used by this session manager.

Returns:

a ExecutorService used by all SPARQLProtocolSession and RDF4JProtocolSession instances created by this session manager.

getDefaultHttpClientConfig

public RDF4JHttpClientConfig getDefaultHttpClientConfig()

Returns the RDF4JHttpClientConfig that will be used when lazily creating the internal HTTP client.

Returns:

the current RDF4JHttpClientConfig; never null

setDefaultSparqlServiceTimeouts

public void setDefaultSparqlServiceTimeouts()

Switches the current timeout settings to use the SPARQL-specific timeouts. This method should be called when making SPARQL SERVICE calls to apply shorter timeout values.

The SPARQL-specific timeouts are shorter to ensure that unresponsive or slow SPARQL endpoints do not cause long delays in federated query processing. Quick detection of such issues improves the responsiveness and reliability of SPARQL queries.

setDefaultTimeouts

public void setDefaultTimeouts()

Resets the current timeout settings to the general timeouts. This method should be called to revert any changes made by setDefaultSparqlServiceTimeouts() and apply the general timeout values.

The general timeouts are longer to accommodate operations that may take more time, such as large data transfers or extensive processing, without causing premature timeouts.