一個(gè)簡(jiǎn)單的Android端Socket通信

先上效果圖

SocketCommunication.gif

Demo說(shuō)明

有三個(gè)模擬器淑廊,通過(guò)Socket鸽捻,將信息相互發(fā)送到對(duì)方的設(shè)備上凳鬓。其中的認(rèn)證客戶端是指將此客戶端的信息傳到服務(wù)端茁肠,以便在客戶端一對(duì)一發(fā)送消息時(shí),服務(wù)端可以找到相應(yīng)的設(shè)備缩举。

定義客戶端代碼

public class ClientConnector {

    private Socket mClient;
    /**
     * 服務(wù)端的ip
     */
    private String mDstName;
    /**
     * 服務(wù)端端口號(hào)
     */
    private int mDesPort;

    private ConnectLinstener mListener;


    public ClientConnector(String dstName, int dstPort) {
        this.mDstName = dstName;
        this.mDesPort = dstPort;
    }

    /**
     * 與服務(wù)端進(jìn)行連接
     *
     * @throws IOException
     */
    public void connect() throws IOException {
        if (mClient == null) {
            mClient = new Socket(mDstName, mDesPort);
        }

        //獲取其他客戶端發(fā)送過(guò)來(lái)的數(shù)據(jù)
        InputStream inputStream = mClient.getInputStream();
        byte[] buffer = new byte[1024];
        int len = -1;
        while ((len = inputStream.read(buffer)) != -1) {
            String data = new String(buffer, 0, len);

            //通過(guò)回調(diào)接口將獲取到的數(shù)據(jù)推送出去
            if (mListener != null) {
                mListener.onReceiveData(data);
            }
        }
    }

    /**
     * 認(rèn)證方法垦梆,這個(gè)方法是用來(lái)進(jìn)行客戶端一對(duì)一發(fā)送消息的
     * 在實(shí)際項(xiàng)目中進(jìn)行即時(shí)通訊時(shí)都需要進(jìn)行登錄,這里就是
     * 模擬客戶端的賬號(hào)
     *
     * @param authName
     */
    public void auth(String authName) throws IOException {
        if (mClient != null) {
            //將客戶端賬號(hào)發(fā)送給服務(wù)端蚁孔,讓服務(wù)端保存
            OutputStream outputStream = mClient.getOutputStream();
            //模擬認(rèn)證格式奶赔,以#開(kāi)頭
            outputStream.write(("#" + authName).getBytes());
        }
    }

    /**
     * 將數(shù)據(jù)發(fā)送給指定的接收者
     *
     * @param receiver 信息接數(shù)者
     * @param data     需要發(fā)送的內(nèi)容
     */
    public void send(String receiver, String data) throws IOException {
        OutputStream outputStream = mClient.getOutputStream();
        //模擬內(nèi)容格式:receiver+  # + content
        outputStream.write((receiver + "#" + data).getBytes());
    }

    /**
     * 斷開(kāi)連接
     *
     * @throws IOException
     */
    public void disconnect() throws IOException {
        if (mClient != null) {
            mClient.close();
            mClient = null;
        }
    }


    public void setOnConnectLinstener(ConnectLinstener linstener) {
        this.mListener = linstener;
    }

    /**
     * 數(shù)據(jù)接收回調(diào)接口
     */
    public interface ConnectLinstener {
        void onReceiveData(String data);
    }
}

定義服務(wù)端代碼

public class SocketServer {

    /**
     * 用來(lái)保存不同的客戶端
     */
    private static Map<String, Socket> mClients = new LinkedHashMap<>();

    public static void main(String[] args) {

        int port = 9999;
        try {
            //創(chuàng)建服務(wù)器
            ServerSocket serverSocket = new ServerSocket(port);
            while (true) {
                //獲取客戶端的連接
                final Socket socket = serverSocket.accept();

                new Thread(new Runnable() {
                    @Override
                    public void run() {
                        try {
                            //讀取從客戶端發(fā)送過(guò)來(lái)的數(shù)據(jù)
                            InputStream inputStream = socket.getInputStream();
                            byte[] buffer = new byte[1024];
                            int len = -1;
                            while ((len = inputStream.read(buffer)) != -1) {
                                String data = new String(buffer, 0, len);

                                //先認(rèn)證客戶端
                                if (data.startsWith("#")) {
                                    mClients.put(data, socket);
                                } else {
                                    //將數(shù)據(jù)發(fā)送給指定的客戶端
                                    String[] split = data.split("#");
                                    Socket c = mClients.get("#" + split[0]);
                                    OutputStream outputStream = c.getOutputStream();
                                    outputStream.write(split[1].getBytes());

                                }
                            }
                        } catch (IOException e) {
                            e.printStackTrace();
                        }


                    }
                }).start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }

    }
}

完整的demo

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個(gè)濱河市杠氢,隨后出現(xiàn)的幾起案子站刑,更是在濱河造成了極大的恐慌,老刑警劉巖鼻百,帶你破解...
    沈念sama閱讀 207,113評(píng)論 6 481
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件绞旅,死亡現(xiàn)場(chǎng)離奇詭異,居然都是意外死亡温艇,警方通過(guò)查閱死者的電腦和手機(jī)因悲,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 88,644評(píng)論 2 381
  • 文/潘曉璐 我一進(jìn)店門(mén),熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái)勺爱,“玉大人晃琳,你說(shuō)我怎么就攤上這事∷雎常” “怎么了卫旱?”我有些...
    開(kāi)封第一講書(shū)人閱讀 153,340評(píng)論 0 344
  • 文/不壞的土叔 我叫張陵,是天一觀的道長(zhǎng)围段。 經(jīng)常有香客問(wèn)我顾翼,道長(zhǎng),這世上最難降的妖魔是什么奈泪? 我笑而不...
    開(kāi)封第一講書(shū)人閱讀 55,449評(píng)論 1 279
  • 正文 為了忘掉前任适贸,我火速辦了婚禮,結(jié)果婚禮上涝桅,老公的妹妹穿的比我還像新娘拜姿。我一直安慰自己,他們只是感情好冯遂,可當(dāng)我...
    茶點(diǎn)故事閱讀 64,445評(píng)論 5 374
  • 文/花漫 我一把揭開(kāi)白布蕊肥。 她就那樣靜靜地躺著,像睡著了一般债蜜。 火紅的嫁衣襯著肌膚如雪晴埂。 梳的紋絲不亂的頭發(fā)上究反,一...
    開(kāi)封第一講書(shū)人閱讀 49,166評(píng)論 1 284
  • 那天,我揣著相機(jī)與錄音儒洛,去河邊找鬼精耐。 笑死,一個(gè)胖子當(dāng)著我的面吹牛琅锻,可吹牛的內(nèi)容都是我干的卦停。 我是一名探鬼主播,決...
    沈念sama閱讀 38,442評(píng)論 3 401
  • 文/蒼蘭香墨 我猛地睜開(kāi)眼恼蓬,長(zhǎng)吁一口氣:“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼惊完!你這毒婦竟也來(lái)了?” 一聲冷哼從身側(cè)響起处硬,我...
    開(kāi)封第一講書(shū)人閱讀 37,105評(píng)論 0 261
  • 序言:老撾萬(wàn)榮一對(duì)情侶失蹤小槐,失蹤者是張志新(化名)和其女友劉穎,沒(méi)想到半個(gè)月后荷辕,有當(dāng)?shù)厝嗽跇?shù)林里發(fā)現(xiàn)了一具尸體凿跳,經(jīng)...
    沈念sama閱讀 43,601評(píng)論 1 300
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 36,066評(píng)論 2 325
  • 正文 我和宋清朗相戀三年疮方,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了控嗜。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 38,161評(píng)論 1 334
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡骡显,死狀恐怖疆栏,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情惫谤,我是刑警寧澤壁顶,帶...
    沈念sama閱讀 33,792評(píng)論 4 323
  • 正文 年R本政府宣布,位于F島的核電站石挂,受9級(jí)特大地震影響博助,放射性物質(zhì)發(fā)生泄漏险污。R本人自食惡果不足惜痹愚,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 39,351評(píng)論 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望蛔糯。 院中可真熱鬧拯腮,春花似錦、人聲如沸蚁飒。這莊子的主人今日做“春日...
    開(kāi)封第一講書(shū)人閱讀 30,352評(píng)論 0 19
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)淮逻。三九已至琼懊,卻和暖如春阁簸,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背哼丈。 一陣腳步聲響...
    開(kāi)封第一講書(shū)人閱讀 31,584評(píng)論 1 261
  • 我被黑心中介騙來(lái)泰國(guó)打工启妹, 沒(méi)想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人醉旦。 一個(gè)月前我還...
    沈念sama閱讀 45,618評(píng)論 2 355
  • 正文 我出身青樓饶米,卻偏偏與公主長(zhǎng)得像,于是被迫代替她去往敵國(guó)和親车胡。 傳聞我的和親對(duì)象是個(gè)殘疾皇子檬输,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 42,916評(píng)論 2 344

推薦閱讀更多精彩內(nèi)容

  • Spring Cloud為開(kāi)發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見(jiàn)模式的工具(例如配置管理,服務(wù)發(fā)現(xiàn)匈棘,斷路器丧慈,智...
    卡卡羅2017閱讀 134,601評(píng)論 18 139
  • Android 自定義View的各種姿勢(shì)1 Activity的顯示之ViewRootImpl詳解 Activity...
    passiontim閱讀 171,522評(píng)論 25 707
  • 點(diǎn)擊查看原文 Web SDK 開(kāi)發(fā)手冊(cè) SDK 概述 網(wǎng)易云信 SDK 為 Web 應(yīng)用提供一個(gè)完善的 IM 系統(tǒng)...
    layjoy閱讀 13,677評(píng)論 0 15
  • 發(fā)現(xiàn) 關(guān)注 消息 iOS 第三方庫(kù)、插件主卫、知名博客總結(jié) 作者大灰狼的小綿羊哥哥關(guān)注 2017.06.26 09:4...
    肇東周閱讀 12,033評(píng)論 4 62
  • 在生活中伊滋,一感覺(jué)和別人聊得來(lái),就恨不得掏心掏肺队秩,因此一旦有細(xì)小的背叛笑旺,就會(huì)耿耿于懷。其實(shí)不是別人的錯(cuò)馍资,而是自己的錯(cuò)...
    大人的大閱讀 274評(píng)論 0 0