需求:
网络连接断开 弹出popupwindow 当前网络连接断开 网络恢复时popupwindow 消失重新请求网络。
需求描述完毕 上一张帅图
思路：广播 发送及时消息 断网flag popupwindow何时展示 大致就是这些需要考虑
吐槽:好久没写了 忙着换工作 赶新项目进度 新项目 用的是Dagger2 + RxJava + Retrofit + RxBus + DataBinding 很酸爽
后面又时间会跟大家分享。欢迎加入QQ群 521039620一块讨论 后面我们会一起讨论热修复 增量更新kotlin等 互相学习~。
直接上代码:
广播代码:
/**
* 使用广播去监听网络
* Created by 邓鉴恒 on 16/9/13.
感谢这个哥们儿~ 找不到参考地址了 这里保留他的名字 谢谢了
*/
public class NetStateReceiver extends BroadcastReceiver { private final static String ANDROID_NET_CHANGE_ACTION = "android.net.conn.CONNECTIVITY_CHANGE";
private final static String TAG = NetStateReceiver.class.getSimpleName(); private static boolean isNetAvailable = false;
private static HttpUtil.NetType mNetType;
private static ArrayList<NetChangeObserver> mNetChangeObservers = new ArrayList<NetChangeObserver>();
private static BroadcastReceiver mBroadcastReceiver; private static BroadcastReceiver getReceiver() {
if (null == mBroadcastReceiver) {
synchronized (NetStateReceiver.class) {
if (null == mBroadcastReceiver) {
mBroadcastReceiver = new NetStateReceiver();
}
}
}
return mBroadcastReceiver;
} @Override
public void onReceive(Context context, Intent intent) {
mBroadcastReceiver = NetStateReceiver.this;
if (intent.getAction().equalsIgnoreCase(ANDROID_NET_CHANGE_ACTION)) {
if (!HttpUtil.isNetworkAvailable(context)) {
Log.e(this.getClass().getName(), "<--- network disconnected --->");
isNetAvailable = false;
} else {
Log.e(this.getClass().getName(), "<--- network connected --->");
isNetAvailable = true;
mNetType = HttpUtil.getAPNType(context);
}
notifyObserver();
}
} /**
* 注册
*
* @param mContext
*/
public static void registerNetworkStateReceiver(Context mContext) {
IntentFilter filter = new IntentFilter();
filter.addAction(ANDROID_NET_CHANGE_ACTION);
mContext.getApplicationContext().registerReceiver(getReceiver(), filter);
} /**
* 清除
*
* @param mContext
*/
public static void checkNetworkState(Context mContext) {
Intent intent = new Intent();
intent.setAction(ANDROID_NET_CHANGE_ACTION);
mContext.sendBroadcast(intent);
} /**
* 反注册
*
* @param mContext
*/
public static void unRegisterNetworkStateReceiver(Context mContext) {
if (mBroadcastReceiver != null) {
try {
mContext.getApplicationContext().unregisterReceiver(mBroadcastReceiver);
} catch (Exception e) { }
} } public static boolean isNetworkAvailable() {
return isNetAvailable;
} public static HttpUtil.NetType getAPNType() {
return mNetType;
} private void notifyObserver() {
if (!mNetChangeObservers.isEmpty()) {
int size = mNetChangeObservers.size();
for (int i = 0; i < size; i++) {
NetChangeObserver observer = mNetChangeObservers.get(i);
if (observer != null) {
if (isNetworkAvailable()) {
observer.onNetConnected(mNetType);
} else {
observer.onNetDisConnect();
}
}
}
}
} /**
* 添加网络监听
*
* @param observer
*/
public static void registerObserver(NetChangeObserver observer) {
if (mNetChangeObservers == null) {
mNetChangeObservers = new ArrayList<NetChangeObserver>();
}
mNetChangeObservers.add(observer);
} /**
* 移除网络监听
*
* @param observer
*/
public static void removeRegisterObserver(NetChangeObserver observer) {
if (mNetChangeObservers != null) {
if (mNetChangeObservers.contains(observer)) {
mNetChangeObservers.remove(observer);
}
}
}
}
// 接口：
public interface NetChangeObserver {
/**
* 网络连接回调 type为网络类型
*/
void onNetConnected(HttpUtil.NetType type);
/**
* 没有网络
*/
void onNetDisConnect();
}
BaseActivity:
//网络观察者
protected NetChangeObserver mNetChangeObserver = null;
protected NetworkPopupWindow networkWindow; protected boolean network = true;
onCreate：
mNetChangeObserver = new NetChangeObserver() {
@Override
public void onNetConnected(HttpUtil.NetType type) {
if (networkWindow != null && networkWindow.isShowing()) {
networkWindow.dismiss();
}
onNetworkConnected(type);
network = true;
}
@Override
public void onNetDisConnect() {
network = false;
onNetworkDisConnected();
}
};
//开启广播去监听 网络 改变事件
NetStateReceiver.registerObserver(mNetChangeObserver);
//======================baseacivity中重写
/**
* 网络连接状态
* @param type 网络状态
*/
protected void onNetworkConnected(HttpUtil.NetType type) {
} /**
* 网络断开的时候调用
*/
protected void onNetworkDisConnected() {
} //相关类如下 ================================
/**
* 处理网络断开的dialog显示
*/ private View decorView; @Override
public void onWindowFocusChanged(boolean hasFocus) {
super.onWindowFocusChanged(hasFocus);
if (hasFocus && !network) {
if (networkWindow == null) {
networkWindow = new NetworkPopupWindow(BaseActivity.this);
Rect rect = new Rect();
decorView = getWindow().getDecorView();
decorView.getWindowVisibleDisplayFrame(rect);
int statusBarHeight = rect.top; //状态栏高度
Log.d("标题栏高度", "onWindowFocusChanged: " + statusBarHeight);
}
decorView.post(() -> networkWindow.showAtLocation(decorView, Gravity.TOP, 0,
0));
}
}
public class NetworkPopupWindow extends PopupWindow {
public NetworkPopupWindow(final Context context) {
LayoutInflater inflater = (LayoutInflater) context
.getSystemService(Context.LAYOUT_INFLATER_SERVICE);
View mMenuView = inflater.inflate(R.layout.networkpopupwindow, null);
mMenuView.setOnClickListener(v -> context.startActivity(new Intent(Settings.ACTION_SETTINGS)));
// 设置SelectPicPopupWindow的View
this.setContentView(mMenuView);
// 设置SelectPicPopupWindow弹出窗体的宽
this.setWidth(LayoutParams.FILL_PARENT);
// 设置SelectPicPopupWindow弹出窗体的高
this.setHeight(LayoutParams.WRAP_CONTENT);
// 设置SelectPicPopupWindow弹出窗体可点击
this.setFocusable(false);
// 设置SelectPicPopupWindow弹出窗体动画效果
// this.setAnimationStyle(R.style.AnimBottom);
// 实例化一个ColorDrawable颜色为半透明
ColorDrawable dw = new ColorDrawable(9000);
// 设置SelectPicPopupWindow弹出窗体的背景
this.setBackgroundDrawable(dw);
}
}
//layout 布局 wifi_off_icon一张图片 可要可不要
<?xml version="1.0" encoding="utf-8"?>
<RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android"
android:layout_width="match_parent"
android:layout_height="match_parent"
>
<TextView
android:layout_width="match_parent"
android:layout_height="45dip"
android:background="#ffdcd0"
android:drawableLeft="@drawable/wifi_off_icon"
android:drawablePadding="12.5dip"
android:gravity="center_vertical"
android:paddingLeft="10dip"
android:text="世界上最遥远的距离就是没网。检查设置"
android:textColor="#665b55" /> </RelativeLayout>
Application:
@Override
public void onCreate() {
super.onCreate();
NetStateReceiver.registerNetworkStateReceiver(this);//初始化网络监听
}
@Override
public void onLowMemory() {
super.onLowMemory();
NetStateReceiver.unRegisterNetworkStateReceiver(this);
android.os.Process.killProcess(android.os.Process.myPid());
exit();
}
RxBus(没用到 扩展):
/**
* 使用RxBus 代替 event bus
* Created by kcw001 on 2016/7/21.
*/
public class RxBus { private static volatile RxBus INSTANCE = new RxBus(); private final Subject<Object,Object> bus; private final Map<Class<?>,Object> mStickyEventMap; public RxBus(){
bus = new SerializedSubject<>(PublishSubject.create());
mStickyEventMap = new ConcurrentHashMap<>();//存
} public static RxBus getDefault(){
if(INSTANCE==null){
synchronized (RxBus.class){
if(INSTANCE==null){
INSTANCE = new RxBus();
}
}
}
return INSTANCE;
} /**
* 发送事件 单靠一种类型完全解决不了我们的需求 Sticky 方式补充
* @param event
*/
public void post(Object event){
synchronized (mStickyEventMap){
mStickyEventMap.put(event.getClass(),event);
}
bus.onNext(event);
} /**
* 根据eventType获取Sticky事件
*/
public <T> T getStickyEvent(Class<T> eventType) {
synchronized (mStickyEventMap) {
return eventType.cast(mStickyEventMap.get(eventType));
}
} /**
* 根据传递的eventType 类型返回eventType的观察者
*/
public <T> Observable<T> toObservable(Class<T> eventType){
synchronized (mStickyEventMap) {
Observable<T> observable = bus.ofType(eventType);
Object event = mStickyEventMap.get(eventType);
if(event!=null){
return Observable.merge(observable,Observable.create(new Observable.OnSubscribe<T>(){ @Override
public void call(Subscriber<? super T> subscriber) {
subscriber.onNext(eventType.cast(event));
}
}));
}else{
return observable;
}
}
//return bus.ofType(eventType);
}
}
Activity中（集成baseActivity):
@Override
protected void onNetworkConnected(HttpUtil.NetType type) {
if (!network) {
initUi();//重新请求网络
network = true;
}
} @Override
protected void onNetworkDisConnected() {//断网 }
大致如上 如有遗漏或者更好的想法 欢迎加群 学习交流
QQ群521039620