阿卡输入流处理

Question

我建立的与Java阿卡/播放架构的系统。我需要建立一个演员谁做了SSH连接到外部系统&维护用户交互的跨度会话..

我发现，支持JAVA SSH连接

1. 就是Java JCraft/JSch库有一种方法可以将JSch输入流打包为事件驱动的输入流，因此当数据到达时会触发onmessage（data）事件。
2. 其他选项我有一个工作线程读取/等待数据从生活在演员的范围内的流，这是一个很好的模式，我担心工作线程会显着降低可扩展性
3. 我发现akka套接字的支持，但不具体SSH，有没有这样的图书馆？

Answer 1

Jsch通道支持写入给定的OutputStream

channel.setOutputStream(stream) 

作为解决方案我所做的就是编写自定义的OutputStream上write(buffer)通过 actorRef.tell（通过缓冲区的内容，以给定的演员缓冲区，ActorRef.noSender（））;

从而消除了外螺纹的需求。