package com.slp.nio;

 import org.junit.Test;

 import java.io.File;

 import java.io.IOException;

 import java.net.InetSocketAddress;

 import java.nio.ByteBuffer;

 import java.nio.channels.FileChannel;

 import java.nio.channels.ServerSocketChannel;

 import java.nio.channels.SocketChannel;

 import java.nio.file.Paths;

 import java.nio.file.StandardOpenOption;

 /**

  * Created by sanglp on 2017/3/1.

  * 一、使用NIO完成网络通信的三个核心

  * 1、通道：负责连接

  *     |--java.nio.channels.channel接口

  *        |--SelectableChannel

  *           |--SocketChannel

  *           |--ServerSocketChannel

  *           |--DatagramChannel

  *

  *           |--Pipe.SinkChannel

  *           |--Pipe.SourceChannel

  * 2、缓冲区：负责数据的存取

  * 3、选择器：是SelectableChannel的多路复用器，用于监控SelectableChannel的IO状况

  *

  */

 public class TestBlockingNIO {

     //客户端

     @org.junit.Test

     public void client() throws IOException {

       // 1、获取通道

        SocketChannel socketChannel = SocketChannel.open(new InetSocketAddress("127.0.0.1",9898));

         FileChannel inChannel = FileChannel.open(Paths.get("2.jpg"), StandardOpenOption.READ);

         //2、分配指定大小的缓冲区

         ByteBuffer buffer =ByteBuffer.allocate(1024);

         //3、读取本地文件 并发送到服务端

         while (inChannel.read(buffer)!=-1){

             buffer.flip();

             socketChannel.write(buffer);

             buffer.clear();

         }

         //4、关闭通道

         socketChannel.close();

         inChannel.close();

     }

     //服务端

     @Test

     public void server() throws IOException {

         //1、获取通道

         ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();

         FileChannel outChannel = FileChannel.open(Paths.get("3.jpg"),StandardOpenOption.WRITE,StandardOpenOption.CREATE);

         //2、绑定连接

         serverSocketChannel.bind(new InetSocketAddress(9898));

         //3、获取客户端连接

         SocketChannel socketChannel = serverSocketChannel.accept();

         //4、分配指定大小的缓冲区

         ByteBuffer buffer = ByteBuffer.allocate(1024);

         //5、接收客户端的数据，并保存到本地

         while (socketChannel.read(buffer)!=-1){

             buffer.flip();

             outChannel.write(buffer);

             buffer.clear();

         }

         //关闭通道

         socketChannel.close();

         serverSocketChannel.close();

     }

 }