FluorineFx:远程共享对象(Remote SharedObjects)

单纯从客户端上来看,FluorineFx的RSO跟FMS中的RSO几乎没什么不同(参见Flash/Flex学习笔记(15):FMS 3.5之远程共享对象(Remote Shared Object) ),只不过FMS是Adobe的收费产品,FluorineFx是用于.Net平台的开源免费产品

.

服务端代码:

1、为了防止客户端随意连接或创建任何属性的RSO,服务端可以定义一个用于安全处理的cs文件

using System.Collections;
using FluorineFx.Messaging.Api;
using FluorineFx.Messaging.Api.SO;

namespace _02_SharedObject
{
    public class SampleSOSecurityHandler : ISharedObjectSecurity 
    {
        #region ISharedObjectSecurity Members

        //是否允许连接
        public bool IsConnectionAllowed(ISharedObject so)
        {            
            return true;
        }

        //是否允许创建rso对象(下面的代码仅允许创建名为position的rso对象)
        public bool IsCreationAllowed(IScope scope, string name, bool persistent)
        {
            if (!"position".Equals(name) || !persistent)
                return false;
            else
                return true;
        }

        //是否允许删除
        public bool IsDeleteAllowed(ISharedObject so, string key)
        {
            return false;
        }

        //是否允许rso对象向服务端send指定回调方法(下面的代码仅允许发送名为drop的回调方法)
        public bool IsSendAllowed(ISharedObject so, string message, IList arguments)
        {
            if (!"drop".Equals(message))
            {
                return false;
            }
            else
            {
                //这里把第一个参数处理一下,客户端可以在drop()方法中访问到处理后的参数
                if (arguments.Count > 0) {
                    arguments[0] = "from server :" + arguments[0];
                }
                return true;
            }
        }

        //rso对象的属性是否可写
        public bool IsWriteAllowed(ISharedObject so, string key, object value)
        {
            return true;
        }

        #endregion
    }
}

2、创建一个ApplicationAdapter(应用适配器)

using FluorineFx.Messaging.Adapter;
using FluorineFx.Messaging.Api;
using FluorineFx.Messaging.Api.SO;


namespace _02_SharedObject
{
    /// <summary>
    /// Summary description for AppHandler.
    /// </summary>
    public class SharedBallApplication : ApplicationAdapter
    {
        public SharedBallApplication()
        {
        }

        public override bool AppStart(IScope application)
        {
            RegisterSharedObjectSecurity(new SampleSOSecurityHandler());//注册刚才定义的安全处理Handler
            return base.AppStart(application);
        }

        /// <summary>
        /// 每当有新客户端连接到服务器时,该方法会被触发
        /// </summary>
        /// <param name="connection"></param>
        /// <param name="parameters"></param>
        /// <returns></returns>
        public override bool AppConnect(IConnection connection, object[] parameters)
        {
            string userName=string.Empty, passWord=string.Empty;

            if (parameters.Length >= 2)
            {
                userName = parameters[0].ToString();//第一个参数当作用户名
                passWord = parameters[1].ToString();//第二个参数当作密码
            }

            if (userName == "jimmy.yang" && passWord == "123456")//安全性校验
            {
                if (base.AppConnect(connection, parameters))
                {
                    //获取共享对象(position)
                    ISharedObject users_so = GetSharedObject(connection.Scope, "position");
                    if (users_so == null)
                    {
                        //创建共享对象
                        CreateSharedObject(connection.Scope, "position", true);
                        users_so = GetSharedObject(connection.Scope, "position");
                    }

                    //更新共享对象
                    users_so.SetAttribute("x", 200);
                    users_so.SetAttribute("y", 200);


                    connection.Client.SetAttribute("clientName", userName); //回传数据到客户端连接

                    return true;
                }
                else {
                    RejectClient("连接失败,请检查服务端是否运行正常!");
                    return false;
                }
            }
            else 
            {
                RejectClient("用户名或密码错误");
                return false;
            }          

             
        }
       
    }
}

最后还要一些配置文件来提供必要的信息,详情见最后的示例源码下载

Flash客户端代码:(几乎跟在FMS环境中完全一样)

import flash.display.StageAlign;
import flash.net.NetConnection;
import flash.events.NetStatusEvent;
import flash.net.SharedObject;
import flash.events.SyncEvent;
import flash.events.MouseEvent;

stage.align = StageAlign.TOP_LEFT;

var nc:NetConnection = new NetConnection();
var ball_so:SharedObject;
var userName:String = "";
var passWord:String = "";
var remoteUrl:String = "";

if (root.loaderInfo.parameters.remotingGatewayPath != null)
{
	remoteUrl = root.loaderInfo.parameters.remotingGatewayPath;
}
else
{
	remoteUrl = "rtmp://localhost:1935/SharedBall";
}

if (root.loaderInfo.parameters.userName != null)
{
	userName = root.loaderInfo.parameters.userName;
}
else
{
	userName = "jimmy.yang";
}

if (root.loaderInfo.parameters.passWord != null)
{
	passWord = root.loaderInfo.parameters.passWord;
}
else
{
	passWord = "123456";
}

this.nc.addEventListener(NetStatusEvent.NET_STATUS,net_status_handler);
this.nc.connect(remoteUrl,userName,passWord);
this.nc.client = this;
this.txtStatus.text = "服务端连接中...";
SharedBall_mc.buttonMode = true;

function net_status_handler(e:NetStatusEvent):void
{
	this.txtStatus.text = "as3 状态:" + e.info.code;
	if (e.info.code == "NetConnection.Connect.Success")
	{
		ball_so = SharedObject.getRemote("position",nc.uri,true);
		this.ball_so.addEventListener(SyncEvent.SYNC,sync_handler);
		this.ball_so.connect(this.nc);
		this.ball_so.client = this;
	}
}


function sync_handler(e:SyncEvent):void
{
	if (ball_so.data.x == undefined || ball_so.data.y == undefined)
	{
		SharedBall_mc.x = 100;
		SharedBall_mc.y = 100;
	}
	else
	{
		SharedBall_mc.x = ball_so.data.x;
		SharedBall_mc.y = ball_so.data.y;
	}
}

SharedBall_mc.addEventListener(MouseEvent.MOUSE_DOWN,mouse_down_handler);

function mouse_down_handler(e:MouseEvent):void
{
	SharedBall_mc.startDrag();
	this.stage.addEventListener(MouseEvent.MOUSE_UP,mouse_up_handler);
	this.stage.addEventListener(MouseEvent.MOUSE_MOVE,mouse_move_handler);
}

function mouse_move_handler(e:MouseEvent):void
{
	ball_so.setProperty("x",this.mouseX);
	ball_so.setProperty("y",this.mouseY);
	trace(ball_so.data.x,ball_so.data.y);
}

function mouse_up_handler(e:MouseEvent):void
{
	SharedBall_mc.stopDrag();
	this.stage.removeEventListener(MouseEvent.MOUSE_UP,mouse_up_handler);
	this.stage.removeEventListener(MouseEvent.MOUSE_MOVE,mouse_move_handler);
	ball_so.send("drop",this.userName);
}


function drop(msg:Object):void{
	this.txtStatus.text = msg.toString();
}

 运行截图:

在这个示例中,小球的坐标来自于服务端的共享对象属性值,所以如果一切顺利,在不同的机器上浏览“嵌入有该swf的页面”,当一台机器上拖动小球时,另一台机器上的小球也会随之运动。

示例源代码下载:http://cid-2959920b8267aaca.office.live.com/self.aspx/Flash/FluorineFx^_02.rar

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏wannshan(javaer,RPC)

dubbo集群容错机制代码分析1

dubbo版本2.5.3 我们这里以zookeeper作为注册中心为例说明。 这里说的集群,可以理解为,一个接口服务对应有多个提供者。 在dubbo的调用方(...

55550
来自专栏腾讯云API

腾讯云API:用Python使用腾讯云API(cvm实例)

腾讯云API地址:https://cloud.tencent.com/document/api

86640
来自专栏菩提树下的杨过

Oracle中使用Entity Framework 6.x Code-First方式开发

去年写过一篇EF的简单学习笔记,当时EF还不支持Oracle的Code-First开发模式,今天无意又看了下Oracle官网,发现EF6.X已经支持了,并且给出...

28750
来自专栏Adam笔记

KSCrash源码分析

1K00
来自专栏walterlv - 吕毅的博客

如何让 .NET Core 命令行程序接受密码的输入而不显示密码明文

发布于 2018-05-26 08:51 更新于 2018-09...

16730
来自专栏Ryan Miao

Spring cache简单使用guava cache

Spring cache简单使用 前言 spring有一套和各种缓存的集成方式。类似于sl4j,你可以选择log框架实现,也一样可以实现缓存实现,比如ehcac...

78670
来自专栏lulianqi

一个基于.NET平台的自动化/压力测试系统设计简述

AutoTest是一个基于.NET平台实现的自动化/压力测试的系统,可独立运行于windows平台下,支持分布式部署,不需要其他配置或编译器的支持。(本质是一个...

24310
来自专栏Android 研究

OKHttp源码解析(八)--中阶之连接与请求前奏

在http请求中,对于请求速度提升和降低延迟,keepalive在网络连接发挥着重大作用。

40420
来自专栏华仔的技术笔记

一个ITMS-90032的坑

40570
来自专栏开发之途

Android 模拟登陆网站实现移动客户端

60780

扫码关注云+社区

领取腾讯云代金券