在HTTP 503上重新建立传输控制协议

Question

我们在部署在k8s集群上的Java应用程序中使用okhttp。我们的源应用程序没有启用istio，并通过特使sidecar连接到目的地。连接链如下所示：

SRC--------

因此，实际上SRC应用程序并不是直接与DST应用程序建立连接，而是与它前面的代理建立连接。当DST应用程序关闭时，它会终止DST和特使之间的所有连接，但SRC和特使之间的连接保持打开状态。这就是为什么SRC应用程序开始收到503个错误。从SRC到DST的另一条消息也得到503，因为我们一直在重用在okhttp的连接池中建立的空闲连接。这个问题的解决方案是重新建立新的TCP连接，而不是使用连接池中的一个空闲连接。是否可以根据收到的单个HTTP 503将okhttp配置为终止整个TCP连接？

Answer 1

这样的办法应该行得通

import okhttp3.OkHttpClient
import okhttp3.Request

fun main() {
  val client = OkHttpClient.Builder()
    .eventListenerFactory(LoggingEventListener.Factory())
    .addNetworkInterceptor { chain ->
      chain.proceed(chain.request()).also { response ->
        println(response.code)
        if (response.code == 503) {
          println("closing")
          chain.connection()?.socket()?.close()
        }
      }
    }
    .build()

  val response1 = client.newCall(Request.Builder().url("https://httpbin.org/get").build()).execute()

  val response2 = client.newCall(Request.Builder().url("https://httpbin.org/status/503").build()).execute()

  val response3 = client.newCall(Request.Builder().url("https://httpbin.org/get").build()).execute()
}