首页 > 其他 > 详细

无题2

时间:2016-12-17 14:30:57      阅读:198      评论:0      收藏:0      [点我收藏+]
技术分享
package nio;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SocketChannel;

public class SocketChannelDemo {

    public static void main(String[] args) {
        // TODO Auto-generated method stub
        try {
            SocketChannel socketChannel = SocketChannel.open();
            socketChannel.connect(new InetSocketAddress("127.0.0.1", 9999));

            ByteBuffer bb = ByteBuffer.allocate(48);
            int byteNum;

            int bytes = socketChannel.read(bb);
            bb.flip();
            while (bb.hasRemaining()) {
                System.out.print((char) bb.get());
            }
            bb.clear();
            
            socketChannel.close();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

    }

}
View Code
技术分享
package nio;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;

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

        try {
            ServerSocketChannel ssc = ServerSocketChannel.open();
            ssc.socket().bind(new InetSocketAddress(9999));
            String msg = "send something to you";
            ByteBuffer bb = ByteBuffer.allocate(48);
            bb.clear();
            bb.put(msg.getBytes());
            bb.flip();
            while (true) {
                SocketChannel socketChannel = ssc.accept();
                while (bb.hasRemaining()) {
                    socketChannel.write(bb);
                }
                socketChannel.close();
            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

    }
}
View Code

我一直在想为什么socket客户端只能读一次或得返回信息,原来是我server端写错了,应该把设置byteBuffer内容的这段代码写在 while循环里

如下:

  while (true) {
                SocketChannel socketChannel = ssc.accept();
                String msg = "send something to you";
                ByteBuffer bb = ByteBuffer.allocate(48);
                bb.clear();
                bb.put(msg.getBytes());
                bb.flip();
                while (bb.hasRemaining()) {
                    socketChannel.write(bb);
                }
//                socketChannel.close();
            }

 

无题2

原文:http://www.cnblogs.com/jarman/p/6189561.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!