Android使用文件进行IPC

2024-08-01 18:58:17

一、文件进行IPC介绍

共享文件也是一种不错的进程间通信方式，两个进程通过读/写同一个文件来交换数据。在Windows上，一个文件如果被加了排斥锁将会导致其他线程无法对其进行访问，包括读写，而由于Android系统基于Linux，使其并发读/写文件可以没有限制地进行，甚至两个线程同时对同一个文件进行读写操作是允许的，尽管这可能出现问题。通过文件交换数据很好使用，除了可以交换一些文本信息外，还可以序列化一个对象到文件系统中的同时从另一个进程中恢复这个对象。

二、使用方法

1.数据类实现Parcelable或Serializable接口

public class User implements Parcelable, Serializable {
public User() {
  }

  public User(int userId, String userName, boolean isMale) {
    ...
  }

  @Override
  public int describeContents() {
    return 0;
  }

  @Override
  public void writeToParcel(Parcel dest, int flags) {
    ...
  }

  public static final Parcelable.Creator<User> CREATOR = new Parcelable.Creator<User>() {
    @Override
    public User createFromParcel(Parcel source) {
      return ...;
    }

    @Override
    public User[] newArray(int size) {
      return ...;
    }
  };

  private User(Parcel in) {
    ...
  }

  @Override
  public String toString() {
    return ...;
  }
}

2.序列化一个对象到sd卡上的一个文件里

private void persistToFile() {
    new Thread(new Runnable() {
      @Override
      public void run() {
        User user = new User(1, "hello world", false);
        File dir = new File(MyConstants.CHAPTER_2_PATH);
        if (!dir.exists()) {
          dir.mkdirs();
        }
        File cachedFile = new File(MyConstants.CACHE_FILE_PATH);
        ObjectOutputStream objectOutputStream = null;
        try {
          objectOutputStream = new ObjectOutputStream(new FileOutputStream(cachedFile));
          objectOutputStream.writeObject(user);
          Log.d(TAG, "persist user:" + user);
          mTextView.setText("persist user:" + user);
        } catch (IOException e) {
          e.printStackTrace();
        } finally {
          MyUtils.close(objectOutputStream);
        }
      }
    }).start();
  }

3.在另外的进程中反序列化

private void recoverFromFile(){
    new Thread(new Runnable() {
      @Override
      public void run() {
        User user = null;
        File cachedFile = new File(MyConstants.CACHE_FILE_PATH);
        if(cachedFile.exists()){
          ObjectInputStream objectInputStream = null;
          try{
            objectInputStream = new ObjectInputStream(new FileInputStream(cachedFile));
            user = (User)objectInputStream.readObject();
            Log.d(TAG,"recover user:"+user);
            mTextView.setText("recover user:"+user);
          }catch (IOException e) {
            e.printStackTrace();
          }catch (ClassNotFoundException e){
            e.printStackTrace();
          }finally {
            MyUtils.close(objectInputStream);
          }
        }
      }
    }).start();
  }

4.在AndroidManifest.xml中开启多进程

   <activity
      ...
      android:process=":remote" />

三、小案例

1.修改activity_main.xml文件

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout
  xmlns:android="http://schemas.android.com/apk/res/android"
  xmlns:tools="http://schemas.android.com/tools"
  android:layout_width="match_parent"
  android:layout_height="match_parent"
  android:fitsSystemWindows="true"
  tools:context="com.zhangmiao.ipcdemo.MainActivity"
  android:orientation="vertical"
  >
  <TextView
    android:layout_width="wrap_content"
    android:layout_height="wrap_content"
    android:layout_gravity="center_horizontal"
    android:text="File">
  </TextView>
  <Button
    android:id="@+id/button1"
    android:layout_width="wrap_content"
    android:layout_height="wrap_content"
    android:text="open activity B"
    />

  <TextView
    android:id="@+id/textView1"
    android:layout_width="wrap_content"
    android:layout_height="wrap_content"
    android:text="A">
  </TextView>
</LinearLayout>

2.添加activity_second.xml文件

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout
  xmlns:android="http://schemas.android.com/apk/res/android"
  android:orientation="vertical"
  android:layout_width="match_parent"
  android:layout_height="match_parent">

  <TextView
    android:layout_width="wrap_content"
    android:layout_height="wrap_content"
    android:text="at activity B"
    android:layout_gravity="center_horizontal"
    />
  <TextView
    android:id="@+id/textView1"
    android:layout_width="wrap_content"
    android:layout_height="wrap_content"
    android:text="Activity B"
    />
</LinearLayout>

3.添加MyUtils类与MyConstants类（辅助类）

package com.zhangmiao.ipcdemo;

import android.app.ActivityManager;
import android.content.Context;

import java.io.Closeable;
import java.io.IOException;
import java.util.List;
import java.util.concurrent.RecursiveTask;

/**
 * Created by zhangmiao on 2016/12/26.
 */
public class MyUtils {
  public static void close(Closeable closeable) {
    try {
      if (closeable != null) {
        closeable.close();
      }
    } catch (IOException e) {
      e.printStackTrace();
    }
  }
}

package com.zhangmiao.ipcdemo;

import android.os.Environment;

/**
 * Created by zhangmiao on 2016/12/26.
 */
public class MyConstants {
  public static final String CHAPTER_2_PATH = Environment.getExternalStorageDirectory().getPath() + "/zhangmiao/charpter_2/";
  public static final String CACHE_FILE_PATH = CHAPTER_2_PATH + "usercache";

  public static final int MSG_FROM_CLIENT = 0;
  public static final int MSG_FROM_SERVICE = 1;
}

4.添加User类

package com.zhangmiao.ipcdemo;

import android.os.Parcel;
import android.os.Parcelable;

import java.io.Serializable;

/**
 * Created by zhangmiao on 2016/12/26.
 */
public class User implements Parcelable, Serializable {

  public static int sUserId = 1;

  private int userId;
  private String userName;
  private Boolean isMale;

  public User() {
  }

  public User(int userId, String userName, boolean isMale) {
    this.userId = userId;
    this.userName = userName;
    this.isMale = isMale;
  }

  @Override
  public int describeContents() {
    return 0;
  }

  @Override
  public void writeToParcel(Parcel dest, int flags) {
    dest.writeInt(userId);
    dest.writeString(userName);
    dest.writeInt(isMale ? 1 : 0);
  }

  public static final Parcelable.Creator<User> CREATOR = new Parcelable.Creator<User>() {
    @Override
    public User createFromParcel(Parcel source) {
      return new User(source);
    }

    @Override
    public User[] newArray(int size) {
      return new User[size];
    }
  };

  private User(Parcel in) {
    userId = in.readInt();
    userName = in.readString();
    isMale = in.readInt() == 1;
  }

  @Override
  public String toString() {
    return String.format(
        "User:{userId:%s, userName:%s, isMale:%s},",userId, userName, isMale
    );
  }
}

5.添加SecondActivity类

package com.zhangmiao.ipcdemo;

import android.app.Activity;
import android.os.Bundle;
import android.util.Log;
import android.widget.TextView;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.ObjectInputStream;

/**
 * Created by zhangmiao on 2016/12/26.
 */
public class SecondActivity extends Activity {

  private static final String TAG = "SecondActivity";

  private TextView mTextView;

  @Override
  protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_second);
    Log.d(TAG, "onCreate");
    mTextView = (TextView)findViewById(R.id.textView1);
  }

  @Override
  protected void onResume() {
    Log.d(TAG,"onResume");
    super.onResume();
    User user = (User)getIntent().getSerializableExtra("extra_user");
    Log.d(TAG,"user:"+user.toString());
    recoverFromFile();
  }

  private void recoverFromFile(){
    new Thread(new Runnable() {
      @Override
      public void run() {
        User user = null;
        File cachedFile = new File(MyConstants.CACHE_FILE_PATH);
        if(cachedFile.exists()){
          ObjectInputStream objectInputStream = null;
          try{
            objectInputStream = new ObjectInputStream(new FileInputStream(cachedFile));
            user = (User)objectInputStream.readObject();
            Log.d(TAG,"recover user:"+user);
            mTextView.setText("recover user:"+user);
          }catch (IOException e) {
            e.printStackTrace();
          }catch (ClassNotFoundException e){
            e.printStackTrace();
          }finally {
            MyUtils.close(objectInputStream);
          }
        }
      }
    }).start();
  }
}

6.修改MainActivity类

package com.zhangmiao.ipcdemo;

import android.content.ComponentName;
import android.content.Context;
import android.content.Intent;
import android.content.ServiceConnection;
import android.os.Bundle;
import android.os.Handler;
import android.os.IBinder;
import android.os.Message;
import android.os.Messenger;
import android.os.RemoteException;
import android.support.v7.app.AppCompatActivity;
import android.util.Log;
import android.view.View;
import android.widget.Button;
import android.widget.TextView;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.ObjectOutputStream;
import java.io.Serializable;

public class MainActivity extends AppCompatActivity {

  private static final String TAG = "MainActivity";
  private TextView mTextView;

  @Override
  protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main);
    User.sUserId = 2;
    findViewById(R.id.button1).setOnClickListener(new View.OnClickListener() {
      @Override
      public void onClick(View v) {
        Intent intent = new Intent();
        intent.setClass(MainActivity.this, SecondActivity.class);
        User user = new User(0, "jake", true);
        intent.putExtra("extra_user", (Serializable) user);
        startActivity(intent);
      }
    });
    mTextView = (TextView) findViewById(R.id.textView1);
  }

  @Override
  protected void onResume() {
    super.onResume();
    Log.d(TAG, "UserManager.sUserId=" + User.sUserId);
    super.onStart();
    persistToFile();
  }

  private void persistToFile() {
    new Thread(new Runnable() {
      @Override
      public void run() {
        User user = new User(1, "hello world", false);
        File dir = new File(MyConstants.CHAPTER_2_PATH);
        if (!dir.exists()) {
          dir.mkdirs();
        }
        File cachedFile = new File(MyConstants.CACHE_FILE_PATH);
        ObjectOutputStream objectOutputStream = null;
        try {
          objectOutputStream = new ObjectOutputStream(new FileOutputStream(cachedFile));
          objectOutputStream.writeObject(user);
          Log.d(TAG, "persist user:" + user);
          mTextView.setText("persist user:" + user);
        } catch (IOException e) {
          e.printStackTrace();
        } finally {
          MyUtils.close(objectOutputStream);
        }
      }
    }).start();
  }
}

7.修改AndroidManifest.xml文件

<?xml version="1.0" encoding="utf-8"?>
<manifest
  xmlns:android="http://schemas.android.com/apk/res/android"
  package="com.zhangmiao.ipcdemo">

  <uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE" />

  <application
    android:allowBackup="true"
    android:icon="@mipmap/ic_launcher"
    android:label="@string/app_name"
    android:supportsRtl="true"
    android:theme="@style/AppTheme">
    <activity
      android:name=".MainActivity"
      android:label="@string/app_name"
      android:launchMode="standard"
      android:theme="@style/AppTheme.NoActionBar">
      <intent-filter>
        <action android:name="android.intent.action.MAIN" />
        <category android:name="android.intent.category.LAUNCHER" />
      </intent-filter>
    </activity>
    <activity
      android:name=".SecondActivity"
      android:configChanges="screenLayout"
      android:label="@string/app_name"
      android:process=":remote" />
  </application>
</manifest>

完整代码下载地址：https://github.com/ZhangMiao147/IPCDemo

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我们。

Android系统进程间通信（IPC）机制Binder中的Server启动过程源代码分析

在前面一篇文章Android系统进程间通信(IPC)机制Binder中的Server和Client获得Service Manager接口之路中,介绍了在Android系统中Binder进程间通信机制中的Server角色是如何获得Service Manager远程接口的,即defaultServiceManager函数的实现.Server获得了Service Manager远程接口之后,就要把自己的Service添加到Service Manager中去,然后把自己启动起来,等待Client的请求.
Android IPC机制利用Messenger实现跨进程通信

写作原因:跨进程通信的实现和理解是Android进阶中重要的一环.下面博主分享IPC一些相关知识.操作及自己在学习IPC过程中的一些理解.这一章使用Messenger实现跨进程通信,其中bindService基础部分参见Android IPC机制绑定Service实现本地通信. 跨进程简介在介绍使用Messenger跨进程通信之前先要了解以下问题:为什么需要跨进程通信?只有有了需求才有学习的价值.我个人将不同进程简单的理解为不同的应用程序(当然也有例外,比如可以在同一个应用程序中开启两个或多个
Android系统进程间通信（IPC）机制Binder中的Client获得Server远程接口过程源代码分析

在上一篇文章中,我们分析了Android系统进程间通信机制Binder中的Server在启动过程使用Service Manager的addService接口把自己添加到Service Manager守护过程中接受管理.在这一篇文章中,我们将深入到Binder驱动程序源代码去分析Client是如何通过Service Manager的getService接口中来获得Server远程接口的.Client只有获得了Server的远程接口之后,才能进一步调用Server提供的服务. 这里,我们仍然是通过A
Android系统进程间通信（IPC）机制Binder中的Server和Client获得Service Manager接口之路

在前面一篇文章浅谈Service Manager成为Android进程间通信(IPC)机制Binder守护进程之路中,介绍了Service Manager是如何成为Binder机制的守护进程的.既然作为守护进程,Service Manager的职责当然就是为Server和Client服务了.那么,Server和Client如何获得Service Manager接口,进而享受它提供的服务呢?本文将简要分析Server和Client获得Service Manager的过程. 在阅读本文之前,希望读者
浅谈Service Manager成为Android进程间通信（IPC）机制Binder守护进程之路

上一篇文章Android进程间通信(IPC)机制Binder简要介绍和学习计划简要介绍了Android系统进程间通信机制Binder的总体架构,它由Client.Server.Service Manager和驱动程序Binder四个组件构成.本文着重介绍组件Service Manager,它是整个Binder机制的守护进程,用来管理开发者创建的各种Server,并且向Client提供查询Server远程接口的功能. 既然Service Manager组件是用来管理Server并且向Client提
开放IPC$共享

首先,我们先认识一下什么是IPC$ IPC$(Internet Process Connection)是共享"命名管道"的资源,它是为了让进程间通信而开放的命名管道,通过提供可信任的用户名和口令,连接双方可以建立安全的通道并以此通道进行加密数据的交换,从而实现对远程计算机的访问.IPC$是NT/2000的一项新功能,它有一个特点,即在同一时间内,两个IP之间只允许建立一个连接.NT/2000在提供了ipc$功能的同时,在初次安装系统时还打开了默认共享,即所有的逻辑共享(c$,d$,e$
Android IPC进程间通信详解最新AndroidStudio的AIDL操作)

前言前面梳理了Android的线程间的通信<Thread.Handler和HandlerThread关系何在?> ,这些都是在同一个进程中,那进程间的通信,或者说不同的应用间的通信该如何实现呢?这个时候就要用到AIDL(Android Interface Definition LanguageAndroid接口定义语言 ). 使用方法(AndroidStudio) 我发现现在AIDL的教程基本上还是eclipse的,但是在AndroidStudio里面使用AIDL还是有一些不同的,来看看怎么
Android进程间通信（IPC）机制Binder简要介绍

在Android系统中,每一个应用程序都是由一些Activity和Service组成的,这些Activity和Service有可能运行在同一个进程中,也有可能运行在不同的进程中.那么,不在同一个进程的Activity或者Service是如何通信的呢?这就是本文中要介绍的Binder进程间通信机制了. 我们知道,Android系统是基于Linux内核的,而Linux内核继承和兼容了丰富的Unix系统进程间通信(IPC)机制.有传统的管道(Pipe).信号(Signal)和跟踪(Trace),这三项
Android IPC机制绑定Service实现本地通信

**写作原因:跨进程通信的实现和理解是Android进阶中重要的一环.下面博主分享IPC一些相关知识.操作及自己在学习IPC过程中的一些理解. 这一章是为下面的Messenger和AIDL的使用做准备,主要讲解Android Service的绑定和Activity与本地Service之间通信相关知识.** 简介我们都知道启动Service有两种方式:startService()和bindService().相比第一种方式,bindService()能够更加灵活地实现与启动端Activity的数
android IPC之binder通信机制

Binder通信机制说来简单,但是在使用的过程的遇到了一些问题,最后终于解决了,在这总结一下,一并分享给大家: 1.要使用Binder通信,首先要定义接口,然后实现服务端BnInterface***和客户端BpInterface***,说到底一个是把参数解包,一个是把参数打包. 2.服务端要能够接收Binder调用请求,要具备两个条件:一个是实现Bn接口,另一个是调用IPCProcess()->self->startThreadPool() IPCThread()->Self->j

Android使用文件进行IPC

相关推荐

随机推荐