2. 程式人生 > >android socket通訊demo （本篇服務於android訊息推送）

android socket通訊demo （本篇服務於android訊息推送）

阿新 • • 發佈：2019-02-07

本文系作者原創，轉載請附原文地址，謝謝。

文章末尾提供本文中的原始碼下載連結，需資源積分1分，人艱不拆，下載後評論資源可獲系統返回積分=無損！

前言：

關於什麼是socket通訊，本篇文件中不進行解釋，不甚清楚的可以去百科查詢，日後得空我也會整理相關的內容。

本文是對上一篇關於訊息推送的文章的補充，此處給出快速連結：http://blog.csdn.net/a774057695/article/details/47024887

本篇書寫的目的：

1.       讓android客戶端和伺服器端實現socket通訊，且demo需實現雙向

2.       為實現伺服器向客戶端推送訊息奠定基礎

特別說明：

1.       伺服器端利用pc機執行apach伺服器模擬

2.       Pc整合xampp環境

3.       伺服器端eclipse編譯，java實現

4.       客戶端使用真機除錯（使用模擬器需要對原始碼進行修改，因為沒有嘗試，所以沒有給出示例程式碼，使用模擬器調試出錯的請留意該點）

5.       手機和pc加入同一域，至少連入同一臺路由器，使用wifi共享的方法本文不提供技術支援、不保證其可行性。

功能概述：

l  伺服器端：

主函式實現：阻塞的程式碼段等待socket連線、啟動執行緒為socket連線提供應答；

互動執行緒（暫且這樣稱呼）：實現收到客戶端訊息後進行反饋

單向執行緒（暫且這樣稱呼）：實現接受控制檯輸入並向客戶端傳送

連線斷開刪去該條socket

l  客戶端：

實現向伺服器端建立socket連線

啟動執行緒監聽伺服器傳送的訊息、並反饋UI顯示

將本地訊息發往伺服器

程式碼結構：

伺服器端：（主要）

       |-- MyServer

              |--src

                     |--[package]

                            |--MyServer.java

                            |--ServerThread.java

                            |--Thread2.java

客戶端：（主要）

       |--MultiThreadClient

              |--src

                     |--[package]

                            |--ClientThread.java

                            |--MainActivity.java

              |--res

                     |--layout

                            |--activity_main.xml

              |--AndroidManifest.xml

程式碼示例及關鍵點：

l  伺服器端：

MyServer.java

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
public class MyServer {
   //定義儲存所有Socket的ArrayList
   public static ArrayList<Socket> socketList = new ArrayList<Socket>();
   /**
    * @param args
    * @throws IOException
    */
   public static void main(String[] args) throws IOException {
      // param 埠號
      ServerSocket ss = new ServerSocket(30000);
      while(true){
         //此程式碼會阻塞，將一直等待別人連線
         Socket s = ss.accept();
         socketList.add(s);
         /*每當客戶端連線後啟動一條ServerThread執行緒為該客戶端服務*/
         new Thread(new ServerThread(s)).start();
         new Thread(new Thread2(s)).start();
      }
   }
 
}

此處我們需要留意的是埠號，第一不要去使用系統關鍵服務的埠號，第二我們要注意客戶端中的埠號需要匹配，在後面我們還會提及。

ServerThread.java

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;
 
public class ServerThread implements Runnable {
 
   //定義當前執行緒所處理的Socket
   Socket s = null;
   //該執行緒所處理的Socket所對應的輸入流
   BufferedReader br = null;
   public ServerThread(Socket s) throws IOException {
      this.s = s;
      //初始化該Socket對應的輸入流
      br = new BufferedReader(new InputStreamReader(s.getInputStream(),
            "utf-8"));
   }
 
   @Override
   public void run() {
      try
      {
         String content = null;
         //採用迴圈不斷從Socket中讀取客戶端傳送過來的資料
         while((content = readFromClient())!=null){
            //遍歷socketList中的每個Socket
            //將讀到的內容向每個Socket傳送一次
            for(Socket s : MyServer.socketList){
                OutputStream os = s.getOutputStream();
                //簡單處理模擬應答
                os.write((content + "——返回自伺服器\n").getBytes("utf-8"));
            }
         }
      }catch (IOException e) {
         e.printStackTrace();
      }
   }
   /**
    * 讀取客戶端資料
    * @return
    */
   public String readFromClient()
   {
      try{
         return br.readLine();
      }catch(IOException e){   //如果捕捉到異常，表明該Socket對應的客戶端已經被關閉
         //刪除該Socket
         MyServer.socketList.remove(s);
      }
      return null;
   }
 
}

這裡也沒有太多值得注意的，這條執行緒是實現對客戶端應答，當客戶端向伺服器發出訊息，伺服器收到後進行反饋，這裡我們只是對原來的內容進行了簡單的處理，可以按照伺服器-客戶端之間的約定，實現更有意義的事情。

當連線斷開時，刪除該socket

Thread2.java

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;
 
 
public class Thread2 implements Runnable {
 
   //定義當前執行緒所處理的Socket
   Socket s = null;
   //該執行緒所處理的Socket所對應的輸入流
   BufferedReader br = null;
 
   public Thread2(Socket s) throws IOException {
      this.s = s;
      //初始化該Socket對應的輸入流
      br = new BufferedReader(new InputStreamReader(s.getInputStream(),
            "utf-8"));
   }
  
   /**
    * 讀取控制檯輸入
    * */
   private void readConsole() {
        //陣列緩衝
        byte[] b = new byte[1024];
        //有效資料個數
        int n = 0;
        try{
         while(true){
              //提示資訊
              System.out.println("請輸入：");
              //讀取資料
              n = System.in.read(b);
              //轉換為字串
              String str = new String(b,0,n - 2);
            //傳送到客戶端
             for(Socket s : MyServer.socketList){
                OutputStream os = s.getOutputStream();
                os.write(("伺服器傳送"+str + "\n").getBytes("utf-8"));
            }
              //判斷是否是quit
              if(str.equalsIgnoreCase("quit")){
                        break; //結束迴圈
              }
              //回顯內容
              System.out.println("輸入內容為：" + str);
             }
        }catch(Exception e){}
   }
  
 
   @Override
   public void run() {
      readConsole();
     
   }
}

這條執行緒實現讀取控制檯輸入內容並向客戶端傳送，這裡我們沒有關心連線斷開，這與demo的目的不衝突，但是投入生產時還是應當注意。

l  客戶端：

AndroidManifest.xml

建立一個應用，首先做得事情不是在預設開啟的佈局檔案中進行佈局，而是規劃一下需要哪些許可權，並在配置檔案中新增！

本處我們需要申請Internet許可權：

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

手打的朋友請注意：是uses，不是user！

activity_main.xml

預覽：（真的太大，求調大小功能）

 
<RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:tools="http://schemas.android.com/tools"
    android:id="@+id/RelativeLayout1"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    android:gravity="bottom"
    android:orientation="vertical" >
 
<!--個並不美觀的佈局 -->
    <EditText
        android:id="@+id/show"
        android:layout_width="match_parent"
        android:layout_height="wrap_content"
        android:layout_above="@+id/linearLayout1"
        android:layout_alignParentLeft="true"
        android:cursorVisible="false"
        android:gravity="top" />
 
    <LinearLayout
        android:layout_width="match_parent"
        android:layout_height="wrap_content"
        android:id="@+id/linearLayout1"
        android:orientation="horizontal"
        android:weightSum="5"
        android:layout_alignParentBottom="true" >
 
        <EditText
            android:id="@+id/input"
            android:layout_width="0dp"
            android:layout_height="wrap_content"
            android:layout_weight="5"
             >
            <requestFocus />
        </EditText>
 
        <Button
            android:id="@+id/send"
            android:layout_width="wrap_content"
            android:layout_height="wrap_content"
            android:layout_weight="1"
            android:text="send" />
    </LinearLayout>
 
</RelativeLayout>

MainActivity.java

package com.example.multithreadclient;
 
import java.io.IOException;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.net.Socket;
 
import android.app.Activity;
import android.os.AsyncTask;
import android.os.Bundle;
import android.os.Handler;
import android.view.View;
import android.view.View.OnClickListener;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;
 
public class MainActivity extends Activity {
 
       EditText input, show;
       TextView mode;
       Button send,smode,cmode;
       OutputStream os;
       Handler handler;
 
       @Override
       protected void onCreate(Bundle savedInstanceState) {
              super.onCreate(savedInstanceState);
              setContentView(R.layout.activity_main);
              input = (EditText) findViewById(R.id.input);
              send = (Button) findViewById(R.id.send);
              show = (EditText) findViewById(R.id.show);
             
              handler = new Handler() {
                     public void handleMessage(android.os.Message msg) {
                            if (msg.what == 0x123) {
                                   show.append("\n" + msg.obj.toString());
                            }
                     };
              };
              new AsyncTask<String, String, String>(){
 
                     @Override
                     protected String doInBackground(String... params) {
                            // TODO Auto-generated method stub
                            Socket s;
                            try {
                                   /**@ param param1 param2
                                    * param1: 伺服器ip地址，本例中，即pc機的ip地址 cmd輸入ipconfig -all可查詢
                                    * param2：埠號 注意和伺服器原始碼中的匹配本
                                    *例中30000
                                    * */
                                   s = new Socket(param1,param2);
                                   //客戶端啟動ClientThread執行緒，不斷讀取來自伺服器的資料
                                   new Thread(new ClientThread(s, handler)).start();
                                   os = s.getOutputStream();
                            } catch (Exception e) {
                                   e.printStackTrace();
                            }
                            return null;
                     }
                    
              }.execute("");
             
              send.setOnClickListener(new OnClickListener() {
 
                     @Override
                     public void onClick(View v) {
                            // TODO Auto-generated method stub
                            try {
                                   //將使用者在文字框中輸入的內容寫入網路
                                   os.write((input.getText().toString() + "\r\n")
                                                 .getBytes("utf-8"));
                                   input.setText("");
                            } catch (IOException e) {
                                   // TODO Auto-generated catch block
                                   e.printStackTrace();
                            }
                     }
              });
       }
      
       @Override
       protected void onDestroy() {
              super.onDestroy();
              try {
                     os.write("".getBytes("utf-8"));
              } catch (UnsupportedEncodingException e) {
                     // TODO Auto-generated catch block
                     e.printStackTrace();
              } catch (IOException e) {
                     // TODO Auto-generated catch block
                     e.printStackTrace();
              }
       }
}

值得特別注意的就是兩個引數！在註釋中已經說得很明白了，第一個是pc機的ip，第二個是伺服器約定的埠號。使用模擬器進行除錯需要修改ip，我印象中是10.0.2.2，而127.0.0.1會被認為是android模擬器本身。

ClientThread.java

package com.example.multithreadclient;
 
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
 
import android.os.Handler;
import android.os.Message;
 
public class ClientThread implements Runnable {
 
       private Socket s;  //該執行緒負責處理的Socket
       private Handler handler;
       //該執行緒所處理的Socket對應的輸入流
       BufferedReader br = null;
 
       public ClientThread(Socket s, Handler handler) throws IOException {
              this.s = s;
              this.handler = handler;
              br = new BufferedReader(new InputStreamReader(s.getInputStream()));
       }
 
       @Override
       public void run() {
              // TODO Auto-generated method stub
              try {
                     String content = null;
                     //不斷讀取Socket輸入流中的內容
                     while ((content = br.readLine()) != null) {
                            //每當讀到來自伺服器的資料後，傳送訊息通知程式介面顯示資料
                            Message msg = new Message();
                            msg.what = 0x123;
                            msg.obj = content;
                            handler.sendMessage(msg);
                     }
              } catch (Exception e) {
                     e.printStackTrace();
              }
 
       }
}

此處沒有特別關注的地方

執行測試：

除錯android應用，將其安裝到手機，只是想先裝上去而已

執行xampp panel 啟動apach服務

Eclipse中執行伺服器端程式

重新啟動手機端的客戶端程式——只是需要伺服器先啟動，客戶端再連線而已。

你可以在eclipse的console中輸入想要傳送的訊息，回車會被去掉，輸入quit回車可以停止之，然並卵

你也可以在手機端傳送訊息等待回傳訊息

截圖就不附了

本文系作者原創，轉載請附原文地址，謝謝。

本文中的原始碼下載連結：http://download.csdn.net/detail/a774057695/8929341 需資源積分1分，人艱不拆，下載後評論資源可獲系統返回積分=無損！

相關推薦

android socket通訊demo （本篇服務於android訊息推送）

本文系作者原創，轉載請附原文地址，謝謝。 文章末尾提供本文中的原始碼下載連結，需資源積分1分，人艱不拆，下載後評論資源可獲系統返回積分=無損！ 前言： 關於什麼是socket通訊，本篇文件中不進行解釋，不甚清楚的可以去百科查詢，日後得空我也會整理相關的內容。 本文

C#Socket通訊原理（基礎篇）

這幾天博主花了4天時間去學習，整理Socket通訊。大致懂了一點，現在我來總結一下關於C#Socket通訊的原理首先我們要知道網路中的程序是如何進行通訊的在本地可以通過程序PID來唯一標識一個程序，但是在網路中這是行不通的。其實TCP/IP協議族已經幫我們解決了這個問題，網路

思路超簡單的Android Socket 通訊 Demo 註釋詳細

思路超簡單的Android Socket 通訊  Demo 註釋詳細 demo下載  http://download.csdn.net/detail/menglele1314/9280379 服務端往Socket的輸出流裡面寫東西，客戶端就可以通過Socket的輸入流讀取對

Androin學習筆記四十二：Java android Socket通訊檢測（server）連線是否斷開

Pre 在利用socket寫通訊程式的時候，想檢測伺服器是否還活著。 從網上找了很多資料，都沒有自己合適的，最後自己想了個辦法，不過也相當於截取了心跳檢測的一部分。 這裡檢測的是遠端server的連線，而不是本地是否連線成功。首先想到socket類的方法isClosed()、isConnected

微信服務號模板訊息推送

一.微信服務號新建模板   二.建立模板訊息pojo import java.util.HashMap; import net.sf.json.JSONObject; public class TemplateData { private String touser;

WebSocket瀏覽器與伺服器之間的對話（用於訊息推送）

 1.如果加入資料庫後，A發訊息時客戶B未上線，服務端將會把訊息存在資料庫中，等客戶B上線後，在將訊息取出傳送給客戶B 2.服務端也可傳送訊息到任意客戶端上。 程式的執行效果截圖如下（在chrome，搜狗，firefox下測試通過）：程式碼將在最後給出 首先我們開啟一個

微信公眾號開發（二、訊息推送）

微信公眾號的配置完了，訊息推送就比較簡單了。本節主要介紹一下推送的程式碼。          一、首先需要在公眾號平臺中新建一個模板（用於推送訊息）。下面是測試和正式微信公眾號的模板。正式的模板可以設

java實現桌面右下角彈窗（模仿，類似於qq訊息彈窗）

最近需要一個java實現桌面彈窗的小功能，類似於電腦桌面右下角的小廣告一樣的功能，在csdn上找到一個很好的一個，功能很多，我去除了一點不需要的程式碼，改了下外觀等。 原作者：https://www.cnblogs.com/hgxbo/p/5508384.html 修改後的

Unity3D中的SendMessage使用（訊息推送）

    概述     Unity提供的訊息推送機制可以非常方便我們的指令碼開發，它實現的是一種偽監聽者模式，利用的是反射機制。     常用函式     關於訊息推送，常用的函式有三個：”SendMessage“、”SendMessageUpwards“、”Broadcas

［iOS］關於 App 混合（Hybrid）開發的優化，包括H5、Weex等（本篇博客主要針對 iOS 應用講解，但該思想同樣適用於Android）

color 數據 後臺 lib 新版 生成 下載地址 代碼 版本 　　我們知道混合開發，可以節省很多成本（時間成本，經濟成本等等），所以有很多公司比較鐘愛這種開發形式，今天所講的優化方式，也是我在我們公司的應用中實際用了的，而且我寫的這個優化的 SDK 已經開源到 gith

android socket 通訊（客戶端) 發送數據

exc ring private soc 頭信息 tput output vid array /** ClientSocket通訊類 **/ public class ClientSocket { /**服務器地址*/ private String serve

Android查缺補漏（IPC篇）-- 進程間通訊基礎知識熱身

內部 eat ack 學習過程 and ... 綁定 his nec 本文作者：CodingBlock 文章鏈接：http://www.cnblogs.com/codingblock/p/8479282.html 在Android中進程間通信是比較難的一部分，同時又非常重要

Android wifi通訊 開發（wifi列表 +連線具體的wifi熱點+socket的獲取） 之 解決熱點連成功的時延問題

寫這篇部落格前，說一些題外話：樓主是在一家做嵌入式研發的公司當然也有軟體研發，總之就是以軟硬體通訊為主把資料展示到前端，所 以不可避免的有 wifi 藍芽 網口 串列埠 等這些通訊媒介，網上的wifi通訊千篇一律下面我來總結我的wifi通訊 ，

Android java和C的Socket通訊demo(可用)

原址 關於Android應用與Framework的socket通訊，相信關心這個問題的朋友們已經看過《android使用socket使底層和framework通訊》這篇文章，美中不足的是作者只貼出一些關鍵的程式碼片段而並沒有放出原始碼。我這裡還是以一個能實際執行的例子為基礎

Android查缺補漏（View篇）--事件分發機制

touch事件 滑動沖突 今天 version schema ttr 步驟 isp win 事件分發機制是Android中非常重要的一個知識點，同時也是難點，相信到目前為止很多Android開發者對事件分發機制並沒有一個非常系統的認識，當然也包括博主個人在內。可能在平時的開

Android查缺補漏（View篇）--布局文件中的“@+id”和“@id”有什麽區別？

新增 布局 parent 直接 使用 margin 移除 控件 Coding Android布局文件中的“@+id”和“@id”有什麽區別？ +id表示為控件指定一個id（新增一個id），如： <cn.codingblock.view.customer_view.

MySQL-MMM高可用群集（本篇使用MariaDB代替MySQL進行實驗部署）

可用 個數 兩個 切換 p地址 default 編輯 主主 ins 1.MySQL-MMM概述 MMM（Master-Master replication manager for MySQL）是一套支持雙主故障切換和雙主日常管理的腳本程序。MMM使用Perl語言開發，主要用

C#Socket通訊基礎（非同步Socket通訊TCP）伺服器與客戶端

一、效果圖 二、伺服器端程式碼（原始碼下載地址：https://download.csdn.net/download/xiaochenxihua/10748789） using System; using System.Collections.Generic; using System

C#Socket通訊基礎（非同步Socket通訊UDP）

一、通訊原理參考https://blog.csdn.net/xiaochenXIHUA/article/details/83446031。 非同步通訊解決同步通訊的缺點可以雙向傳送和接收資訊；非同步通訊思路是引入多執行緒機制，在一個程序中使用兩個執行緒，分別處理接收執行緒與傳送執行緒，這種機制稱

C#Socket通訊基礎（同步Socket通訊UDP）

一、UDP通訊原理 UDP協議使用無連線的套接字，因此不需要再網路裝置之間傳送連線資訊，但是必須用Bind方法繫結到一個本地地址/埠上。 ①建立套接字 ②繫結IP地址和埠作為伺服器端 ③直接使用SendTo/ReceiveFrom來執行操作 注意：同步Socket（UDP）通訊存