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

・変更前

package org.red5.demos.oflaDemo2;

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(&quot;oflaDemo appStart&quot;);
		System.out.println(&quot;oflaDemo appStart&quot;);

		//Get plugin
		//AuthPlugin authPlugin = (AuthPlugin) PluginRegistry.getPlugin(&quot;authPlugin&quot;);
		//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(&quot;oflaDemo appConnect&quot;);
		// Trigger calling of &quot;onBWDone&quot;, 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, &quot;live0&quot;);
//			SimplePlayItem item = new SimplePlayItem();
//			item.setStart(0);
//			item.setLength(10000);
//			item.setName(&quot;on2_flash8_w_audio&quot;);
//			serverStream.addItem(item);
//			item = new SimplePlayItem();
//			item.setStart(20000);
//			item.setLength(10000);
//			item.setName(&quot;on2_flash8_w_audio&quot;);
//			serverStream.addItem(item);
//			serverStream.start();
//			try {
//				serverStream.saveAs(&quot;aaa&quot;, false);
//				serverStream.saveAs(&quot;bbb&quot;, false);
//			} catch (Exception e) {}
//		}

		return super.appConnect(conn, params);
	}

	/** {@inheritDoc} */
    @Override
	public void appDisconnect(IConnection conn) {
		log.info(&quot;oflaDemo appDisconnect&quot;);
		if (scope == conn.getScope() &amp;&amp; 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;
import org.red5.server.api.stream.IServerStream;
// 追加
import org.red5.server.api.IBandwidthConfigure;
import org.red5.server.api.stream.IStreamCapableConnection;
import org.red5.server.api.stream.support.SimpleConnectionBWConfig;

public class Application extends ApplicationAdapter {

	private IServerStream serverStream;

	/** {@inheritDoc} */
    @Override
	public boolean appStart(IScope app) {
	    super.appStart(app);
		log.info(&quot;oflaDemo appStart&quot;);
		System.out.println(&quot;oflaDemo appStart&quot;);

		//Get plugin
		//AuthPlugin authPlugin = (AuthPlugin) PluginRegistry.getPlugin(&quot;authPlugin&quot;);
		//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(&quot;oflaDemo appConnect&quot;);
		// Trigger calling of &quot;onBWDone&quot;, 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);
		}

Eclipseで実行（コンパイル）していきます。
実行（コンパイル）、およびは、動作確認については、前回の記事「Red5 フリーソフトのFlashストリーミングサーバ～開発クライアントの構築その６～」を参照してください。

帯域制限するためのクラスがバージョン0.9から削除されているのかは、不明です。
ここまでが、開発クライアントに関する記事となります。