`
sooxin
  • 浏览: 257629 次
  • 性别: Icon_minigender_1
  • 来自: 成都
社区版块
存档分类
最新评论

利用BlazeDS的AMF3数据封装与Flash 进行Socket通讯

阅读更多

出处:http://hi.baidu.com/mr%5Fziqiang/blog/item/600c630ef00392cc7acbe142.html

 

前几天看到了Adobe有个开源项目BlazeDS,里面提供了Java封装AMF3格式的方法。这个项目貌似主要是利用Flex来Remoting的,不过我们可以利用他来与Flash中的Socket通讯。

AS3 Socket类有readObject和writeObject的方法,这两个方法可以从以 AMF 序列化格式编码的套接字读取、发送一个对象,之前一直没有办法得到AMF3封装的数据,不过看来这一次可以好好利用BlazeDS提供的方法了。

我觉得这对于喜欢Flash网络游戏开发的爱好者是一个惊喜。因为无论在服务器端还是在客户端写程序你都可以随心所遇的进行数据封装,可读性很高,可以马上就开始你的测试。并且因为是二进制传输,效率比XMLSocket要高。

不过对于这个问题杨师哥认为到最后还是需要规划好事件,设计自己的通讯协议。前期测试阶段使用为了便于沟通使用AMF封装没问题。

进入主题前,我觉得有必要稍微了解一下AS 3中的Socket的通讯方式,As3 cookbook书中提到Flash中的socket连接方式是异步方式,我们通常在事件中进行判断。(书中510页)

怎么理解呢?用以前Luar举得一个例子理解一下同步与异步。(不知道我自己理解的对不对)

有一棵苹果树,我们要等苹果熟的时候摘苹果。那么我们有两种方式:

第一种同步方式——我们找个凳子坐在苹果树下面等着,一直等着,等到苹果熟了。我们把他摘下来

第二中异步方式——我们不用一直等着,苹果熟了有个事件通知我们,我们再去摘。

对于Socket类提供的readObject你不用担心数据没有传输完,多大的数据只要传过来是一个Object对象你要做的就是一句代码:socket.readObject();接收完之后他会执行你的下一个语句。

因此,在你的SOCKET_DATA事件处理函数中只要两句就行了:

obj=socket.readObject();
this.dispatchEvent(new Event("recieved"));

感觉很爽吧。你可以比较一下非AMF的方式(看这里),是不是简洁多了。

好了现在看一下服务器端的代码AmfServer.java。(根据Weni的代码改的)

import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.HashMap;

import flex.messaging.io.SerializationContext;
import flex.messaging.io.amf.Amf3Input;
import flex.messaging.io.amf.Amf3Output;

public class AmfServer
{
public static void main(String args[])
{
   SerializationContext serializationContext=new SerializationContext();
  
   //序列化amf3对象
   Amf3Output amfout=new Amf3Output(serializationContext);
  
   //实现了一个输出流,其中的数据被写入一个 byte 数组。
   ByteArrayOutputStream byteoutStream=new ByteArrayOutputStream();
  
   //将byteoutStream产生的数组流导入到DataOutputStream流中
   DataOutputStream dataoutstream=new DataOutputStream(byteoutStream);
  
   //创建ServerSocket和Socket对象
   ServerSocket serverSocekt;
   Socket socket;
  
   // 设置流的编码格式为amf3
   amfout.setOutputStream(dataoutstream);
  
   //创建Map对象、Double对象数组
   HashMap map=new HashMap();
   map.put("Event", "人物移动");
   map.put("user", "闪刀浪子");
   map.put("x", 100);
   map.put("y", 100);  
  
   try {
    amfout.writeObject(map);//实际上是将map对象写入到dataoutstream流中
    dataoutstream.flush();//清空缓存
   } catch (IOException e) {
    e.printStackTrace();
   }
  
   //将ByteArrayOutputStream流中转化成字节数组
   byte[] messageBytes=byteoutStream.toByteArray();//amf3数据
  
   OutputStreamWriter osw;//使用amf3格式将写入流中的数据编码成字节
   BufferedWriter bwrite;//用来封装OutputStreamWriter,以提高效率
  
   try {
   
    System.out.println("输出数组长度"+messageBytes.length);   
    serverSocekt=new ServerSocket(1028);//开启服务器进程   
    System.out.println("服务器已经启动。。。。。。。");   
    socket=serverSocekt.accept();   
    if(socket.isConnected())
    {
     System.out.println(">>>>>>>>>>客户端已连接");
    }
    //socket.
    osw=new OutputStreamWriter(socket.getOutputStream());//将字符流转化为字节流
    bwrite=new BufferedWriter(osw);//封装osw对象,提高写入的效率
   
    socket.getOutputStream().write(messageBytes);//向流中写入二进制数据
    socket.getOutputStream().flush();
    socket.getOutputStream().close();
   
   } catch (FileNotFoundException e) {
    e.printStackTrace();
   }
   catch (IOException e) {
    e.printStackTrace();
   }
}
}

上面的这个例子我们模拟了一个事件——人物移动,并把相关数据一并封装到了一个Object对象里面。

下面是客户端的代码(AmfSocket.fla),因为比较简单随意没有注释了。

var socket:Socket=new Socket();
socket.addEventListener(Event.CLOSE, closeHandler);
socket.addEventListener(Event.CONNECT, connectHandler);
socket.addEventListener(IOErrorEvent.IO_ERROR, ioErrorHandler);
socket.addEventListener(SecurityErrorEvent.SECURITY_ERROR, securityErrorHandler);
socket.addEventListener(ProgressEvent.SOCKET_DATA, socketDataHandler);
socket.connect("localhost",1028);
var obj:Object=new Object();

addEventListener("recieved",recievedData);
function recievedData(evt:Event)
{
switch (obj.Event) {
   case "人物移动" :
    trace("把玩家:"+obj.user+" 移动到"+obj.x+","+obj.y);
    break;
   case "人物换装" :
    trace("人物换装");
    break;
   case "消息广播" :
    trace("系统信息");
    break;
   default :
    break;
}

};

function closeHandler(event:Event):void {
trace("连接关闭");
}

function connectHandler(event:Event):void {
trace("连接成功");
}

function ioErrorHandler(event:IOErrorEvent):void {
trace("ioErrorHandler信息: " + event);
}

function securityErrorHandler(event:SecurityErrorEvent):void {
trace("securityErrorHandler信息: " + event);
}

function socketDataHandler(event:ProgressEvent):void {
trace("接收数据");
obj=socket.readObject();
this.dispatchEvent(new Event("recieved"));
}

执行结果:
连接成功
接收数据
闪刀浪子移动到100,100
连接关闭

源文件在这里

使用说明:压缩包里面有两个类包。关于AMF3封装的类就存在flex-messaging-core.jar的flex.messaging.io.amf包里面,其中几个比较重要的类有(Amf3Output、Amf3Input)。

如果你要下载完整的东西可以去Adobe下载BlazeDS.war,然后更名为BlazeDS.zip,把里面的东西解压出来。

转载请注明出处:http://hi.baidu.com/mr%5Fziqiang/blog/item/600c630ef00392cc7acbe142.html

分享到:
评论

相关推荐

    AMF抓取flex页面数据

    - Flex应用通常通过HTTP/HTTPS与服务器通信,使用AMF协议封装数据,通过Flash Player发送到服务器。这些请求可能包括服务调用、事件处理等。 3. **抓取AMF数据** - 抓取AMF数据需要特殊工具,如Charles、...

    blazeds flash开源服务器

    Blazeds,全称为BlazeDS,是一款由Adobe公司开发并开源的服务器端技术,它主要为Flash客户端提供数据服务,使Flash与后端服务器能够进行高效的数据交互。Blazeds是基于Java平台的,利用Action Message Format (AMF)...

    AMF格式文件

    AMF格式文件最初在Flash Player 6中引入,并被广泛应用于网络通信,特别是在Adobe Flex框架和BlazeDS中间件中,它允许客户端和服务器之间通过AMF编码的数据进行高效、强类型的数据交换。 AMF格式文件有多个版本,...

    Blazeds与java通信

    Blazeds是一个强大的Java服务器端技术,主要用于实现Flex(一种基于Adobe Flash的用户界面开发工具)与后端Java应用程序之间的数据交互。它提供了一个全面的解决方案,使开发人员能够构建富互联网应用程序(RIA),...

    Flex blazeds封装实体

    BlazDS提供了丰富的数据服务,包括远程方法调用(Remote Method Invocation, RMI)、消息代理(Message Brokering)以及数据推送等功能,使得Flex应用程序能够轻松地与Java服务器进行数据交互。 在Flex BlazDS中,...

    blazeDs解决flex客户端与Server的远程通讯

    Flex是一种用于构建富互联网应用程序(RIA)的客户端框架,而BlazeDS则是其背后的通信引擎,提供了数据推送、发布/订阅消息模式等功能,使得Flex应用能够与后端服务(如Java应用服务器)进行高效的数据交换。...

    FLex与Java交互必备blazeds

    Blazeds是Adobe官方推出的一款开源项目,全称为Flex Business Application Platform,它是Flex与Java应用程序之间进行数据交互的重要桥梁。Flex是一种基于ActionScript的富互联网应用程序(RIA)开发框架,而Java则...

    利用BlazeDS实现Flex和JAVA通讯,内含与spring整合

    BlazeDS允许Flex客户端与Java后端进行实时数据交互,使得富互联网应用(RIA)能充分利用后端数据和服务。 **为何选择BlazeDS** 1. **性能高效**:BlazeDS使用AMF(Action Message Format)协议,该协议比XML更轻量...

    flex C# 基于socket 通讯 应用程序源码

    - BlazeDS或LiveCycle Data Services:Adobe提供的中间件,允许Flex应用程序与Java或.NET服务进行数据交换,包括Socket通信。 2. **C#服务端开发**: - `System.Net.Sockets.Socket`类:用于创建和管理Socket连接...

    amf.zip_AMF_amf_python

    Python中的AMF库可以帮助开发者解析和序列化这两种格式的数据,使得在Python应用中可以方便地与使用AMF的系统进行交互,比如与Adobe的Flex或Adobe BlazeDS服务进行数据交换。 这个名为"amf.py"的文件可能是整个库的...

    blazeds4.7官方下载

    BlazeDS是Adobe公司开发的一款开源的服务器端技术,它主要负责实现Java应用程序与客户端的Flex应用程序之间的数据交互。BlazeDS的出现极大地推动了富互联网应用(RIA)的发展,使得开发者可以利用Flex的图形界面优势...

    基于AMF的Android数据通信.pdf

    通过使用AMF,Android应用可以与服务器端进行高效的数据交换,提高应用性能和用户体验。 3. AMF序列化 AMF序列化是将对象转换为二进制数据的过程。通过使用AMF序列化,Android应用可以将对象转换为二进制数据,...

    BlazeDS开发者指南中文版

    利用Flash Player插件或Adobe AIR,BlazeDS可以为JavaScript提供AMF支持,实现与服务器的低延迟通信。 总之,BlazeDS是实现客户端和服务器之间高性能数据交换的重要工具,尤其适合需要实时更新的Web应用。通过深入...

    AMF1.0(AMP).zip

    AMF,全称为Action Message Format,是一种数据序列化协议,主要在Adobe的Flex、Flash Player以及服务器端技术如Adobe LiveCycle Data Services等中使用。它允许应用程序之间高效地传输复杂的数据结构,包括对象、...

    Blazeds向客户端推送数据.

    3. **数据实体(Data Objects)**:在Java环境中,创建实体对象作为数据传输的格式。例如,`Tick`类包含了如`askPrice`、`bidPrice`和`midPrice`等字段,这些字段可以通过Blazeds框架序列化为AMF格式,然后通过通道...

    使用BlazeDS实现flex与java 整合

    BlazeDS通过AMF(Action Message Format)协议,实现了高性能、低延迟的数据传输,使得Flex前端可以高效地与Java后端进行交互。在本文中,我们将深入探讨如何使用BlazeDS来整合Flex和Java,以及在这个过程中可能遇到...

    asp与flash通讯

    在实际项目中,开发者需要根据具体需求选择合适的通信方式,如使用FlashVars进行简单的数据传递,或者利用XMLSocket或AMF实现复杂的数据交换和实时交互。了解这些技术,并熟练应用它们,可以使ASP和Flash结合的Web...

    BlazeDS 数据通信技术

    这一框架使用通道来封装Flex应用程序与BlazeDS服务端之间的连接。下面详细介绍BlazeDS客户端的主要结构: - **通道(Channel)**:通道是连接Flex客户端与BlazeDS服务端的基础。它们负责处理客户端与服务端之间的通信...

Global site tag (gtag.js) - Google Analytics