在学习如何使用akka I / O时，我试图在akka I / o之上实现一个简单的协议，并在此处遵循文档。
但是，在我的gradle文件中，我使用的是2.3.9版，如下所示
dependencies {
compile group: 'org.slf4j', name: 'slf4j-log4j12', version: '1.7.7'
compile group: 'com.typesafe.akka', name: 'akka-actor_2.11', version: '2.3.9'
compile group: 'com.typesafe.akka', name: 'akka-contrib_2.11', version: '2.3.9'
compile group: 'org.scala-lang', name: 'scala-library', version: '2.11.5'
testCompile group: 'junit', name: 'junit', version: '4.11'
}
导入一些特定于管道的东西，例如
import akka.io.SymmetricPipelineStage;
import akka.io.PipelineContext;
import akka.io.SymmetricPipePair;
生成无法解决符号错误。
因此，我的问题。
管道是实验性的，实际上在Akka 2.3中已删除。删除记录在《迁移指南2.2.x至2.3.x》中。
还有提到的能够与打包阿卡2.3“前辈”管道实施在这里，虽然它并不似乎是一个简单的加法依赖的。
我敢打赌，Akka Streams旨在更好地替代管线，它是Akka 2.4中的新功能，但现在可以作为实验模块使用。可以通过将Akka流与Akka I / O结合使用来处理编码/解码阶段或协议层。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句