我是scala世界的新手,请原谅我的琐碎问题. :)我只想打开一个端口,将其插入沙子并接收消息.
如果收到HELO,我想回应一条消息,但是我无法以任何方式写入套接字.
我用nc侦听传入的连接:
nc -k -l 127.0.0.1 3333
当客户端连接我写
HELO
在netcat中,但是客户端未发送任何答案.
这是我的scala代码:
package hello
import java.io._
import java.net.{ InetAddress, ServerSocket, Socket, SocketException }
import java.util.Random
import scala.actors.Actor
import scala.actors.Actor._
object HelloWorld extends {
def main(args: Array[String]) {}
val ia = InetAddress.getByName("localhost");
val socket = new Socket(ia, 3333)
val out = new ObjectOutputStream(
new DataOutputStream(this.socket.getOutputStream))
val in = new DataInputStream(socket.getInputStream())
println("Starting client");
var i = 0;
/* The actor!
*
*/
val myActor = actor {
loop {
receive {
case s: String => {
if (s.startsWith("HELO")) {
println("DEBUG: RECEIVED HELO=>SENDING AUTH!")
this.out.writeUTF("HALLO")
this.out.flush();
} else {
println("received:" + s);
}
}
case _ => println("I have no idea what I just got.")
}
}
}
/*
* Testing the actor!
*
*/
myActor ! "foobar";
while (!socket.isConnected()) {
println("Not connected waiting")
Thread.sleep(5000);
}
if (socket.isConnected()) {
println("connected");
}
try {
while (true) {
i += 1;
val x = in.readLine()
myActor ! x;
Thread.sleep(500);
}
} catch {
case e: IOException =>
e.printStackTrace()
}
}
接收工作正常,参与者对收到的消息做出反应,但写入从未完成.我只是监视某件事,还是我的代码发送给outputSteam错误.
这是控制台窗口中的输出:
Starting client
connected
received:foobar
DEBUG: RECEIVED HELO=>SENDING AUTH!
解决方法:
如果此代码确实是您正在使用的代码,那么它将存在一个严重的问题:它正在使用静态初始化程序内部的线程.
这里:
object HelloWorld extends {
扩展什么?
def main(args: Array[String]) {}
没有主要方法,因此其他所有内容都在构造方法内部以对象HelloWorld.基本上,这意味着使用线程的所有操作(包括参与者)都不可靠.将这些内容放入main方法中.