为什么我的客户端无法接收来自服务器的消息

Question

服务器：

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.Arrays;
import java.util.Iterator;
public class TrainAgain {

private int port;
private Selector selector;

public TrainAgain(int port) {
    this.port = port;
}

public void startServer() {
    try {
        //open serversocketchannel, bind to port,config non-blocking and register on selector .
        selector = Selector.open();
        ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
        serverSocketChannel.socket().bind(new InetSocketAddress("localhost",port));
        serverSocketChannel.configureBlocking(false);
        serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
        System.out.println("listen on port " + port);

        while (true) {
            //blocking here listening to channel that connected
            int r = selector.select();
            if (r == 0) {
                continue;
            }
            //after connected, use iterator to scan them all
            Iterator<SelectionKey> itr = selector.selectedKeys().iterator();
            while (itr.hasNext()) {
                SelectionKey key = itr.next();
                itr.remove();
                if (key.isAcceptable()) {
                    //channel is ready to accept a new socket channel
                    ServerSocketChannel ssc = (ServerSocketChannel) key.channel();
                    ssc.configureBlocking(false);
                    //get the socket channel and registed it to selector;
                    SocketChannel sc = ssc.accept();
                    sc.configureBlocking(false);
                    if (sc == null) {
                        continue;
                    }
                    sc.register(selector, SelectionKey.OP_READ);
                    System.out.println("connected to a new socket channel :" + sc);
                }else if(key.isConnectable()){
                    ((SocketChannel)key.channel()).finishConnect();
                } else if (key.isReadable()) {
                    //channel is ready for reading
                    SocketChannel sc = (SocketChannel) key.channel();
                    sc.configureBlocking(false);
                    ByteBuffer buffer = ByteBuffer.allocate(48);
                    while (true) {
                        buffer.clear();
                        int n = sc.read(buffer);
                        if (n <= 0) {
                            break;
                        }
                        System.out.println("receive data :" + Arrays.toString(buffer.array())+" from "+sc);
                    }
                    buffer = ByteBuffer.wrap("welcome!".getBytes());
                    buffer.flip();
                    //I write buffer here
                    sc.write(buffer);
                    System.out.println("write data :" + Arrays.toString(buffer.array())+" to "+sc);
                }


            }

        }

    } catch (IOException e) {
        e.printStackTrace();
    }


}

public static void main(String[] args) {
    TrainAgain again = new TrainAgain(8000);
    again.startServer();
}

}

客户：

import java.io.IOException;
import java.io.RandomAccessFile;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;
import java.nio.channels.SocketChannel;
import java.util.Arrays;

public class Client {

private void startClient(int port) {
    try {
        //get socketchannel and connect to server
        SocketChannel sc = SocketChannel.open();
        sc.connect(new InetSocketAddress("localhost",port));
        System.out.println("connect to server from "+sc);
        sc.configureBlocking(false);
        RandomAccessFile randomAccessFile = new RandomAccessFile("D:\\nio-data.txt","rw");
        FileChannel fc = randomAccessFile.getChannel();
        //transfer data from filechannel to socketchannel
        fc.transferTo(0, randomAccessFile.length(), sc);

        ByteBuffer buffer = ByteBuffer.allocate(48);
        if(sc.isConnectionPending()){
            sc.finishConnect();
        }
        System.out.println("connect to server from "+sc);
        while(true){
            buffer.clear();
            System.out.println("read data from "+sc);
            //blocking here, why can't I read buffer
            int r = sc.read(buffer);
            if(r <= 0){
                break;
            }
            System.out.println(Arrays.toString(buffer.array()));
        }

    } catch (IOException e) {
        e.printStackTrace();
    }

}


public static void main(String[] args) {
    Client client = new Client();
    client.startClient(8000);
}
}

但最终，客户端阻塞了read（buffer）语句。

Answer 1

我搞定了！经过仔细调试，我发现在功能为将零设置为缓冲区的位置的wrap（字节）之后，我使用了另一种功能为将现在为零的位置设置为限制的filp方法。所以缓冲区实际上并没有发送到客户端。