0

私はオペコードを解析するサーバーを書いています (自分自身にロープを教える単純な小さな趣味の MMO サーバーです。現時点では少し面倒です)、サーバーに 2 番目のオペコードを解析させるのに問題があります。問題が何であるかわかりません。各オペコードの形式は、PRINTMSG などの 8 バイトのヘッダーと、この場合は Hello などのメッセージである本体です。各オペコードは「|」で終了します。私のコードは各オペコードを正しく取得して解析しているようですが、最初のコード以降は何も実行していないため、BufferedReaders について理解できないことがあると思います。read() を使用して読み取り、各文字を 48 バイト配列に格納しています。自動フラッシュは true に設定されています。

関連するサーバーコードは次のとおりです。

public String readInputStream() {
    String msg = "";
    char[] charArray = new char[48];
    short i = 0;
    char current = '#';
    int characterInt = -1;

    while (current != '|') {
        try {
            if (in.ready()) {
                characterInt = in.read();
                if (characterInt == (-1)) continue;
                current = (char) characterInt;
                if (current == '|') break;
                charArray[i] = current;
                //if ((charArray[i] == 'n') && (charArray[i-1] == '\\')) {
                //  charArray = new char[48];
                //}

                i++;
            }

        }


        catch (IOException e) {
            System.out.println("Error reading input stream in server ConnectionThread");
            if (DEBUGMODE) System.exit(1);
        }
    }

    msg = new String(charArray);
    msg = msg.substring(0,i);
    return msg;
}
public static void printMsg(String msg) {
    System.out.println("(Op-PRINTMSG): " +msg+"\n");
}



public static void executeOpCode(String op, String body) {
        if (op.equals("ABSPLAYX")) receivedPlayerAbsoluteX(body);
        else if (op.equals("ABSPLAYY")) receivedPlayerAbsoluteY(body);
        else if (op.equals("FIRSTVOL")) requestVolley();
        else if (op.equals("SECNDVOL")) returnVolley(body);
        else if (op.equals("PRINTMSG")) printMsg(body);

    }

そしてメインループ：

public void run() {

    while (shouldBeListening) {
        //Main loop for the connection thread
        String op = readInputStream();
        //If stream has data, add the opcodes to opQueue.
        if (op != ("")) {
            separateOpsFromStream(op, incomingOpQueue);
        }

        //Extract incoming opcode head and body, then execute.
        //This executes everything in the queue before moving on.
        while (incomingOpQueue.size() > 0) {

            op = incomingOpQueue.poll();
            if (op != "") {
                String opHeader = OpCodeOperations.readHeader(op);
                String opBody = OpCodeOperations.readBody(op);
                playerData.executeOpCode(opHeader, opBody);
            }
        }


    }


}
4

3 に答える 3

0

リーダーをマークしてリセットしようとしましたか?

 bufferedReader.mark(0);
 bufferedReader.reset();
于 2013-11-03T03:42:06.363 に答える