Wowza服務器模塊 - 視頻聊天定時器/倒計時

Question

對於我們當前的項目，我們需要一個視頻聊天應用程序，用於跟蹤這些視頻對話的持續時間。

每個對話的聊天時間也有限，之後聊天結束。

我已經構建了基本模塊，但是我在實現該定時器時遇到了問題。 在WOWZA 1對1的視頻聊天應用總是2流：

User1的發佈一個流，其用戶2起着（預訂）
用戶2發佈一個流，其用戶1起着（預訂）

在數據庫中保存（在聊天之前）有限的時間量。

現在減少這個數量的最佳方法是什麼？

我不能這樣做在StreamListener，因爲總是有兩個流，它會減少兩次。

也許某種單身？

謝謝！

Answer 1

而不是單身人士，如果您的視頻聊天時間一旦開始聊天就不會改變，您可以實現一個模塊並在play或publish事件上附加TimerTask。以下是您幫助您入門的一個示例。

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) {  
    } 

}