2. 程式人生 > >android socket聊天室——也不僅僅是聊天室

android socket聊天室——也不僅僅是聊天室

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

前提概要

筆者很久之前其實就已經學習過了socket，當然也是用socket做過了聊天室，但是覺得此知識點比較一般，並無特別難的技術點，於是也並未深究。
然而近期一個專案中對socket的使用卻讓筆者感覺socket強大無比，可以實現諸多功能。

個人Socket體驗

專案主要有關智慧家居，需要實現多臺手機同時對燈進行操作（開或者關），主要需要實現以下幾點：
1、進入介面時獲取所有燈的狀態。
2、一臺手機改變了燈的狀態，其他的手機上可以有所顯示。
3、硬體上改變了燈的狀態（手動開關燈），所有手機上要有所顯示。

此功能如果使用HTTP讀取的方式實現就不太合適了。一方面客戶端與伺服器讀取檔案的同步性難以保證，即使保證了，也需要浪費大量效能；另一方面，類似筆者的這種專案功能伺服器和客戶端互動比較頻繁，對“即時性”要求也比較高，用HTTP不僅效能消耗太大，而且難以保證“即時性”。

但是使用Socket就很容易實現了，主要邏輯如下：
1、每次進入介面與伺服器建立Socket連線，並得到此時燈的狀態
2、每次需要對燈進行操作的時候建立一個執行緒把燈的狀態傳遞給伺服器，伺服器接收到之後，把該狀態傳遞給每一個此時與伺服器建立連線的客戶端。

此次體驗也是讓筆者想起了學長之前做的一道筆試題，題目大概如下：

將淘寶網頁和手機版同時開啟賬戶，手機停留在購物車介面，此時網頁上將某一物品加入購物車，如何設計才能讓手機自動重新整理購物車。

如果使用socket，相信是一個不錯的思路。

好了，接下來進入正題，展示socket聊天室demo。

效果（原始碼在文章結尾）

這裡寫圖片描述

主要思路

Android

1、進入介面客戶端與伺服器建立socket，同時此時開啟一個執行緒一直接收伺服器傳送來的訊息。
2、每次點選button獲取EditText中的字串，呼叫子執行緒把字串傳送給伺服器。

伺服器

1、建立一個ArrayList儲存Socket。
2、迴圈接收請求訪問該埠的客戶端，接收到之後，把該socket儲存到ArrayList中，並且為每一個socket開啟一個執行緒用於通訊。
3、每個socket的執行緒的邏輯如下：迴圈接收客戶端發來的訊息，接收到之後，利用之前的ArrayList，傳送到每一個客戶端。如果某個客戶端返回空值或者無法傳送過去，那麼表示該客戶端已經斷開，就從ArrayList中移除。

程式碼

（借鑑《Android瘋狂講義》）

Android

不要忘記在AndroidManifest裡面加上訪問網路的許可權

MainActivity:

package com.example.double2.sockettesttwo;

import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.support.v7.app.AppCompatActivity;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;

public class MainActivity extends AppCompatActivity {

    private EditText etMain;
    private Button btnMain;
    private TextView tvMain;
    private ClientThread mClientThread;

    //在主執行緒中定義Handler傳入子執行緒用於更新TextView
    private Handler mHandler;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        etMain = (EditText) findViewById(R.id.et_main);
        btnMain = (Button) findViewById(R.id.btn_main);
        tvMain = (TextView) findViewById(R.id.tv_main);

        mHandler=new Handler() {
            @Override
            public void handleMessage(Message msg) {
                if (msg.what == 0) {
                    tvMain.append("\n" + msg.obj.toString());
                }
            }
        };

        //點選button時，獲取EditText中string並且呼叫子執行緒的Handler傳送到伺服器
        btnMain.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                try {
                    Message msg = new Message();
                    msg.what = 1;
                    msg.obj = etMain.getText().toString();
                    mClientThread.revHandler.sendMessage(msg);
                    etMain.setText("");
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        });


        mClientThread = new ClientThread(mHandler);
        new Thread(mClientThread).start();


    }
}

ClientThread

package com.example.double2.sockettesttwo;

import android.os.Handler;
import android.os.Looper;
import android.os.Message;
import android.util.Log;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;

/**
 * 專案名稱：SocketTestTwo
 * 建立人：Double2號
 * 建立時間：2016.11.20 9:16
 * 修改備註：
 */
public class ClientThread implements Runnable {
    private Socket mSocket;
    private BufferedReader mBufferedReader = null;
    private OutputStream mOutputStream = null;
    private Handler mHandler;

    public Handler revHandler;

    public ClientThread(Handler handler) {
        mHandler = handler;
    }

    @Override
    public void run() {
        try {
            mSocket = new Socket("10.3.20.159", 30003);
            Log.d("xjj","connect success");
            mBufferedReader = new BufferedReader(new InputStreamReader(mSocket.getInputStream()));
            mOutputStream = mSocket.getOutputStream();

            new Thread(){
                @Override
                public void run() {
                    super.run();
                    try {
                        String content = null;
                        while ((content = mBufferedReader.readLine()) != null) {
                            Log.d("xjj",content);
                            Message msg = new Message();
                            msg.what = 0;
                            msg.obj = content;
                            mHandler.sendMessage(msg);
                        }
                    }catch (IOException e){
                        e.printStackTrace();
                    }
                }
            }.start();

            //由於子執行緒中沒有預設初始化Looper，要在子執行緒中建立Handler，需要自己寫
            Looper.prepare();
            revHandler = new Handler() {
                @Override
                public void handleMessage(Message msg) {
                    if (msg.what == 1) {
                        try {
                            mOutputStream.write((msg.obj.toString() + "\r\n").getBytes("utf-8"));
                        } catch (IOException e) {
                            e.printStackTrace();
                        }
                    }
                }
            };
            Looper.loop();





        } catch (IOException e) {
            e.printStackTrace();
            Log.d("xjj","");
        }
    }
}

activity_main

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout
    xmlns:android="http://schemas.android.com/apk/res/android"
    android:id="@+id/activity_main"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    android:padding="@dimen/activity_vertical_margin"
    android:orientation="vertical"
    >

    <LinearLayout
        android:layout_width="match_parent"
        android:layout_height="wrap_content"
        android:orientation="horizontal">

        <EditText
            android:id="@+id/et_main"
            android:layout_width="0dp"
            android:layout_height="wrap_content"
            android:layout_weight="1"/>

        <Button
            android:id="@+id/btn_main"
            android:layout_width="wrap_content"
            android:layout_height="wrap_content"
            android:text="@string/send"/>
    </LinearLayout>

    <TextView
        android:id="@+id/tv_main"
        android:layout_width="match_parent"
        android:layout_height="match_parent"
        />
</LinearLayout>

伺服器：

MySever

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;

public class MySever {

    public static ArrayList<Socket> socketList = new ArrayList<Socket>();
    public static String content="";

    public static void main(String[] args) throws IOException {
        //建立ServerSocket
        ServerSocket ss = new ServerSocket(30003);

        //不斷接收此埠的socket，並存儲到socketList中
        //並且為每一個socket開啟一個執行緒，用於接收資訊
        while (true) {
            Socket s = ss.accept();
            System.out.println("connect success!");
            socketList.add(s);

            new Thread(new ServerThread(s)).start();
        }
    }

}

SeverThread

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.net.Socket;
import java.net.SocketException;
import java.util.Iterator;

public class ServerThread implements Runnable {

    private Socket mSocket = null;
    private BufferedReader mBufferedReader = null;

    // 建構函式中接收socket並且初始化BufferedReader
    public ServerThread(Socket socket) 
            throws UnsupportedEncodingException, IOException {
        mSocket = socket;
        mBufferedReader = new BufferedReader(
                new InputStreamReader(mSocket.getInputStream(), "utf-8"));
    }

    @Override
    public void run() {
        // TODO Auto-generated method stub

        try {
            String content = null;

            //迴圈接收來自此客戶端的訊息
            //如果接收不到了，表面已經斷開，就將此客戶端從socketList中移除
            while ((content = mBufferedReader.readLine()) != null) {

                System.out.println(content);

                //向連線中的每個客戶端傳送資料
                //如果異常，說明斷開，就將該條目從socketList中移除
                for (Iterator<Socket> it = MySever.socketList.iterator(); 
                        it.hasNext();) {
                    Socket s = it.next();
                    try {
                        OutputStream os = s.getOutputStream();
                        os.write((content + "\n").getBytes("utf-8"));
                    } catch (SocketException e) {
                        e.printStackTrace();
                        it.remove();
                    }
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
            MySever.socketList.remove(mSocket);
        }
    }

}

原始碼地址：

相關推薦

android socket聊天室——也不僅僅是聊天室

前提概要 筆者很久之前其實就已經學習過了socket，當然也是用socket做過了聊天室，但是覺得此知識點比較一般，並無特別難的技術點，於是也並未深究。 然而近期一個專案中對socket的使用卻讓筆者感覺socket強大無比，可以實現諸多功能。 個人S

Android Socket 聊天室

專案地址：https://github.com/SunnyLine/Android-Socket-ChatRoom 部分截圖： 以下為程式碼邏輯部分 Java: 監聽某個埠，有使用者訪問時，將這個Socket放入到一個集合中作為一個使用者組，並監聽這個Socket

Socket之簡單的Unity3D聊天室__TCP協議

reac span 範圍 pan ati 線程 atm socket all 服務器端程序 1 using System; 2 using System.Collections.Generic; 3 using System.Linq; 4 using Syst

1024_(即時通訊)使用node.js和socket.io實現多人聊天室

使用node.js和socket.io實現多人聊天室 2015年01月24日 03:24:54 遠古大猛獁 閱讀數：2775 轉自： http://www.cnblogs.com/flyoung2008/archive/2012/07/19/2600132.html

java socket多執行緒實現聊天室

java socket多執行緒實現聊天室 程式碼放在我的GitHub上點選檢視 版本1，一對一，收發有順序 /** * @Author: Hzw * @Time: 2018/4/19 11:38 * @Description: 聊天室客戶端V1.0,雙向通訊，客戶端傳

express + socket.io實現超簡易聊天室

什麼是socket.io socket.io是webSocket的一個封裝元件，實現雙向通訊，可以用這個來實現聊天室功能、線上小遊戲等等，是個有趣好玩的東西，博主就喜歡搗鼓這些 實現聊天室思路 聊天室就是要聊天嘛，就像打電話一樣，我這邊說話你那邊應該要馬上聽到，所以就需要用到雙向通訊，瀏覽器發

java socket 基於netty的網路聊天室

Netty是一個Java的NIO客戶端服務端框架可以快速的開發網路應用程式，比如客戶端和服務端的協議，大大簡化了網路程式的開發過程。我們知道Netty的整體架構主要由3部分組成：緩衝(buffer)、通道(channel)、事件模型(event model)。所有的

Node.js websocket 使用 socket.io庫實現實時聊天室

認識websocket WebSocket protocol 是HTML5一種新的協議。它實現了瀏覽器與伺服器全雙工通訊(full-duple)。一開始的握手需要藉助HTTP請求完成。 其實websocket 並不是很依賴Http協議，它也擁有自己的一套協議

Socket編寫一個簡易的聊天室（相關知識點的總結）

初次接觸到Socket的時候，還以為是網路程式設計的部分。學完後才發現，他也是Java中的一個類。只是它和TCP協議掛鉤了。在用Socket的時候要考慮到網路和協議的問題，以及每個應用程式相對應的埠，當伺服器或者客服端通過網路接受到資訊的時候，會先根據IP地址找到相應的位置

Python基於Socket實現簡易多人聊天室

##前言 套接字(Sockets)是雙向通訊通道的端點。 套接字可以在一個程序內，在同一機器上的程序之間，或者在不同主機的程序之間進行通訊，主機可以是任何一臺有連線網際網路的機器。 套接字可以通過多種不同的通道型別實現：Unix域套接字，TCP，UDP等。 套接字型檔提供了處理公共傳輸的特定類，以及一個用於處

微服務-springboot+websocket線上聊天室(多人聊天)

一.引入依賴 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-websock

Android即時通訊--仿QQ即時聊天：（一）初識Socket

/** * socket服務端 * * @author ZHY * */ public class ServerSocketTest { public static void main(String[] args) throws IOException { final ServerSock

聊天源碼IM聊天室模板 群組聊天app 即時通訊IM設計聊天

redis 需求 obs 私有化 擁有 查看 即時通 緩存 相關 （此貼長期有效）系統提供多種方式合作，支持源碼轉讓/支持按年整體運維合作/支持行業定制開發，更多需求請聯系我們 團隊Tel：15538001716 （V同） 獨立IM：個性化定制，私有化部署，全功能，高並發，

java Socket實現簡單在線聊天（一）

結合線程 java.awt exc iss order 新建 exception connect border 出處：http://blog.csdn.net/tuzongxun 最近的項目有一個在線網頁交流的需求，由於很久以前做過的demo已經忘記的差不多了，因此便重新學

使用socket.io實現簡單的聊天功能

ins sock UNC say mes 輪詢 var document style Socket.io實際上是WebSocket的父集，Socket.io封裝了WebSocket和輪詢等方法 首先得在你的項目中安裝socket.io $ npm install sock

Python3：利用Socket實現多使用者實時聊天.

我們繼續在用程式碼演示Socket和Server 實現通訊 這個章節繼續擴充套件 首先我們要做到的是 實時通訊， 這裡面牽扯了3個知識點： 既然是實時通訊，必須是用input線上輸入 我們要把close 語句刪除，否則會自己斷掉 為了達到實時通訊，必須不斷的迴

用socket寫一個簡單的聊天程式

服務端程式碼： # 建立socket物件:socket.socket()——>繫結IP地址和埠:bind——>監聽:listen——># 得到請求:accept——>接收請求:recv——>傳送資訊:send——>關閉close   i

用socket寫一個簡單的聊天程序

cli list t對象 bind bre hid lis 結束 聊天 服務端代碼： # 創建socket對象:socket.socket()——>綁定IP地址和端口:bind——>監聽:listen——># 得到請求:accept——>接收請求:r

Socket程式設計-TCP實現簡單聊天程式

在System.net.Sockets的名稱空間中，TcpListener類與TcpClient類是兩個專門用於TCP協議程式設計的類，它們封裝了底層的套接字並分別提供了用Socket進行同步和非同步通訊的方法，降低了TCP應用程式設計的難度。 在網路應用程式設計中，利用TCP協議編寫的程式

Android Studio-個推-實現簡單聊天(二)

實現聊天，首先要知道聊天雙方的CID，這裡可以獲取到，將其存起來。 這裡用模擬器測試一下，準備倆臺模擬器，分別獲得其CID；準備好聊天介面；注備好聊天介面，就可以測試了。 一、web後臺Contraller package com.smxy.office.con