StakeSquid/dshackle
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

extend http client connections pool

Browse Source
This commit is contained in:
Maxksim Fomenkov
2022-09-08 17:31:14 +03:00
parent 7b00adf9d6
commit c64e85e3c4
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/kotlin/io/emeraldpay/dshackle/upstream/rpcclient/JsonRpcHttpClient.kt
View File

@@ -27,6 +27,7 @@ import io.netty.resolver.DefaultAddressResolverGroup
import org.slf4j.LoggerFactory import org.slf4j.LoggerFactory
import reactor.core.publisher.Mono import reactor.core.publisher.Mono
import reactor.netty.http.client.HttpClient import reactor.netty.http.client.HttpClient
import reactor.netty.resources.ConnectionProvider
import java.io.ByteArrayInputStream import java.io.ByteArrayInputStream
import java.security.KeyStore import java.security.KeyStore
import java.security.cert.CertificateFactory import java.security.cert.CertificateFactory
@@ -53,7 +54,11 @@ class JsonRpcHttpClient(
private val httpClient: HttpClient private val httpClient: HttpClient
init { init {
var build = HttpClient.create() val connectionProvider = ConnectionProvider.builder("dshackleConnectionPool")
.maxConnections(1000)
.pendingAcquireMaxCount(5000)
.build()
var build = HttpClient.create(connectionProvider)
.resolver(DefaultAddressResolverGroup.INSTANCE) .resolver(DefaultAddressResolverGroup.INSTANCE)
build = build.headers { h -> build = build.headers { h ->