轉(zhuǎn)自：http://semi-sleep.javaeye.com/blog/348768

Red5如何響應(yīng)rmpt的請求，中間涉及哪些關(guān)鍵類？

1.Red5在啟動(dòng)時(shí)會調(diào)用RTMPMinaTransport的start()方法，該方法會開啟rmtp的socket監(jiān)聽端口（默認(rèn)是1935），然后使用mina(apache的io操作類庫)的api將RTMPMinaIoHandler綁定到該端口。

2.RTMPMinaIoHandler上定義了messageReceived、messageSent、sessionOpened和 sessionClosed等方法，當(dāng)有socket請求時(shí)，相應(yīng)的方法會被調(diào)用，這時(shí)RTMPMinaIoHandler會使用當(dāng)前的socket連接來創(chuàng)建一個(gè)RTMPMinaConnection（或者使用一個(gè)之前創(chuàng)建好的RTMPMinaConnection），并將其作為參數(shù)傳遞給定義于 RTMPHandler類上的相應(yīng)的messageReceived、messageSent、connectionOpened和 connectionClosed方法。

3.RTMPHandler會調(diào)用Server類的lookupGlobal獲得當(dāng)前的GlobalScope，然后再利用GlobalScope 找到當(dāng)前socket請求應(yīng)該使用的WebScope（這個(gè)WebScope就是我們在自己的項(xiàng)目的WEB-INF"red5-web.xml中定義的啦）。最后，RTMPHandler會調(diào)用RTMPMinaConnection的connect方法連接到相應(yīng)的WebScope。

4.至此，控制流進(jìn)入了我們自己項(xiàng)目中了，通常來說，WebScope又會將請求轉(zhuǎn)移給ApplicationAdapter，由它來最終響應(yīng)請求，而我們的項(xiàng)目通過重載ApplicationAdapter的方法來實(shí)現(xiàn)自己的邏輯。

1 RTMPMinaIoHandler
2   |--[delegate method call and pass RTMPMinaConnection to]-->RTMPHandler
3      |--[call lookupGlobal method]-->Server
4      |--[use globalScope to lookup webScope]-->GlobalScope
5      |--[call connect method and pass WebScope to]-->RTMPMinaConnection

Red5如何啟動(dòng)？在它的啟動(dòng)過程中如何初始化這些關(guān)鍵類？

這里探討的是Red5 standalone的啟動(dòng)過程（也就是我們執(zhí)行red5.bat），關(guān)于Red5如何在tomcat中啟動(dòng)，目前仍在研究中。

Red5啟動(dòng)過程如下：

1.編輯red5.bat，找到關(guān)鍵的一行：

C:\Program Files\Java\jre1.5.0_15\bin\java"
  -Djava.security.manager
   -Djava.security.policy=conf/red5.policy
   -cp red5.jar;conf;bin org.red5.server.Standalone

可以看到它是調(diào)用org.red5.server.Standalone作為程序啟動(dòng)的入口，這也是為什么使用eclipse在debug模式下啟動(dòng) Standalone就可以調(diào)試Red5代碼。需要注意的是，如果你要調(diào)試Red5，記得除了源代碼(src)之外，把conf和webapps兩個(gè)文件夾都拷入項(xiàng)目中，并把conf加入classpath。

2.觀察Standalone的main方法，你會看到它使用spring的ContextSingletonBeanFactoryLocator來載入classpath下面的red5.xml，注意ContextSingletonBeanFactoryLocator還會在下面的步驟中被使用，由于它是singleton的，所以保證了我們自己的項(xiàng)目中定義的bean可以引用red5.xml中定義的bean，這個(gè)下面會有介紹。

try {
ContextSingletonBeanFactoryLocator.getInstance(red5Config).useBeanFactory("red5.common");
} catch (Exception e) {
// Don't raise wrapped exceptions as their stacktraces may confuse people

raiseOriginalException(e);
}

3.查看red5.xml，這個(gè)文件首先定義了指向classpath:/red5-common.xml的名字為“red5.common”的 BeanFactory，注意它會是整個(gè)BeanFactory層次中的根節(jié)點(diǎn)，所以在red5-common.xml中定義的bean可以被其他地方所引用。

<bean id="red5.common" class="org.springframework.context.support.FileSystemXmlApplicationContext">
<constructor-arg><list><value>classpath:/red5-common.xml</value></list></constructor-arg>
</bean>

這里我們主要留意red5-common.xml中定義的類型為org.red5.server.Server的“red5.server”，它會在接下來很多地方被用到。

4.回到red5.xml，接著定義指向classpath:/red5-core.xml的名字為“red5.core”的BeanFactory，注意“red5.core”是以“red5.common”為parent context。

<bean id="red5.core" class="org.springframework.context.support.FileSystemXmlApplicationContext">
<constructor-arg><list><value>classpath:/red5-core.xml</value></list></constructor-arg>
<constructor-arg><ref bean="red5.common" /></constructor-arg>
</bean>

查看red5-core.xml，這個(gè)文件主要定義了之前說過的RTMPMinaTransport，RMTPMinaIoHandler和 RTMPHandler這些類的Bean。對于RTMPMinaTransport，注意init-method="start"這段代碼，這說明 RTMPMinaTransport的start方法會在該Bean初始化時(shí)調(diào)用，正如上面提到的，該方法會做開啟1935端口，綁定 RTMPMinaIoHandler到該端口等等的操作。對于RTMPHandler，注意它的server屬性通過“red5.server”引用了定義在parent context（red5-common.xml）上面的Server，通過它RTMPHandler能夠找到GlobalScope，進(jìn)而找到 WebScope。

<bean id="rtmpHandler"
    class="org.red5.server.net.rtmp.RTMPHandler">
    <property name="server" ref="red5.server" />
    <property name="statusObjectService" ref="statusObjectService" />
</bean>


<bean id="rtmpMinaIoHandler"
    class="org.red5.server.net.rtmp.RTMPMinaIoHandler">
    <property name="handler" ref="rtmpHandler" />
    <property name="codecFactory" ref="rtmpCodecFactory" />
    <property name="rtmpConnManager" ref="rtmpMinaConnManager" />
</bean>


<bean id="rtmpTransport" class="org.red5.server.net.rtmp.RTMPMinaTransport" init-method="start" destroy-method="stop">
    <property name="ioHandler" ref="rtmpMinaIoHandler" />
    <property name="address" value="${rtmp.host}" />
    <property name="port" value="${rtmp.port}" />
    <property name="receiveBufferSize" value="${rtmp.receive_buffer_size}" />
    <property name="sendBufferSize" value="${rtmp.send_buffer_size}" />
    <property name="eventThreadsCore" value="${rtmp.event_threads_core}" />
    <property name="eventThreadsMax" value="${rtmp.event_threads_max}" />
    <property name="eventThreadsQueue" value="${rtmp.event_threads_queue}" />
    <property name="eventThreadsKeepalive" value="${rtmp.event_threads_keepalive}" />
    
    <property name="jmxPollInterval" value="1000" />
    <property name="tcpNoDelay" value="${rtmp.tcp_nodelay}" />
</bean>

5.再次回到red5.xml，接下來定義類型為org.red5.server.ContextLoader的bean，并在初始化后調(diào)用它的init方法。

查看該方法的源代碼，可以看到它會讀取在classPath下面的red5.globals文件，對于每一行初始化一個(gè)以“red5.common”為 parent context的BeanFactory，具體來說，現(xiàn)在red5.globals中只有一行 default.context=${red5.root}/webapps/red5-default.xml，那么會創(chuàng)建一個(gè)名字為 “default.context”的指向webapps/red5-default.xml的Bean Factory，它以“red5.common”為parent context。

protected void loadContext(String name, String config) {
    log.debug("Load context - name: " + name + " config: " + config);
    ApplicationContext context = new FileSystemXmlApplicationContext(
            new String[] { config }, parentContext);
    contextMap.put(name, context);
    // add the context to the parent, this will be red5.xml
    ConfigurableBeanFactory factory = ((ConfigurableApplicationContext) applicationContext)
            .getBeanFactory();
    // Register context in parent bean factory
    factory.registerSingleton(name, context);
}

查看red5-default.xml，發(fā)現(xiàn)它主要是定義了GlobalScope的bean，然后把它注冊到“red5.server”上。

<bean id="global.scope" class="org.red5.server.GlobalScope" init-method="register">
    <property name="server" ref="red5.server" />
    <property name="name" value="default" />
    <property name="context" ref="global.context" />
    <property name="handler" ref="global.handler" />
    <property name="persistenceClass">
        <value>org.red5.server.persistence.FilePersistence</value>
    </property>
</bean>

6.繼續(xù)看red5.xml，最后定義類型為org.red5.server.jetty.JettyLoader的bean，并且在初始化后調(diào)用它的init方法，查看該方法源代碼，很明顯它是初始化并且啟動(dòng)jetty這個(gè)web server。

7.到了這里似乎所有的初始化和啟動(dòng)都完畢了，但是問題就來了，這里僅僅定義了 RTMPMinaIoHandler，RTMPHandler，Server和GlobalScope，但是在我們之前提到過的Red5響應(yīng)rmpt的請求的過程中，還需要有WebScope來最終處理RTMPMinaConnection，這個(gè)WebScope又是怎么配置并且加進(jìn)來的呢？

8.查看webapps下的項(xiàng)目，這里以oflaDemo為例，查看WEB-INF下面的web.xml，發(fā)現(xiàn)有以下三個(gè)參數(shù) contextConfigLocation，locatorFactorySelector和parentContextKey，同時(shí)還有一個(gè) org.springframework.web.context.ContextLoaderListener。

<context-param>
  <param-name>contextConfigLocation</param-name>
  <param-value>/WEB-INF/red5-*.xml</param-value>
</context-param>

<context-param>
  <param-name>locatorFactorySelector</param-name>
  <param-value>red5.xml</param-value>
</context-param>

<context-param>
  <param-name>parentContextKey</param-name>
  <param-value>default.context</param-value>
</context-param>

<listener>
    <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>

查看這個(gè)listener的javadoc，其實(shí)這個(gè)listener會在web app（就是我們自己的項(xiàng)目）啟動(dòng)時(shí)，創(chuàng)建一個(gè)指向contextConfigLocation（其實(shí)就是WEB-INF"red5-web.xml）的 Bean Factory，同時(shí)為它設(shè)置parent context。這個(gè)parent context實(shí)際上是使用locatorFactorySelector找到ContextSingletonBeanFactoryLocator，進(jìn)而使用parentContextKey找到定義在這個(gè)locator里面的Bean Fanctory，由于ContextSingletonBeanFactoryLocator是singleton的，所以這個(gè) ContextSingletonBeanFactoryLocator對象跟我們在第2步中拿到的對象是一樣的，而由于 parentContextKey被設(shè)置成“default.context”，這就意味著該parent context是第5步中定義的名為“default.context”的Bean Factory。基于以上的參數(shù)，我們得到這樣一個(gè)Bean Factory的鏈條，由上至下分別是

conf\red5-common.xml -> webapps\red5-default.xml -> webapps\oflaDemo\WEB-INF\red5-web.xml

這就使得red5-web.xml可以使用red5-common.xml和red5-default.xml中定義的bean。

9.最后查看webapps"oflaDemo"WEB-INF"red5-web.xml，它定義了類型為 org.red5.server.WebScope的bean，初始化了它的server（指向“red5.server”），parent（指向 “global.scope”）等屬性，最后調(diào)用它的register方法初始化，查看該方法源代碼，發(fā)現(xiàn)它會把自己注冊到GlobalScope上面，至此所有的關(guān)鍵類的初始化完畢。

Spring beanFactory 的層次圖

看清了Red5 Standalone的啟動(dòng)過程，感覺為了實(shí)現(xiàn)自定義項(xiàng)目集成到Red5的核心服務(wù)上，Red5 Standalone非常依賴于spring的多個(gè)Bean Factory之間的復(fù)雜層次關(guān)系，之所以Red5能建立這樣一種層次關(guān)系，是因?yàn)樗軌蚩刂苆etty這樣一個(gè)嵌入式的web server。問題在于，一旦Red5需要作為一個(gè)web app運(yùn)行在類似Tomcat這樣的獨(dú)立的web server上面，那么整個(gè)過程就很不一樣了，所以后很多東西都要改，我想這也是為什么Red5 0.8 RC1為什么只有安裝版但還沒有war版的原因。

最后，如果哪位成功在Tomcat上配置過Red5 0.7的war版本，還請告訴我一聲，我試了0.6的war可以，不知道0.7為什么老不行。。。

發(fā)表于 2009-06-23 17:30 tomjamescn 閱讀(929) 評論(0) 編輯收藏

[轉(zhuǎn)]Red5源代碼分析 - 關(guān)鍵類及其初始化過程

Red5如何響應(yīng)rmpt的請求，中間涉及哪些關(guān)鍵類？

Red5如何啟動(dòng)？在它的啟動(dòng)過程中如何初始化這些關(guān)鍵類？

Spring beanFactory 的層次圖

常用鏈接

留言簿(2)

隨筆分類

隨筆檔案

文章檔案

搜索

最新評論

閱讀排行榜

評論排行榜

tomjamescn 學(xué)習(xí)JavaSE和JavaEE相關(guān)知識...
BlogJava \| 首頁 \| 發(fā)新隨筆 \| 發(fā)新文章 \| 聯(lián)系 \| 聚合 \| 管理	隨筆：58 文章：21 評論：5 引用：0