From bb518e8e8e7c6dc5c23476170f7901ad6a69de3c Mon Sep 17 00:00:00 2001
From: 18034727885 <973609879@qq.com>
Date: 星期三, 01 七月 2026 14:31:39 +0800
Subject: [PATCH] 修复问题
---
rxnetty/src/main/java/cn/sinata/rxnetty/CoreService.java | 47 ++++++++++++++++++++---------------------------
1 files changed, 20 insertions(+), 27 deletions(-)
diff --git a/rxnetty/src/main/java/cn/sinata/rxnetty/CoreService.java b/rxnetty/src/main/java/cn/sinata/rxnetty/CoreService.java
index 93f3225..38cb22b 100644
--- a/rxnetty/src/main/java/cn/sinata/rxnetty/CoreService.java
+++ b/rxnetty/src/main/java/cn/sinata/rxnetty/CoreService.java
@@ -29,6 +29,7 @@
import io.reactivex.netty.channel.ObservableConnection;
import rx.Observable;
import rx.Subscriber;
+import rx.android.schedulers.AndroidSchedulers;
import rx.functions.Action1;
import rx.functions.Func1;
import rx.schedulers.Schedulers;
@@ -283,36 +284,28 @@
private void reConnect() {
if (isDestroy) {
-// String s = CacheUtil.get().getAsString("reConnect");
-// s = s + "###"+ "server已死";
-// CacheUtil.get().put("reConnect",s);
return;
}
//reconnect
-// String s = CacheUtil.get().getAsString("reConnect");
-// s = s + "###"+ "倒计时3秒";
-// CacheUtil.get().put("reConnect",s);
-
- Observable.timer(3, TimeUnit.SECONDS).subscribe(new Action1<Long>() {
- @Override
- public void call(Long aLong) {
-// String s = CacheUtil.get().getAsString("reConnect");
-// s = s + "###"+ "倒计时结束";
-// CacheUtil.get().put("reConnect",s);
- if (mConnection != null) {
- mConnection.close();
- mConnection = null;
- }
-
- Log.i("CoreService", "sendHeart_websocket长连接断开，重新连接");
- connectServer();
- }
-
- @Override
- protected void finalize() throws Throwable {
- super.finalize();
- }
- });
+ Observable.timer(3, TimeUnit.SECONDS)
+ .subscribeOn(Schedulers.io())
+ .observeOn(AndroidSchedulers.mainThread())
+ .subscribe(new Action1<Long>() {
+ @Override
+ public void call(Long aLong) {
+ if (mConnection != null) {
+ mConnection.close();
+ mConnection = null;
+ }
+ Log.i("CoreService", "sendHeart_websocket长连接断开，重新连接");
+ connectServer();
+ }
+ }, new Action1<Throwable>() {
+ @Override
+ public void call(Throwable throwable) {
+ throwable.printStackTrace();
+ }
+ });
}
--
Gitblit v1.7.1