Red5流媒体RTMP服务端和Flash方法相互调用的示例代码
服务端代码[*]package org.zyf.myServer;//需要修改
[*]import org.red5.server.adapter.ApplicationAdapter;
[*]import org.red5.server.api.IConnection;
[*]import org.apache.commons.logging.Log;
[*]import org.apache.commons.logging.LogFactory;
[*]import org.red5.server.api.Red5;
[*]import org.red5.server.api.service.IServiceCapableConnection;
[*]
[*]public class Application extends ApplicationAdapter {
[*]
[*] protected static Log log = LogFactory.getLog(Application.class.getName());
[*] public String CallServer(String str){
[*] System.out.println("user connected.param= " + str );
[*] IConnection myConn=Red5.getConnectionLocal();
[*] if (myConn instanceof IServiceCapableConnection)
[*] {
[*] //转发消息
[*] IServiceCapableConnection sc = (IServiceCapableConnection) myConn;
[*] sc.invoke("CallBack", new Object[]{"wellcome"});
[*] }
[*] return "hellow";
[*] }
[*]
[*] public boolean appConnect(IConnection conn, Object[] params) {
[*] // Trigger calling of "onBWDone", required for some FLV players
[*]
[*] if (params == null || params.length == 0) {
[*] log.debug("user unknown connected");
[*] // NOTE: "rejectClient" terminates the execution of the current method!
[*] //rejectClient("No username passed.");
[*] }
[*] else
[*] {
[*] log.debug("user "+params+" connected");
[*] }
[*]
[*] return super.appConnect(conn, params);
[*] }
[*]
[*]}
Flash代码:
[*]//import flash.net.Responder;
[*]
[*]NetConnection.defaultObjectEncoding = flash.net.ObjectEncoding.AMF0;
[*]var nc:NetConnection = new NetConnection();
[*]nc.addEventListener(NetStatusEvent.NET_STATUS,StatusHander);
[*]nc.addEventListener(AsyncErrorEvent.ASYNC_ERROR,ErroHander);
[*]nc.connect("rtmp://192.168.10.10/myServer");
[*]trace("connect..");
[*]
[*]
[*]var obj:Object = new Object();
[*]function StatusHander(event:NetStatusEvent):void
[*]{
[*] var info:Object = event.info;
[*]
[*] trace("StatusHander");
[*] switch(info.code)
[*] {
[*] case "NetConnection.Connect.Success":
[*] trace("Sucess");
[*] nc.client = this;
[*] nc.call("CallServer",new Responder(Result),"msg=NC.call");
[*] break;
[*] case "NetConnection.Connect.Failed":
[*] trace("Failed");
[*] break;
[*] default:
[*] trace(info.code);
[*] break;
[*] }
[*]}
[*]var a:int=0;
[*]function Result(obj:Object):void
[*] {
[*] trace("i got it: "+obj);
[*] }
[*]function ErroHander(event:AsyncErrorEvent):void
[*]{
[*] trace("Erro:");
[*]}
[*]
[*]function CallBack(str:String):String
[*]{
[*] trace("CallBack()"+str);
[*] return str+" len = "+ str.length;
[*]}
[*]
[*]//stop();
输出：
connect..
StatusHander
Sucess
CallBack()wellcome.
i got it: hellow
页:
[1]