red5 视频应用开发指南。第三个项目成功运行经验(3)

    username = loginName.text;
    nc = new NetConnection();
    nc.addEventListener( NetStatusEvent.NET_STATUS , netStatus );// connect to red5, passing false as parameter
    nc.connect( "rtmp://127.0.0.1/red5_5", username);

package com.red5app;

import java.util.HashMap;  
import java.util.List;  
import java.util.Map;  
  

import org.red5.server.adapter.ApplicationAdapter;  
import org.red5.server.api.IConnection;  
import org.red5.server.api.Red5;  
import org.red5.server.api.scope.IScope;
import org.red5.server.api.service.IServiceCapableConnection;  
import org.red5.server.api.so.ISharedObject;  

public class Application  extends ApplicationAdapter{
    private Map<String,IConnection>  clientDic = new HashMap<String,IConnection>();
    //最开始执行的程序
    public Boolean appStart(){
         return true;
     }
     //断开连接时执行的程序
     public void appStop(){
         
     }
     //连接时执行的程序
     public boolean connect (IConnection conn,IScope scope,Object[] params){
          //1,判断是否有用户名
         if(params.length==0){
             rejectClient("Must pass the login name.");
         }
         String loginname=params[0].toString();
         
         conn.setAttribute("UserName", loginname);
        if(!clientDic.keySet().contains(loginname))
         {
             
             clientDic.put(loginname, conn);
             //2 ，新建作用域SharedObject
             ISharedObject so = getSharedObject(scope, "UserSO");
             if(so==null)
             {
                 this.createSharedObject(scope, "UserSO", true);
                 so = getSharedObject(scope, "UserSO");
             }
             so.setAttribute("userlist", clientDic.keySet().toArray());
         }
         else{
             rejectClient("The same user has logged in already");
         }
         
         return super.connect(conn, scope, params);
     }
     public void disconnect (IConnection conn,IScope scope){
         String loginname=conn.getAttribute("UserName").toString();
         if(loginname!=null){
             clientDic.remove(loginname);
             ISharedObject so= getSharedObject(scope,"UserSO");
             if(so!=null){
                 so.setAttribute("userlist",clientDic.keySet().toArray());
             }
          }
          super.disconnect(conn, scope);
     }
}