本文实例讲述了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文件格式:
<"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,%dn", 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观察者模式实例分析】相关文章：
★ Android SQLite数据库增删改查操作的案例分析