1

我正在关注 java net 编程中的一个示例，并决定分别在 java-scala 中编写一个客户端-服务器，这是 scala 代码：

import scala.actors.Actor
import scala.actors.Actor._

import java.io._
import java.net._

class EchoActor(private val sock: Socket,
    private val id: Int) extends Actor{

    def act(){
        try{
            val in = new BufferedReader(
                new InputStreamReader(sock.getInputStream()))

            val out = new PrintWriter(
                sock.getOutputStream(), true)

            out.println("Hello! press BYE to exit")
            var done = false
            while(!done){
                var str = in.readLine()
                if (str == null) done = true
                else{
                    println(str) // debug
                    out.println("Echo (" + id + "): " + str)
                    if (str.trim().equals("BYE")) done = true
                }
            }
            sock.close()
        }
        catch{
            case e => e printStackTrace
        }
    }
}


object Main{
    def main(args: Array[String]){
        try{
            var i = 1
            val s = new ServerSocket(8189)

            while(true){
                var inc = s.accept()
                println("Spawning " + i)
                var a = new EchoActor(inc, i)
                a.start()
                i += 1
            }
        }
        catch{
            case e => e printStackTrace
        }
    }
}

这是java的：

import java.net.*;
import java.io.*;


public class Client{
    public static void main(String[] args){

        try{
            Socket s = new Socket("127.0.0.1",8189);

            BufferedReader in = new BufferedReader(
                new InputStreamReader(System.in));

            PrintWriter out = new PrintWriter(
                s.getOutputStream(), true);

            BufferedReader socketIn = new BufferedReader(
                new InputStreamReader(s.getInputStream()));

            System.out.println("Enter: to exit");
            String resp;
            String st
            while(true){
                st = in.readLine();
                if(st.equals("exit") || st.equals("quit")) break;
                else{
                    out.println(st);
                    resp = socketIn.readLine();
                    System.out.println(resp);
                }
            }
        }
        catch(Exception e){
            e.printStackTrace();
        }
    }
}

服务器的输出：

Spawning 1
s

s

l
l
scala

java

java的输出：

Enter: to exit
s
Hello! press BYE to exit

Echo (1): s
s
Echo (1):

Echo (1): s
l
Echo (1):
l
Echo (1): l
scala
Echo (1): l

Echo (1): scala
java
Echo (1):

Echo (1): java

如您所见，我收到Echo (1)的响应为空，我希望打印Echo (1)我刚刚发送的字符串，您必须重新键入“Enter”以获取先前发送的字符串，这就是问题所在，我只需要来自服务器的一个响应像这样只有一次：Echo (1): some string，我没有想法，我通过打印到控制台来跟踪它，但不知道发生了什么。

编辑：

预期客户的输出：

...
s
Echo (1): s
java
Echo (1): java

在预期的输出中，您无需重新输入enter即可从服务器获取响应。

服务器的输出已经按预期工作。

4

2 回答 2

2

您会感到困惑，因为您在客户端首次连接时发送“Hello！press BYE to exit”，但客户端实际上并没有专门阅读这一行。因此，当您期望读取您发送的回显消息时，您正在客户端读取它，因此您的客户端总是在您认为它取决于的地方读取一个回显。

解决方案：要么从服务器中删除“Hello！press BYE to exit”，要么在你第一次连接客户端时阅读它，然后再进入循环。

于 2012-05-07T04:43:54.530 回答
0

在我看来，您向 Actor 发送了一个“”，所以他只返回“Echo (1):”+“”。如果我计算输入，我看到的“s”与“Echo (1): s”一样多。

于 2012-05-04T09:39:38.707 回答