Android BitTube进程间数据传递
发布日期:2021-07-29 10:44:35 浏览次数:0 分类:技术文章


Android 4.0里面除了个BitTube的东西,字面意思理解就是字节管道,可以用来在进程间进行数据的传递,但是是单向的

如果要在两个进程间使用BitTube进行数据的传递,一般都是这么使用的(以SensorEventConnection和SensorEventQueue通信为例)

1、首先在SensorEventConnection的构造函数里面 new 一个BitTube,不需要参数,

[cpp] 
  1. SensorService::SensorEventConnection::SensorEventConnection(  
  2.         const sp<SensorService>& service)  
  3.     : mService(service), mChannel(new BitTube())  
  4. {  
  5. }  

我们看下BitTube的构造函数

[cpp] 
  1. BitTube::BitTube()  
  2.     : mSendFd(-1), mReceiveFd(-1)  
  3. {  
  4.     int sockets[2];  
  5.     if (socketpair(AF_UNIX, SOCK_SEQPACKET, 0, sockets) == 0) { //创造一对未命名的、相互连接的UNIX域套接字  
  6.         int size = SOCKET_BUFFER_SIZE;  
  7.         setsockopt(sockets[0], SOL_SOCKET, SO_SNDBUF, &size, sizeof(size));  
  8.         setsockopt(sockets[0], SOL_SOCKET, SO_RCVBUF, &size, sizeof(size));  
  9.         setsockopt(sockets[1], SOL_SOCKET, SO_SNDBUF, &size, sizeof(size));  
  10.         setsockopt(sockets[1], SOL_SOCKET, SO_RCVBUF, &size, sizeof(size));  
  11.         fcntl(sockets[0], F_SETFL, O_NONBLOCK);//设置为非阻塞  
  12.         fcntl(sockets[1], F_SETFL, O_NONBLOCK);//设置为非阻塞  
  13.         mReceiveFd = sockets[0];//用于数据接收的socket  
  14.         mSendFd = sockets[1];//用于数据发送的socket  
  15.     } else {  
  16.         mReceiveFd = -errno;  
  17.         ALOGE("BitTube: pipe creation failed (%s)", strerror(-mReceiveFd));  
  18.     }  
  19. }  

里面主要就是创建了一对未命名的互连的套接字,并设置为非阻塞的

2、然后,我们就可以使用这个BitTube了,这里这里在SensorEventQueue的onFirstRef调用时,

[cpp] 
  1. void SensorEventQueue::onFirstRef()  
  2. {  
  3.     mSensorChannel = mSensorEventConnection->getSensorChannel();  
  4. }  

通过getSensorChannel获取SensorEventConnection端面的BitTube我们看一下这个函数的实现,从Bp端面到Bn端

[cpp] 
  1.  virtual sp<BitTube> getSensorChannel() const  
  2.     {  
  3.         Parcel data, reply;  
  4.         data.writeInterfaceToken(ISensorEventConnection::getInterfaceDescriptor());  
  5.         remote()->transact(GET_SENSOR_CHANNEL, data, &reply);  
  6.         return new BitTube(reply);  
  7. }  

利用返回值new 一个新的BitTube

[cpp] 
  1. BitTube::BitTube(const Parcel& data)  
  2.     : mSendFd(-1), mReceiveFd(-1)  
  3. {  
  4.     mReceiveFd = dup(data.readFileDescriptor());  
  5.     if (mReceiveFd >= 0) {  
  6.         int size = SOCKET_BUFFER_SIZE;  
  7.         setsockopt(mReceiveFd, SOL_SOCKET, SO_SNDBUF, &size, sizeof(size));  
  8.         setsockopt(mReceiveFd, SOL_SOCKET, SO_RCVBUF, &size, sizeof(size));  
  9.         fcntl(mReceiveFd, F_SETFL, O_NONBLOCK);  
  10.     } else {  
  11.         mReceiveFd = -errno;  
  12.         ALOGE("BitTube(Parcel): can't dup filedescriptor (%s)",  
  13.                 strerror(-mReceiveFd));  
  14.     }  
  15. }  

利用readFileDescriptor读取描述符,然后设置mReceiveFd

3、我们看一下相应的Bn端是怎么实现的

[cpp] 
  1. status_t BnSensorEventConnection::onTransact(  
  2.     uint32_t code, const Parcel& data, Parcel* reply, uint32_t flags)  
  3. {  
  4.     switch(code) {  
  5.         case GET_SENSOR_CHANNEL: {  
  6.             CHECK_INTERFACE(ISensorEventConnection, data, reply);  
  7.             sp<BitTube> channel(getSensorChannel());  
  8.             channel->writeToParcel(reply);  
  9.             return NO_ERROR;  
  10.         } break;  
  11. ….  
  12. }  

调用getSensorChannel返回我们在第一步中new出来的BitTube,然后调用BitTube的writeToParcel

[cpp] 
  1. status_t BitTube::writeToParcel(Parcel* reply) const  
  2. {  
  3.     if (mReceiveFd < 0)  
  4.         return -EINVAL;  
  5.   
  6.     status_t result = reply->writeDupFileDescriptor(mReceiveFd);  
  7.     close(mReceiveFd);  
  8.     mReceiveFd = -1;  
  9.     return result;  
  10. }  

其实就是将其mReceiveFd描述符返回过去

 

通过这几步我们就可以在SensorEventConnection中发送数据,

ssize_tSensorEventQueue::write(const sp<BitTube>& tube,

        ASensorEvent const* events, size_tnumEvents) {

    return BitTube::sendObjects(tube, events,numEvents);

}

这里的tube参数就是我们第一步创建的

然后在SensorEventQueue读取数据

[cpp] 
  1. ssize_t SensorEventQueue::read(ASensorEvent* events, size_t numEvents)  
  2. {  
  3.     return BitTube::recvObjects(mSensorChannel, events, numEvents);  
  4. }  

这里的mSensorChannel就是我们上面第二步创建的。


上一篇:Android实战技术: 用Dimension解决多屏幕适配的问题
下一篇:Android混淆打包

关于作者

    白红宇是个全栈工程师,前端vue,小程序,app开发到后端框架设计,数据库设计,环境部署上线运维。

最新文章