java-Scala套接字无法写入输出流

2019-12-09 22:00:37 阅读：264 来源： 互联网

标签：outputstream scala sockets serialization java

我是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方法中.

标签：outputstream,scala,sockets,serialization,java
来源： https://codeday.me/bug/20191209/2097270.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

java-Scala套接字无法写入输出流