Commit 1dd297e9 authored by 王雷's avatar 王雷

修改socket的内存泄漏

parent 05019768
...@@ -51,7 +51,7 @@ repositories { ...@@ -51,7 +51,7 @@ repositories {
} }
group 'com.qmai.android.print' group 'com.qmai.android.print'
version '1.1.43-SNAPSHOT' version '1.1.45-SNAPSHOT'
gradlePublish { gradlePublish {
......
...@@ -17,7 +17,7 @@ abstract class DeviceManager { ...@@ -17,7 +17,7 @@ abstract class DeviceManager {
abstract var mType: Int abstract var mType: Int
var name: String? = null var name: String? = null
@Deprecated("后续用 mPrintSize 代替打印杯贴大小") @Deprecated("后续用 mPrintSize 代替打印杯贴大小")
var maxLineChars: Int = 55 var maxLineChars: Int = 80
var mPrintSize:Int = -1 var mPrintSize:Int = -1
companion object { companion object {
//小票模式 //小票模式
......
...@@ -22,7 +22,7 @@ android { ...@@ -22,7 +22,7 @@ android {
} }
group 'com.qmai.android.sdk' group 'com.qmai.android.sdk'
version '2.1.2-SNAPSHOT' version '2.1.3-SNAPSHOT'
gradlePublish { gradlePublish {
......
...@@ -171,6 +171,7 @@ public class BaseMsgWebSocket { ...@@ -171,6 +171,7 @@ public class BaseMsgWebSocket {
openTimingGetMessage = isOpen; openTimingGetMessage = isOpen;
return mBaseMsgWebSocket; return mBaseMsgWebSocket;
} }
/** /**
* 设置是否打印日志 * 设置是否打印日志
* *
...@@ -305,7 +306,7 @@ public class BaseMsgWebSocket { ...@@ -305,7 +306,7 @@ public class BaseMsgWebSocket {
Logger.e(TAG, "onMessage;;" + text); Logger.e(TAG, "onMessage;;" + text);
if (mWebSocketSubscriberListener != null) { if (mWebSocketSubscriberListener != null) {
mWebSocketSubscriberListener.onMessage(text); mWebSocketSubscriberListener.onMessage(text);
}else { } else {
// checkMessage(text); // checkMessage(text);
} }
} }
...@@ -382,8 +383,8 @@ public class BaseMsgWebSocket { ...@@ -382,8 +383,8 @@ public class BaseMsgWebSocket {
* 根据接收的消息,进行相应的处理,这里随便写的,要根据自己定的规则进行处理 * 根据接收的消息,进行相应的处理,这里随便写的,要根据自己定的规则进行处理
*/ */
// private void checkMessage (String message) { // private void checkMessage (String message) {
// 这里需要去调整,最好是调整成,任意结构的解析。 // 这里需要去调整,最好是调整成,任意结构的解析。
// 思路: 1、外部传入一个类型,T ,2、判断的条件是什么?能否传入或者注解。 // 思路: 1、外部传入一个类型,T ,2、判断的条件是什么?能否传入或者注解。
// try { // try {
// Log.d(TAG, "checkMessage: message= " + message); // Log.d(TAG, "checkMessage: message= " + message);
// JSONObject jsonObject = new JSONObject(message); // JSONObject jsonObject = new JSONObject(message);
...@@ -431,6 +432,7 @@ public class BaseMsgWebSocket { ...@@ -431,6 +432,7 @@ public class BaseMsgWebSocket {
// //
// } // }
// } // }
/** /**
* 发送绑定/验证 请求 * 发送绑定/验证 请求
*/ */
...@@ -441,7 +443,7 @@ public class BaseMsgWebSocket { ...@@ -441,7 +443,7 @@ public class BaseMsgWebSocket {
/** /**
* 入队操作 * 入队操作
*/ */
public void joinMessageQueue(String message){ public void joinMessageQueue(String message) {
if (useQueue) {//如果开启队列,消息加入队列--------------------------------------------- if (useQueue) {//如果开启队列,消息加入队列---------------------------------------------
Logger.e(TAG, "------消息加入队列 "); Logger.e(TAG, "------消息加入队列 ");
MessageQueue.getInstance().enQueue(message); MessageQueue.getInstance().enQueue(message);
...@@ -539,14 +541,14 @@ public class BaseMsgWebSocket { ...@@ -539,14 +541,14 @@ public class BaseMsgWebSocket {
if (openTimingGetMessage) { if (openTimingGetMessage) {
if (number * pingRate % getMessageInterval == 0) { if (number * pingRate % getMessageInterval == 0) {
//定时拉取服务端打印消息 //定时拉取服务端打印消息
if (mSocketTimerMessageListener!=null){ if (mSocketTimerMessageListener != null) {
mSocketTimerMessageListener.timerMessage(); mSocketTimerMessageListener.timerMessage();
} }
} else { } else {
Logger.e(TAG, "number = " + number + " ;; pingRate = " + pingRate + " ;; getMessageInterval = " + getMessageInterval); Logger.e(TAG, "number = " + number + " ;; pingRate = " + pingRate + " ;; getMessageInterval = " + getMessageInterval);
} }
} else { } else {
Logger.e(TAG, "isSocket2 = " + " ;; openTimingGetMessage = " + openTimingGetMessage); Logger.e(TAG, "isSocket2 = " + " ;; openTimingGetMessage = " + openTimingGetMessage);
} }
} }
}); });
...@@ -561,6 +563,14 @@ public class BaseMsgWebSocket { ...@@ -561,6 +563,14 @@ public class BaseMsgWebSocket {
Logger.e(TAG, "socket心跳已关闭..."); Logger.e(TAG, "socket心跳已关闭...");
} }
public void cancelListener() {
this.mWebSocketSubscriberListener = null;
this.mSocketTimerMessageListener = null;
this.queueMessageListener = null;
this.socketMessageListener = null;
this.socketConnectListener = null;
}
public BaseMsgWebSocket setWebSocketSubscriberListener(WebSocketSubscriberListener mWebSocketSubscriberListener) { public BaseMsgWebSocket setWebSocketSubscriberListener(WebSocketSubscriberListener mWebSocketSubscriberListener) {
this.mWebSocketSubscriberListener = mWebSocketSubscriberListener; this.mWebSocketSubscriberListener = mWebSocketSubscriberListener;
return this; return this;
......
...@@ -39,6 +39,7 @@ dependencies { ...@@ -39,6 +39,7 @@ dependencies {
implementation project(path: ':tools') implementation project(path: ':tools')
implementation 'androidx.recyclerview:recyclerview:1.0.0' implementation 'androidx.recyclerview:recyclerview:1.0.0'
implementation 'com.github.ybq:Android-SpinKit:1.4.0' implementation 'com.github.ybq:Android-SpinKit:1.4.0'
api 'com.blankj:utilcodex:1.30.6'
// implementation 'com.qmai.android.tools:tools:1.1.1-SNAPSHOT' // implementation 'com.qmai.android.tools:tools:1.1.1-SNAPSHOT'
...@@ -49,7 +50,7 @@ repositories { ...@@ -49,7 +50,7 @@ repositories {
group 'com.qmai.android.sdk' group 'com.qmai.android.sdk'
version '1.1.36-SNAPSHOT' version '1.1.37-SNAPSHOT'
gradlePublish { gradlePublish {
......
...@@ -12,14 +12,16 @@ import android.widget.Toast; ...@@ -12,14 +12,16 @@ import android.widget.Toast;
import androidx.annotation.MainThread; import androidx.annotation.MainThread;
import kotlin.Deprecated;
/** /**
* created by wangwei ON 2019-11-04 email:wangwei_5521@163.com * created by wangwei ON 2019-11-04 email:wangwei_5521@163.com
* *
* @version 1.1.1 * @version 1.1.1
* @Description * @Description
**/ **/
@Deprecated(message = "废弃用 com.blankj.utilcode.util.ToastUtils" )
public class ToastUtils { public class ToastUtils {
private static volatile ToastUtils instance; private static volatile ToastUtils instance;
private static final int COLOR_DEFAULT = 0xFEFFFFFF; private static final int COLOR_DEFAULT = 0xFEFFFFFF;
...@@ -45,14 +47,17 @@ public class ToastUtils { ...@@ -45,14 +47,17 @@ public class ToastUtils {
@MainThread @MainThread
public void showCenter(String msg) { public void showCenter(String msg) {
getToast().setText(msg); com.blankj.utilcode.util.ToastUtils.showShort(msg);
/*getToast().setText(msg);
mToast.setGravity(Gravity.CENTER, 0, 0); mToast.setGravity(Gravity.CENTER, 0, 0);
mToast.show(); mToast.show();*/
} }
@MainThread @MainThread
public void showToast(CharSequence msg) { public void showToast(CharSequence msg) {
getToast(); com.blankj.utilcode.util.ToastUtils.showShort(msg);
/* getToast();
View toastView = mToast.getView(); View toastView = mToast.getView();
TextView message = toastView.findViewById(android.R.id.message); TextView message = toastView.findViewById(android.R.id.message);
message.setText(msg); message.setText(msg);
...@@ -82,7 +87,7 @@ public class ToastUtils { ...@@ -82,7 +87,7 @@ public class ToastUtils {
} }
} }
} }
mToast.show(); mToast.show();*/
} }
public ToastUtils setsMsgTextSize(int msgTextSize) { public ToastUtils setsMsgTextSize(int msgTextSize) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment