save

罗明文

昨天 aa512ff5fc428fbee046d6bc0761c3675023769e

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
Êþº¾3
Ä
Ô
Õ    Ö
'×    Ø    Ù
'Ú<    ÛÜ
ÝÞß
à
Ýá
âãä
à
âå
æ    ç
èéêëêìêíêî
ïð
à
âñ
ò
óôõ
 à
óö    $÷ø
ù
úû    üýÿ









.

.
    

ÿÿ
.

.

-
 

8

8

8

*



*

 
8


8





8

 
H×


H
!
"
H
#
$
N
%
&
N
'
(
R
)
8
*
8
+
'
,    
-

.
/
ó
0    
1

2
3

2
4
è
5
6
7

8
9

:
;

<    $
=    $
>

?

@
A
Ý
B
C
ià
D
kà
E
F
Ý
G
H
rà
Ý
I
J
u×

K
L
M
N
O
yà
Ý
P
è
Q

R
S
è
T
U
InnerClasses
 wakeLockUtils
!Lcn/sinata/rxnetty/WakeLockUtils;
mNetChangeObserver
/Lcn/sinata/rxnetty/netStatus/NetChangeObserver;
    isDestroy

Z

subscriber
Lrx/Subscriber;
    Signature
$Lrx/Subscriber<Ljava/lang/Boolean;>;

receiveSub
*Lrx/Subscriber<Lio/netty/buffer/ByteBuf;>;
mConnection
1Lio/reactivex/netty/channel/ObservableConnection;
eLio/reactivex/netty/channel/ObservableConnection<Lio/netty/buffer/ByteBuf;Lio/netty/buffer/ByteBuf;>;
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
Lcn/sinata/rxnetty/CoreService;
onBind
.(Landroid/content/Intent;)Landroid/os/IBinder;
intent
Landroid/content/Intent;
RuntimeInvisibleAnnotations
Landroidx/annotation/Nullable;
onCreate
init

checkState
 StackMapTable
initCheckOb
onStartCommand
(Landroid/content/Intent;II)I
flags

I
startId
getNotification
()Landroid/app/Notification;
channel
!Landroid/app/NotificationChannel;
notificationManager
!Landroid/app/NotificationManager;
context
Landroid/content/Context;
mBuilder
Builder
.Landroidx/core/app/NotificationCompat$Builder;
icon
name
action
Ljava/lang/String;
 contentIntent
Landroid/app/PendingIntent;
    onDestroy
 connectServer
 connectionSub
 initReceiveOb
    reConnect
connect
$(Ljava/lang/String;I)Lrx/Observable;
url
port
9(Ljava/lang/String;I)Lrx/Observable<Ljava/lang/Boolean;>;
receive
()Lrx/Observable;
,()Lrx/Observable<Lio/netty/buffer/ByteBuf;>;
send
#(Ljava/lang/String;)Lrx/Observable;

s
5(Ljava/lang/String;)Lrx/Observable<Ljava/lang/Void;>;

access$000
0(Lcn/sinata/rxnetty/CoreService;)Lrx/Subscriber;
x0

access$002
?(Lcn/sinata/rxnetty/CoreService;Lrx/Subscriber;)Lrx/Subscriber;
x1

access$100
"(Lcn/sinata/rxnetty/CoreService;)V

access$200

SourceFile
CoreService.java¹‘»‘‹ˆ‘ƒ„…†‘
V
W
X
Y
Z
[
cn/sinata/rxnetty/CoreService$1Ð
\
]
^
_
`
cn/sinata/rxnetty/CoreService$2
a
b¡‘Ž
c
d
e
f
g
h
i
h
j
h
k
h¼‘
cn/sinata/rxnetty/CoreService$3
l
mž‘
n
o
p
cn/sinata/rxnetty/CoreService$4
q
r
s†
cn/sinata/rxnetty/Config§¨
t
u
android/app/Service
v
x¥
y
android/os/Build$VERSION_CODES
 VERSION_CODES
android/content/Context
notification
z
{
android/app/NotificationManager
android/app/NotificationChannel
101
服务
|
}
~
android/graphics/Color

€

~
‚
ƒ
„
,androidx/core/app/NotificationCompat$Builder
…
†
‡
ˆ
‡
‰
Š
icon_pt
mipmap
‹
Œ

Ž


‘
正在运行
’
“
app_name
string
”
•
–
“
java/lang/StringBuilder
—
˜
 .ACTION.CLICK
™
Œ
android/content/Intent
š
.broadcast.MBroadcastReceiver
›
œ
android/app/PendingIntent

ž
Ÿ
 
¡¨¸‘‚
¢
£‘
¤
p‡ˆ
¥
¦
h
§‘
¨Ã
netty
service关闭了
©
ª
«
¬
­
®º‘
¯µ
°¥½¾
±
²
³
´
µ
cn/sinata/rxnetty/CoreService$5
cn/sinata/rxnetty/CoreService$6
开始重新链接
service已经关闭
¶
[
cn/sinata/rxnetty/CoreService$7
\
·
2cn/sinata/rxnetty/pipeline/LengthFieldConfigurator
¸
¹
º
»½Ã
cn/sinata/rxnetty/CoreService$8
¼
½
¾Ã
¿
À
Á
Â
Ã
cn/sinata/rxnetty/CoreService
java/util/concurrent/TimeUnit
SECONDS
Ljava/util/concurrent/TimeUnit;
 rx/Observable
interval
1(JLjava/util/concurrent/TimeUnit;)Lrx/Observable;
    subscribe
"(Lrx/Subscriber;)Lrx/Subscription;
cn/sinata/rxnetty/NettyClient
getInstance
!()Lcn/sinata/rxnetty/NettyClient;
setSendListener
%(Lcn/sinata/rxnetty/OnSendListener;)V
/io/reactivex/netty/channel/ObservableConnection

getChannel
()Lio/netty/channel/Channel;
io/netty/channel/Channel
isActive
()Z

isWritable
isOpen
isRegistered
setOnCheckListener
&(Lcn/sinata/rxnetty/OnCheckListener;)V
,cn/sinata/rxnetty/netStatus/NetStateReceiver
registerNetworkStateReceiver
(Landroid/content/Context;)V
registerObserver
2(Lcn/sinata/rxnetty/netStatus/NetChangeObserver;)V
isStartForeground
startForeground
(ILandroid/app/Notification;)V
android/os/Build$VERSION
VERSION
SDK_INT
android/os/Build
getSystemService
&(Ljava/lang/String;)Ljava/lang/Object;
.(Ljava/lang/String;Ljava/lang/CharSequence;I)V
enableLights
(Z)V
 setLightColor
(I)V
setShowBadge
createNotificationChannel
$(Landroid/app/NotificationChannel;)V
$androidx/core/app/NotificationCompat
.(Landroid/content/Context;Ljava/lang/String;)V
setShowWhen
1(Z)Landroidx/core/app/NotificationCompat$Builder;
 setAutoCancel
getResources
!()Landroid/content/res/Resources;
getPackageName
()Ljava/lang/String;
android/content/res/Resources
 getIdentifier
9(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)I
setSmallIcon
1(I)Landroidx/core/app/NotificationCompat$Builder;
setContentText
H(Ljava/lang/CharSequence;)Landroidx/core/app/NotificationCompat$Builder;
    getString
(I)Ljava/lang/String;
setContentTitle
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
toString
(Ljava/lang/String;)V
setClassName
>(Ljava/lang/String;Ljava/lang/String;)Landroid/content/Intent;
getBroadcast
P(Landroid/content/Context;ILandroid/content/Intent;I)Landroid/app/PendingIntent;
setContentIntent
K(Landroid/app/PendingIntent;)Landroidx/core/app/NotificationCompat$Builder;
build
cn/sinata/rxnetty/WakeLockUtils
releaseWakeLock
unRegisterNetworkStateReceiver
 rx/Subscriber
isUnsubscribed
unsubscribe
close
cn/sinata/rxnetty/Logger

e
'(Ljava/lang/String;Ljava/lang/String;)V
$cn/sinata/rxnetty/netStatus/NetUtils
isNetworkAvailable
(Landroid/content/Context;)Z
 SOCKET_SERVER
SOCKET_PORT
rx/schedulers/Schedulers
io
()Lrx/Scheduler;
subscribeOn
(Lrx/Scheduler;)Lrx/Observable;
timer
)(Lrx/functions/Action1;)Lrx/Subscription;
io/reactivex/netty/RxNetty
createTcpClient
k(Ljava/lang/String;ILio/reactivex/netty/pipeline/PipelineConfigurator;)Lio/reactivex/netty/client/RxClient;
"io/reactivex/netty/client/RxClient
flatMap
%(Lrx/functions/Func1;)Lrx/Observable;
getInput
java/lang/String
getBytes
()[B
writeBytesAndFlush
([B)Lrx/Observable;!'‚ƒ„…†‡ˆ
‰Š‹ˆ
‰ŒŽ
‰
‘
’A
*·*
µ*µ±“v    °”
•–
—˜’6

°“
%”•–™š
›
œ
‘
’L
*·²
¸»Y*· ¶W±“*->”
•–ž‘
’E
¸»Y*·¶*¶±“D`a”
•–
Ÿ‘
’ 

R*´ÆI*´¶Æ?*´¶¹
™0*´¶¹
™!*´¶¹
™*´¶¹
š*·±“de$f3gBhMiQk”
R•– ûM¡‘
’=
¸»Y*·¶±“
nt”
•–
¢£
’–-*¶*¸*» Y*·!µ*´¸"²#™ *e*·%¶&¬“{}~Š‹!Œ+Ž”*-•–-™š
-¤¥-¦¥ 
+§¨
’
Íä²(¡3*+¶,À-L+Æ%».Y/0·1M,¶2,4¶5,¶6+,¶7*L»8Y+/·9M,¶:W,¶;W+¶<=>+¶?¶@>,¶AW,B¶CW+¶<DE+¶?¶@6,*¶F¶GW»HY·I*¶J¶KL¶K¶M:»NY·O:*¶J»HY·I*¶J¶KP¶K¶M¶QW+S¸T:,¶UW,¶V°“b’”•–˜#™(š.›3œ8Ÿ: E¡K¢Q£a¤g¥n¦§Š¨¢©­ªÍ«Ø¬ß­”f
#©ª&«¬
䕖:ª­®
EŸ¯±aƒ²¥e³¥¢B´µ­7™šØ¶· 
8
¸‘
’È
b*·W*µ*´XÆ
*´X¶Y*¸Z*´[Æ*´[¶\š
*´[¶]*´Æ*´¶\š
*´¶]*´Æ*´¶^W_`¸a±“6 ´µ    ¶·¸¹,º3¼D½K¿RÀZÂaÔ
b•– ¹‘
’k
$*¸b™*·c*²d²e¶f¸g¶h*´[¶W±“ÇÈÉÊË#Δ
$•– 
#º‘
’r
**´[Æ*´[¶\š
*´[¶]*
µ[*»iY*·jµ[±“ÓÔÕ×Ù)ô”
*•– »‘
’;
 *»kY*·lµ±“
ù
”
 •–¼‘
’s
,_m¸a*´™_n¸a±o²
¸q»rY*·s¶tW±“




"+
-”
,•– 

½¾’g+»uY·v¸w¹x
»yY*·z¶{°“
3
4
5
3” •–¿µ
À¥‰Á
ÂÃ’L

*´Æ*´¶|°
°“
I
J
L”
•– 
‰Ä
ÅÆ’Z*´Æ*´+¶}¶~°
°“
P
Q
S”•–ǵ
 
‰ÈÉÊ
’/

*´°“
”
˖ÌÍ
’;*+Zµ°“
”˖Έ
ÏÐ
’/

*·±“
”
˖ÑÐ
’/

*·
±“
”
˖ÒӀZyrki 8
°    )þ
    üþ
w