Android IPC機制（五）用Socket實現跨進程聊天程式

来源:https://www.cnblogs.com/ganchuanpu/archive/2018/07/10/9288014.html
-Advertisement-
Play Games

1.Socket簡介 Socket也稱作“套接字“，是在應用層和傳輸層之間的一個抽象層，它把TCP/IP層複雜的操作抽象為幾個簡單的介面供應用層調用以實現進程在網路中通信。它分為流式套接字和數據包套接字，分別對應網路傳輸控制層的TCP和UDP協議。TCP協議是一種面向連接的、可靠的、基於位元組流的傳輸 ...


1.Socket簡介

Socket也稱作“套接字“，是在應用層和傳輸層之間的一個抽象層，它把TCP/IP層複雜的操作抽象為幾個簡單的介面供應用層調用以實現進程在網路中通信。它分為流式套接字和數據包套接字，分別對應網路傳輸控制層的TCP和UDP協議。TCP協議是一種面向連接的、可靠的、基於位元組流的傳輸層通信協議。它使用三次握手協議建立連接，並且提供了超時重傳機制，具有很高的穩定性。UDP協議則是是一種無連接的協議，且不對傳送數據包進行可靠性保證，適合於一次傳輸少量數據，UDP傳輸的可靠性由應用層負責。在網路質量令人十分不滿意的環境下，UDP協議數據包丟失會比較嚴重。但是由於UDP的特性：它不屬於連接型協議，因而具有資源消耗小，處理速度快的優點，所以通常音頻、視頻和普通數據在傳送時使用UDP較多。 
這裡寫圖片描述

從上圖我們也可以看出，不同的用戶進程通過Socket來進行通信，所以Socket也是一種IPC方式，接下來我們用TCP服務來實現一個簡單的聊天程式。

2.實現聊天程式服務端

配置

首先我們來實現服務端，當然要使用Socket我們需要在AndroidManifest.xml聲明如下的許可權：

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

我們需要實現一個遠程的Service來當作聊天程式的服務端，AndroidManifest.xml文件中配置service：

<service
            android:name=".SocketServerService"
            android:process=":remote" />

實現Service

接下來我們在Service啟動時，線上程中建立TCP服務，我們監聽的是8688埠，等待客戶端連接，當客戶端連接時就會生成Socket。通過每次創建的Socket就可以和不同的客戶端通信了。當客戶端斷開連接時，服務端也會關閉Socket並結束結束通話線程。服務端首先會向客戶端發送一條消息：“您好，我是服務端”，並接收客戶端發來的消息，將收到的消息進行加工再返回給客戶端。

package com.example.liuwangshu.moonsocket;
import android.app.Service;
import android.content.Intent;
import android.os.IBinder;
import android.text.TextUtils;
import android.util.Log;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class SocketServerService extends Service {
    private boolean isServiceDestroyed = false;

    @Override
    public void onCreate() {
        new Thread(new TcpServer()).start();
        super.onCreate();
    }

    @Override
    public IBinder onBind(Intent intent) {
        // TODO: Return the communication channel to the service.
        throw new UnsupportedOperationException("Not yet implemented");
    }

    private class TcpServer implements Runnable {
        @Override
        public void run() {
            ServerSocket serverSocket;
            try {
                //監聽8688埠
                serverSocket = new ServerSocket(8688);
            } catch (IOException e) {

                return;
            }
            while (!isServiceDestroyed) {
                try {
                    // 接受客戶端請求，並且阻塞直到接收到消息
                    final Socket client = serverSocket.accept();
                    new Thread() {
                        @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 BufferedWriter(new OutputStreamWriter(client.getOutputStream())), true);
        out.println("您好，我是服務端");
        while (!isServiceDestroyed) {
            String str = in.readLine();
            Log.i("moon", "收到客戶端發來的信息" + str);
            if (TextUtils.isEmpty(str)) {
                //客戶端斷開了連接
                Log.i("moon", "客戶端斷開連接");
                break;
            }
            String message = "收到了客戶端的信息為：" + str;
            // 從客戶端收到的消息加工再發送給客戶端
            out.println(message);
        }
        out.close();
        in.close();
        client.close();
    }

    @Override
    public void onDestroy() {
        isServiceDestroyed = true;
        super.onDestroy();
    }
}

3.實現聊天程式客戶端

客戶端Activity會在onCreate方法中啟動服務端，並開啟線程連接服務端Socket。為了確保能連接成功，採用了超時重連的策略，每次連接失敗時都會重新建立連接。連接成功後，客戶端會收到服務端發送的消息：“您好，我是服務端”，我們也可以在EditText輸入字元併發送到服務端。

package com.example.liuwangshu.moonsocket;

import android.content.Intent;
import android.os.SystemClock;
import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.text.TextUtils;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;


public class SocketClientActivity extends AppCompatActivity {
    private Button bt_send;
    private EditText et_receive;
    private Socket mClientSocket;
    private PrintWriter mPrintWriter;
    private TextView tv_message;



    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_socket);
        initView();
        Intent service = new Intent(this, SocketServerService.class);
        startService(service);
        new Thread() {
            @Override
            public void run() {
                connectSocketServer();
            }
        }.start();

    }

    private void initView() {
        et_receive= (EditText) findViewById(R.id.et_receive);
        bt_send= (Button) findViewById(R.id.bt_send);
        tv_message= (TextView) this.findViewById(R.id.tv_message);
        bt_send.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                final String msg = et_receive.getText().toString();
                //向伺服器發送信息
                if(!TextUtils.isEmpty(msg)&&null!=mPrintWriter) {
                    mPrintWriter.println(msg);
                    tv_message.setText(tv_message.getText() + "\n" + "客戶端：" + msg);
                    et_receive.setText("");
                }
            }
        });

    }

    private void connectSocketServer() {
        Socket socket = null;
        while (socket == null) {
            try {
                //選擇和伺服器相同的埠8688
                socket = new Socket("localhost", 8688);
                mClientSocket = socket;
                mPrintWriter = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())), true);
            } catch (IOException e) {
                SystemClock.sleep(1000);
        }
        }
        try {
            // 接收伺服器端的消息
            BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            while (!isFinishing()) {
                final String msg = br.readLine();
                if (msg != null) {
                    runOnUiThread(new Runnable() {
                                      @Override
                                      public void run() {
                                          tv_message.setText(tv_message.getText() + "\n" + "服務端：" + msg);
                                      }
                                  }
                    );
                }
            }
            mPrintWriter.close();
            br.close();
            socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

}

佈局很簡單(activity_socket.xml)：

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

    <TextView
        android:id="@+id/tv_message"
        android:layout_width="match_parent"
        android:layout_height="400dp" />

    <LinearLayout
        android:layout_width="match_parent"
        android:layout_height="50dp"
        android:layout_alignParentBottom="true"
        android:orientation="horizontal">

        <EditText
            android:id="@+id/et_receive"
            android:layout_width="0dp"
            android:layout_height="match_parent"
            android:layout_weight="2"
            />

        <Button
            android:id="@+id/bt_send"
            android:layout_width="0dp"
            android:layout_height="match_parent"
            android:layout_weight="1"
            android:text="向伺服器發消息" />
    </LinearLayout>
</RelativeLayout>

4.運行聊天程式

運行程式，我們可以看到客戶端和服務端是兩個進程： 
這裡寫圖片描述

客戶端首先會收到服務端的信息：”您好，我是服務端”，接下來我們向服務端發送“我想要怒放的生命”。這時候服務端收到了這條信息並返回給客戶端加工後的這條信息： 
這裡寫圖片描述

　　

　　

https://github.com/henrymorgen/MoonSocket　　

　　


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 關於Vue-cli 跨域，即使是非自己的伺服器也可以get到內容
    剛入門vue ，打算用vue的腳手架做一個小項目。需要用到第三方的api，無奈遇到各種各樣的問題。 比如 Access-Control-Allow-Origin ，或者使用了ajax的jsonp模式之後也會出現個別api不相容這個模式而出現另一個錯誤。還有的需要修改後端php之類的，頭大。 後來又聽 ...
  • 樹葉飄落、雪花飄落等同時多個圖片飄落
    snowfall.jquery.js是樹葉等圖片飄落的插件，但是只支持一種圖片的飄落效果，但是我遇到的情況需要飄落未知數種類的圖片，即圖片有多種；那麼就要對原插件做些修改； 在原snowfall.js找到下麵代碼： 將上面代碼修改成： 修改前原插件中的 options.image是一個圖片地址，修改 ...
  • Easyui前端、JAVA後臺 上傳附件
    前端使用easyui框架，後端使用JAVA 的JFinal框架開發 功能描述：實現附件上傳功能。文件上傳路徑為：。。/upload(上傳文件夾)/身份證號/慢病編碼/上傳的附件。 細節要求：實現多圖片上傳，上傳後可在前臺頁面實現二次增加和刪除 1.前臺頁面顯示：填寫身份證號、選擇慢病信息，點擊“上傳 ...
  • Reverse a String-freecodecamp演算法題目
    Reverse a String（翻轉字元串） 把字元串轉化成數組 藉助數組的reverse方法翻轉數組順序 把數組轉化成字元串 用.split('')將字元串轉換成單個字母組成的數組 用.reverse()把數組反轉 用.join('')把數組元素連接成字元串 .split()方法：http:// ...
  • javascript立即執行函數
    概念：立即執行函數顧名思義就是函數定義好之後立即執行。函數表達式方式：函數表達式後面加括弧（）即可立即執行函數。 var xmlhttpUtil = function () { function getText(url,callback){ alert("dog"); }(); 匿名函數方式：匿名函... ...
  • Javascript的載入
    1. 瀏覽器載入 (1) 同步載入 在網頁中，瀏覽器載入js文件的方式是通過<script>標簽。如下所示： <script>標簽很方便，只要加入後，瀏覽器便可讀取並運行，但是在讀取的時候，瀏覽器是按照<script>標簽的出現順序，讀取Javascript文件，然後立即運行，導致在多個文件相互依賴 ...
  • WEB相關背景知識（新手）
    1.評估功能變數名稱類型 .com——商業實體 .edu——僅限有學位或更高等學歷授予資格的高等教育使用 .gov——僅限政府使用 .net——與Internrt網路支持相關的團體，通常是Internet服務提供商或者電信公司 .org——非盈利組織 2.HTML -HTML是一套標記符號或者代碼集，他們插 ...
  • JS模塊化
    一、理解 1、什麼是模塊、模塊化？ 將一個複雜的程式依據一定的規範封裝成幾個文件，併進行組合在一起 2、為什麼要模塊化？ 降低複雜度，提高解耦性，部署方便 3、模塊化的好處 避免命名衝突（減少命名空間污染） 更好的分離，按需載入 更高復用性 高可維護性 4、頁面引入載入script 二、模塊化規範 ...
一周排行
    -Advertisement-
    Play Games
  • UOS 開啟 VisualStudio 遠程調試 .NET 應用之旅
    前言 在我們開發過程中基本上不可或缺的用到一些敏感機密數據，比如SQL伺服器的連接串或者是OAuth2的Secret等，這些敏感數據在代碼中是不太安全的，我們不應該在源代碼中存儲密碼和其他的敏感數據，一種推薦的方式是通過Asp.Net Core的機密管理器。 機密管理器 在 ASP.NET Core ...
  • C# - 能否讓 SortedSet.RemoveWhere 內傳入的委托非同步執行
    新改進提供的Taurus Rpc 功能，可以簡化微服務間的調用，同時可以不用再手動輸出模塊名稱，或調用路徑，包括負載均衡，這一切，由框架實現並提供了。新的Taurus Rpc 功能，將使得服務間的調用，更加輕鬆、簡約、高效。 ...
  • 順序棧的介面程式
    順序棧的介面程式 目錄順序棧的介面程式頭文件創建順序棧入棧出棧利用棧將10進位轉16進位數驗證 頭文件 #include <stdio.h> #include <stdbool.h> #include <stdlib.h> 創建順序棧 // 指的是順序棧中的元素的數據類型，用戶可以根據需要進行修改 ...
  • mORMot2 獲取數據集1
    前言 整理這個官方翻譯的系列，原因是網上大部分的 tomcat 版本比較舊，此版本為 v11 最新的版本。 開源項目 從零手寫實現 tomcat minicat 別稱【嗅虎】心有猛虎，輕嗅薔薇。 系列文章 web server apache tomcat11-01-官方文檔入門介紹 web serv ...
  • 萬字長文總結與剖析C語言關鍵字 -- <<C語言深度解剖>>
    C總結與剖析:關鍵字篇 -- <<C語言深度解剖>> 目錄C總結與剖析:關鍵字篇 -- <<C語言深度解剖>>程式的本質:二進位文件變數1.變數:記憶體上的某個位置開闢的空間2.變數的初始化3.為什麼要有變數4.局部變數與全局變數5.變數的大小由類型決定6.任何一個變數,記憶體賦值都是從低地址開始往高地 ...
  • 【Flink入門修煉】2-3 Flink Checkpoint 原理機制
    如果讓你來做一個有狀態流式應用的故障恢復，你會如何來做呢？ 單機和多機會遇到什麼不同的問題？ Flink Checkpoint 是做什麼用的？原理是什麼？ ...
  • C++ 多級繼承與多重繼承：代碼組織與靈活性的平衡
    C++ 多級繼承 多級繼承是一種面向對象編程（OOP）特性，允許一個類從多個基類繼承屬性和方法。它使代碼更易於組織和維護，並促進代碼重用。 多級繼承的語法 在 C++ 中，使用 : 符號來指定繼承關係。多級繼承的語法如下： class DerivedClass : public BaseClass1 ...
  • 圖文結合手把手教你創建SpringCloud項目
    前言 什麼是SpringCloud？ Spring Cloud 是一系列框架的有序集合，它利用 Spring Boot 的開發便利性簡化了分散式系統的開發，比如服務註冊、服務發現、網關、路由、鏈路追蹤等。Spring Cloud 並不是重覆造輪子，而是將市面上開發得比較好的模塊集成進去，進行封裝，從 ...
  • 類模板的常見用法
    class_template 類模板和函數模板的定義和使用類似，我們已經進行了介紹。有時，有兩個或多個類，其功能是相同的，僅僅是數據類型不同。類模板用於實現類所需數據的類型參數化 template<class NameType, class AgeType> class Person { publi ...
  • system-v IPC共用記憶體通信
    目錄system v IPC簡介共用記憶體需要用到的函數介面shmget函數--獲取對象IDshmat函數--獲得映射空間shmctl函數--釋放資源共用記憶體實現思路註意 system v IPC簡介 消息隊列、共用記憶體和信號量統稱為system v IPC(進程間通信機制)，V是羅馬數字5，是UNI ...
所有分類