4

現在のプロジェクトでは、これらのビデオ会話の長さを追跡するビデオ チャット アプリケーションが必要です。

すべての会話には、チャットが終了するまでの限られた時間もあります。

私はすでに基本的なモジュールを構築しましたが、そのタイマーの実装に問題があります。WOWZA 1 対 1 ビデオ チャット アプリケーションでは、常に 2 つのストリームがあります。

ユーザー 1 がストリームを公開し、ユーザー 2 が再生 (サブスクライブ) します。 ユーザー 2
がストリームを公開し、ユーザー 1 が再生 (サブスクライブ) します。

制限時間は (チャットの前に) データベースに保存されます。

この量を減らすための最良の方法は何ですか？

常に 2 つのストリームがあり、2 倍に減少するため、StreamListener ではそれを行うことはできません。

たぶんある種のシングルトン？

ありがとう！

4

1 に答える 1

1

シングルトンの代わりに、チャットの開始後にビデオチャットの時間が変わらない場合は、モジュールを実装してTimerTaskonplayまたはpublisheventをアタッチできます。以下は、始めるのに役立つ例です。

import java.util.Timer;
import java.util.TimerTask;

import com.wowza.wms.amf.AMFDataList;
import com.wowza.wms.client.IClient;
import com.wowza.wms.logging.WMSLogger;
import com.wowza.wms.module.*;
import com.wowza.wms.request.RequestFunction;
import com.wowza.wms.stream.IMediaStream;
import com.wowza.wms.stream.IMediaStreamActionNotify;

public class KillAfterNSeconds extends ModuleBase implements IMediaStreamActionNotify {

    private class StreamKiller extends TimerTask{       
        private IMediaStream stream;        
        public StreamKiller(IMediaStream s){
            this.stream = s;
        }       
        @Override
        public void run() {
            try{
                // Complete all your clean up, such as :
                if(stream != null){
                    WMSLogger.getLogger("").info("Killing stream: " + stream.getName());
                    stream.getClient().shutdownClient();
                    stream.shutdown();
                    stream.close();
                }               
            }catch(Exception e){}
        }
    }

    public void publish(IClient paramIClient,
            RequestFunction paramRequestFunction, AMFDataList paramAMFDataList) {
        WMSLogger.getLogger("").info("Start running publish..");
        IMediaStream stream = getStream(paramIClient, paramRequestFunction);
        stream.addClientListener(this);
        Timer timer = new Timer();
        TimerTask task = new StreamKiller(stream);
        // replace here with the actual time to kill stream
        timer.schedule(task, 10000); 
        invokePrevious(paramIClient, paramRequestFunction, paramAMFDataList);
        WMSLogger.getLogger("").info("Finish running publish..");
        return;
    }

    @Override
    public void onUnPublish(IMediaStream stream, String streamName,
            boolean isRecord, boolean isAppend) {
        WMSLogger.getLogger("").info("Start onUnPublish..");
        double elapSeconds = stream.getElapsedTime().getTimeSeconds();
        WMSLogger.getLogger("").info("Elapsed time " + elapSeconds);
        WMSLogger.getLogger("").info("Finish running onUnPublish..");
    }

    @Override
    public void onPause(IMediaStream arg0, boolean arg1, double arg2) {     
    }
    @Override
    public void onPlay(IMediaStream arg0, String arg1, double arg2,
            double arg3, int arg4) {
    }
    @Override
    public void onPublish(IMediaStream arg0, String arg1, boolean arg2,
            boolean arg3) {
    }
    @Override
    public void onSeek(IMediaStream arg0, double arg1) {
    }
    @Override
    public void onStop(IMediaStream arg0) {     
    }

}
于 2013-02-20T10:25:53.690 に答える