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
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類