Ṣètò ọ̀nà gRPC ti Pub/Sub Java fún HTTP CONNECT

Fi ProxyDetector sórí nípasẹ̀ olupèsè ọ̀nà GAX, kí o sì pa àdírẹ́sì àfojúsùn àti ìdánimọ̀ TLS ti Pub/Sub mọ́.

Nígbà tí ìsopọ̀ Pub/Sub Java gRPC bá nílò proxy HTTP CONNECT, lo olupèsè ọ̀nà ti ẹ̀rọ alábàáṣepọ̀ tí a ti ṣẹ̀dá. Ètò URLConnection lasan kò ṣètò ìṣètò ọ̀nà yìí.

Fún ẹ̀rọ alábàáṣepọ̀ topic-admin:

var channelProvider = TopicAdminSettings
    .defaultGrpcTransportProviderBuilder()
    .setChannelConfigurator(channel -> channel.proxyDetector(target ->
        HttpConnectProxiedSocketAddress.newBuilder()
            .setProxyAddress(new InetSocketAddress("proxy.example", 8080))
            .setTargetAddress((InetSocketAddress) target)
            .setUsername(proxyUser)
            .setPassword(proxyPassword)
            .build()))
    .build();

var settings = TopicAdminSettings.newBuilder()
    .setTransportChannelProvider(channelProvider)
    .build();
try (TopicAdminClient client = TopicAdminClient.create(settings)) {
    // Perform the application's intended topic-admin operation here.
}

TopicAdminClient àti TopicAdminSettings jẹ́ kíláàsì Pub/Sub v1; HttpConnectProxiedSocketAddress wá láti io.grpc àti InetSocketAddress láti java.net. Àpẹẹrẹ náà gbà àfojúsùn àdírẹ́sì íńtánẹ́ẹ̀tì lasan tí ọ̀nà yìí ń lò.

Olùwádìí náà dá àdírẹ́sì ìsopọ̀ proxy padà pẹ̀lú àfojúsùn ìpilẹ̀. Olùkọ́ gRPC nílò kí wọ́n yanjú àdírẹ́sì proxy. Fi ojú-òpin iṣẹ́ náà sí bí Pub/Sub: rírọ́pò rẹ̀ pẹ̀lú orúkọ olùgbàlejò proxy yóò pàdánù àfojúsùn iṣẹ́ àti ìdánimọ̀ TLS tí wọ́n ní lọ́kàn.

Yọ àwọn ìpè orúkọ aṣàmúlò/ọ̀rọ̀ìpamọ́ kúrò fún proxy tí kò ní ìjẹ́rìí; àwọn olùdíje HTTP gbangba wà nínú àkójọ proxy HTTP. Àwọn ìpè yẹn jẹ́ ojú-ìkànnì ẹ̀rí HTTP CONNECT, kì í ṣe SOCKS tàbí ìmúṣẹ NTLM gbogbogbò.

Tí ìkùnà bá ṣẹlẹ̀ kí iṣẹ́ gRPC tó bẹ̀rẹ̀ nígbà tí ẹ̀rí tí a ṣẹ̀dá lọ́nà ọ̀tọ̀ ń gba tọ́kẹ̀nì, yẹ̀ ọ̀nà HTTP ti ẹ̀rí yẹn wò. Ó wà ní òde olupèsè ọ̀nà tí a fihàn níbí.

Àwọn àpilẹ̀kọ tó jọra