Scala客户端服务器多线程使用套接字

Question

我无法理解这里的这个 我是几周前的 Scala 初学者，尝试过但失败了 我已经阅读并尝试过有关 Actors、Futures 等的内容并没有为我工作

您能否提供一个服务器客户端示例（或至少是服务器端）的代码 假设使用从多个客户端接收字符串（即文件路径）并在线程中处理每个客户端的套接字打开连接

import java.net.{Socket, ServerSocket}
import java.util.concurrent.{Executors, ExecutorService}
import java.util.Date
import java.io._
import scala.io._
import java.nio._
import java.util._
import scala.util.control.Breaks
import java.security.MessageDigest
import java.security.DigestInputStream
import scala.util.Sorting

class NetworkService(port: Int, poolSize: Int) extends Runnable {
  val serverSocket = new ServerSocket(port)
  val pool: ExecutorService = Executors.newFixedThreadPool(poolSize)

  def run() {
    try {
      var i = 0
      while (true) {
        // This will block until a connection comes in.
        val socket = serverSocket.accept()
        val in = new BufferedReader(new InputStreamReader(socket.getInputStream)).readLine
        /*var f = new FileSplit(in) //FileSplit is another class that i would like each                   
                                    // client's sent string to be passed as an instance of 
          f.move*/
        pool.execute(new Handler(socket))

      }
    } finally {
      pool.shutdown()


    }
  }

}

class Handler(socket: Socket) extends Runnable {
  def message = (Thread.currentThread.getName() + "\n").getBytes

  def run() {
    socket.getOutputStream.write(message)
    socket.getOutputStream.close()

  }
}


object MyServer {
  def main(args: Array[String]) {
(new NetworkService(2030, 2)).run

}
}

Answer 1

您有多种选择。你可以做同样的旧 java 风格的应用程序，基本上只使用 java 标准库和 scala 语法。

也许这有帮助：Scala equivalent of python echo server/client example?

您只需要在新线程中编写处理每个套接字（从 accept() 获得的）的逻辑。

但是，我不建议直接使用普通的旧 java 方法。那里有很棒的图书馆可以为您处理这些问题。例如阿卡：

http://doc.akka.io/docs/akka/2.3.3/scala/io-tcp.html

我还建议您阅读有关 futures 的内容，因为它们对于异步处理非常有用。