Android：ParcelFileDescriptor「createpipe」方法64KB錯誤

Question

我有一個使用ContentProvider類的應用程序。 在openFile方法中，我需要能夠將文件&解碼爲一個數據流。 所以我決定使用內置管道。

問題是如果使用createPipe方法，我只能寫入64KB。 之後，我無法將數據寫入管道。 另外請注意，我不能讀取，直到數據完全解碼&寫入管道。

package com.aujas.html.viewer.content; 
public class LocalFileContentProvider extends ContentProvider { 

private static final String URI_PREFIX = "content://com.aujas.html.viewer.localfile.dec/"; 
public static File file; 
public String filename; 
public ParcelFileDescriptor[] parcels; 

public static String constructUri(String url) { 
    String editString = url.replaceAll("%20", " "); 
    int n = editString.length(); 
    String uri = editString.substring(5, n - 1); 
    Log.d("URI", uri); 
    return URI_PREFIX + uri + "\""; 
} 

public ParcelFileDescriptor openFile(Uri uri, String mode) { 

    Log.d("OPEN", uri.getPath()); 
    return parcels[0]; 

} 

@Override 
public boolean onCreate() { 
    return true; 
} 

@Override 
public int delete(Uri uri, String s, String[] as) { 
    throw new UnsupportedOperationException(
      "Not supported by this provider"); 
} 

@Override 
public String getType(Uri uri) { 
    throw new UnsupportedOperationException(
      "Not supported by this provider"); 
} 

@Override 
public Uri insert(Uri uri, ContentValues contentvalues) { 
    throw new UnsupportedOperationException(
      "Not supported by this provider"); 
} 

@Override 
public Cursor query(Uri uri, String[] as, String s, String[] as1, String s1) { 
    throw new UnsupportedOperationException(
      "Not supported by this provider"); 
} 

@Override 
public int update(Uri uri, ContentValues contentvalues, String s, 
     String[] as) { 
    throw new UnsupportedOperationException(
      "Not supported by this provider"); 
} 

class DecryptAsync extends AsyncTask<String, Integer, String> { 

    @Override 
    protected String doInBackground(String... paramArrayOfParams) { 
     // TODO Auto-generated method stub 
     try { 
      file = new File(paramArrayOfParams[0]); 
      Log.d("DecrypOpened", file.toString()); 
      parcels = ParcelFileDescriptor.createPipe(); 
      Log.d("filebeindec", LocalFileContentProvider.file.toString()); 
      FileInputStream fis = new FileInputStream(LocalFileContentProvider.file); 

      android.os.ParcelFileDescriptor.AutoCloseOutputStream out = new android.os.ParcelFileDescriptor.AutoCloseOutputStream(parcels[1]); 
      Cipher ecipher; 
      Cipher dcipher; 
      SecretKey key; 
      String input = "768f8a949de079da"; 
      byte[] encoded = new BigInteger(input, 16).toByteArray(); 
      key = new SecretKeySpec(encoded, "DES"); 
      byte[] iv = new byte[] { (byte) 0x8E, 0x12, 0x39, (byte) 0x9C, 
        0x07, 0x72, 0x6F, 0x5A }; 
      AlgorithmParameterSpec paramSpec = new IvParameterSpec(iv); 
      ecipher = Cipher.getInstance("DES/CBC/PKCS5Padding"); 
      dcipher = Cipher.getInstance("DES/CBC/PKCS5Padding"); 
      ecipher.init(Cipher.ENCRYPT_MODE, key, paramSpec); 
      dcipher.init(Cipher.DECRYPT_MODE, key, paramSpec); 
      byte[] buf = new byte[1024]; 
      InputStream in = new CipherInputStream(fis, dcipher); 
      int numRead = 0; 
      int n = 1; 
      while ((numRead = in.read(buf)) >= 0) { 
       n++; 
       out.write(buf, 0, numRead); 
       Log.d("Error", "SD"); 
       if (n == 64) { 
        out.flush(); 
        out.flush(); 
        n = 0; 
       } 
      } 

      Log.d("Decypt Done", out.toString()); 
     } catch (Exception e) { 
      Log.d("AsyncError", e.toString()); 
     } 
     return null; 
    } 

    @Override 
    protected void onPostExecute(String result) { 
     // TODO Auto-generated method stub 
     super.onPostExecute(result); 
    } 

} 

}

當我執行此我到64KB只寫。由於每寫入1KB，我得到64個日誌，之後什麼也沒有發生。 這些管道是否有尺寸限制？有沒有解決方法？ 謝謝&關注 rtindru

Answer 1

Linux內核（至少是Android版本）對管道有64k緩衝區限制。

所以，你不能寫出整個文件（大於64K）。你所要做的就是

a）創建管

二）創建作家線程，這將寫入該管道。它會阻塞並等到讀取器線程讀取管道中的內容。

C）啓動此線程

d）返回讀者文件描述符給客戶端。

那麼，會發生什麼呢，作家和讀者都會同時寫和讀。寫入器會在填充緩衝區時阻塞，讀取器將在其清空緩衝區時阻塞。

Answer 2

我擴大了@勝利者，羅寧的回答將如何使用從@commonsware代碼在回答另一個問題代碼：

Custom ContentProvider - openInputStream(), openOutputStream()