UMS开发系列之一：用ActionScript和JavaScript开发RTMP网络实时应用

时间 2019-11-20

标签 ums 开发系列之一 actionscript javascript rtmp 网络实时应用栏目 JavaScript 繁體版

原文原文链接

UMS开发系列之一：用ActionScript和JavaScript开发RTMP网络实时应用

1.导语

本文介绍如何使用ActionScript和UMS开发实时交互式多媒体应用。RTMP协议是flash/AIR平台原生支持的实时消息协议。基于RTMP协议，flash/AIR平台应用能够和服务端进行双向数据通讯、传输实时音视频。ActionScript3中的NetConnection对象提供了与RTMP服务端创建链接、收发数据包的接口。使用这些原生接口进行应用开发，无疑是最高效和便捷的。javascript

2.AMS介绍

AMS是Adobe Media Server(之前叫FMS)的缩写，是Adobe官方推出的标准RTMP服务器，支持用服务端js语言编写服务端扩展，但AMS的js平台比较封闭，不能加载外部模块，只能简单调用服务端的js对象对链接指令、受权进行处理。若是要开发与数据业务集成紧密的大型flash网络应用，则AMS将显得力不从心，由于AMS服务器跟经常使用的数据库（如redis/MySQL/MongoDB/Sqlite3等）集成的能力很是有限。java

3.UMS介绍

UMS是Ultrant Media Server的缩写，是一款多功能高性能流媒体/交互服务器解决方案，基于node.js构建，底层采用高性能C/C++多线程异步框架实现链接管理，并将绝大部分可操做功能以javascript接口方式暴露在node.js上下文中，能实现精确的实时流量统计、链接管理、权限验证以及灵活方便的远程接口扩展，能应对多媒体上层业务的快速变化。业务层逻辑可以彻底经过js进行扩展和控制，支持RTMP协议，支持AMF0/AMF3编码，支持RTMP命令服务端扩展。node

因为node.js是一个开放的开发平台，拥有庞大而活跃的开发者社区，基于node.js开发的模块达到10万之多。UMS将RTMP命令扩展到node.js层面，无异于打通了RTMP链接和庞大的应用层模块之间的藩篱，将AS3应用带入了丰富多彩的接入层，AS3应用能够轻松接入各种数据库模块（sqlite3/redis/mysql/mongodb等）。mysql

长话短说，来看一个简单的AS3和服务端交互的例子。redis

ActionScript代码：

 1 package
 2 {
 3     import flash.display.Sprite;
 4     import flash.events.Event;
 5     import flash.events.NetStatusEvent;
 6     import flash.net.NetConnection;
 7     import flash.net.ObjectEncoding;
 8     import flash.net.Responder;
 9 
10     public class AS3UMSTutor1 extends Sprite
11     {
12         private var _nc:NetConnection = null;
13         private var _responder:Responder = null;
14 
15         public function AS3UMSTutor1()
16         {
17             this.addEventListener(Event.ADDED_TO_STAGE, setupPlayer);
18             this._nc = new NetConnection();
19             this._nc.objectEncoding = ObjectEncoding.AMF3;
20             this._nc.addEventListener( NetStatusEvent.NET_STATUS, netStatusHandler);
21             //Allow method within the class to be called by the server side script
22             this._nc.client = this;
23             this._responder = new Responder(onResponderReply, onResponderError);
24         }
25 
26         protected function setupPlayer(event:Event=null):void {
27             try {
28                 this.removeEventListener(Event.ADDED_TO_STAGE, setupPlayer);
29                 this._nc.connect("rtmp://127.0.0.1/myApp");
30             } catch (err:Error) {
31                 //
32             }
33         }
34 
35         //Handle NetStatus
36         private function netStatusHandler( event:NetStatusEvent ):void
37         {
38             //trace(event.info.code);
39             switch( event.info.code )
40             {
41                 // Successfully connected to UMS, execute function
42                 case "NetConnection.Connect.Success":
43                     {
44                         this._nc.call("helloFromAS3", this._responder, "hello,ums :)");
45                     }
46                     break;
47                 case "NetConnection.Connect.Rejected":
48                     break;
49                 case "NetConnection.Connect.Closed":
50                     break;
51                 case "NetConnection.Connect.Failed":
52                     break;
53             }
54         }
55         private function onResponderReply(result:Object):void{
56             trace(result.message);
57         }
58         private function onResponderError(result:Object):void{
59             trace(result.message);
60         }
61     }
62 }

node.js代码：

  1 ///////////////////////////////////////////////////////////////////////////////
  2 // file : as3tutor1.js
  3 // author : IMMAAC Co.,Ltd.
  4 // description : example file to demonstrate how to use ums
  5 ///////////////////////////////////////////////////////////////////////////////
  6 
  7 var ums = require('umsjs');
  8 
  9 /**
 10  * global options
 11  */
 12 
 13 var rtmpPort = 1935;
 14 
 15 ///////////////////////////////////////////////////////////////////////////////
 16 // @function : main
 17 // @params : server - (RTMPServer, RTMPServer实例)
 18 // @return : 无
 19 // @brief : 用户程序入口，在这里添加相关业务逻辑操做。
 20 // @remark : 进入该入口前，RTMPServer并未添加任何服务端应用程序（server-side
 21 //   application），只是开始在相应端口上监听新链接，但任何新创建的链接
 22 //   都会被拒绝。因此必须为server添加至少一个服务端应用程序，服务才能
 23 //   正常工做。
 24 ///////////////////////////////////////////////////////////////////////////////
 25 function main(server){
 26     // 订阅TCP链接创建的时间通知
 27     server.on('connection', function(conn){
 28         // 接受一个TCP链接
 29         this.accept(conn, true); // 拒绝链接用法 : this.accept(conn, false);
 30     });
 31     // 订阅RTMPServer出错通知
 32     server.on('error', function(err){
 33         console.dir(err);
 34     });
 35     // 订阅RTMPServer关闭通知
 36     server.on('close', function(){
 37         console.log('server closed.');
 38     });
 39     // 载入服务端应用程序'myApp'
 40     loadmyApp(server);
 41 }
 42 
 43 ///////////////////////////////////////////////////////////////////////////////
 44 // @function : loadmyApp
 45 // @params : server - (RTMPServer, 一个已经成功建立并运行的RTMPServer实例)
 46 // @brief : 加载一个名为'myApp'的服务端应用程序。
 47 // @remark : 该示例将完成以下操做：
 48 //   1.建立一个名为'myApp'的服务端应用程序；
 49 //   2.订阅相关事件。
 50 ///////////////////////////////////////////////////////////////////////////////
 51 function loadmyApp(server){
 52     // 建立一个名为'myApp'的服务端应用程序ums.Application的实例
 53     var app = ums.createApplication("myApp");
 54     // 订阅出错事件
 55     app.on('error', function(err){
 56         console.log('error : ', err);
 57     })
 58     // 添加'connect'事件的监听处理函数
 59     app.on('connect', function(cmd, client){
 60         // 接受新链接
 61         app.accept(cmd, client, true);// 拒绝链接用法 : app.accept(cmd, client, false);
 62         // 订阅错误事件
 63         client.on('error', function(err){
 64             console.dir(err);
 65         });
 66         // 订阅关闭事件
 67         client.on('close', function(){
 68             console.log("client[",this.clientId,"] closed. Total time :", 
 69             (new Date()).getTime() - client.connectedTime.getTime());
 70         });
 71         // 订阅helloFromAS3事件
 72         client.on('helloFromAS3', function(cmd, message){
 73             console.dir(message); // hello,ums :)
 74             cmd.echoResult({
 75                 message : 'hello, as3 :)'
 76             });
 77         });
 78     });
 79     // 将服务端应用实例注册到RTMPServer实例中
 80     server.register(app);
 81 }
 82 
 83 ///////////////////////////////////////////////////////////////////////////////
 84 // @function : entryPoint
 85 // @params : 无
 86 // @brief : 主程序入口，在这里完成RTMPServer的初始化工做
 87 ///////////////////////////////////////////////////////////////////////////////
 88 function entryPoint(){
 89     // 建立一个RTMPServer选项集合，构造参数指定为服务器选项集合
 90     var serverOpt = ums.createRTMPOptions(true);
 91     serverOpt.rtmpPort = rtmpPort;
 92     // 建立RTMPServer实例
 93     var server = ums.createRTMPServer(serverOpt);
 94     server.start(function(err){
 95         if (err) {
 96             console.log(err);
 97             return;
 98         }
 99         // 进入用户入口
100         main(server);
101     });
102 }
103 
104 ///////////////////////////////////////////////////////////////////////////////
105 // 进入主程序入口
106 // Every thing starts form here
107 ///////////////////////////////////////////////////////////////////////////////
108 
109 entryPoint();
110 
111 ///////////////////////////////////////////////////////////////////////////////
112 // End of file : as3tutor1.js
113 ///////////////////////////////////////////////////////////////////////////////

4.总结

本文介绍了如何使用AS3原生NetConnection对象与UMS创建RTMP链接，以及经过RTMP调用UMS服务端代码注册的函数，并从服务端返回消息的方法。更多复杂接口和高级用法，将在后续系列教程里面陆续推出，敬请期待。sql