Android開發(fā)藝術探索(2) --- IPC的點點滴滴

1. 多進程

開啟方式：

android:process = ":remote"
android:process="完整報包名"

2. 基本概念

2.1 AIDL

2.1.1 AIDL的基本概念

當客戶端發(fā)起請求時，當前線程會被掛起，所以如果一個遠程方法是很耗時的榨馁，那么不能在UI線程中發(fā)起此遠程請求；
服務端的Binder方法運行在Binder線程池中输钩，所以Binder方法不管是否耗時都應該采用同步的方法去實現(xiàn)
所有能在Binder中傳輸的類都需要實現(xiàn)IInterface這個類
內部Stub類就是Binder

2.1.2 實現(xiàn)AIDL的基本步驟

步驟1：創(chuàng)建服務端工程IPC_Server

步驟2：創(chuàng)建AIDL文件IMyService.AIDl

AIDL 創(chuàng)建

// IMyService.aidl
package com.example.ipc_server;

// Declare any non-default types here with import statements

interface IMyService {
    /**
     * Demonstrates some basic types that you can use as parameters
     * and return values in AIDL.
     */

    List<Student> getStudent();
    void addStudent(in Student student);
}

AIDL支持的數據類型：基本數據類型，String和Charsequence仲智，ArrayList买乃，HashMap，Parcelable坎藐，AIDL
注意：如果使用了Parcelable對象为牍，需要創(chuàng)建和對象同名的aidl文件
注意：除了基本數據類型，其他類型需要表明方向：in out inout
注意：aidl接口不支持靜態(tài)常量岩馍，只能寫方法

步驟3：Server端實現(xiàn)

package com.example.ipcdemo;

import android.app.Service;
import android.content.Intent;
import android.os.Binder;
import android.os.Handler;
import android.os.IBinder;
import android.os.Message;
import android.os.Messenger;
import android.os.RemoteException;
import android.util.Log;

import androidx.annotation.NonNull;

import java.util.ArrayList;
import java.util.List;

public class ServerService extends Service {

    private static final String TAG = "ServerService";

    public final static int MSG_FROM_CLIENT = 1;

    private Binder mBinder = new IBookInterface.Stub() {
        @Override
        public List<Book> getBook() throws RemoteException {
            // 具體代碼
            return null;
        }

        @Override
        public void addBook(Book book) throws RemoteException {
            //具體代碼
        }
    };
    public ServerService() {

    }

    @Override
    public IBinder onBind(Intent intent) {
        return mBinder;
    }


}

步驟4：Client端實現(xiàn)

package com.example.ipcdemo;

import androidx.appcompat.app.AppCompatActivity;

import android.content.ComponentName;
import android.content.Intent;
import android.content.ServiceConnection;
import android.os.Bundle;
import android.os.IBinder;
import android.os.Message;
import android.os.Messenger;
import android.os.RemoteException;
import android.view.View;
import android.widget.Button;

public class MainActivity extends AppCompatActivity {

    ServiceConnection connection = new ServiceConnection() {
        @Override
        public void onServiceConnected(ComponentName componentName, IBinder iBinder) {
            IBookInterface iBookInterface = IBookInterface.Stub.asInterface(iBinder); //轉化成aidl接口 IBookInterface.adil
            try {
                iBookInterface.addBook(new Book("大頭兒子與小頭爸爸", 10));
            } catch (RemoteException e) {
                e.printStackTrace();
            }
        }

        @Override
        public void onServiceDisconnected(ComponentName componentName) {

        }
    };

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        Button btn = findViewById(R.id.btn);
        final Intent intent = new Intent(this, ServerService.class);
        btn.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View view) {
                bindService(intent, connection, BIND_AUTO_CREATE);
            }
        });
    }
}

2.1.3 推薦閱讀

[Android]Service和Activity雙向通信的兩種方式
Android 通過AIDL在兩個APP之間Service通信
帶你了解android的IPC機制
AIDL碉咆，在Stub類中的asInterface函數

3. Android中的IPC方式

3.1 使用Bundle

四大組件中的Activity，Service蛀恩，Receiver都支持在Intent中傳遞Bundle
Bundle繼承了Parcelable接口疫铜，因此可以在不同的進程中傳遞數據

3.2 使用文件進行傳輸

利用序列化和反序列化操作將對象寫入文件并讀取
但是反序列化操作只能保證內容上是一樣的，本質上還是兩個對象
可能會產生并發(fā)讀寫問題

3.3 使用Messenger

使用串行的方式來處理消息双谆，大量消息時效率低

package com.example.ipcdemo;

import androidx.appcompat.app.AppCompatActivity;

import android.content.ComponentName;
import android.content.Intent;
import android.content.ServiceConnection;
import android.os.Bundle;
import android.os.IBinder;
import android.os.Message;
import android.os.Messenger;
import android.os.RemoteException;
import android.view.View;
import android.widget.Button;

public class MainActivity extends AppCompatActivity {

    Messenger mMessenger;

    ServiceConnection connection = new ServiceConnection() {
        @Override
        public void onServiceConnected(ComponentName componentName, IBinder iBinder) {
            mMessenger = new Messenger(iBinder);
            Message msg = new Message();
            msg.what = ServerService.MSG_FROM_CLIENT;
            Bundle bundle = new Bundle();
            bundle.putString("msg", "Hello!!!");
            msg.setData(bundle);
            try {
                mMessenger.send(msg);
            } catch (RemoteException e) {
                e.printStackTrace();
            }
        }

        @Override
        public void onServiceDisconnected(ComponentName componentName) {

        }
    };

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        Button btn = findViewById(R.id.btn);
        final Intent intent = new Intent(this, ServerService.class);
        btn.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View view) {
                bindService(intent, connection, BIND_AUTO_CREATE);
            }
        });
    }
}

package com.example.ipcdemo;

import android.app.Service;
import android.content.Intent;
import android.os.Handler;
import android.os.IBinder;
import android.os.Message;
import android.os.Messenger;
import android.util.Log;

import androidx.annotation.NonNull;

public class ServerService extends Service {

    private static final String TAG = "ServerService";

    public final static int MSG_FROM_CLIENT = 1;


    static class ServerHandler extends Handler {
        @Override
        public void handleMessage(@NonNull Message msg) {
            switch(msg.what) {
                case MSG_FROM_CLIENT:
                    Log.d(TAG, "handleMessage:  receive message from client!" + msg.getData().getString("msg"));
                    break;
            }
        }
    }

    public ServerService() {

    }

    @Override
    public IBinder onBind(Intent intent) {
        ServerHandler serverHandler = new ServerHandler();
        Messenger messenger = new Messenger(serverHandler);
        return messenger.getBinder();
    }


}

3.3 ContentProvider

抽象類壳咕，需要實現(xiàn)onCreate(),query,update,insert,delete,getType
注冊
繼承SQLiteDatabaseHelper，操作數據庫
注意：query,update,insert,delete存在并發(fā)訪問顽馋，因此要注意線程安全和同步
注意：SqliteDatabase對象內部操作數據庫有同步處理谓厘，但多個SqliteDatabase對象之間不能保證同步

3.4 Socket

實現(xiàn)步驟：

設置網絡權限
<INTERNET>
<ACCESS_NETWORK_STATE>

注意：不能在主線程訪問網絡

在服務端Server創(chuàng)建ServerSocket監(jiān)聽8688端口

BufferedReader 讀取客戶端數據
PrintWriter 給客戶端發(fā)送數據

在客戶端Client創(chuàng)建Socket連接8688端口

BufferedReader 讀取服務端數據
PrintWriter 給服務端發(fā)送數據

package com.example.socketdemo;

import androidx.appcompat.app.AppCompatActivity;

import android.content.Intent;
import android.os.Bundle;
import android.util.Log;

import java.io.IOException;
import java.io.PrintWriter;
import java.net.Socket;

public class ClientActivity extends AppCompatActivity {

    private static final String TAG = "ClientActivity";

    Socket socket = null;
    PrintWriter out = null;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_client);
        Intent intent = new Intent(this, Server.class);
        startService(intent);
        new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    socket = new Socket("localhost",8688);
                } catch (IOException e) {
                    e.printStackTrace();
                }
                while(true) {
                    try {
                        out = new PrintWriter(socket.getOutputStream());
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                    Log.d(TAG, "run: sendMessage ");
                    out.println("123");
                }
            }
        }).start();

    }
}

package com.example.socketdemo;

import android.app.Service;
import android.content.Intent;
import android.os.IBinder;
import android.util.Log;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Random;

public class Server extends Service {
    private static final String TAG = "Server";
    boolean mIsServiceDestroyed = false;

    public Server() {
    }

    @Override
    public void onCreate() {
        super.onCreate();
        new socketThread().start();

    }

    @Override
    public IBinder onBind(Intent intent) {
        // TODO: Return the communication channel to the service.
        throw new UnsupportedOperationException("Not yet implemented");
    }
    class socketThread extends Thread {
        @Override
        public void run() {
            ServerSocket serverSocket = null;
            try {
                serverSocket = new ServerSocket(8688);
            } catch (IOException e) {
                e.printStackTrace();
            }
            if(!mIsServiceDestroyed) {
                try {
                    final Socket client = serverSocket.accept();
                    new Thread(new Runnable() {
                        @Override
                        public 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 OutputStreamWriter(client.getOutputStream()));

        out.println("Hello");

        while(!mIsServiceDestroyed) {
            String str = in.readLine();
            Log.d(TAG, "responseClient: " +str);
            if(str == null) {
                break;
            }
            out.println("Hello " + new Random().nextInt(3));
        }

        Log.d(TAG, "Client Quit" );

        client.close();
    }

}

參考資料：
https://blog.csdn.net/ding3106/article/details/80714410

我的問題：Socket連接不上

網上的解決方法：
1.設置訪問的ip為10.0.2.2

模擬器默認把127.0.0.1和localhost當做本身了，在模擬器上可以用10.0.2.2代替127.0.0.1和localhost寸谜，另外如果是在局域網環(huán)境可以用 192.168.0.x或者192.168.1.x(根據具體配置)連接本機,這樣應該就不會報錯了竟稳。

目前這個辦法對我沒用

2. 網絡問題

可正常建立連接的：1，同處于一個校園網（使用狀態(tài)信息或者wifi信息里的ip連接）2. 服務器開熱點（移動網打開的情況下）熊痴，客戶端連狀態(tài)信息里面的ip

https://blog.csdn.net/qq_37735413/article/details/80012390
https://www.cnblogs.com/1995hxt/p/4469389.html

4. Binder連接池

?著作權歸作者所有,轉載或內容合作請聯(lián)系作者

人面猴
序言：七十年代末他爸，一起剝皮案震驚了整個濱河市，隨后出現(xiàn)的幾起案子果善，更是在濱河造成了極大的恐慌诊笤，老刑警劉巖，帶你破解...
沈念sama閱讀 217,277評論 6贊 503
死咒
序言：濱河連續(xù)發(fā)生了三起死亡事件巾陕，死亡現(xiàn)場離奇詭異讨跟，居然都是意外死亡纪他，警方通過查閱死者的電腦和手機，發(fā)現(xiàn)死者居然都...
沈念sama閱讀 92,689評論 3贊 393
救了他兩次的神仙讓他今天三更去死
文/潘曉璐我一進店門许赃，熙熙樓的掌柜王于貴愁眉苦臉地迎上來止喷，“玉大人馆类，你說我怎么就攤上這事混聊。” “怎么了乾巧？”我有些...
開封第一講書人閱讀 163,624評論 0贊 353
道士緝兇錄：失蹤的賣姜人
文/不壞的土叔我叫張陵句喜，是天一觀的道長。經常有香客問我沟于，道長咳胃，這世上最難降的妖魔是什么？我笑而不...
開封第一講書人閱讀 58,356評論 1贊 293
?港島之戀（遺憾婚禮）
正文為了忘掉前任旷太，我火速辦了婚禮展懈，結果婚禮上，老公的妹妹穿的比我還像新娘供璧。我一直安慰自己存崖，他們只是感情好，可當我...
茶點故事閱讀 67,402評論 6贊 392
惡毒庶女頂嫁案：這布局不是一般人想出來的
文/花漫我一把揭開白布睡毒。她就那樣靜靜地躺著来惧，像睡著了一般。火紅的嫁衣襯著肌膚如雪演顾。梳的紋絲不亂的頭發(fā)上供搀，一...
開封第一講書人閱讀 51,292評論 1贊 301
城市分裂傳說
那天，我揣著相機與錄音钠至，去河邊找鬼葛虐。笑死，一個胖子當著我的面吹牛棉钧，可吹牛的內容都是我干的屿脐。我是一名探鬼主播，決...
沈念sama閱讀 40,135評論 3贊 418
雙鴛鴦連環(huán)套：你想象不到人心有多黑
文/蒼蘭香墨我猛地睜開眼掰盘，長吁一口氣：“原來是場噩夢啊……” “哼摄悯！你這毒婦竟也來了？” 一聲冷哼從身側響起愧捕，我...
開封第一講書人閱讀 38,992評論 0贊 275
萬榮殺人案實錄
序言：老撾萬榮一對情侶失蹤奢驯，失蹤者是張志新（化名）和其女友劉穎，沒想到半個月后次绘，有當地人在樹林里發(fā)現(xiàn)了一具尸體瘪阁，經...
沈念sama閱讀 45,429評論 1贊 314
?護林員之死
正文獨居荒郊野嶺守林人離奇死亡撒遣，尸身上長有42處帶血的膿包…… 初始之章·張勛以下內容為張勛視角年9月15日...
茶點故事閱讀 37,636評論 3贊 334
?白月光啟示錄
正文我和宋清朗相戀三年，在試婚紗的時候發(fā)現(xiàn)自己被綠了管跺。大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片义黎。...
茶點故事閱讀 39,785評論 1贊 348
活死人
序言：一個原本活蹦亂跳的男人離奇死亡，死狀恐怖豁跑，靈堂內的尸體忽然破棺而出廉涕，到底是詐尸還是另有隱情，我是刑警寧澤艇拍，帶...
沈念sama閱讀 35,492評論 5贊 345
?日本核電站爆炸內幕
正文年R本政府宣布狐蜕，位于F島的核電站，受9級特大地震影響卸夕，放射性物質發(fā)生泄漏层释。R本人自食惡果不足惜，卻給世界環(huán)境...
茶點故事閱讀 41,092評論 3贊 328
男人毒藥：我在死后第九天來索命
文/蒙蒙一快集、第九天我趴在偏房一處隱蔽的房頂上張望贡羔。院中可真熱鬧，春花似錦个初、人聲如沸乖寒。這莊子的主人今日做“春日...
開封第一講書人閱讀 31,723評論 0贊 22
一樁弒父案勃黍，背后竟有這般陰謀
文/蒼蘭香墨我抬頭看了看天上的太陽宵统。三九已至，卻和暖如春覆获，著一層夾襖步出監(jiān)牢的瞬間马澈，已是汗流浹背。一陣腳步聲響...
開封第一講書人閱讀 32,858評論 1贊 269
情欲美人皮
我被黑心中介騙來泰國打工弄息，沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留痊班，地道東北人。一個月前我還...
沈念sama閱讀 47,891評論 2贊 370
代替公主和親
正文我出身青樓摹量，卻偏偏與公主長得像涤伐，于是被迫代替她去往敵國和親。傳聞我的和親對象是個殘疾皇子缨称，可洞房花燭夜當晚...
茶點故事閱讀 44,713評論 2贊 354