Red5 フリーソフトのFlashストリーミングサーバ～開発クライアントの構築その５～

Red5 フリーソフトのFlashストリーミングサーバ

～開発クライアントの構築その５～

Red5用のプロジェクト(4)

(1)oflaDemo2の構成

今連載では前回の続きで、サンプル「oflaDemo2」の②に関するファイルを説明および変更箇所について掲載していきます。
念のため、構成を、掲載しておきます。
[styled_images width=”623px” height=”384px”] [image title=”1″]https://techpjin.sakura.ne.jp/techpjin_new/wp-content/uploads/2013/01/red5_client3_1.png[/image] [/styled_images] [clearboth]

②の各ファイルは、「oflaDemo2」アプリケーションを機能させる大事なファイルとなります。

Application.java
DemoService.java
DemoServiceImpl.java
IDemoService.java
SecurityTest.java

では、実際に、編集箇所を見ていきたいと思います。

(2)Application.javaの編集

「Application.java」は、red5アプリケーションの「oflaDemo2」（元は、サンプル「oflaDemo」）です。
ライブストリーミングなどをする際に、中心となるアプリケーションファイルとなります。
ストリーミングをする際に、中継地点的な役割を担っています。
変更する箇所は、1行目となります。

変更前

package org.red5.demos.oflaDemo;
 
import org.red5.server.adapter.ApplicationAdapter;
import org.red5.server.api.IConnection;
import org.red5.server.api.IScope;
import org.red5.server.api.stream.IServerStream;
 
public class Application extends ApplicationAdapter {
 
    private IServerStream serverStream;
 
    /** {@inheritDoc} */
    @Override
    public boolean appStart(IScope app) {
        super.appStart(app);
        log.info("oflaDemo appStart");
        System.out.println("oflaDemo appStart");
 
        //Get plugin
        //AuthPlugin authPlugin = (AuthPlugin) PluginRegistry.getPlugin("authPlugin");
        //Get the handler (application listener in this case) that you want
        //FMSAuthenticationHandler authHandler = authPlugin.getFMSAuthenticationHandler();
        //Red5AuthenticationHandler authHandler = authPlugin.getRed5AuthenticationHandler();
        //Add the handler as a listener for your app (in appStart or where-ever)
        //addListener(authHandler);
 
        return true;
    }
 
    /** {@inheritDoc} */
    @Override
    public boolean appConnect(IConnection conn, Object[] params) {
        log.info("oflaDemo appConnect");
        // Trigger calling of "onBWDone", required for some FLV players
        /*
        measureBandwidth(conn);
        if (conn instanceof IStreamCapableConnection) {
            IStreamCapableConnection streamConn = (IStreamCapableConnection) conn;
            SimpleConnectionBWConfig bwConfig = new SimpleConnectionBWConfig();
            bwConfig.getChannelBandwidth()[IBandwidthConfigure.OVERALL_CHANNEL] =
                1024 * 1024;
            bwConfig.getChannelInitialBurst()[IBandwidthConfigure.OVERALL_CHANNEL] =
                128 * 1024;
            streamConn.setBandwidthConfigure(bwConfig);
        }
        */
 
//      if (appScope == conn.getScope()) {
//          serverStream = StreamUtils.createServerStream(appScope, "live0");
//          SimplePlayItem item = new SimplePlayItem();
//          item.setStart(0);
//          item.setLength(10000);
//          item.setName("on2_flash8_w_audio");
//          serverStream.addItem(item);
//          item = new SimplePlayItem();
//          item.setStart(20000);
//          item.setLength(10000);
//          item.setName("on2_flash8_w_audio");
//          serverStream.addItem(item);
//          serverStream.start();
//          try {
//              serverStream.saveAs("aaa", false);
//              serverStream.saveAs("bbb", false);
//          } catch (Exception e) {}
//      }
 
        return super.appConnect(conn, params);
    }
 
    /** {@inheritDoc} */
    @Override
    public void appDisconnect(IConnection conn) {
        log.info("oflaDemo appDisconnect");
        if (scope == conn.getScope() && serverStream != null) {
            serverStream.close();
        }
        super.appDisconnect(conn);
    }
}

変更後

package org.red5.demos.oflaDemo2;
 
import org.red5.server.adapter.ApplicationAdapter;
import org.red5.server.api.IConnection;
import org.red5.server.api.IScope;