使用Java创建WSClient使用PlayWS - Materializer

Question

基本上，我试图使用Java在我的SBT应用程序中创建一个自定义WSClient。由于我不需要任何注入依赖项，所以我使用了文档中显示的方法。要创建自定义的WSClient，它需要一个Akka.stream.Materializer对象，但是由于它是抽象的，所以我不能创建Materializer对象。

private Materializer materializer;


private WSClient wsClient() throws IOException {

    scala.Option<String> noneString = scala.None$.empty();
    WSClientConfig wsClientConfig = new WSClientConfig(
            Duration.apply(120, TimeUnit.SECONDS), // connectionTimeout
            Duration.apply(120, TimeUnit.SECONDS), // idleTimeout
            Duration.apply(120, TimeUnit.SECONDS), // requestTimeout
            true, // followRedirects
            true, // useProxyProperties
            noneString, // userAgent
            true, // compressionEnabled / enforced
            SSLConfigFactory.defaultConfig());

    AhcWSClientConfig clientConfig = AhcWSClientConfigFactory.forClientConfig(wsClientConfig);

    // Add underlying asynchttpclient options to WSClient
    AhcConfigBuilder builder = new AhcConfigBuilder(clientConfig);
    DefaultAsyncHttpClientConfig.Builder ahcBuilder = builder.configure();
    AsyncHttpClientConfig.AdditionalChannelInitializer logging = new AsyncHttpClientConfig.AdditionalChannelInitializer() {
        @Override
        public void initChannel(io.netty.channel.Channel channel) throws Exception {

        }
    };
    ahcBuilder.setHttpAdditionalChannelInitializer(logging);
    // #ws-custom-client

   
    WSClient customWSClient = new play.libs.ws.ahc.AhcWSClient(ahcBuilder.build(), materializer);
    // #ws-client

    // #ws-close-client
    customWSClient.close();
    return customWSClient;
}

注释-我不想使用依赖注入

我该怎么做呢？

Answer 1

来自Akka流文档

akka.actor.ActorSystem system = play.libs.Akka.system();
akka.stream.Materializer materializer = akka.stream.ActorMaterializer.create(system);

请记住，play.libs.Akka.system()是不推荐的，将来将被删除。