领购物优惠券9块9包邮
首页 > 移动开发 > Android开发

Android观察者模式实例分析

   2015-06-30 0
核心提示：这篇文章主要介绍了Android观察者模式,实例分析了Android观察者模式的原理与相关使用技巧,具有一定参考借鉴价值,需要的朋友可以参考下

本文实例讲述了Android观察者模式。分享给大家供大家参考。具体分析如下：

一、环境：

主机:WIN8
开发环境:Eclipse

二、说明:

1.打开sd卡中的xml文件，如果不存在，这新建一个，并写入默认配置
2.读取xml文件
3.Config_Info.java为配置信息数据结构
4.IF_Config.java为配置类的存取接口，其他类可以通过此接口直接获取配置信息
5.IF_Subject_Config.java为观察者模式目标类接口
6.IF_Observer_Config.java为观察者模式观察者类接口
7.Config.java为配置类，完成1，2两部工作,同时是观察者模式的目标类，一旦配置信息由变化着通知观察者类
8.TestClass.java为观察者模式的观察者
通过存取接口+观察者模式可以实现松耦合的设计。

三、xml文件格式:

<xml version="1.0" encoding="UTF-8" standalone="true"> 
-<config> 
<title>远程视频会见系统</title> 
<local_port>12600</local_port> 
<schedule_service_ip>10.58.1.59</schedule_service_ip>
<schedule_service_port>12601</schedule_service_port> 
</config>

四、源代码：

Config_Info.java:

/** 
 * 配置信息数据类型 
 * 新建时间:2014/12/8 by jdh 
 */ 
package com.example.helloanychat; 
public class Config_Info { 
 //标题 
 public String title; 
 //本机ip 
 public String local_ip; 
 //本机端口 
 public int local_port; 
 //调度服务器ip 
 public String schedule_server_ip; 
 //调度服务器端口 
 public int schedule_server_port; 
}

IF_Config.java:

/** 
 * 接口：配置类，读写 
 * 新建时间:2014/12/8 by jdh 
 */ 
package com.example.helloanychat; 
public interface IF_Config { 
 public Config_Info get_config_info(); 
}

IF_Subject_Config.java:

/** 
 * 接口：配置类，观察者模式:目标 
 * 新建时间：2014/12/8 by jdh 
 */ 
package com.example.helloanychat; 
public interface IF_Subject_Config { 
 public void register_observer(IF_Observer_Config observer); 
 public void remove_observer(IF_Observer_Config observer); 
 public void notify_observer(); 
}

IF_Observer_Config.java：

/** 
 * 接口：配置类，观察者模式:观察者 
 * 新建时间：2014/12/8 by jdh 
 */ 
package com.example.helloanychat; 
public interface IF_Observer_Config { 
 public void update(Config_Info info); 
}

Config.java:

/** 
 * 配置信息类 
 * 新建日期:2014/12/8 by jdh 
 * 修改日期:2014/12/9 by jdh 
 */ 
package com.example.helloanychat; 
import java.io.File; 
import java.io.FileInputStream; 
import java.io.FileOutputStream; 
import java.io.IOException; 
import java.io.StringWriter; 
import java.net.Inet6Address; 
import java.net.InetAddress; 
import java.net.NetworkInterface; 
import java.net.SocketException; 
import java.util.ArrayList; 
import java.util.Enumeration; 
import java.util.List; 
import java.util.Timer; 
import java.util.TimerTask; 
import javax.xml.parsers.DocumentBuilder; 
import javax.xml.parsers.DocumentBuilderFactory; 
import android.os.Environment; 
import android.util.Log; 
import org.w3c.dom.Document; 
import org.w3c.dom.Element; 
import org.w3c.dom.NodeList; 
import org.xmlpull.v1.XmlPullParserFactory; 
import org.xmlpull.v1.XmlSerializer; 
public class Config implements IF_Config,IF_Subject_Config { 
 //配置信息 
 private Config_Info Info = new Config_Info(); 
 //存储观察者的列表 
 private List<IF_Observer_Config> Observers = new ArrayList<IF_Observer_Config>(); 
 //定时器 
 private Timer Timer_Work = new Timer(); 
 //工作间隔,单位:ms 
 private final int INTERVAL_WORK = 5000; 
 /** 
 * 构造函数 
 */ 
 public Config() { 
 //生成配置信息 
 generate_config_info(); 
 //创建定时线程 
 Timer_Work.schedule(new Task(),INTERVAL_WORK,INTERVAL_WORK);
 // 定时任务 
 } 
 //接口：读写 
 @Override 
 public Config_Info get_config_info() { 
 return Info; 
 } 
 //读写，观察者模式：目标 
 @Override 
 public void register_observer(IF_Observer_Config observer) { 
 Observers.add(observer); 
 } 
 @Override 
 public void remove_observer(IF_Observer_Config observer) { 
 int index = Observers.indexOf(observer); 
 if (index >= 0) { 
  Observers.remove(observer); 
 } 
 } 
 @Override 
 public void notify_observer() { 
 for (int i = 0; i < Observers.size(); i++) { 
  IF_Observer_Config o = (IF_Observer_Config) Observers.get(i); 
  o.update(Info); 
 } 
 } 
 /** 
 * 得到本机ip地址 
 * @return 本机ip地址 
 */ 
 private String getLocalIpAddress() { 
 try { 
  for (Enumeration<NetworkInterface> en = NetworkInterface 
   .getNetworkInterfaces(); en.hasMoreElements();) { 
  NetworkInterface intf = en.nextElement(); 
  for (Enumeration<InetAddress> enumIpAddr = intf 
   .getInetAddresses(); enumIpAddr.hasMoreElements();) { 
   InetAddress inetAddress = enumIpAddr.nextElement(); 
   //if (!inetAddress.isLoopbackAddress()) { 
   if (!inetAddress.isLoopbackAddress() && !(inetAddress instanceof Inet6Address)) { 
   return inetAddress.getHostAddress().toString(); 
   } 
  } 
  } 
 } catch (SocketException ex) { 
  Log.e("WifiPreference IpAddress", ex.toString()); 
 } 
 return null; 
 } 
 /** 
 * 生成xml配置文件的String数据流 
 * Config_Info的本机ip信息不会保存 
 * @param info:配置信息 
 * @return xml的String数据流 
 */ 
 private String produce_xml_string(Config_Info info) { 
 StringWriter stringWriter = new StringWriter(); 
 try { 
  // 获取XmlSerializer对象 
  XmlPullParserFactory factory = XmlPullParserFactory.newInstance(); 
  XmlSerializer xmlSerializer = factory.newSerializer(); 
  // 设置输出流对象 
  xmlSerializer.setOutput(stringWriter); 
  //开始标签 
  xmlSerializer.startDocument("utf-8", true); 
  xmlSerializer.startTag(null, "config"); 
  //标题 
  xmlSerializer.startTag(null, "title"); 
  xmlSerializer.text(info.title); 
  xmlSerializer.endTag(null, "title"); 
  //本机端口 
  xmlSerializer.startTag(null, "local_port"); 
  xmlSerializer.text(Integer.toString(info.local_port)); 
  xmlSerializer.endTag(null, "local_port"); 
  //调度服务器ip 
  xmlSerializer.startTag(null, "schedule_service_ip"); 
  xmlSerializer.text(info.schedule_server_ip); 
  xmlSerializer.endTag(null, "schedule_service_ip"); 
  //调度服务器端口 
  xmlSerializer.startTag(null, "schedule_service_port"); 
  xmlSerializer.text(Integer.toString(info.schedule_server_port)); 
  xmlSerializer.endTag(null, "schedule_service_port"); 
  xmlSerializer.endTag(null, "config"); 
  xmlSerializer.endDocument(); 
 } catch (Exception e) { 
  e.printStackTrace(); 
 } 
 return stringWriter.toString(); 
 } 
 /** 
 * 工作任务:得到配置信息 
 */ 
 private void generate_config_info() 
 { 
 boolean ok; 
 File sd_path; 
 File file_cfg_dir; 
 File file_cfg; 
 FileOutputStream out; 
 String str; 
 FileInputStream in; 
 Config_Info info = new Config_Info(); 
 //得到本机ip地址 
 info.local_ip = getLocalIpAddress(); 
 //获取SD卡目录 
 sd_path = Environment.getExternalStorageDirectory(); 
 //判断文件夹是否存在 
 file_cfg_dir = new File(sd_path.getPath() + "//Remote_Meeting"); 
 if (!file_cfg_dir.exists() && !file_cfg_dir.isDirectory()) { 
  System.out.println("配置文件夹Remote_Meeting不存在!"); 
  ok = file_cfg_dir.mkdirs(); 
  if (ok) { 
  System.out.println("创建文件夹成功!");
  } else { 
  System.out.println("创建文件夹失败!");
  } 
 } 
 //判断配置文件是否存在 
 file_cfg = new File(file_cfg_dir.getPath(),"cfg.xml"); 
 if (!file_cfg.exists()) 
 { 
  System.out.println("配置文件cfg.xml不存在!"); 
  try { 
  file_cfg.createNewFile(); 
  System.out.println("创建文件cfg.xml成功!"); 
  //生成初始化的配置数据 
  try { 
   out = new FileOutputStream(file_cfg); 
   //保存默认配置 
   Info.title = "远程视频会见系统"; 
   Info.local_port = 12600; 
   Info.schedule_server_ip = "10.58.1.59"; 
   Info.schedule_server_port = 12601; 
   str = produce_xml_string(Info); 
   out.write(str.getBytes()); 
   out.close(); 
   //保存本机ip 
   Info.local_ip = info.local_ip; 
   //通知观察者 
   notify_observer(); 
  } catch (IOException e) { 
   // TODO Auto-generated catch block 
   e.printStackTrace(); 
  } 
  } catch (IOException e) { 
  // TODO Auto-generated catch block 
  e.printStackTrace(); 
  } 
 } 
 else 
 { 
  //解析xml文件 
  try { 
  in = new FileInputStream(file_cfg); 
  DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance(); 
  DocumentBuilder builder = factory.newDocumentBuilder(); 
  Document document = builder.parse(in); 
  // 获取根节点 
  Element root = document.getDocumentElement(); 
  NodeList node = root.getChildNodes(); 
  //获得第1子节点:标题 
  info.title = node.item(0).getFirstChild().getNodeValue(); 
  //获得第2子节点:本机端口 
  info.local_port = Integer.parseInt(node.item(1).getFirstChild().getNodeValue()); 
  //获得第3子节点:调度服务器ip 
  info.schedule_server_ip = node.item(2).getFirstChild().getNodeValue(); 
  //获得第4子节点:调度服务器端口 
  info.schedule_server_port = Integer.parseInt(node.item(3).getFirstChild().getNodeValue()); 
  //判断配置信息是否变更 
  do 
  { 
   if (!info.title.equals(Info.title)) 
   { 
   break; 
   } 
   if (!info.local_ip.equals(Info.local_ip)) 
   { 
   break; 
   } 
   if (info.local_port != Info.local_port) 
   { 
   break; 
   } 
   if (!info.schedule_server_ip.equals(Info.schedule_server_ip)) 
   { 
   break; 
   } 
   if (info.schedule_server_port != Info.schedule_server_port) 
   { 
   break; 
   } 
   //全部相同 
   return; 
  } while (false); 
  //赋值 
  Info.title = info.title; 
  Info.local_ip = info.local_ip; 
  Info.local_port = info.local_port; 
  Info.schedule_server_ip = info.schedule_server_ip; 
  Info.schedule_server_port = info.schedule_server_port; 
  //通知观察者 
  notify_observer(); 
  } catch (Exception e) { 
  e.printStackTrace(); 
  } 
 } 
 } 
 /** 
 * 定时器线程定时工作 
 */ 
 private class Task extends TimerTask { 
 @Override 
 public void run() { 
  generate_config_info(); 
 } 
 } 
}

TestClass.java：

package com.example.helloanychat; 
public class TestClass implements IF_Observer_Config { 
 public TestClass () { 
 } 
 @Override 
 public void update(Config_Info info) { 
 System.out.printf("-------------更新数据：%s,%s,%d,%s,%d\n", 
 info.title,info.local_ip,info.local_port,info.schedule_server_ip,info.schedule_server_port); 
 } 
}

MainActivity:

TestClass testclass = new TestClass(); 
Config config = new Config(); 
mEditIP.setText(config.get_config_info().local_ip); 
config.register_observer(testclass);

希望本文所述对大家的Android程序设计有所帮助。

 
标签： Android 观察者 模式
反对 0举报 0 评论 0
 

免责声明：本文仅代表作者个人观点，与乐学笔记（本网）无关。其原创性以及文中陈述文字和内容未经本站证实，对本文以及其中全部或者部分内容、文字的真实性、完整性、及时性本站不作任何保证或承诺，请读者仅作参考，并请自行核实相关内容。
    本网站有部分内容均转载自其它媒体，转载目的在于传递更多信息，并不代表本网赞同其观点和对其真实性负责，若因作品内容、知识产权、版权和其他问题，请及时提供相关证明等材料并与我们留言联系，本网站将在规定时间内给予删除等相关处理.

  • 说一说Android Studio和IDEA中一个很有用的内存调试插件
    说一说Android Studio和IDEA中一个很有用的内存
    JetBrains JVM Debugger Memory View plugin 在我最近的研发活动期间寻找新的工具，以提高我的开发经验，使Android Studio的生活更轻松，我发现一个有用的插件，我从来没有听说过。 这就是为什么，我决定写这个强大的工具，它如何帮助我与内存调试我的应用程
    02-05 AndroidStudio
  • 安卓中通知功能的具体实现
    安卓中通知功能的具体实现
    通知[Notification]是Android中比较有特色的功能，当某个应用程序希望给用户发出一些提示信息，而该应用程序又不在前台运行时，就可以借助通知实现。使用通知的步骤1、需要一个NotificationManager来获得NotificationManager manager = （NotificationManager
    02-05 安卓开发
  • Android view系统分析-setContentView
    Android view系统分析-setContentView
    第一天上班，列了一下今年要学习的东西。主要就是深入学习Android相关的系统源代码，夯实基础。对于学习Android系统源代码，也没什么大概，就从我们平常使用最基础的东西学起，也就是从view这个切入点开始学习Android的源码，在没分析源码之前，我们有的时候
    02-05 安卓开发
  • 如何进行网络视频截图/获取视频的缩略图
    如何进行网络视频截图/获取视频的缩略图
    小编导读：获取视频的缩略图，截图正在播放的视频某一帧，是在音视频开发中，常遇到的问题。本文是主要用于点播中截图视频，同时还可以获取点播视频的缩略图进行显示，留下一个问题，如下图所示， 如果要获取直播中节目视频缩略图，该怎么做呢？（ps:直播是直
    02-05 Bitmap安卓开发
  • Android NDK 层发起 HTTP 请求的问题及解决
    Android NDK 层发起 HTTP 请求的问题及解决
    前言新的一年，大家新年快乐~~鸡年大吉！本次给大家带来何老师的最新文章~虽然何老师还在过节，但依然放心不下广大开发者，在此佳节还未结束之际，给大家带来最新的技术分享~ 事件的起因不说了，总之是需要实现一个 NDK 层的网络请求。为了多端适用，还是选择
    02-05 HTTP安卓开发
  • SDK热更之如何在SDK代码中自动插桩及如何生成补
    写在前面本文是SDKHotfix相关的SDK热更系列文章中的一篇，以下为项目及系列文章相关链接：SDKHotfix整体介绍：http://blog.bihe0832.com/sdk_hotfix_project.htmlSDKHotfix对应github地址：https://github.com/bihe0832/SDKHoxFix这篇文章主要介绍一下SDK热更
    02-05 加密解密Java
  • 安装量破千万的第一个产品，我总结了3句话
    安装量破千万的第一个产品，我总结了3句话
    在今天的文章中，作者回顾了自己的第一个产品，他说“我做的第一款产品，是我的一块里程碑。”一起来看看~背景老牌大型互联网公司，部门内部创业的一个项目。我作为产品经理，也是第一次做产品经理，主导产品项目。实际上，项目初期包括我和安卓开发2个人。开
    02-05 互联网产品经理
  • 移动周刊第 176 期：Android 知识梳理
    移动周刊第 176 期：Android 知识梳理
    写在前面 本期移动周刊第 176 期如约而至，聚焦 Android、iOS、VR/AR/MR、直播等前沿移动开发技术，收录一周最热点，解读开发技巧，每周三移动周刊抢先看，我们希望从中能够让你有一些收获，如果你有好的文章以及优化建议，请发送邮件至mobilehub@csdn.net，
    02-05 安卓热修复
  • Android插件化（六）: OpenAtlasの改写aapt以防止资源ID冲突
    Android插件化（六）: OpenAtlasの改写aapt以防
    引言Android应用程序的编译中，负责资源打包的是aapt,如果不对打包后的资源ID进行控制，就会导致插件中的资源ID冲突。所以，我们需要改写aapt的源码，以达到通过某种方式传递资源ID的Package ID,通过aapt打包时获取到这个Package ID并且应用才插件资源的命名
    02-05 安卓开发
  • Android架构（一）MVP架构在Android中的实践
    Android架构（一）MVP架构在Android中的实践
    为什么要重视程序的架构设计 对程序进行架构设计的原因，归根结底是为了 提高生产力 。通过设计是程序模块化，做到模块内部的 高聚合 和模块之间的 低耦合 (如依赖注入就是低耦合的集中体现)。 这样做的好处是使得程序开发过程中，开发人员主需要专注于一点，
    02-05 安卓开发
更多>其他开发
KendoUI2014移动调查报告：HTML5vs原生之辩 WebComponents-面向未来的组件标准
更多>Android开发
说一说Android Studio和IDEA中一个很有用的内存调试插件 安卓中通知功能的具体实现
更多>IOS开发
详解iOS开发中的转场动画和组动画以及UIView封装动画 iOS开发基础之C语言
更多>WP开发
微软官方公布Win10家庭版欧美地区零售价 Win10 Mobile预览版10149已知问题与解决办法汇总
点击排行
网站首页  |  关于我们  |  联系方式  |  使用协议  |  版权隐私  |  网站地图  |  网站留言  |  违规举报