package cn.sinata.rxnetty;
|
|
import android.app.job.JobScheduler;
|
import android.content.Context;
|
import android.content.Intent;
|
import android.os.Build;
|
import android.util.Log;
|
|
import java.util.ArrayList;
|
|
/**
|
* 使用的是rxjava1。而不是rxjava2。所以尽量不要在主项目中使用rxjava1相关类。以免交叉。不好维护修改。
|
*/
|
|
public class NettyClient {
|
|
public boolean isStop = false;
|
private Context mContext;
|
private ArrayList<OnMessageListener> listeners ;
|
private OnSendListener sendListener;
|
private OnConnectListener connectListener;
|
private OnCheckListener onCheckListener;
|
|
public void init(Context context,String server,int port) {
|
init(context,server,port,false);
|
}
|
|
public void init(Context context,String server,int port,boolean isStartForeground) {
|
mContext = context.getApplicationContext();
|
Config.SOCKET_SERVER = server;
|
Config.SOCKET_PORT = port;
|
Config.isStartForeground= isStartForeground;
|
}
|
|
public OnConnectListener getConnectListener() {
|
return connectListener;
|
}
|
|
private static final class Singleton {
|
private final static NettyClient INSTANCE = new NettyClient();
|
}
|
|
public static NettyClient getInstance() {
|
return Singleton.INSTANCE;
|
}
|
|
ArrayList<OnMessageListener> getListeners() {
|
return listeners;
|
}
|
|
|
|
/**
|
* 添加消息监听
|
* @param listener
|
*/
|
public void addOnMessageListener(OnMessageListener listener) {
|
if (listeners == null) {
|
listeners = new ArrayList<>();
|
}
|
if (listener != null && !listeners.contains(listener)) {
|
listeners.add(listener);
|
}
|
}
|
|
/**
|
* 连接完成监听
|
* @param listener
|
*/
|
public void setOnConnectListener(OnConnectListener listener) {
|
this.connectListener = listener;
|
}
|
|
/**
|
* 移除消息监听
|
* @param listener
|
*/
|
public void removeOnMessageListener(OnMessageListener listener) {
|
if (listeners == null) {
|
return;
|
}
|
if (listener != null && listeners.contains(listener)) {
|
listeners.remove(listener);
|
}
|
}
|
|
void setSendListener(OnSendListener listener) {
|
this.sendListener = listener;
|
}
|
|
void setOnCheckListener(OnCheckListener listener) {
|
this.onCheckListener = listener;
|
}
|
|
/**
|
* 发送消息给服务器
|
* @param msg
|
*/
|
public void sendMessage(String msg) {
|
if (sendListener != null) {
|
Log.e("Heart",msg);
|
sendListener.onSend(msg);
|
}
|
}
|
|
/**
|
* 检测netty连接状况
|
*/
|
public void checkNettyState() {
|
if (onCheckListener != null) {
|
onCheckListener.doCheck();
|
}
|
}
|
|
public void startService() {
|
if (mContext == null) {
|
return;
|
}
|
if (!isStop) {
|
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.LOLLIPOP) {
|
try {
|
Intent intent = new Intent(this.getContext(), NJobService.class);
|
this.mContext.stopService(intent);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
} else {
|
this.mContext.stopService(new Intent(this.mContext, CoreService.class));
|
}
|
}
|
isStop = false;
|
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.LOLLIPOP) {
|
try {
|
Intent intent = new Intent(this.getContext(), NJobService.class);
|
this.mContext.startService(intent);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
} else {
|
this.mContext.startService(new Intent(this.mContext, CoreService.class));
|
}
|
}
|
|
public void stopService() {
|
if (mContext == null) {
|
return;
|
}
|
isStop = true;
|
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.LOLLIPOP) {
|
try {
|
JobScheduler jobScheduler = (JobScheduler) this.mContext.getSystemService(Context.JOB_SCHEDULER_SERVICE);
|
if(jobScheduler!=null)
|
jobScheduler.cancel(11);
|
this.mContext.stopService(new Intent(this.mContext, NJobService.class));
|
this.mContext.stopService(new Intent(this.mContext, CoreService.class));
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
} else {
|
this.mContext.stopService(new Intent(this.mContext, CoreService.class));
|
}
|
}
|
|
private Context getContext() {
|
return mContext;
|
}
|
}
|
