在开发中，如果在Binder传输传输比较大的数据，会报TransactionTooLargeException错误异常，这个异常是因为Binder驱动对内存限制引起的，默认进程在打开Binder驱动的时候，都限制为1M-8K的大小，也就是说，在默认情况下，我们传输的数据不能大于这个数值
下面是通过Binder驱动传输一个1M数据的例子
ServiceConnection serviceConnection = new ServiceConnection() {
@Override
public void onServiceConnected(ComponentName name, IBinder service) {
try {
Parcel data = Parcel.obtain();
Parcel reply = Parcel.obtain();
byte[] a = new byte[1024 * 1024 * 1];//1M
data.writeByteArray(a);
service.transact(12345, data, reply, 0);//发送数据到Service进程
} catch (RemoteException e) {
e.printStackTrace();
}
}
@Override
public void onServiceDisconnected(ComponentName name) {
}
};
//通过bindService启动一个Service
Intent intent = new Intent(this, RemoteService.class);
bindService(intent, mServiceConnection, Context.BIND_AUTO_CREATE);
程序运行之后会报TransactionTooLargeException
异常消息
这就是传输的数据超过限制大小所报的错误，所以传输大数据的时候，就可以通过Android匿名共享内存的方法来解决这个问题
Android匿名共享内存例子
发送端（AshmemActivity）
public class AshmemActivity extends AppCompatActivity {
ServiceConnection mServiceConnection = new ServiceConnection() {
@Override
public void onServiceConnected(ComponentName name, IBinder service) {
try {
String str = "发送端的数据";
//创建一个MemoryFile对象，第二个参数为占用内存的大小，这里为字符串字节数组的长度
MemoryFile memoryFile = new MemoryFile("larger_data", str.getBytes().length);
//将字符串转化为字节数组写入MemoryFile
memoryFile.writeBytes(str.getBytes(), 0, 0, str.getBytes().length);
//通过反射获取MemoryFile的文件描述符，到时远程就可以通过这个参数获取到数据
Method method = MemoryFile.class.getDeclaredMethod("getFileDescriptor");
FileDescriptor des = (FileDescriptor) method.invoke(memoryFile);
Parcel data = Parcel.obtain();
//将文件描述符打包到Parce
data.writeFileDescriptor(des);
//还有一些网上例子是把文件描述符封装为ParcelFileDescriptor，再通过writeParcelable打包进去
//ParcelFileDescriptor pfd = ParcelFileDescriptor.dup(des);
//data.writeParcelable(pfd);
//这两种方法都可行，只是远程进程获取的方式有些不同
//发送数据的字节数组长度，作用是告诉远程传输数据的长度
data.writeInt(str.getBytes().length);
Parcel reply = Parcel.obtain();
//这里固定业务码为88888
service.transact(88888, data, reply, 0);
} catch (RemoteException e) {
e.printStackTrace();
}
}
@Override
public void onServiceDisconnected(ComponentName name) {
}
};
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_ashmem);
//启动AshmenSerice服务
Intent intent = new Intent(this, AshmemService.class);
bindService(intent, mServiceConnection, Context.BIND_AUTO_CREATE);
}
@Override
protected void onDestroy() {
super.onDestroy();
unbindService(mServiceConnection);
}
}
接收端（AshmemService）
public class AshmemService extends Service {
public AshmemService() {
}
@Override
public IBinder onBind(Intent intent) {
return new AshmenBinder();
}
class AshmenBinder extends Binder {
@Override
protected boolean onTransact(int code, @NonNull Parcel data, @Nullable Parcel reply, int flags) throws RemoteException {
if (code == 88888) {
try {
//获取文件描述符
ParcelFileDescriptor pfd = data.readFileDescriptor();
//获取传输数据的大小
int size = data.readInt();
//根据文件描述符获取InputStream
InputStream inputStream = new FileInputStream(pfd.getFileDescriptor());
//定义一个缓冲区
byte[] bytes = new byte[1024];
//把数据写入缓冲区
inputStream.read(bytes, 0, size);
//把字节数组转换为字符串
String message = new String(bytes, 0, size, UTF_8);
//打印数据
Log.i("CJT", "接受到的数据为：" + message);
} catch (IOException e) {
e.printStackTrace();
}
return true;
} else {
return super.onTransact(code, data, reply, flags);
}
}
}
}
这样就完成了一次跨进程传输大数据的简单流程，可能有人会想，不对呀，你就传递一个字符串，算哪门子大数据
那现在我们就根据上面通讯的例子，再把一张图片从接收端（AshmemService）传递回发送端（AshmemActivity）
接收端（传输图片）（AshmemService）
public class AshmemService extends Service {
//...省略其他代码
class AshmenBinder extends Binder {
@Override
protected boolean onTransact(int code, @NonNull Parcel data, @Nullable Parcel reply, int flags) throws RemoteException {
if (code == 88888) {
try {
//获取文件描述符
ParcelFileDescriptor pfd = data.readFileDescriptor();
//获取传输数据的大小
int size = data.readInt();
//根据文件描述符获取InputStream
InputStream inputStream = new FileInputStream(pfd.getFileDescriptor());
//定义一个缓冲区
byte[] bytes = new byte[1024];
//把数据写入缓冲区
inputStream.read(bytes, 0, size);
//把字节数组转换为字符串
String message = new String(bytes, 0, size, UTF_8);
//打印数据
Log.i("CJT", "接受到的数据为：" + message);
//返回数据给接收端
//获取一张本地图片资源的Bitmap
Bitmap bitmap = BitmapFactory.decodeResource(getResources(), R.mipmap.larger_image);
//将Bitmap转换为字节数组
ByteArrayOutputStream stream = new ByteArrayOutputStream();
bitmap.compress(Bitmap.CompressFormat.PNG, 100, stream);
byte[] img = stream.toByteArray();
//创建一个MemoryFile对象
MemoryFile file = new MemoryFile("larger_bitmap", img.length);
//将字节数组写入
file.getOutputStream().write(img);
//反射获取文件描述符
Method method = MemoryFile.class.getDeclaredMethod("getFileDescriptor");
FileDescriptor des = (FileDescriptor) method.invoke(file);
//通过writeParcelable打包文件描述符
reply.writeParcelable(ParcelFileDescriptor.dup(des), 0);
} catch (IOException e) {
e.printStackTrace();
}
return true;
} else {
return super.onTransact(code, data, reply, flags);
}
}
}
}
发送端（接收图片）（AshmemActivity）
public class AshmemActivity extends AppCompatActivity {
ServiceConnection mServiceConnection = new ServiceConnection() {
@Override
public void onServiceConnected(ComponentName name, IBinder service) {
try {
String str = "发送端的数据";
//创建一个MemoryFile对象，第二个参数为占用内存的大小，这里为字符串字节数组的长度
MemoryFile memoryFile = new MemoryFile("larger_data", str.getBytes().length);
//将字符串转化为字节数组写入MemoryFile
memoryFile.writeBytes(str.getBytes(), 0, 0, str.getBytes().length);
//通过反射获取MemoryFile的文件描述符，到时远程就可以通过这个参数获取到数据
Method method = MemoryFile.class.getDeclaredMethod("getFileDescriptor");
FileDescriptor des = (FileDescriptor) method.invoke(memoryFile);
Parcel data = Parcel.obtain();
//将文件描述符打包到Parce
data.writeFileDescriptor(des);
//还有一些网上例子是把文件描述符封装为ParcelFileDescriptor，再通过writeParcelable打包进去
//ParcelFileDescriptor pfd = ParcelFileDescriptor.dup(des);
//data.writeParcelable(pfd);
//这两种方法都可行，只是远程进程获取的方式有些不同
//发送数据的字节数组长度，作用是告诉远程传输数据的长度
data.writeInt(str.getBytes().length);
Parcel reply = Parcel.obtain();
//这里固定业务码为88888
service.transact(88888, data, reply, 0);
//发送后等待远程返回
//获取文件描述符
ParcelFileDescriptor pfd = reply.readParcelable(getClassLoader());
//获取数据流
FileInputStream fileInputStream = new FileInputStream(pfd.getFileDescriptor());
//将输入流解码为Bitmap
Bitmap bitmap = BitmapFactory.decodeStream(fileInputStream);
//设置到ImageView控件上
imageView.setImageBitmap(bitmap);
} catch (RemoteException e) {
e.printStackTrace();
}
}
@Override
public void onServiceDisconnected(ComponentName name) {
}
};
//省略部分代码...
}
网友评论