客户端无法接收服务器消息的原因（java）

Question

我刚刚开始学习Java。我修改了服务器/客户端通信程序的客户端代码，为客户端创建了两个线程，一个是用于接收用户输入的主线程，另一个是用于接收服务器响应的inputThread。我确信服务器已经向客户机发送了响应，但是，在客户机上没有获得响应消息。

这是我的代码。有谁能帮我弄明白吗？谢谢

package clientnio;

import java.net.*; 
import java.nio.*; 
import java.io.*;
import java.nio.channels.*; 
import java.util.Scanner; 

public class ClientNIO {
public static int bufferLen = 50;
public static SocketChannel client;
public static ByteBuffer writeBuffer;
public static ByteBuffer readBuffer;

public static void main(String[] args) { 
    writeBuffer = ByteBuffer.allocate(bufferLen);
    readBuffer = ByteBuffer.allocate(bufferLen);

    try { 
        SocketAddress address = new InetSocketAddress("localhost",5505); 
        System.out.println("Local address: "+ address);
        client=SocketChannel.open(address);
        client.configureBlocking(false); 

        //readBuffer.flip();
        new inputThread(readBuffer);

        /*
        String a="asdasdasdasddffasfas"; 
        writeBuffer.put(a.getBytes()); 
        writeBuffer.clear();  
        int d=client.write(writeBuffer);
        writeBuffer.flip();
        */

        while (true) {
            InputStream inStream = System.in;
            Scanner scan = new Scanner(inStream);
            if (scan.hasNext()==true) {
                String inputLine = scan.nextLine();
                writeBuffer.put(inputLine.getBytes()); 
                //writeBuffer.clear();
                System.out.println(writeBuffer.remaining());
                client.write(writeBuffer);
                System.out.println("Sending data: "+new String(writeBuffer.array()));
                writeBuffer.flip(); 
                Thread.sleep(300);
            }
        }                 
    } 
    catch(Exception e) { 
        System.out.println(e);
    } 

}
}

class inputThread extends Thread {
private ByteBuffer readBuffer;
public inputThread(ByteBuffer readBuffer1) {  
    System.out.println("Receiving thread starts.");
    this.readBuffer = readBuffer1;
    start();
}

@Override
public void run() {
    try {
        while (true) {
            readBuffer.flip();
            int i=ClientNIO.client.read(readBuffer); 
            if(i>0) { 
                byte[] b=readBuffer.array(); 
                System.out.println("Receiving data: "+new String(b)); 
                    //client.close(); 
                    //System.out.println("Connection closed."); 
                    //break; 
            }
            Thread.sleep(100); 
        }
    }
    catch (Exception e) {
       System.out.println(e);
    }
  }
}

Answer 1

免责声明：我不是Java的活跃用户。（我只在学校用过。）

建议：我认为，如果您使用阻塞模式，将大大简化调试过程，至少在您的代码示例正常工作之前是这样。（当前您的代码似乎没有从非阻塞模式中受益。）

我已经确定了两个问题，最后归纳为四行可能需要更改的代码：

• 当bytebuffer分配它的备份数组时，它通过将position设置为零，并将limit设置为该数组的容量，从而将自己设置为准备写入。您对bytebuffer.flip()的两种用法（分别在写入循环和读取循环中）似乎与惯例背道而驰。
• 调用byteBuffer.array()方法总是返回整个备份数组，因此它的大小总是BufferLen。因此，由全尺寸数组构造的string可能包含以前传输的垃圾。
  • 通常，需要将数组修剪到传输大小，并且字符串和字节数组之间的转换必须使用与服务器相同的编码。

  我对第一个问题的建议更改:
  （注意：我不知道如何修复数组修剪和编码问题。）

  writeBuffer.put(inputLine.getBytes()); 
  writeBuffer.flip();                       // <--here
  client.write(writeBuffer);
  ...
  writeBuffer.clear();                      // <-- should be clear() instead of flip()
  Thread.sleep(300);
  

  // readBuffer.flip();                      // <-- remove this line
  int i=ClientNIO.client.read(readBuffer); 
  if(i>0) { 
      readBuffer.flip();                     // <-- move it here
      byte[] b=readBuffer.array(); 
      System.out.println("Receiving data: "+new String(b)); 
      ...
  }
  

  参考文献

  • http://docs.oracle.com/javase/1.4.2/docs/api/java/nio/bytebuffer.html
  • http://docs.oracle.com/javase/1.4.2/docs/api/java/nio/channels/socketchannel.html
  • SocketChannel始终为空
  • http://www.exampledepot.com/egs/java.nio.charset/convertchar.html