ServerSocketChannel
ServerSocketChannel作用？就是专职干什么的？
1、监听新进来的TCP链接通道，
2、创建新的SocketChannel
ServerSocketChannel 不具备 什么能力
ServerSocketChannel并不能进行数据传输的能力
如何创建ServerSocketChannel实例
ServerSocketChannel socketChannel =ServerSocketChannel.open();
该对象关联了一个未绑定ServerSocket的通道，
为ServerSocketChannel绑定监听端口号
JDK1.7前，需要调用ServerSocketChannel的socket方法，再调用bind()来进行关联
JDK1.7后，就可以直接调用ServerSocketChannel的bind()来进行端口绑定了。
ServerSocketChannel如何监听新进来的连接
通过 ServerSocketChannel.accept() 方法监听新进来的连接。
ServerSocketChannel 默认是 阻塞模式，可以查看JDK源码
如下，所示：
通过ServerSocketChannel.configureBlocking(true)来设定阻塞模式
1、在阻塞模式下，
如果有新的连接进来，那么accept()方法返回的是一个包含新进来的连接的SocketChannel,
如果没有新的连接，那么accept()方法，就会一直阻塞在这里，直到有的新连接进来
2、在非阻塞模式下ServerSocketChannel. configureBlocking(false)
如果有连接进来，那么accept()方法返回的是一个包含新进来的连接的SocketChannel
如果没有新的连接，那么accept()方法会立即返回null
3、阻塞模式与非阻塞模式的根本区别？
其实，就是在没有新的连接的情况下，如何处理的？不返回，一直等待的话，就是阻塞；
如果立即返回的话，就是非阻塞了。
SocketChannel
创建SocketChannel的方式？
方式一：在客户端创建
SocketChannel socketChannel = SocketChannel.open();
方式二：在服务器端创建
ServerSocketChannel接受一个连接请求后得到，如
SocketChannel socketChannel = serverSocketChannel.accept();
将管道中的数据读到缓存里，用的是socketChannel的read方法
int read = socketChannel.read(sizeBuffer);
将缓存里的数据写到管道中，用的是socketChannel的write方法
socketChannel.write(sizeBuffer);
例子如下：
服务端：
package xingej.channel;import java.io.IOException;import java.net.InetSocketAddress;import java.nio.ByteBuffer;import java.nio.channels.ServerSocketChannel;import java.nio.channels.SocketChannel;public class ServerSocketChannelTest { public void initChannel() throws IOException { //服务器端，通过open方法，来创建ServerSocketChannel //注意，此时，服务器端，还没有进行绑定端口呢 ServerSocketChannel serverSocketChannel = ServerSocketChannel.open(); //设置为非阻塞模式// serverSocketChannel.configureBlocking(false); //绑定端口号 //JDK1.7版本之后的写法 serverSocketChannel.bind(new InetSocketAddress(8081)); //JDK1.7版本之前的写法// serverSocketChannel.socket().bind(new InetSocketAddress(8081)); //创建字节缓存区 //缓存区的大小是1024字节，这个可以自己调试，如改成64,128.... ByteBuffer byteBuffer = ByteBuffer.allocate(1024); while (true) { System.out.println("-------服务器端-----开始接收-----客户端的连接---------"); //在服务器端，接收客户端的链接，如果存在客户端的话，就返回一个 //SocketChannel对象 //如果是阻塞模式的话，没有新的链接进来，就会阻塞在这里，否则，往下执行 //如果是非阻塞模式的话，没有新的链接进来，就会立马返回一个null，程序不会阻塞在这里， //会立马往下进行的 SocketChannel socketChannel = serverSocketChannel.accept(); if (null != socketChannel) { while (true) { //清楚缓存区的数据，可以接收新的数据 byteBuffer.clear(); //将管道socketChannel的数据读取到 缓存byteBuffer里 //readSize 表示 读取的字节数 int readSize = socketChannel.read(byteBuffer); if (readSize == -1) { break; } //再从 字节缓存里，进行其他 业务逻辑操作，\ // 注意，这里的缓存区使用的字节类型 // 因此，如果需要其他类型的话，需要进行转换 System.out.println(new String(byteBuffer.array())); } } try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } } public static void main(String[] args) throws IOException { new ServerSocketChannelTest().initChannel(); }}
客户端如下：
package xingej.channel;import java.io.IOException;import java.net.InetSocketAddress;import java.nio.ByteBuffer;import java.nio.channels.SocketChannel;public class SocketChannelTest { public void connectServer() throws IOException{ // 创建一个 SocketChannel对象， // 请注意，并没有进行 链接服务器端哦 SocketChannel socketChannel = SocketChannel.open(); //开始链接服务器端 socketChannel.connect(new InetSocketAddress("localhost", 8081)); //在客户端创建 字节缓存区 ByteBuffer byteBuffer = ByteBuffer.allocate(1024); String msg = "\nhello, nio, hello ,spark, hello ,hadoop, flume, mesos, marathon, netty, mina, stream, inputstream, outputstream \n" + "hello, nio, hello ,spark, hello ,hadoop, flume, mesos, marathon, netty, mina, stream, inputstream, outputstream \n" + "hello, nio, hello ,spark, hello ,hadoop, flume, mesos, marathon, netty, mina, stream, inputstream, outputstream 北京\n"; //往字节缓存区，添加数据 byteBuffer.put(msg.getBytes()); // 针对是更新limit值，将此值更新为position了，用于接下来的读操作 byteBuffer.flip(); while(byteBuffer.hasRemaining()) { //将字节缓存里的数据，写到管道中去 socketChannel.write(byteBuffer); } socketChannel.close(); } public static void main(String[] args) throws IOException{ new SocketChannelTest().connectServer(); }}
启动方式：
先启动服务器端，然后再启动客户端