最近在做專案時遇到這樣一個需求：依次讀取本地資料夾裡所有檔案的內容，轉為JSON，傳送到ActiveMQ的訊息佇列, 然後從MQ的訊息佇列上獲取檔案的資訊，依次寫到本地。常見的檔案型別，比如.txt 和.png等檔案的讀寫並不難。但是，我剛才所提到的需求，如果用常規的方法去讀寫，比如按位元組讀取檔案內容，轉為字串，再轉為JSON傳送到MQ的佇列，然後從MQ獲取原檔案資訊寫到檔案，就會發現寫出來的檔案和檔案不一樣。我的解決方法是：按位元組讀取原檔案，轉為位元組陣列，將位元組陣列轉為Base64編碼格式的字串，然後轉為JOSN傳送到MQ，然後從MQ獲取到JOSN，將檔案內容通過Base64解碼為字元陣列，寫檔案到某個路徑。以下為程式碼：

測試類 Test.class




/**
 * @Desc: 測試類
 * @Date: 2016/7/1
 * @Version: 1.0
 * @Author: lzy
 */
public class Test {
    public static void main(String[] args){

        String fileName="JUBE99EGRR311800";           //檔名：測試檔案是沒有後綴名的二進位制
        String fileReadPath="d:/read/";               //檔案所在資料夾
        String filePath=fileReadPath+fileName;        //檔案路徑

        //工具類
        FileUtil fileUtil=new FileUtil();

        //按位元組讀取檔案內容，並轉換為Base64編碼字串
        String fileJsonStr=fileUtil.fileToJson(fileName,filePath);

        //檔案內容Base64解碼,按位元組寫檔案
        fileUtil.writeFile(fileJsonStr,"d:/write/");
    }
}123456789101112131415161718192021222324

FileUtil.class 檔案轉換工具類



/**
 * @Desc: 檔案內容轉換工具類
 * @Date: 2016/7/1
 * @Version: 1.0
 * @Author: lzy
 */

public class FileUtil {

    /**
     * 檔案內容轉為 Base64 編碼的 JSON
     * @param fileName 檔名
     * @param filePath 檔案路徑
     * @return
     */
    public String fileToJson(String fileName,String filePath){

        String fileContentJson="";      //檔案內容轉JSON
        try {
            if(null!=filePath && !filePath.equals("")){
                if(null!=fileName && !fileName.equals("")){
                    //將檔案內容轉為位元組陣列
                    byte[] fileByte=toByteArray(filePath);

                    //將位元組陣列轉為Base64編碼
                    String fileContent=ByteToBase64(fileByte);

                    FileEntity fileEntity=new FileEntity();
                    fileEntity.setFileName(fileName);
                    fileEntity.setFileContent(fileContent);

                    //實體轉JSON
                    fileContentJson = FileEntitytoJSON(fileEntity);
                }
            }
        }catch (Exception e){
            Log.error("fileToJson error",e);
        }

        return fileContentJson;
    }

    /**
     * 將檔案轉成位元組陣列
     * @param filePath
     * @return
     */
    public byte[] toByteArray(String filePath){

        ByteArrayOutputStream bos=null;
        BufferedInputStream in = null;
        try {
            File f = new File(filePath);
            if(f.exists()){
                in = new BufferedInputStream(new FileInputStream(f));
                bos = new ByteArrayOutputStream((int) f.length());

                int buf_size = 1024;
                byte[] buffer = new byte[buf_size];
                int len = 0;
                while (-1 != (len = in.read(buffer, 0, buf_size))) {
                    bos.write(buffer, 0, len);
                }
                //return bos.toByteArray();
            }

        } catch (IOException e) {
            Log.error("toByteArray() Exception", e);
        } finally {
            try {
                in.close();
                bos.close();
            } catch (IOException e) {
                Log.error("toByteArray() Exception",e);
            }
        }
        return bos.toByteArray();
    }

    /**
     * Base64加密
     * @param b
     * @return
     */
    public String ByteToBase64(byte[] b) {
        String str="";
        if(null!=b){
            BASE64Encoder encoder = new BASE64Encoder();
            str=encoder.encode(b);
        }
        return str;
    }

    /**
     * Base64解密
     * @param str
     * @return
     */
    public byte[] Base64toByte(String str) {
        byte[] b = new byte[0];
        BASE64Decoder decoder = new BASE64Decoder();
        try {
            if(null!=str && !str.equals("")){
                b = decoder.decodeBuffer(str);
            }
        } catch (IOException e) {
            Log.error("Base64toByte() Exception",e);
        }
        return b;
    }

    /**
     * 實體轉JSON
     * @param fileEntity
     * @return
     */
    public String FileEntitytoJSON(FileEntity fileEntity) {
        String str="";
        if(null!=fileEntity){
            JSONObject json = JSONObject.fromObject(fileEntity);
            str = json.toString();
        }
        return str;
    }

    /**
     * JSON轉實體
     * @param msg
     * @return
     */
    public FileEntity JSONtoFileEntity(String msg) {
        FileEntity fileEntity=new FileEntity();
        if(null!=msg && !msg.equals("")){
            JSONObject obj = new JSONObject().fromObject(msg);
            fileEntity = (FileEntity) JSONObject.toBean(obj, FileEntity.class);
        }
        return fileEntity;
    }

    /**
     * 寫檔案
     * @param fileJson json
     * @param filePath 檔案路徑
     */
    public void writeFile(String fileJson,String filePath){
        FileOutputStream fos=null;
        try{

            if(null!=fileJson && !fileJson.equals("")){
                if(null!=filePath && !filePath.equals("")){
                    //json轉為檔案實體
                    FileEntity fileEntity=JSONtoFileEntity(fileJson);

                    //Base64檔案內容解碼
                    byte[] b=Base64toByte(fileEntity.getFileContent());

                    File file=new File(filePath);
                    if (!file.exists()) {
                        file.mkdirs();
                    }

                    fos = new FileOutputStream(filePath + File.separator +fileEntity.getFileName());
                    fos.write(b);
                }
            }

        }catch (Exception e){
            Log.error("write Exception:",e);
        }finally {
            try {
                fos.close();
            } catch (IOException e) {
                Log.error("fos.close() Exception:", e);
            }
        }

    }
}123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178

FileEntity.class 檔案實體類

/**
 * @Desc:檔案資訊實體
 * @Date: 2016/6/29
 * @Version: 1.0
 * @Author: lzy
 */
public class FileEntity {
    private String fileName;       //檔名
    private String fileContent;    //檔案內容

    public String getFileName() {
        return fileName;
    }

    public void setFileName(String fileName) {
        this.fileName = fileName;
    }

    public String getFileContent() {
        return fileContent;
    }

    public void setFileContent(String fileContent) {
        this.fileContent = fileContent;
    }
}