169it科技资讯


当前位置:  编程技术>综合
本页文章导读:
    ▪java设计模式-观察者模式初探      1、什么是观察者模式? 观察者模式定义了一种一对多的依赖关系,让多个观察者对象同时监听某一个主题对象。这个主题对象在状态发生变化时,会通知所有观察者对象,让他们自动更新自.........
    ▪MANIFEST.MF格式总结       【说明】 Java打包文件(jar文件)中通常会包含清单文件(META-INF/MANIFEST.MF),该文件可以包含主类以及加载类路径等信息。 该文件有着严格的格式要求,甚至一个空格都会引起错误。.........
    ▪Android 4.2 Wifi Display核心分析 (一)      作者: Wolf Geek     转载请说明出处         上一回,主要介绍了有关WifiDisplay设备连接和建立数据流的流程,这一回将接着向底层前进。由于涉及的内容较多,这里仅仅理.........

[1]java设计模式-观察者模式初探
    来源:    发布时间: 2014-02-18
1、什么是观察者模式?
观察者模式定义了一种一对多的依赖关系,让多个观察者对象同时监听某一个主题对象。这个主题对象在状态发生变化时,会通知所有观察者对象,让他们自动更新自己。

举个例子:在java GUI程序中,一个按钮有多个监听器,当这个按钮被点击时,即上面所说的主题对象状态发生变化,多个监听器自动得到调用。

2、观察者模式的组成:可以概括为两个抽象和两个具体。
- 抽象主题(Subject)角色:把所有对观察者对象的引用保存在一个集合中,每个抽象主题角色都可以有任意数量的观察者。抽象主题提供一个接口,可以增加和删除观察者角色。一般用一个抽象类或接口来实现。
- 抽象观察者(Observer)角色:为所有具体的观察者定义一个接口,在得到主题的通知时更新自己。
- 具体主题角(ConcreteSubject)色:在具体主题角色内部状态改变时,给所有登记过的观察者发出通知。具体主题角色通常由一个子类来实现。
- 具体观察者(ConcreteObserver)角色:该角色实现抽象观察者角色所要求的更新接口,以便使本身的状态与主题的状态相协调。如果需要,具体观察者角色可以保存一个指向具体主题角色的引用。通常用一个子类来实现。

上面说的还是很抽象,还是用代码来说话吧!

代码如下:
//抽象主题角色:
//抽象主题角色
public interface Subject
{
	//注册观察者对象
	public void addWatcher(Observer watcher);
	
	//删除观察者对象
	public void removeWatcher(Observer watcher);
	
	//通知所有的观察者对象
	public void notifyWatchers(String str);
}

//具体主题角色:
//具体主题角色
public class ConcreteSubject implements Subject
{
	//把所有对观察者对象的引用保存在一个集合中
	private List<Observer> list = new ArrayList<Observer>();
	
	@Override
	public void addWatcher(Observer watcher)
	{
		list.add(watcher);
	}

	@Override
	public void removeWatcher(Observer watcher)
	{
		list.remove(watcher);
	}

	@Override
	public void notifyWatchers(String str)
	{
		for(Observer watcher : list)
		{
			watcher.update(str);
		}
	}	
}

//抽象观察者角色:
//抽象观察者角色
public interface Observer
{
	public void update(String str);
}

//具体观察者对象:
//具体观察者对象
public class ConcreteObserver implements Observer
{
	@Override
	public void update(String str)
	{
		System.out.println(str);
	}
}

//测试类:
public class TestObserver
{
	public static void main(String[] args)
	{
		//相当于GUI中一个按钮
		Subject watched = new ConcreteSubject();
		
		//相当于按钮的事件监听器
		Observer watcher1 = new ConcreteObserver();
		Observer watcher2 = new ConcreteObserver();
		Observer watcher3 = new ConcreteObserver();
		
		//将监听器注册到主题角色中
		watched.addWatcher(watcher1);
		watched.addWatcher(watcher2);
		watched.addWatcher(watcher3);
		
		//在单击按钮后,触发了事件
		watched.notifyWatchers("hello");
		System.out.println("-----------");
		
		watched.removeWatcher(watcher1);
		watched.notifyWatchers("world");
	}
}


3、总结:java在GUI编程中大量使用了观察者模式,在jdk中也提供了对观察者模式的支持,它们在java.util包中的Obserable类和Observer接口,其中的实现思路与上面的代码大体相同,所以在理解了上面简单代码的基础上,再去研究jdk对观察者模式所提供的源码就不是什么难事了。

已有 0 人发表留言,猛击->>这里<<-参与讨论


ITeye推荐
  • —软件人才免语言低担保 赴美带薪读研!—




    
[2]MANIFEST.MF格式总结
    来源: 互联网  发布时间: 2014-02-18
【说明】
Java打包文件(jar文件)中通常会包含清单文件(META-INF/MANIFEST.MF),该文件可以包含主类以及加载类路径等信息。
该文件有着严格的格式要求,甚至一个空格都会引起错误。

【MANIFEST.MF格式说明】
1. 文件中的内容以键值对的形式出现,键值对之间采用"冒号+空格"进行分隔(注意:冒号后的空格必须有,否则格式有错误)
2. 文件每行最多72个字符,可以分多行写,但是在行的末尾必须加上空格符作为续行符(注意:末尾的续行符不能少)
3. 文件的最后必须要空两行,并且这两行都必须顶格
4. 通常指定Class-Path时会采用每一行一个JAR包的方法,因为每一行的长度有限制,当JAR较多时容易超过

【MANIFEST.MF示例】
Manifest-Version: 1.0
Created-By: 1.6.0_10-rc2 (Sun Microsystems Inc.)
Premain-Class: itracer.ITracer
Can-Redefine-Classes: true
Can-Retransform-Classes: true
Can-Set-Native-Method-Prefix: true
Class-Path: lib/asm-4.0.jar 
 lib/asm-util-4.0.jar 
 lib/log4j.jar


(注:示例中指定Class-Path时采用了分行的方法,则每行的后面(除最后一行外)都有一个空格,并且由于多个Classpath之间有空格符进行分隔,所以
在每行的开头有一个空格符。整个文件的最后空两行,并且这两行都必须顶格)
作者:chendeng8899 发表于2013-1-14 11:09:33 原文链接
阅读:3 评论:0 查看评论

    
[3]Android 4.2 Wifi Display核心分析 (一)
    来源: 互联网  发布时间: 2014-02-18

作者: Wolf Geek     转载请说明出处

        上一回,主要介绍了有关WifiDisplay设备连接和建立数据流的流程,这一回将接着向底层前进。由于涉及的内容较多,这里仅仅理清一个大概的头绪,细节的部分将不再展开,如果有什么错误的地方我会及时更正。

       当Source端通过RemoteDisplay.cpp的构造函数注册了Wifidisplay处理线程,并且ANetworkSession初始化了通信所用的数据管道并且开始监听数据流变化后,Source端将通过函数mSource->start(iface)开始建立RTSP连接并且向Sink端传递数据流。接下来,将具体分析其流程。mSource->start(iface)的具体实现在以下文件,

 frameworks/av/media/libstagefright/wifi-display/source/WifiDisplaySource.cpp

status_t WifiDisplaySource::start(const char *iface) {
    CHECK_EQ(mState, INITIALIZED);

    sp<AMessage> msg = new AMessage(kWhatStart, id());
    msg->setString("iface", iface);

    sp<AMessage> response;
    status_t err = msg->postAndAwaitResponse(&response);

    if (err != OK) {
        return err;
    }

    if (!response->findInt32("err", &err)) {
        err = OK;
    }

    return err;
}

该函数首先通过CHECK_EQ来判断当前Source端状态是否为 INITIALIZED,如果是将通过 AMessage创建 标识为kWhatStart的消息,用于在onMessageReceived处理分支中进行匹配,msg->setString(“iface”,iface)用于在传递消息过程中携带网络地址端口信息, msg->postAndAwaitResponse用于返回相应结果。这种方式在Android的流媒体类中相当常见,是一种异步消息处理框架。与该框架相关的类主要有ALooper、AHandler、ALooperRoster等,具体请见。

接下来,我们来看看当Source端接收到kWhatStart的消息后做何种处理,

void WifiDisplaySource::onMessageReceived(const sp<AMessage> &msg) {
    switch (msg->what()) {
        case kWhatStart:
        {
            uint32_t replyID;
            CHECK(msg->senderAwaitsResponse(&replyID));

            AString iface;
            CHECK(msg->findString("iface", &iface));

            status_t err = OK;

            ssize_t colonPos = iface.find(":");  //寻找“:”所在位置

            unsigned long port;

            if (colonPos >= 0) {
                const char *s = iface.c_str() + colonPos + 1;

                char *end;
                port = strtoul(s, &end, 10);  //得到port号

                if (end == s || *end != '\0' || port > 65535) {
                    err = -EINVAL;
                } else {
                    iface.erase(colonPos, iface.size() - colonPos);  
                }
            } else {
                port = kWifiDisplayDefaultPort;
            }

            if (err == OK) {
                if (inet_aton(iface.c_str(), &mInterfaceAddr) != 0) {  //将IP地址转化为32位的网络序列IP地址
                    sp<AMessage> notify = new AMessage(kWhatRTSPNotify, id());//建立标识为 kWhatRTSPNotify的消息作为参数传递

                    err = mNetSession->createRTSPServer(
                            mInterfaceAddr, port, notify, &mSessionID);
                } else {
                    err = -EINVAL;
                }
            }

            if (err == OK) {
                mState = AWAITING_CLIENT_CONNECTION;
            }

            sp<AMessage> response = new AMessage;
            response->setInt32("err", err);
            response->postReply(replyID);
            break;
        }
      ...
   }
}

首先,可以看到当Source端接收到消息标识为 kWhatStart的消息后,消息指针msg会通过函数msg->senderAwaitsResponse(&replyID)获取对应于postAndAwaitResponse函数的响应标识,并把处理中的错误信息作为消息载体通过response->postReply(replyID)传递回start(iface)函数。然后,该处理函数将接收到的网络地址端口信息iface拆分为IP地址和端口两个部分,并且利用 createRTSPServer创建RTSP服务端,函数会返回相应的Session编号。如果RTSP服务端创建成功,则将Source端状态更改为 AWAITING_CLIENT_CONNECTION,表示等待客户端连接。

 接着看创建RTSP服务端具体做了哪些动作,

frameworks/av/media/libstagefright/wifi-display/ANetworkSession.cpp

status_t ANetworkSession::createRTSPServer(
        const struct in_addr &addr, unsigned port,
        const sp<AMessage> ¬ify, int32_t *sessionID) {
    return createClientOrServer(
            kModeCreateRTSPServer,
            &addr,
            port,
            NULL /* remoteHost */,
            0 /* remotePort */,
            notify,
            sessionID);
}

可以看到函数createRTSPServer具体又调用了 createClientOrServer函数。在此类中,与建立管道数据流相关的函数都会调用该函数,它们分别是createRTSPClient、createRTSPServer、createUDPSession、createTCPDatagramSession等函数。

其中可以不用关注函数createTCPDatagramSession,这是因为Sink端默认选择了UDP方式进行传输。具体起关键性作用的是在WifiDisplaySink.h头文件中的static const bool sUseTCPInterleaving = false变量 ,具体而言,该变量为false就导致Sink端不会向Source端发送“Transport: RTP/AVP/TCP”这样的请求,这样在Source端就不会将Sender类中的mTransportMode变量设置为TRANSPORT_TCP或者 TRANSPORT_TCP_INTERLEAVED,所以在Sender类中最终并不会调用函数createTCPDatagramSession。        

接下来,将重点看看函数createClientOrServer,其中与建立RTSP服务端无关的步骤先省略不看。

status_t ANetworkSession::createClientOrServer(
        Mode mode,
        const struct in_addr *localAddr,
        unsigned port,
        const char *remoteHost,
        unsigned remotePort,
        const sp<AMessage> ¬ify,
        int32_t *sessionID) {
    Mutex::Autolock autoLock(mLock);

    *sessionID = 0;
    status_t err = OK;
    int s, res;
    sp<Session> session;

    s = socket(
            AF_INET,
            (mode == kModeCreateUDPSession) ? SOCK_DGRAM : SOCK_STREAM,
            0);    //建立类型为流套接字的socket

  ...

    if (mode == kModeCreateRTSPServer
            || mode == kModeCreateTCPDatagramSessionPassive) {
        const int yes = 1;
        res = setsockopt(s, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(yes));//允许socket和一个已在使用中的地址捆绑
    err = MakeSocketNonBlocking(s);  //设置socket为非阻塞方式

    struct sockaddr_in addr;
    memset(addr.sin_zero, 0, sizeof(addr.sin_zero));
    addr.sin_family = AF_INET;

    if (mode == kModeCreateRTSPClient
            || mode == kModeCreateTCPDatagramSessionActive) {
     ...
    } else if (localAddr != NULL) {
        addr.sin_addr = *localAddr;
        addr.sin_port = htons(port);
    } else {
        ...
    }

    if (mode == kModeCreateRTSPClient
            || mode == kModeCreateTCPDatagramSessionActive) {
       ...
       
    } else {
        res = bind(s, (const struct sockaddr *)&addr, sizeof(addr));//socket与
sockaddr结构体指针绑定,sockaddr对应与iface
        if (res == 0) {  //绑定成功
            if (mode == kModeCreateRTSPServer
                    || mode == kModeCreateTCPDatagramSessionPassive) {
                res = listen(s, 4);  //作为服务端开始监听rtsp连接请求
            } else {
                  ...
                }
            }
        }
    }
     ...
    Session::State state;
    switch (mode) {
        ...

        case kModeCreateRTSPServer:
            state = Session::LISTENING_RTSP;   //设置Session状态为 LISTENING_RTSP
            break;
       ...
    }

    session = new Session(
            mNextSessionID++,
            state,
            s,
            notify);    //创建一个session对象,sessionID加1

    ...
    mSessions.add(session->sessionID(), session); //将该对象加入vector结构中保存

    interrupt();  //向管道写端写数据

    *sessionID = session->sessionID();  //由指针带出当前sessionID

    goto bail;
...

bail:
    return err;
}

可以看到建立RTSP服务端的步骤没什么特别的地方,无非是建立socket,绑定地址然后监听等步骤,只不过为了标识不同的请求和区分当前状态,这里用Session结构体和相应的状态来管理对应的socket。

回到RemoteDisplay.cpp的构造函数中,可以看到在Source端调用函数mSource->start(iface)之前就通过mNetSession->start()开启了ANetworkSession线程,接下来看一下mNetSession->start()究竟干了什么事。


status_t ANetworkSession::start(){
   ...
   int res =pipe(mPipeFd);  //建立读写管道,控制threadLoop的执行
   if (res != 0) {
        mPipeFd[0] = mPipeFd[1] = -1;
        return -errno;            
   }
   mThread = new NetworkThread(this); //构造ANetworkSession的内部结构线程
   status_t err = mThread->run("ANetworkSession", ANDROID_PRIORITY_AUDIO);//开启该线程,将会调用NetworkThread线程中threadLoop,进一步会调用AnetworkSession::threadLoop()
   ...
   return OK;
}

   可以看到 ANetworkSession采用了管道的方式来控制
    
最新技术文章:
▪error while loading shared libraries的解決方法    ▪版本控制的极佳实践    ▪安装多个jdk,多个tomcat版本的冲突问题
▪简单选择排序算法    ▪国外 Android资源大集合 和个人学习android收藏    ▪.NET MVC 给loading数据加 ajax 等待loading效果
▪http代理工作原理(3)    ▪关注细节-TWaver Android    ▪Spring怎样把Bean实例暴露出来?
▪java写入excel2007的操作    ▪http代理工作原理(1)    ▪浅谈三层架构
▪http代理工作原理(2)    ▪解析三层架构……如何分层?    ▪linux PS命令
▪secureMRT Linux命令汉字出现乱码    ▪把C++类成员方法直接作为线程回调函数    ▪weak-and算法原理演示(wand)
▪53个要点提高PHP编程效率    ▪linux僵尸进程    ▪java 序列化到mysql数据库中
▪利用ndk编译ffmpeg    ▪活用CSS巧妙解决超长文本内容显示问题    ▪通过DBMS_RANDOM得到随机
▪CodeSmith 使用教程(8): CodeTemplate对象    ▪android4.0 进程回收机制    ▪仿天猫首页-产品分类
▪从Samples中入门IOS开发(四)------ 基于socket的...    ▪工作趣事 之 重装服务器后的网站不能正常访...    ▪java序列化学习笔记
▪Office 2010下VBA Addressof的应用    ▪一起来学ASP.NET Ajax(二)之初识ASP.NET Ajax    ▪更改CentOS yum 源为163的源
▪ORACLE 常用表达式    ▪记录一下,AS3反射功能的实现方法    ▪u盘文件系统问题
▪java设计模式-观察者模式初探    ▪MANIFEST.MF格式总结    ▪Android 4.2 Wifi Display核心分析 (一)
▪Perl 正则表达式 记忆方法    ▪.NET MVC 给loading数据加 ajax 等待laoding效果    ▪java 类之访问权限
▪extjs在myeclipse提示    ▪xml不提示问题    ▪Android应用程序运行的性能设计
▪sharepoint 2010 自定义列表启用版本记录控制 如...    ▪解决UIScrollView截获touch事件的一个极其简单有...    ▪Chain of Responsibility -- 责任链模式
▪运行skyeye缺少libbfd-2.18.50.0.2.20071001.so问题    ▪sharepoint 2010 使用sharepoint脚本STSNavigate方法实...    ▪让javascript显原型!
▪kohana基本安装配置    ▪MVVM开发模式实例解析    ▪sharepoint 2010 设置pdf文件在浏览器中访问
▪spring+hibernate+事务    ▪MyEclipse中文乱码,编码格式设置,文件编码格...    ▪struts+spring+hibernate用jquery实现数据分页异步加...
▪windows平台c++开发"麻烦"总结    ▪Android Wifi几点    ▪Myeclipse中JDBC连接池的配置
▪优化后的冒泡排序算法    ▪elasticsearch RESTful搜索引擎-(java jest 使用[入门])...    ▪MyEclipse下安装SVN插件SubEclipse的方法
▪100个windows平台C++开发错误之七编程    ▪串口转以太网模块WIZ140SR/WIZ145SR 数据手册(版...    ▪初识XML(三)Schema
▪Deep Copy VS Shallow Copy    ▪iphone游戏开发之cocos2d (七) 自定义精灵类,实...    ▪100个windows平台C++开发错误之八编程
▪C++程序的内存布局    ▪将不确定变为确定系列~Linq的批量操作靠的住...    ▪DIV始终保持在浏览器中央,兼容各浏览器版本
▪Activity生命周期管理之三——Stopping或者Restarti...    ▪《C语言参悟之旅》-读书笔记(八)    ▪C++函数参数小结
▪android Content Provider详解九    ▪简单的图片无缝滚动效果    ▪required artifact is missing.
▪c++编程风格----读书笔记(1)    ▪codeforces round 160    ▪【Visual C++】游戏开发笔记四十 浅墨DirectX教程...
▪【D3D11游戏编程】学习笔记十八:模板缓冲区...    ▪codeforces 70D 动态凸包    ▪c++编程风格----读书笔记(2)
▪Android窗口管理服务WindowManagerService计算Activity...    ▪keytool 错误: java.io.FileNotFoundException: MyAndroidKey....    ▪《HTTP权威指南》读书笔记---缓存
▪markdown    ▪[设计模式]总结    ▪网站用户行为分析在用户市场领域的应用
 


站内导航:


特别声明:169IT网站部分信息来自互联网,如果侵犯您的权利,请及时告知,本站将立即删除!

©2012-2017,169IT.COM,E-mail:www_169it_com#163.com(请将#改为@)

浙ICP备11055608号