在Android上面如何使用帶有心跳檢測的Socket

由于移動設(shè)備的網(wǎng)絡(luò)的復(fù)雜性，經(jīng)常會出現(xiàn)網(wǎng)絡(luò)斷開，如果沒有心跳包的檢測，客戶端只會在需要發(fā)送數(shù)據(jù)的時候才知道自己已經(jīng)斷線，會延誤，甚至丟失服務(wù)器發(fā)送過來的數(shù)據(jù)。一下簡單建立一個帶有心跳檢測的SocketDemo。

Android 后臺Servevice

package org.feng.sockettest.server;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.lang.ref.WeakReference;
import java.net.Socket;import java.net.UnknownHostException;
import java.util.Arrays;
import android.app.Service;
import android.content.Intent;
import android.os.Handler;
import android.os.IBinder;
import android.os.RemoteException;
import android.support.v4.content.LocalBroadcastManager;
import android.util.Log;

public class BackService extends Service { 
    private static final String TAG = "BackService"; 
    private static final long HEART_BEAT_RATE = 3 * 1000; 
    public static final String HOST = "192.168.1.101";// "192.168.1.21";// 
    public static final int PORT = 9800; 
    public static final String MESSAGE_ACTION="org.feng.message_ACTION"; 
    public static final String HEART_BEAT_ACTION="org.feng.heart_beat_ACTION"; 
    private ReadThread mReadThread; 
    private LocalBroadcastManager mLocalBroadcastManager;   
    private WeakReference<Socket> mSocket; // For heart Beat     
    private Handler mHandler = new Handler();
    private Runnable heartBeatRunnable = new Runnable() { 
        @Override 
        public void run() {
            if (System.currentTimeMillis() - sendTime >= HEART_BEAT_RATE) { 
                boolean isSuccess = sendMsg("");//就發(fā)送一個\r\n過去 如果發(fā)送失敗，就重新初始化一個socket 
                if (!isSuccess) {                   
                mHandler.removeCallbacks(heartBeatRunnable);                    
                mReadThread.release();                  
                releaseLastSocket(mSocket); 
                new InitSocketThread().start();             
                }           
            }           
        mHandler.postDelayed(this, HEART_BEAT_RATE);
        }   
    }; 
    private long sendTime = 0L; 
    private IBackService.Stub iBackService = new IBackService.Stub() { 
        @Override 
        public boolean sendMessage(String message) throws RemoteException { 
            return sendMsg(message);        
        }   
    }; 

    @Override 
    public IBinder onBind(Intent arg0) { 
        return iBackService;    
    } 

    @Override 
    public void onCreate() { 
        super.onCreate(); 
        new InitSocketThread().start();     
        mLocalBroadcastManager=LocalBroadcastManager.getInstance(this);         
    } 
    public boolean sendMsg(String msg) { 
        if (null == mSocket || null == mSocket.get()) { 
            return false;       
        }       
        Socket soc = mSocket.get();
        try { 
            if (!soc.isClosed() && !soc.isOutputShutdown()) {
                OutputStream os = soc.getOutputStream();                
                String message = msg + "\r\n";                                  
                os.write(message.getBytes());               
                os.flush();             
                sendTime = System.currentTimeMillis();//每次發(fā)送成數(shù)據(jù)，就改一下最后成功發(fā)送的時間，節(jié)省心跳間隔時間 
            } else { 
                return false;           
            }       
        } catch (IOException e) {           
            e.printStackTrace(); 
            return false;       
        }
        return true;    
    } 
    private void initSocket() {
    //初始化Socket 
        try {           
            Socket so = new Socket(HOST, PORT);         
            mSocket = new WeakReference<Socket>(so);    
            mReadThread = new ReadThread(so);           
            mReadThread.start();            
            mHandler.postDelayed(heartBeatRunnable,             
            HEART_BEAT_RATE);//初始化成功后，就準(zhǔn)備發(fā)送心跳包 
        } catch (UnknownHostException e) {
            e.printStackTrace();        
        } catch (IOException e) {           
            e.printStackTrace();        
        }   
    } 
    private void releaseLastSocket(WeakReference<Socket> mSocket){ 
        try { 
            if (null != mSocket) {              
                Socket sk = mSocket.get(); 
                if (!sk.isClosed()) {                   
                    sk.close();             
                }               
                sk = null;              
                mSocket = null;         
            }       
        } catch (IOException e) {           
            e.printStackTrace();        
        }   
    } 
    class InitSocketThread extends Thread { 
        @Override 
        public void run() { 
            super.run();            
            initSocket();       
        }   
    } 
    // Thread to read content from Socket 
    class ReadThread extends Thread { 
        private WeakReference<Socket> mWeakSocket; 
        private boolean isStart = true; 
        public ReadThread(Socket socket) {          
            mWeakSocket = new WeakReference<Socket>(socket);        
        } 
        public void release() {         
            isStart = false;            
            releaseLastSocket(mWeakSocket);     
        } 
        @Override 
        public void run() { 
            super.run();            
            Socket socket = mWeakSocket.get();
             if (null != socket) { 
                try {                   
                    InputStream is = socket.getInputStream(); 
                    byte[] buffer = new byte[1024 * 4];
                    int length = 0; 
                    while (!socket.isClosed() &&!socket.isInputShutdown()&& isStart && ((length = is.read(buffer)) != -1)) {
                        if (length > 0) {                           
                            String message = new String(Arrays.copyOf(buffer,length)).trim();                           
                            Log.e(TAG, message); //收到服務(wù)器過來的消息，就通過Broadcast發(fā)送出去 
                            if(message.equals("ok")){
                                //處理心跳回復(fù) 
                                Intent intent=new Intent(HEART_BEAT_ACTION);                                
                                mLocalBroadcastManager.sendBroadcast(intent);                           
                            }else{ 
                                //其他消息回復(fù) 
                                Intent intent=new Intent(MESSAGE_ACTION);                               
                                intent.putExtra("message", message);                                
                                mLocalBroadcastManager.sendBroadcast(intent);                           
                            }                       
                        }                   
                    }               
                } catch (IOException e) {                   
                    e.printStackTrace();                
                }           
            }       
        }   
    }
}

在Activity中發(fā)送以及接收數(shù)據(jù)：

package org.feng.sockettest;
import java.lang.ref.WeakReference;
import org.feng.sockettest.server.BackService;
import org.feng.sockettest.server.IBackService;
import android.app.Activity;
import android.content.BroadcastReceiver;
import android.content.ComponentName;
import android.content.Context;
import android.content.Intent;
import android.content.IntentFilter;
import android.content.ServiceConnection;
import android.os.Bundle;
import android.os.IBinder;
import android.os.RemoteException;
import android.support.v4.content.LocalBroadcastManager;
import android.view.View;
import android.widget.EditText;
import android.widget.TextView;
import android.widget.Toast;


public class MainActivity extends Activity { 
    private static final String TAG = "MainActivity"; 
    private IBackService iBackService; 
    private ServiceConnection conn = new ServiceConnection() { 
        @Override 
        public void onServiceDisconnected(ComponentName name) {         
            iBackService = null;        
        } 
        @Override 
        public void onServiceConnected(ComponentName name, IBinder service) {           
            iBackService = IBackService.Stub.asInterface(service);      
        }   
    }; 
    private TextView mResultText; 
    private EditText mEditText; 
    private Intent mServiceIntent; 
    class MessageBackReciver extends BroadcastReceiver { 
        private WeakReference<TextView> textView; 
        public MessageBackReciver(TextView tv) {            
            textView = new WeakReference<TextView>(tv);     
        } 
        @Override 
        public void onReceive(Context context, Intent intent) {         
            String action = intent.getAction();         
            TextView tv = textView.get();
             if (action.equals(BackService.HEART_BEAT_ACTION)) { 
                if (null != tv) {                   
                    tv.setText("Get a heart heat");             
                }           
            } else {                
                String message = intent.getStringExtra("message");              
                tv.setText(message);            
            }       
        };  
    } 
    private MessageBackReciver mReciver; 
    private IntentFilter mIntentFilter; 
    private LocalBroadcastManager mLocalBroadcastManager; 
    @Override 
    public void onCreate(Bundle savedInstanceState) { 
        super.onCreate(savedInstanceState);     
        setContentView(R.layout.activity_main);     
        mLocalBroadcastManager = LocalBroadcastManager.getInstance(this);       
        mResultText = (TextView) findViewById(R.id.resule_text);        
        mEditText = (EditText) findViewById(R.id.content_edit);     
        mReciver = new MessageBackReciver(mResultText);     
        mServiceIntent = new Intent(this, BackService.class);       
        mIntentFilter = new IntentFilter();     
        mIntentFilter.addAction(BackService.HEART_BEAT_ACTION);     
        mIntentFilter.addAction(BackService.MESSAGE_ACTION);    
    } 
    @Override 
    protected void onStart() { 
        super.onStart();        
        mLocalBroadcastManager.registerReceiver(mReciver, mIntentFilter);       
        bindService(mServiceIntent, conn, BIND_AUTO_CREATE);    
    } 
    @Override 
    protected void onStop() { 
        super.onStop();     
        unbindService(conn);        
        mLocalBroadcastManager.unregisterReceiver(mReciver);    
    } 
    public void onClick(View view) { 
        switch (view.getId()) { 
            case R.id.send:         
                String content = mEditText.getText().toString(); 
                try { 
                    boolean isSend = iBackService.sendMessage(content);//Send Content by socket 
                    Toast.makeText(this, isSend ? "success" : "fail",                       Toast.LENGTH_SHORT).show();             
                    mEditText.setText("");          
                } catch (RemoteException e) {               
                    e.printStackTrace();            
                } 
                break; 
            default: break;     
        }   
    }
}

完整項目帶服務(wù)器段代碼的見http://git.oschina.net/fengcunhan/SocketTest.git
該文章轉(zhuǎn)載自：https://my.oschina.net/fengcunhan/blog/178155

最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點，簡書系信息發(fā)布平臺，僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

  • Spring Cloud為開發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見模式的工具（例如配置管理，服務(wù)發(fā)現(xiàn)，斷路器，智...
    卡卡羅2017閱讀 136,545評論 19贊 139
  • Android 自定義View的各種姿勢1 Activity的顯示之ViewRootImpl詳解 Activity...
    passiontim閱讀 178,983評論 25贊 709
  • 一、本周小理論 1.沉沒成本效應(yīng)——及時止損，當(dāng)下決策莫回看 2.自由個性理論——分清主客，性格定義不設(shè)限 3.踢...
    我是駱駝草閱讀 290評論 0贊 4
  • 今天看了王路老師的文章，王路：勞碌命是如何養(yǎng)成的？覺得很有感觸。 這些舉動有很好的理由：看郵件是怕耽誤工作；看朋友...
    郭志遠閱讀 346評論 0贊 1
  • 今天晚上我給孩子檢查作業(yè)時，看到張清菡書寫的字，五花八門的結(jié)構(gòu)，就如大風(fēng)給刮得。我就和她說，字就如其人，你字寫的好...
    兆木兆木閱讀 178評論 0贊 1

友情鏈接更多精彩內(nèi)容