Alpakka

Alpakka为集成各种用例，提供了各种Akka Stream连接器、集成模式和数据转换。

例如Spring Web

Spring 5.0引入了Reactive Streams的兼容性。

由于采用了Reactive Streams，多个库现在可以互操作，因为所有这些库都实现了相同的接口。按照设计，Akka Stream隐藏了终端用户的原始响应流类型，因为它允许从响应流分离这些类型，并允许无缝迁移到 java.util.concurrent.Flow（在Java9引入）。

此 Alpakka 模块使您可以直接返回 Spring Web 终结点中的源。

在Spring Web（或Spring Boot）中使用Akka Streams是非常简单的，因为Alpakka提供了对框架的自动配置，这意味着Spring已经知道了Sources和Sinks等。

所有你需要做的就是引入上面的依赖（akka-stream-alpakka-spring-web），像往常一样启动你的应用程序：

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class DemoApplication {

  public static void main(String[] args) {
    SpringApplication.run(DemoApplication.class, args);
  }

}

你可以直接在HTTP端点返回Akka Streams：

import akka.NotUsed;
import akka.actor.ActorSystem;
import akka.stream.Materializer;
import akka.stream.javadsl.Source;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class SampleController {

  @RequestMapping("/")
  public Source<String, NotUsed> index() {
    return
      Source.repeat("Hello world!")
        .intersperse("\n")
        .take(10);
  }

}

javadsl 和scaladsl Akka Stream 类型均支持。

所提供的配置
自动启用的配置如下：

import akka.actor.ActorSystem;
import akka.stream.ActorMaterializer;
import akka.stream.Materializer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.ReactiveAdapterRegistry;
import org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter;

@Configuration
@ConditionalOnClass(akka.stream.javadsl.Source.class)
public class SpringWebAkkaStreamsConfiguration {

    private final ActorSystem system;
    private final ActorMaterializer mat;

    @Autowired
    public SpringWebAkkaStreamsConfiguration(RequestMappingHandlerAdapter requestMappingHandlerAdapter) {
        final ReactiveAdapterRegistry registry = requestMappingHandlerAdapter.getReactiveAdapterRegistry();

        system = ActorSystem.create("SpringWebAkkaStreamsSystem");
        mat = ActorMaterializer.create(system);
        new AkkaStreamsRegistrar(mat).registerAdapters(registry);
    }

    @Bean
    @ConditionalOnMissingBean(ActorSystem.class)
    public ActorSystem getActorSystem() {
        return system;
    }

    @Bean
    @ConditionalOnMissingBean(Materializer.class)
    public ActorMaterializer getMaterializer() {
        return mat;
    }
}

如果你想手动配置稍有不同。

虽然这里介绍的集成有效，但并不是将Akka与服务HTTP应用程序结合使用的最佳方式。建议使用Akka HTTP。