red5的共享對(duì)象，使服務(wù)器和客戶端的交互變的更簡(jiǎn)單和直接，服務(wù)器把處理完的業(yè)務(wù)邏輯放在共享對(duì)象(SharedObject)中，客戶端只需要調(diào)用(SharedObject)，就可以直接操作后臺(tái)所返回的數(shù)據(jù)。所有的red5應(yīng)用程序都繼承自ApplicationAdapter類：
1
import java.util.HashMap;
2import java.util.Map;
3
4import org.red5.server.adapter.ApplicationAdapter;
5import org.red5.server.api.IClient;
6import org.red5.server.api.IConnection;
7import org.red5.server.api.IScope;
8import org.red5.server.api.so.ISharedObject;
9
10
11
/** *//**
12
* red5后臺(tái)服務(wù)器與flash前臺(tái)交互類
13 * @author zhanghh
14 *
15
*/
16public class Application extends ApplicationAdapter
{
17
18 private Map<String, IConnection> onLineClient = new HashMap<String, IConnection>();
19
20
21 // 屬性
22 private IScope appScope;
23
24 private String username;
25
26 private ISharedObject so;
27
28 private String sharedName;
29
30
/** *//**
31 * 客戶端連接服務(wù)器的方法
32
*/
33 public String createSharedObjectPond(Object[] params){
34 //接收客戶端傳過(guò)來(lái)的參數(shù)值
35 sharedName = (String) params[0];
36
37 //創(chuàng)建共享對(duì)象
38 createSharedObject(appScope,sharedName,true);
39 so = getSharedObject(appScope, sharedName);
40
41 //引用共享對(duì)象的監(jiān)聽(tīng)器
42 so.addSharedObjectListener(new SampleSharedObjectListener());
43
44
45 //將此三個(gè)屬性值放入共享對(duì)象中
46 so.beginUpdate();
47 so.setAttribute("temperature", 20);
48 so.setAttribute("humidity", 50);
49 so.setAttribute("nutrition", 85);
50 so.endUpdate();
51
52 return sharedName;
53 }
54
55 /** *//**
56 * 此應(yīng)用于開(kāi)始運(yùn)行時(shí)觸發(fā)的方法
57 */
58 public boolean appStart(IScope app) {
59 System.out.println("red5系統(tǒng)已啟動(dòng)~！");
60 if (!super.appStart(app)) {
61 return false;
62 }
63 appScope = app;
64 return true;
65
66 }
67
68 /** *//**
69 * 連接服務(wù)器
70 */
71 public boolean connect(IConnection conn, IScope scope, Object[] params) {
72 username = "";
73 // 登入時(shí)將連接ID和連接信息形成對(duì)應(yīng)關(guān)系并存入在線列表
74 String link_id = conn.getClient().getId();
75 System.out.println("連接--->link_id:"+link_id);
76 onLineClient.put(username, conn);
77
78 return true;
79
80 }
81
82 /** *//**
83 * 斷開(kāi)服務(wù)器
84 */
85 public void disconnect(IConnection conn, IScope scope) {
86 super.disconnect(conn, scope);
87 System.out.println("歡迎下次光臨,再見(jiàn)!");
88 }
89
90}
91
為了得到客戶端共享對(duì)象的改變通報(bào)，監(jiān)聽(tīng)器必須繼承接口ISharedObjectListener：
1import org.red5.server.api.so.ISharedObjectBase;
2import org.red5.server.api.so.ISharedObjectListener;
3
4
5/** *//**
6 * 共享對(duì)象的監(jiān)聽(tīng)實(shí)現(xiàn)類
7 * @author zhanghh
8 *
9 */
10public class SampleSharedObjectListener implements ISharedObjectListener{
11
12 /** *//**
13 * 監(jiān)聽(tīng)客戶端屬性的變化值
14 */
15 @Override
16 public void onSharedObjectUpdate(ISharedObjectBase so, String key, Object value) {
17 //共享對(duì)象so的屬性<key>
18 //被修改成<value>
19 //客戶端有任何的屬性值改變，都會(huì)調(diào)用onSharedObjectUpdate()方法
20 }
21 @Override
22 public void onSharedObjectConnect(ISharedObjectBase so) {
23 //red5每次連接的時(shí)候調(diào)用此方法
24 }
25 @Override
26 public void onSharedObjectClear(ISharedObjectBase arg0) {
27 // TODO Auto-generated method stub
28 }
29 @Override
30 public void onSharedObjectDelete(ISharedObjectBase arg0, String arg1) {
31 // TODO Auto-generated method stub
32 }
33 @Override
34 public void onSharedObjectDisconnect(ISharedObjectBase arg0) {
35 // TODO Auto-generated method stub
36 }
37 @Override
38 public void onSharedObjectSend(ISharedObjectBase so, String method, List params) {
39 // TODO Auto-generated method stub
40 }
41 @Override
42 public void onSharedObjectUpdate(ISharedObjectBase arg0, IAttributeStore arg1) {
43 // TODO Auto-generated method stub
44 }
45 @Override
46 public void onSharedObjectUpdate(ISharedObjectBase arg0, Map<String, Object> arg1) {
47 // TODO Auto-generated method stub
48 }
49}
50
共享對(duì)象在被服務(wù)器處理完業(yè)務(wù)邏輯之后，要把處理后的值廣播給客戶端，最好作為注冊(cè)句柄被通報(bào)。
使用beginUpdate() 和 endUpdate()方法：
1//將此三個(gè)屬性值放入共享對(duì)象中
2 so.beginUpdate();
3 so.setAttribute("temperature", 20);
4 so.setAttribute("humidity", 50);
5 so.setAttribute("nutrition", 85);
6 so.endUpdate();
posted on 2009-05-26 18:09
kenzhang 閱讀(3903)
評(píng)論(3) 編輯 收藏