一、单向认证

public class SSLSingleTrustManager implements TrustManager, X509TrustManager {

public void checkClientTrusted(X509Certificate[] chain, String authType)throws CertificateException {

return;

}

public void checkServerTrusted(X509Certificate[] chain, String authType)throws CertificateException {

return;

}

public X509Certificate[]getAcceptedIssuers() {

return null;

}

public boolean isServerTrusted(X509Certificate[] certs) {

return true;

}

public boolean isClientTrusted(X509Certificate[] certs) {

return true;

}

}

private void singleTrust(MqttConnectOptions options ){

TrustManager[] trustAllCerts =new TrustManager[]{new SSLSingleTrustManager()};

SSLContext sc =null;

try {

sc =SSLContext.getInstance("SSL");

sc.init(null, trustAllCerts, null);

}catch (NoSuchAlgorithmException e) {

e.printStackTrace();

}catch (KeyManagementException e) {

e.printStackTrace();

}

SocketFactory factory = sc.getSocketFactory();

options.setSocketFactory(factory);

}

二、手动重连

用手动重连原因当然是自动重连不好用了！！

options.setAutomaticReconnect(true);

这一段是源码，重连

/**

* Reconnect

* Only appropriate if cleanSession is false and we were connected.

* Declare as synchronized to avoid multiple calls to this method to send connect

* multiple times

*/

synchronized void reconnect() {

if (myClient ==null) {

service.traceError(TAG,"Reconnect myClient = null. Will not do reconnect");

return;

}

if (isConnecting) {

service.traceDebug(TAG, "The client is connecting. Reconnect return directly.");

return ;

}

if(!service.isOnline()){

service.traceDebug(TAG,

"The network is not reachable. Will not do reconnect");

return;

}

if(connectOptions.isAutomaticReconnect()){

//The Automatic reconnect functionality is enabled here

Log.i(TAG, "Requesting Automatic reconnect using New Java AC");

final Bundle resultBundle =new Bundle();

resultBundle.putString(

MqttServiceConstants.CALLBACK_ACTIVITY_TOKEN,

reconnectActivityToken);

resultBundle.putString(

MqttServiceConstants.CALLBACK_INVOCATION_CONTEXT, null);

resultBundle.putString(MqttServiceConstants.CALLBACK_ACTION,

MqttServiceConstants.CONNECT_ACTION);

try {

myClient.reconnect();

}catch (MqttException ex){

Log.e(TAG, "Exception occurred attempting to reconnect: " + ex.getMessage());

setConnectingState(false);

handleException(resultBundle, ex);

}

}else if (disconnected && !cleanSession) {

// use the activityToke the same with action connect

service.traceDebug(TAG,"Do Real Reconnect!");

final Bundle resultBundle =new Bundle();

resultBundle.putString(

MqttServiceConstants.CALLBACK_ACTIVITY_TOKEN,

reconnectActivityToken);

resultBundle.putString(

MqttServiceConstants.CALLBACK_INVOCATION_CONTEXT, null);

resultBundle.putString(MqttServiceConstants.CALLBACK_ACTION,

MqttServiceConstants.CONNECT_ACTION);

try {

IMqttActionListener listener =new MqttConnectionListener(resultBundle) {

@Override

public void onSuccess(IMqttToken asyncActionToken) {

// since the device's cpu can go to sleep, acquire a

// wakelock and drop it later.

service.traceDebug(TAG,"Reconnect Success!");

service.traceDebug(TAG,"DeliverBacklog when reconnect.");

doAfterConnectSuccess(resultBundle);

}

@Override

public void onFailure(IMqttToken asyncActionToken, Throwable exception) {

resultBundle.putString(

MqttServiceConstants.CALLBACK_ERROR_MESSAGE,

exception.getLocalizedMessage());

resultBundle.putSerializable(

MqttServiceConstants.CALLBACK_EXCEPTION,

exception);

service.callbackToActivity(clientHandle, Status.ERROR,

resultBundle);

doAfterConnectFail(resultBundle);

}

};

myClient.connect(connectOptions, null, listener);

setConnectingState(true);

}catch (MqttException e) {

service.traceError(TAG, "Cannot reconnect to remote server." + e.getMessage());

setConnectingState(false);

handleException(resultBundle, e);

}catch (Exception e){

/* TODO: Added Due to: https://github.com/eclipse/paho.mqtt.android/issues/101

For some reason in a small number of cases, myClient is null here and so

a NullPointer Exception is thrown. This is a workaround to pass the exception

up to the application. myClient should not be null so more investigation is

required.

*/

service.traceError(TAG, "Cannot reconnect to remote server." + e.getMessage());

setConnectingState(false);

MqttException newEx =new MqttException(MqttException.REASON_CODE_UNEXPECTED_ERROR, e.getCause());

handleException(resultBundle, newEx);

}

}

}

一顿骚操作看的眼花缭乱，经过断网测试，这经常抛出已连接客户机的异常拒绝重连，导致一旦掉线后一直无法重连。

于是乎有了不要自动重连手动重连的方案，每十秒尝试一次重连，屡试不爽

public void connectionLost(Throwable cause) {

if (!isConnecting){

startReconnect();

isConnecting =true;

}

}

private void startReconnect(){

if (!isDissConnectedBySelf) {

synchronized (MQTTManager.class) {

LogUtils.d(TAG, "开始重连 ");

runnable = getRunnable();

isNeedReConnect =true;

mHandler.postDelayed(runnable, 2000);

}

}else {

LogUtils.d(TAG, "主动断开不重连接 ");

}

}

private void stopToConnect(){

LogUtils.d(TAG,"结束重连 ");

isNeedReConnect =false;

isDissConnectedBySelf =false;

mHandler.removeCallbacks(runnable);

runnable =null;

}

private RunnablegetRunnable(){

if (runnable!=null){

return runnable;

}

return new Runnable() {

@Override

public void run() {

LogUtils.d(TAG,isNeedReConnect +" "+isConnectIsNomarl() +" "+isNetworkAvailable());

if (isNeedReConnect &&isConnectIsNomarl() &&isNetworkAvailable()) {

LogUtils.d(TAG,"重连尝试 "+currentConnectTime++);

doClientConnection();

}

mHandler.postDelayed(this,TIME_OUT);

}

};

}