Notice: Firmware Links Under Maintenance We are currently undergoing maintenance on all firmware links. If any links are inaccessible, please email or contact Tech Support for the firmware. We appreciate your patience during the maintenance, thank you for your understanding.

Difference between revisions of "Test LiveFeed"

(→‎LiveFeed Test)
Line 45: Line 45:
 
</body>
 
</body>
 
</html>
 
</html>
 +
==2==
 +
<html><?xml version="1.0" encoding="utf-8"?>
 +
<s:Application xmlns:fx="http://ns.adobe.com/mxml/2009"
 +
  xmlns:s="library://ns.adobe.com/flex/spark"
 +
  xmlns:mx="library://ns.adobe.com/flex/mx"
 +
  xmlns:views="rtmfptest.views.*"
 +
  backgroundColor="#F2F0F0"
 +
  width="450"
 +
  height="592" creationComplete="init()" xmlns:local="*">
 +
<fx:Declarations>
 +
 +
</fx:Declarations>
 +
 +
<fx:Style>
 +
.header {
 +
fontSize: 36px;
 +
}
 +
</fx:Style>
 +
 +
<fx:Script>
 +
<![CDATA[
 +
import mx.core.UIComponent;
 +
import mx.utils.StringUtil;
 +
private var nc:NetConnection;
 +
private var cam:Camera;
 +
private var mic:Microphone;
 +
private var videoFarEnd:Video;
 +
private var publishStream:NetStream;
 +
private var subscribeStream:NetStream;
 +
private var subscribeStreamObject:Object;
 +
 +
private function init():void{
 +
 +
if (ExternalInterface.available) {
 +
try {
 +
var href:String = ExternalInterface.call("window.location.href.toString");
 +
var hostname:String = ExternalInterface.call("window.location.hostname.toString");
 +
connectUrl.text = "rtmp://" + hostname + ":1935";
 +
} catch (error:Error) {
 +
Logger.info(error.message);
 +
}
 +
} else {
 +
Logger.info("Error during set callback");
 +
}
 +
cam = Camera.getCamera();
 +
videoMy.attachCamera(cam);
 +
mic = Microphone.getEnhancedMicrophone();
 +
videoFarEnd = new Video();
 +
var container:UIComponent = new UIComponent();
 +
container.addChild(videoFarEnd);
 +
canvas.addChild(container);
 +
playBtn.enabled = false;
 +
publishBtn.enabled = false;
 +
stopBtn.visible = false;
 +
unpublishBtn.visible = false;
 +
disconnectBtn.visible = false;
 +
var streamName:String = generateRandomString(4);
 +
publishStreamName.text = "Stream-"+streamName;
 +
playStreamName.text = "Stream-"+streamName;
 +
 +
}
 +
 +
// Reset button's state, clear status
 +
private function reset():void {
 +
connectBtn.visible = true;
 +
disconnectBtn.visible = false;
 +
 +
unpublishBtn.visible = false;
 +
 +
publishBtn.enabled = false;
 +
publishBtn.visible = true;
 +
 +
playBtn.visible = true;
 +
playBtn.enabled = false;
 +
 +
stopBtn.visible = false;
 +
 +
setPublishStatus("");
 +
setPlayStatus("");
 +
}
 +
 +
private function initCam():void{
 +
cam.setMode(int(camWidth.text),int(camHeight.text),int(camFPS.text),true);
 +
cam.setQuality(0,int(camQuality.text));
 +
cam.setKeyFrameInterval(int(camKeyFrame.text));
 +
cam.setMotionLevel(0,2000);
 +
Logger.info("Cam initizlized "+cam.width+"x"+cam.height);
 +
}
 +
 +
private function initMic():void{
 +
var options:MicrophoneEnhancedOptions = new MicrophoneEnhancedOptions();
 +
options.mode = MicrophoneEnhancedMode.FULL_DUPLEX;
 +
options.echoPath = 128;
 +
options.nonLinearProcessing = true;
 +
mic.codec = SoundCodec.SPEEX;
 +
mic.encodeQuality = 5;
 +
mic.framesPerPacket=1;
 +
mic.gain=50;
 +
mic.setSilenceLevel(0,2000);
 +
mic.enhancedOptions = options;
 +
Logger.info("Mic initialized");
 +
}
 +
 +
/**
 +
* **************************
 +
* CONNECT / DISCONNECT
 +
* **************************
 +
**/
 +
private function connect():void{
 +
var url:String = StringUtil.trim(connectUrl.text);
 +
Logger.info("connect " + url);
 +
nc = new NetConnection();
 +
//if (url.indexOf("rtmp") == 0){
 +
// nc.objectEncoding = ObjectEncoding.AMF0;
 +
//}
 +
nc.client = this;
 +
nc.addEventListener(NetStatusEvent.NET_STATUS, handleConnectionStatus);
 +
var obj:Object = new Object();
 +
obj.login = generateRandomString(20);
 +
obj.appKey  = "flashStreamingApp";
 +
nc.connect(url,obj);
 +
}
 +
 +
 +
 +
//disconnect
 +
private function disconnect():void{
 +
Logger.info("disconnect");
 +
nc.close();
 +
}
 +
 +
private function handleConnectionStatus(event:NetStatusEvent):void{
 +
Logger.info("handleConnectionStatus: "+event.info.code);
 +
if (event.info.code=="NetConnection.Connect.Success"){
 +
Logger.info("near id: "+nc.nearID);
 +
Logger.info("far id: "+nc.farID);
 +
Logger.info("Connection opened");
 +
disconnectBtn.visible = true;
 +
connectBtn.visible = false;
 +
playBtn.enabled = true;
 +
publishBtn.enabled = true;
 +
setConnectionStatus("CONNECTED");
 +
} else if (event.info.code=="NetConnection.Connect.Closed" || event.info.code=="NetConnection.Connect.Failed"){
 +
nc.removeEventListener(NetStatusEvent.NET_STATUS,handleConnectionStatus);
 +
unpublish();
 +
stop();
 +
Logger.info("Connection closed");
 +
setConnectionStatus("DISCONNECTED");
 +
reset();
 +
}
 +
}
 +
 +
private function setConnectionStatus(event:String): void {
 +
connectionStatus.text = event;
 +
}
 +
 +
/**
 +
* *************************
 +
* PUBLISH / UNPUBLISH
 +
* *************************
 +
**/
 +
private function publish():void{
 +
if (publishStreamName.text == "") {
 +
publishStatus.text = "Empty stream name";
 +
publishStatus.setStyle("color","#FF0000");
 +
return;
 +
}
 +
publishStatus.setStyle("color","#000000");
 +
Logger.info("publish audio: "+publishAudio.selected+" video: "+publishVideo.selected);
 +
publishStream = new NetStream(nc);
 +
if (publishAudio.selected){
 +
initMic();
 +
publishStream.attachAudio(mic);
 +
Logger.info("Init audio stream");
 +
}
 +
if (publishVideo.selected){
 +
initCam();
 +
publishStream.attachCamera(cam);
 +
addH264();
 +
Logger.info("Init video stream");
 +
}
 +
addListenerAndPublish();
 +
Logger.info("Publishing");
 +
 +
}
 +
 +
//unpublish
 +
private function unpublish():void{
 +
Logger.info("unpublish");
 +
if (publishStream!=null){
 +
publishStream.close();
 +
}
 +
videoFarEnd.clear();
 +
}
 +
 +
private function addListenerAndPublish():void{
 +
publishStream.videoReliable=true;
 +
publishStream.audioReliable=false;
 +
publishStream.useHardwareDecoder=true;
 +
publishStream.addEventListener(NetStatusEvent.NET_STATUS, handleStreamStatus);
 +
publishStream.bufferTime=0;
 +
publishStream.publish(publishStreamName.text);
 +
}
 +
 +
public function addH264():void{
 +
var videoStreamSettings:H264VideoStreamSettings = new H264VideoStreamSettings();
 +
videoStreamSettings.setProfileLevel(H264Profile.MAIN,H264Level.LEVEL_3_1);
 +
publishStream.videoStreamSettings = videoStreamSettings;
 +
}
 +
 +
private function setPublishStatus(event:String): void {
 +
publishStatus.text = event;
 +
}
 +
 +
/**
 +
* *************************
 +
* PLAY / STOP
 +
* *************************
 +
**/
 +
private function play():void{
 +
if (playStreamName.text == "") {
 +
playStatus.text = "Empty stream name";
 +
playStatus.setStyle("color","#ff0000");
 +
return;
 +
}
 +
playBtn.enabled = false;
 +
playStatus.setStyle("color","#000000");
 +
Logger.info("play");
 +
subscribeStream = new NetStream(nc);
 +
addListenerAndPlay();
 +
}
 +
 +
private function stop():void{
 +
if (subscribeStream != null) {
 +
stopBtn.enabled = false;
 +
subscribeStream.close();
 +
subscribeStream = null;
 +
}
 +
subscribeStreamObject = null;
 +
videoFarEnd.visible = false;
 +
}
 +
 +
private function addListenerAndPlay():void{
 +
subscribeStream.videoReliable=true;
 +
subscribeStream.audioReliable=false;
 +
subscribeStream.useHardwareDecoder=true;
 +
subscribeStream.addEventListener(NetStatusEvent.NET_STATUS, handleSubscribeStreamStatus);
 +
if (playStreamName.text.indexOf("rtsp://") != -1) {
 +
subscribeStream.bufferTime=0.5;
 +
} else {
 +
subscribeStream.bufferTime=0.0;
 +
}
 +
var soundTransform:SoundTransform = new SoundTransform();
 +
soundTransform.volume=0.7;
 +
subscribeStream.soundTransform = soundTransform;
 +
subscribeStreamObject = createStreamObject();
 +
subscribeStream.play(playStreamName.text);
 +
videoFarEnd.attachNetStream(subscribeStream);
 +
videoFarEnd.width = 320;
 +
videoFarEnd.height = 240;
 +
videoFarEnd.visible = true;
 +
}
 +
 +
private function createStreamObject():Object{
 +
var ret:Object = new Object();
 +
ret.mediaSessionId = generateRandomString(8);
 +
ret.name = playStreamName.text;
 +
return ret;
 +
}
 +
 +
private function generateRandomString(strlen:Number):String{
 +
var chars:String = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789";
 +
var num_chars:Number = chars.length - 1;
 +
var randomChar:String = "";
 +
 +
for (var i:Number = 0; i < strlen; i++){
 +
randomChar += chars.charAt(Math.floor(Math.random() * num_chars));
 +
}
 +
return randomChar;
 +
}
 +
 +
private function setPlayStatus(event:String): void {
 +
playStatus.text = event;
 +
}
 +
 +
/**
 +
* ****************************
 +
* HANDLE CONNECTION STATE
 +
* ****************************
 +
**/
 +
 +
private function handleStreamStatus(event:NetStatusEvent):void{
 +
Logger.info("handleStreamStatus: "+event.info.code);
 +
switch (event.info.code) {
 +
case "NetStream.Failed":
 +
Logger.info("Publish failed");
 +
if (publishStream!=null){
 +
publishStream.close();
 +
publishStream.removeEventListener(NetStatusEvent.NET_STATUS, handleStreamStatus);
 +
publishStream=null;
 +
}
 +
videoFarEnd.clear();
 +
setPublishStatus("PUBLISH STREAM FAILED");
 +
break;
 +
case "NetStream.Publish.BadName":
 +
Logger.info("Bad streamName. Please publish stream with other name");
 +
setPublishStatus("PUBLISH STREAM FAILED");
 +
break;
 +
case "NetStream.Unpublish.Success":
 +
publishStream.removeEventListener(NetStatusEvent.NET_STATUS, handleStreamStatus);
 +
publishStream=null;
 +
setPublishStatus("UNPUBLISHED");
 +
publishBtn.visible = true;
 +
unpublishBtn.visible = false;
 +
break;
 +
case "NetStream.Publish.Start":
 +
setPublishStatus("PUBLISHING");
 +
publishBtn.visible = false;
 +
unpublishBtn.visible = true;
 +
break;
 +
}
 +
}
 +
 +
private function handleSubscribeStreamStatus(event:NetStatusEvent):void{
 +
Logger.info("handleSubscribeStreamStatus: "+event.info.code);
 +
switch (event.info.code) {
 +
case "NetStream.Play.PublishNotify":
 +
case "NetStream.Play.Start":
 +
setPlayStatus("PLAYING");
 +
playBtn.visible = false;
 +
stopBtn.enabled = true;
 +
stopBtn.visible = true;
 +
break;
 +
case "NetStream.Play.UnpublishNotify":
 +
case "NetStream.Play.Stop":
 +
setPlayStatus("STOPPED");
 +
playBtn.enabled = true;
 +
playBtn.visible = true;
 +
stopBtn.visible = false;
 +
break;
 +
case "NetStream.Play.StreamNotFound":
 +
setPlayStatus("STREAM NOT FOUND");
 +
playBtn.enabled = true;
 +
playBtn.visible = true;
 +
stopBtn.visible = false;
 +
break;
 +
case "NetStream.Play.Failed":
 +
setPlayStatus("STREAM FAILED");
 +
playBtn.enabled = true;
 +
playBtn.visible = true;
 +
stopBtn.visible = false;
 +
break;
 +
}
 +
}
 +
 +
private function asyncErrorHandler(event: AsyncErrorEvent):void{
 +
Logger.info("asyncErrorHandler: "+event);
 +
}
 +
 +
private function securityErrorHandler(event: SecurityErrorEvent):void{
 +
Logger.info("securityErrorHandler: "+event);
 +
}
 +
public function ping():void{
 +
nc.call("pong", null);
 +
}
 +
 +
public function OnDataEvent(data:Object):void{
 +
var message:Object = data.payload;
 +
Logger.info(message.body);
 +
}
 +
 +
/**
 +
*************************
 +
*  JavaScript callbacks
 +
*************************
 +
**/
 +
 +
private function getDataFromJS(value:String):void {
 +
if (value != null || value != "") {
 +
connectUrl.text = value;
 +
}
 +
}
 +
 +
]]>
 +
</fx:Script>
 +
<s:Label x="96" y="34" width="265" styleName="header" text="Flash Streaming"/>
 +
<!-- connect / disconnect -->
 +
<s:Button id="connectBtn" x="325" y="93" width="90" label="Login" click="connect()"/>
 +
<s:TextInput id="publishStreamName" x="99" y="143" width="199" text="StreamName"/>
 +
<s:Button id="disconnectBtn" x="325" y="93" label="Logout" click="disconnect()" width="90" enabled="true"/>
 +
<s:TextInput id="connectUrl" x="99" y="93" width="200"/>
 +
 +
<!-- publish / unpublish -->
 +
<s:Button id="publishBtn" x="326" y="143" label="Start" width="90" height="21" click="publish()" enabled="true"/>
 +
<s:CheckBox id="publishAudio" x="146" y="505" label="audio" selected="true" />
 +
<s:CheckBox id="publishVideo" x="223" y="505" label="video" selected="true"/>
 +
 +
<s:Label x="120" y="561" text="width"/>
 +
<s:TextInput id="camWidth" x="120" y="531" width="32" text="320"/>
 +
 +
<s:Label x="159" y="561" text="height"/>
 +
<s:TextInput id="camHeight" x="160" y="531" width="31" text="240"/>
 +
 +
<s:Label x="206" y="561" text="fps"/>
 +
<s:TextInput id="camFPS" x="200" y="531" width="31" text="15"/>
 +
 +
<s:Label x="240" y="561" text="quality"/>
 +
<s:TextInput id="camQuality" x="240" y="531" width="31" text="80"/>
 +
 +
<s:Label x="279" y="561" text="keyframe"/>
 +
<s:TextInput id="camKeyFrame" x="280" y="531" width="31" text="15"/>
 +
 +
<!-- play / stop -->
 +
<s:Button id="playBtn" x="325" y="193" label="Start" width="90" height="21" click="play()" enabled="true"/>
 +
 +
<!-- video view -->
 +
<mx:Canvas id = "canvas" visible="true" x="65" y="257" width="320" height="240">
 +
<mx:VideoDisplay id="videoMy" visible="true" x="0" y="0" width="80" height="60"  chromeColor="#EEA1A1"/>
 +
</mx:Canvas>
 +
<s:Label x="35" y="143" width="56" height="22" text="Publish" verticalAlign="middle"/>
 +
<s:Label x="35" y="93" width="89" height="22" text="Server:" verticalAlign="middle"/>
 +
<s:TextInput id="playStreamName" x="99" y="193" width="199" text="StreamName"/>
 +
<s:Label x="35" y="193" height="22" text="Play" verticalAlign="middle"/>
 +
<s:Button id="unpublishBtn" x="326" y="143" label="Stop" click="unpublish()" width="90" enabled="true"/>
 +
<s:Button id="stopBtn" x="325" y="193" label="Stop" width="90" height="21" click="stop()" enabled="true"/>
 +
<s:Label id="connectionStatus" x="123" y="119" width="150" height="20" textAlign="center"
 +
verticalAlign="top"/>
 +
<s:Label id="publishStatus" x="123" y="169" width="150" height="20" textAlign="center"
 +
verticalAlign="middle"/>
 +
<s:Label id="playStatus" x="123" y="219" width="150" height="20" textAlign="center"
 +
verticalAlign="middle"/>
 +
</s:Application></html>

Revision as of 18:39, 4 September 2018

LiveFeed Test

<!DOCTYPE html> Display Webcam Stream

2

.header { fontSize: 36px; }

Retrieved from "https://DahuaWiki.com/index.php?title=Test_LiveFeed&oldid=34577"