package cn.luxh.app;



import java.io.FileInputStream;

import java.io.FileOutputStream;

import java.io.IOException;

import java.nio.ByteBuffer;

import java.nio.channels.FileChannel;

import java.nio.charset.Charset;



import org.junit.Test;



public class NioTester {

    

    /

      读取文件

      获取通道；创建缓冲区；让通道将数据读到这个缓冲区中。

     /

    ＠Test

    public void testRead（） {

        FileInputStream fis = null;

        FileChannel channel = null;

        try {

            //获取通道Channel，从FileInputStream中获取

            fis = new FileInputStream（D:/test.rar）;

            channel = fis.getChannel（）;

            

            //创建缓冲区

            ByteBuffer buffer = ByteBuffer.allocate（1024）;

            

            //将数据从通道读取到缓冲区

            channel.read（buffer）;

            

            //营业处理惩罚

            //...

            

        } catch （IOException e） {

            e.printStackTrace（）;

        }finally {

            try {

                if（fis != null） {

                    fis.close（）;

                }

                if（channel != null） {

                    channel.close（）;

                }

            } catch （IOException e） {

                e.printStackTrace（）;

            }

            

        }

    }

    

    /

      写文件

      获取通道；创建一个缓冲区，用数据填充它；然后让通道用这些数据来履行写入操纵。 

     /

    ＠Test

    public void testWrite（） {

        FileOutputStream fos = null;

        FileChannel channel = null;

        try {

            //获取通道，从FileOutputStream获取

            fos = new FileOutputStream（D:/test.txt）;

            channel = fos.getChannel（）;

            

            //创建缓冲区

            ByteBuffer buffer = ByteBuffer.allocate（1024）;

            

            String words = hey，girl.I am a coder.;

            byte[] message = words.getBytes（Charset.defaultCharset（））;

            buffer.put（message）;

            buffer.flip（）;

            channel.write（buffer）;

        }catch（IOException e） {

            e.printStackTrace（）;

        }finally {

            try {

                if（fos != null） {

                    fos.close（）;

                }

                if（channel != null） {

                    channel.close（）;

                }

            }catch（IOException e）{

                e.printStackTrace（）;

            }

        }

    }

    

    /

      读写操纵

      获取通道；创建一个 Buffer，然后从源文件中将数据读到这个缓冲区中；

      然后将缓冲区写入目标文件。

      络续反复 读写 直到源文件停止。

     /

    ＠Test

    public void testReadAndWrite（） {

        FileInputStream fis = null;

        FileChannel inChannel = null;

        

        FileOutputStream fos = null;

        FileChannel outChannel = null;

        

        try {

            fis = new FileInputStream（D:/test.txt）;

            inChannel = fis.getChannel（）;

            

            fos = new FileOutputStream（D:/test2.txt）;

            outChannel = fos.getChannel（）;

            

            ByteBuffer buffer = ByteBuffer.allocate（1024）;

            while（true） {

                //重设缓冲区，使它可以接管读入的数据。

                buffer.clear（）;

                if（inChannel.read（buffer）==-1） {

                    break;

                }

                //让缓冲区可以将新读入的数据写入通道

                buffer.flip（）;

                outChannel.write（buffer）;

            }

        }catch（Exception e） {

            e.printStackTrace（）;

        }finally {

            try {

                if（fos != null） {

                    fos.close（）;

                }

                if（outChannel != null） {

                    outChannel.close（）;

                }

                if（fis != null） {

                    fis.close（）;

                }

                if（inChannel != null） {

                    inChannel.close（）;

                }

            }catch（IOException e）{

                e.printStackTrace（）;

            }

        }

    }

}