IPC机制(三)--ContentProvider、Socket和Binder池

2024-05-09 23:33
文章标签 机制 ipc socket binder contentprovider

本文主要是介绍IPC机制(三)--ContentProvider、Socket和Binder池，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

1.ContentProvider

ContentProvider的底层实现是基于Binder，系统为我们做了深度的封装，让我们使用起来非常容易。

// 第一步
// 实现一个内容提供者，每个CURD方法中实现对数据的提供，可以是大多是从数据库加载数据
public class BookProvider extends ContentProvider {private static final String AUTHORITY = "com.gacrnd.gcs.ipc.BookProvider";public static final Uri BOOK_CONTENT_URI = Uri.parse("content://" + AUTHORITY + "/book");public static final Uri USER_CONTENT_URI = Uri.parse("content://" + AUTHORITY + "/user");public static final int BOOK_URI_CODE = 0;public static final int USER_URI_CODE = 1;private Context mContext;private SQLiteDatabase mDatabase;private static final UriMatcher sUriMatcher = new UriMatcher(UriMatcher.NO_MATCH);static {sUriMatcher.addURI(AUTHORITY,"book",BOOK_URI_CODE);sUriMatcher.addURI(AUTHORITY,"user",USER_URI_CODE);}// 通过uri获取表名private String getTableName(Uri uri) {String tableName = null;switch (sUriMatcher.match(uri)) {case BOOK_URI_CODE:tableName = DbOpenHelper.BOOK_TABLE_NAME;break;case USER_URI_CODE:tableName = DbOpenHelper.USER_TABLE_NAME;break;default:break;}return tableName;}@Overridepublic boolean onCreate() {mContext = getContext();//以下应该在子线程中加载数据库initDatabase();return true;}// 初始化数据库private void initDatabase() {mDatabase = new DbOpenHelper(mContext).getWritableDatabase();mDatabase.execSQL("DELETE FROM " + DbOpenHelper.BOOK_TABLE_NAME);mDatabase.execSQL("DELETE FROM " + DbOpenHelper.USER_TABLE_NAME);mDatabase.execSQL("INSERT INTO book VALUES(1,'ANDROID 1');");mDatabase.execSQL("INSERT INTO book VALUES(2,'ANDROID 2');");mDatabase.execSQL("INSERT INTO book VALUES(3,'ANDROID 3');");mDatabase.execSQL("INSERT INTO user VALUES(1,'JackOu',0);");mDatabase.execSQL("INSERT INTO user VALUES(2,'DY',1);");}@Overridepublic Cursor query(Uri uri, String[] projection, String selection, String[] selectionArgs, String sortOrder) {Log.i("JackOu","query:" + Thread.currentThread().getName());String tableName = getTableName(uri);if (tableName == null) {throw new IllegalArgumentException("uri illegal！");}return mDatabase.query(tableName,projection,selection,selectionArgs,null,sortOrder,null);}......//需要基于数据库实现对应的CURD操作
}

// 第二步 在manifest中声明该Provider
<providerandroid:authorities="com.gacrnd.gcs.ipc.BookProvider"android:name=".BookProvider"android:permission="com.gacrnd.gcs.PROVIDER"android:process=":provider"/>

// 第三步
public class DbOpenHelper extends SQLiteOpenHelper {private static final String DB_NAME = "book_provider.db";public static final String BOOK_TABLE_NAME = "book";public static final String USER_TABLE_NAME = "user";private String CREATE_BOOK_TABLE = "CREATE TABLE IF NOT EXISTS " + BOOK_TABLE_NAME+ "(_id INTEGER PRIMARY KEY, name TEXT)";private String CREATE_USER_TABLE = "CREATE TABLE IF NOT EXISTS " + USER_TABLE_NAME+ "(_id INTEGER PRIMARY KEY, name TEXT, sex INT)";private static final int DB_VERSION = 1;public DbOpenHelper(Context context) {super(context, DB_NAME, null, DB_VERSION);}@Overridepublic void onCreate(SQLiteDatabase db) {db.execSQL(CREATE_BOOK_TABLE);db.execSQL(CREATE_USER_TABLE);}@Overridepublic void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {// 忽略数据库版本升级}
}

// 第四步在需要使用的地方获取数据即可
Uri uri = Uri.parse("content://com.gacrnd.gcs.ipc.BookProvider");
getContentResolver().query(uri,null,null,null,null); // 写两个主要是想打印工作线程信息
getContentResolver().query(uri,null,null,null,null);

2. Socket

Socket称为“套接字”，是网络通信中的概念，分为流式套接字和用户数据报套接字两种，分别对应网络传输控制层的TCP和UDP协议。TCP协议是面向连接的协议，提供稳定的双向通信功能，TCP连接的建立需要经过“三次握手”才能完成，为了提供稳定的数据传输功能，其本身提供了超时重传机制，因此具有很高的稳定性。而UDP是无连接的，提供不稳定的单向/双向通信功能，在性能上，UDP协议不需要握手和挥手，效率会更高

2.1 Socket服务端
public class TCPServerService extends Service {private boolean mDestory = false;@Overridepublic IBinder onBind(Intent intent) {return null;}@Overridepublic void onCreate() {// 正常应该用一个线程池来处理客户端来的请求的，但是作为demo，就暴力的新开一个线程处理new Thread(new TcpServer()).start();super.onCreate();}private class TcpServer implements Runnable {@Overridepublic void run() {ServerSocket serverSocket = null;try {serverSocket = new ServerSocket(10000);} catch (IOException e) {e.printStackTrace();return;}// 死循环处理客户端的请求while (!mDestory) {try {// 接收客户端final Socket client = serverSocket.accept();new Thread() {@Overridepublic void run() {try {//处理客户端发来的内容并且回复客户端responseClient(client);} catch (IOException e) {e.printStackTrace();}}}.start();} catch (IOException e) {e.printStackTrace();}}}}private void responseClient(Socket client) throws IOException{//接收客户端的消息BufferedReader in = new BufferedReader(new InputStreamReader(client.getInputStream()));//发送数据到客户端PrintWriter out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(client.getOutputStream())));while (!mDestory) {String fromClient = in.readLine();System.out.println("msg from client:" + fromClient);if (fromClient == null) {//客户端断开，直接返回break;}out.println("收到你的消息");}//交流完毕in.close();out.close();client.close();}@Overridepublic void onDestroy() {mDestory = true;super.onDestroy();}
}
2.2 Socket客户端
//很粗暴的连接服务端，接收并且发送，主要是演示socket通信过程
private void connectServerSocket() {PrintWriter pw = null;BufferedReader br= null;Socket socket = null;try {while (!mDestory) {socket = new Socket("localhost",10000);pw = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);pw.println("client send msg");br = new BufferedReader(new InputStreamReader(socket.getInputStream()));System.out.println("receive from server:" + br.readLine());}pw.close();br.close();socket.close();} catch (IOException e) {e.printStackTrace();}
}
3. Binder池

由于项目业务逻辑越来越服务，需要和多个AIDL交互，如果一个一个绑定，调用，这样显得比较麻烦，所以就有了Binder池的概念出来。所有要请求服务端都放在Binder池中，客户端通过Binder池拿到自己需要服务的客户端。

Binder池.png

3.1 binder池服务端
public class BinderPoolService extends Service {private Binder mBinderPool = new BinderPoolImpl();@Overridepublic IBinder onBind(Intent intent) {return mBinderPool;}
}public class BinderPoolImpl extends IBinderPool.Stub {private static final int SECURITY_SERVICE_PROXY = 0;private static final int COMPUTE_SERVICE_PROXY = 1;public BinderPoolImpl() {super();}@Overridepublic IBinder queryBinder(int binderCode) throws RemoteException {IBinder binder = null;switch (binderCode) {case SECURITY_SERVICE_PROXY:// 此处用伪代码实现，返回SecurityCenterImpl，他继承ISecurityCenter.Stub()，实现了对应接口//binder = new SecurityCenterImpl();break;case COMPUTE_SERVICE_PROXY://binder = new ComputerImpl();break;default:break;}return binder;}
}
3.2 Binder池客户端
public class BinderPool {private static volatile BinderPool sInstance = null;private IBinderPool mBinderPool = null;// 用于等待连接BinderPool，如果没有连接就一直阻塞等待private CountDownLatch mCountDownLatch;private ServiceConnection mServiceConnection = new BinderPoolServiceConnection();private IBinder.DeathRecipient mDeathRecipient = new BinderPoolDeathRecipient();private Context mContext;public BinderPool(Context context) {this.mContext = context.getApplicationContext();connectBinderPoolService();}public static BinderPool getInstance(Context context) {if (sInstance == null) {synchronized (BinderPool.class) {if (sInstance == null) {sInstance = new BinderPool(context);}}}return sInstance;}private synchronized void connectBinderPoolService() {mCountDownLatch = new CountDownLatch(1);Intent intent = new Intent(mContext, BinderPoolService.class);mContext.bindService(intent, mServiceConnection, Context.BIND_AUTO_CREATE);try {mCountDownLatch.await();} catch (InterruptedException e) {e.printStackTrace();}}/*** 查询binder接口*/public IBinder queryBinder(int binderCode) {IBinder binder = null;if (mBinderPool != null) {try {// 从Binder服务端查询需要的接口binder = mBinderPool.queryBinder(binderCode);} catch (RemoteException e) {e.printStackTrace();}}return binder;}private class BinderPoolServiceConnection implements ServiceConnection {@Overridepublic void onServiceConnected(ComponentName name, IBinder service) {mBinderPool = IBinderPool.Stub.asInterface(service);try {mBinderPool.asBinder().linkToDeath(mDeathRecipient, 0);} catch (RemoteException e) {e.printStackTrace();}//绑定成功，释放线程继续执行mCountDownLatch.countDown();}@Overridepublic void onServiceDisconnected(ComponentName name) {}}private class BinderPoolDeathRecipient implements IBinder.DeathRecipient {@Overridepublic void binderDied() {mBinderPool.asBinder().unlinkToDeath(mDeathRecipient, 0);mBinderPool = null;connectBinderPoolService();}}
}

这篇关于IPC机制(三)--ContentProvider、Socket和Binder池的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/974800。

相关文章

JVM 的类初始化机制

JVM 的类初始化机制

前言 当你在 Java 程序中new对象时，有没有考虑过 JVM 是如何把静态的字节码（byte code）转化为运行时对象的呢，这个问题看似简单，但清楚的同学相信也不会太多，这篇文章首先介绍 JVM 类初始化的机制，然后给出几个易出错的实例来分析，帮助大家更好理解这个知识点。 JVM 将字节码转化为运行时对象分为三个阶段，分别是：loading 、Linking、initialization
阅读更多...
Java ArrayList扩容机制 （源码解读）

Java ArrayList扩容机制 （源码解读）

结论：初始长度为10，若所需长度小于1.5倍原长度，则按照1.5倍扩容。若不够用则按照所需长度扩容。 一. 明确类内部重要变量含义         1：数组默认长度         2:这是一个共享的空数组实例，用于明确创建长度为0时的ArrayList ，比如通过 new ArrayList<>(0)，ArrayList 内部的数组 elementData 会指向这个 EMPTY_EL
阅读更多...
【编程底层思考】垃圾收集机制，GC算法，垃圾收集器类型概述

【编程底层思考】垃圾收集机制，GC算法，垃圾收集器类型概述

Java的垃圾收集（Garbage Collection，GC）机制是Java语言的一大特色，它负责自动管理内存的回收，释放不再使用的对象所占用的内存。以下是对Java垃圾收集机制的详细介绍： 一、垃圾收集机制概述： 对象存活判断：垃圾收集器定期检查堆内存中的对象，判断哪些对象是“垃圾”，即不再被任何引用链直接或间接引用的对象。内存回收：将判断为垃圾的对象占用的内存进行回收，以便重新使用。
阅读更多...
【Tools】大模型中的自注意力机制

【Tools】大模型中的自注意力机制

摇来摇去摇碎点点的金黄 伸手牵来一片梦的霞光 南方的小巷推开多情的门窗 年轻和我们歌唱 摇来摇去摇着温柔的阳光 轻轻托起一件梦的衣裳 古老的都市每天都改变模样                      🎵 方芳《摇太阳》 自注意力机制（Self-Attention）是一种在Transformer等大模型中经常使用的注意力机制。该机制通过对输入序列中的每个元素计算与其他元素之间的相似性，
阅读更多...
如何通俗理解注意力机制？

如何通俗理解注意力机制？

1、注意力机制（Attention Mechanism）是机器学习和深度学习中一种模拟人类注意力的方法，用于提高模型在处理大量信息时的效率和效果。通俗地理解，它就像是在一堆信息中找到最重要的部分，把注意力集中在这些关键点上，从而更好地完成任务。以下是几个简单的比喻来帮助理解注意力机制： 2、寻找重点：想象一下，你在阅读一篇文章的时候，有些段落特别重要，你会特别注意这些段落，反复阅读，而对其他部分
阅读更多...
【Tools】大模型中的注意力机制

【Tools】大模型中的注意力机制

摇来摇去摇碎点点的金黄 伸手牵来一片梦的霞光 南方的小巷推开多情的门窗 年轻和我们歌唱 摇来摇去摇着温柔的阳光 轻轻托起一件梦的衣裳 古老的都市每天都改变模样                      🎵 方芳《摇太阳》 在大模型中，注意力机制是一种重要的技术，它被广泛应用于自然语言处理领域，特别是在机器翻译和语言模型中。 注意力机制的基本思想是通过计算输入序列中各个位置的权重，以确
阅读更多...
FreeRTOS内部机制学习03（事件组内部机制）

FreeRTOS内部机制学习03（事件组内部机制）

文章目录 事件组使用的场景事件组的核心以及Set事件API做的事情事件组的特殊之处事件组为什么不关闭中断xEventGroupSetBitsFromISR内部是怎么做的？ 事件组使用的场景 学校组织秋游，组长在等待： 张三：我到了 李四：我到了 王五：我到了 组长说：好，大家都到齐了，出发！ 秋游回来第二天就要提交一篇心得报告，组长在焦急等待：张三、李四、王五谁先写好就交谁的
阅读更多...
UVM：callback机制的意义和用法

UVM：callback机制的意义和用法

1. 作用         Callback机制在UVM验证平台，最大用处就是为了提高验证平台的可重用性。在不创建复杂的OOP层次结构前提下，针对组件中的某些行为，在其之前后之后，内置一些函数，增加或者修改UVM组件的操作，增加新的功能，从而实现一个环境多个用例。此外还可以通过Callback机制构建异常的测试用例。 2. 使用步骤         （1）在UVM组件中内嵌callback函
阅读更多...
Smarty模板引擎工作机制(一)

Smarty模板引擎工作机制(一)

深入浅出Smarty模板引擎工作机制，我们将对比使用smarty模板引擎和没使用smarty模板引擎的两种开发方式的区别，并动手开发一个自己的模板引擎，以便加深对smarty模板引擎工作机制的理解。 在没有使用Smarty模板引擎的情况下，我们都是将PHP程序和网页模板合在一起编辑的，好比下面的源代码： <?php$title="深处浅出之Smarty模板引擎工作机制";$content=
阅读更多...
Redis的rehash机制

Redis的rehash机制

在Redis中，键值对（Key-Value Pair）存储方式是由字典（Dict）保存的，而字典底层是通过哈希表来实现的。通过哈希表中的节点保存字典中的键值对。我们知道当HashMap中由于Hash冲突（负载因子）超过某个阈值时，出于链表性能的考虑，会进行Resize的操作。Redis也一样。 在redis的具体实现中，使用了一种叫做渐进式哈希(rehashing)的机制来提高字典的缩放效率，避
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2