- 浏览: 251657 次
- 性别:
- 来自: 成都
文章分类
最新评论
-
zoukaiwolai:
...
Java 16进制字符串与2进制字符串相互转换 -
sooxin:
j2ee的事务对连接有自己的管理机制,包括建立和关闭。没进j2 ...
c3p0 spring 包没进事务管理,连接池就不能释放 -
sooxin:
mina 采用一种NIO通信,底层的连接机制没有具体研究过,但 ...
转 Mina框架在项目中的使用 -
tywo45:
写得很好,希望博主把格式调一下!
Tomcat性能参数设置介绍 -
freecode:
采用了cp30,项目中出现很多未关闭的连接,一直在找原因.
c3p0 spring 包没进事务管理,连接池就不能释放
出处: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
发表评论
-
小学语文课堂教学三维目标的制定和落实-广安齐祥娥
2019-07-06 11:31 15教学目标是教学过程中重要的一部分,它是教学的出发点 也是教学 ... -
游戏开发中一些有价值的数值公式
2010-02-02 21:00 1568文章来之:http://hi.baidu. ... -
谈谈游戏编号规则
2010-02-02 20:59 1530文章来之:http://hi.baid ... -
关于编辑器
2010-02-02 20:57 1330文章来之:http://hi.baidu.com/mr%5Fz ... -
游戏怎样炼成的
2010-02-02 20:53 788http://hi.baidu.com/mr%5Fziqian ... -
史上最权威的两篇《征途》研究报告
2010-02-02 20:51 11211、关于史玉柱和征途的批判,媒体对从宏观角度来展开,极少 ... -
游戏内置广告的进化——经营式游戏内置广告
2010-02-02 20:47 1066本文转载自游戏力量:http://youxililiang.b ... -
[转]深入分析规则引擎
2010-02-02 18:03 1911作者:PassByYou Email:pas ... -
关于多人物场景下遮挡关系的思考
2010-02-02 16:47 1434作者:闪刀浪子如需转 ... -
游戏之人工智能---AI漫谈
2010-02-02 16:45 2193AI,也就是人工智能, ... -
《大唐豪侠》架构开发纪实
2010-02-02 16:44 1350游戏介绍《大唐豪侠》是网易公司2006年主推的一款网络游戏。它 ... -
转]网游的十大创意设置
2010-02-02 16:24 906好的创意是成为成功网 ... -
重构我们的Flash客户端
2010-02-02 16:15 1021原文来之:http://hi.baidu. ... -
[转]sns产品架构
2010-02-02 16:07 1967最近,时值腾讯QQ空间及手机社区平台高速发展,迭创新高;我也想 ... -
[转]盈利框架决定游戏结构?还是游戏结构决定盈利框架?
2010-02-02 16:05 825这篇文章其实很有意思 ... -
[转]如何保持RMB玩家和免费玩家的平衡
2010-02-02 16:04 803玩了七八年的网游,基 ... -
【转载】下一代互联网上的虚拟现实新发展
2010-02-01 20:27 1281来源:中国教育和科研 ... -
可复用面向对象编程——FACTORY METHOD(工厂方法)
2010-01-26 21:47 8061.诠释 定义一个用于创建对象的接口,让子类决定实例化哪一个 ... -
可复用面向对象编程——BUILDER(生成器)
2010-01-26 21:13 7361.诠释 将一个复杂对象 ... -
可复用面向对象编程——SINGLETON(单件)
2010-01-24 21:37 10171.诠释 SINGLETON模式:让类自身负责保存它的唯一实 ...
相关推荐
blazeds java服务器,用AMF实现flash与后台高效通信
Flex blazeds封装实体 读后台数据
flex与java通过BlazeDs进行交互
Adobe Flex BlazeDS AMF File Format 熟悉下这个东西后,可以自己实现BlazeDS的前端和后端,至少也能在浏览器里的F12开发环境里搞明白AMF的内容了。
blazeds4整合spring3 这是我新近研究的方法 与整合spring2.5以下的方法有不同了,(看过一些教程觉得不是很好,用起来不顺手) 最终参考了官方的sample,得到了这个不错的整合方法。 把要用blazeds公开给flex的java...
Blazeds向客户端推送数据. .
BlazeDS通信到Java的PureMVC——Flex框架,BlazeDS的服务器配置比较麻烦,这里使用的是直接下载blazeds_turnkey_3-0-0-544.zip中的tomcat BlazeDS模板路径为: blazeds_turnkey_3-0-0-544.zip解压后路径\tomcat\...
Flashbuilder4.5 BlazeDS4 Cairngrom3 Spring 实例教程
JAVA通过BlazeDS与FLEX通信 BlazeDS.zip java项目,使用MYECLIPSE导入 FlexJavaServer.fxp FLEX项目,使用FLASHBUILDER4.5导入
自己整了个文档,描述了Flex结合Spring的应用
FLEX,BlazeDS,JAVA实现服务器端数据推送技术,下载后直接导到你的MYECLIPSE即可运行。先在IE内输入:http://localhost:8080/pushDemo/flex/pushDemo.html,点击“button”后,再另一个IE窗口内输入:...
Spring BlazeDS Integration,Flex通过remoteObject与java通讯,附带例子 文档
最简单的BlazeDS实现flex与java通信..无积分下载...最简单的BlazeDS实现flex与java通信..无积分下载...最简单的BlazeDS实现flex与java通信..无积分下载...最简单的BlazeDS实现flex与java通信..无积分下载...最简单的...
BLAZEDS实现Java后台数据推送到Flex
详细介绍jdk环境配置、tomcat服务器配置,以及如何利用java后台和flex前端结合进行web技术开发的过程。其中blazeds用于java和flex通信
想要FLex与Java实现交互,blazeds是一个很好的开源小插件
NULL 博文链接:https://liu0107613.iteye.com/blog/444612
BlazeDS是一个基于服务器的Java远程调用(remoting)和Web消息传递(messaging)技术,使得后台的Java应用程序和运行在浏览器上的Flex应用程序能够相互通信。
flex使用blazeds与java通信配置说明,包括java使用spring框架,blazeds调用spring bean
使用BlazeDS实现flex与java 整合 使用BlazeDS实现flex与java 整合 flex+java