package?com.youngch.common.myapplication.mqtt;


import?android.content.Context;

import?com.youngch.common.myapplication.mqtt.service.MqttActionListener;
import?com.youngch.common.myapplication.mqtt.service.MqttAndroidClient;

import?org.eclipse.paho.client.mqttv3.IMqttActionListener;
import?org.eclipse.paho.client.mqttv3.MqttCallback;
import?org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import?org.eclipse.paho.client.mqttv3.MqttException;


/**
?*?Created?by?ZhangHs?on?2018/4/19.
?*?對mqtt的封裝
?*/

public?class?MqttFactory?{
????private?final?Context?context;
????private?final?String?serverIP;
????private?final?String?port;
????private?final?boolean?autoConnect;
????private?final?int?connectionTimeout;
????private?final?int?keepAliveInterval;
????private?final?String?clientId;
????private?final?MqttCallback?callback;

????private?MqttAndroidClient?client;
????private?MqttConnectOptions?options;
????private?MqttActionListener?actionListener;

????public?MqttFactory（Builder?builder）?{
????????this.context?=?builder.context;
????????this.serverIP?=?builder.serverIP;
????????this.autoConnect?=?builder.autoConnect;
????????this.connectionTimeout?=?builder.connectionTimeout;
????????this.keepAliveInterval?=builder.?keepAliveInterval;
????????this.clientId?=?builder.clientId;
????????this.callback=builder.callback;
????????this.port=builder.port;
????????init（）;
????}
????private?void?init（）{
????????client=new?MqttAndroidClient（context“tcp://“+serverIP+“:“+portclientId）;
????????client.setCallback（callback）;
????????options=new?MqttConnectOptions（）;
????????options.setAutomaticReconnect（autoConnect）;
????????options.setConnectionTimeout（connectionTimeout）;
????????options.setKeepAliveInterval（keepAliveInterval）;

????}

????public?void?connect（）{
????????try?{
????????????client.connect（options?null?actionListener=new?MqttActionListener（MqttActionListener.TYPE.CONNECTMQTT））;
????????}?catch?（MqttException?e）?{
????????????e.printStackTrace（）;
????????}
????}


????public?static?class?Builder?{
????????private?Context?context;
????????private?String?serverIP;
????????private?String?port;
????????private?boolean?autoConnect;
????????private?int?connectionTimeout;
????????private?int?keepAliveInterval;
????????private?String?clientId;
????????private?MqttCallback?callback;

????????public?Builder（Context?context）?{
????????????this.context?=?context;
????????}
????????public?Builder?port（String?port）?{
????????????this.port?=?port;
????????????return?this;
????????}
????????public?Builder?serverIP（String?serverIP）?{
????????????this.serverIP?=?serverIP;
????????????return?this;
????????}
????????public?Builder?clientId（String?clientId）?{
????????????this.clientId?=?clientId;
????????????return?this;
????????}
????????public?Builder?keepAliveInterval（int?keepAliveInterval）?{
????????????this.keepAliveInterval?=?keepAliveInterval;
????????????return?this;
???

?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----
?????目錄???????????0??2018-04-24?13:23??mqtt\
?????文件????????4657??2018-04-20?15:27??mqtt\MqttFactory.java
?????文件????????1887??2018-04-20?15:27??mqtt\MqttIn.java
?????目錄???????????0??2018-04-20?15:29??mqtt\service\
?????文件????????5083??2018-04-20?14:17??mqtt\service\AlarmPingSender.java
?????文件?????????521??2018-04-20?14:17??mqtt\service\BuildConfig.java
?????文件???????10895??2018-04-20?15:29??mqtt\service\DatabaseMessageStore.java
?????文件?????????672??2018-04-20?15:29??mqtt\service\MessageStore.java
?????文件????????1846??2018-04-20?15:27??mqtt\service\MqttActionListener.java
?????文件???????26588??2018-04-20?15:27??mqtt\service\MqttAndroidClient.java
?????文件????????1242??2018-04-20?15:27??mqtt\service\MqttCallBackListener.java
?????文件???????34493??2018-04-20?15:29??mqtt\service\MqttConnection.java
?????文件?????????997??2018-04-20?13:24??mqtt\service\MqttDeliveryTokenAndroid.java
?????文件???????15375??2018-04-20?15:29??mqtt\service\MqttService.java
?????文件?????????634??2018-04-20?13:24??mqtt\service\MqttServiceBinder.java
?????文件????????2365??2018-04-20?13:24??mqtt\service\MqttServiceConstants.java
?????文件????????4742??2018-04-20?13:24??mqtt\service\MqttTokenAndroid.java
?????文件?????????315??2018-04-20?13:24??mqtt\service\MqttTraceHandler.java
?????文件????????1703??2018-04-20?13:24??mqtt\service\ParcelableMqttMessage.java
?????文件?????????196??2018-04-20?13:24??mqtt\service\Status.java