- 浏览: 892258 次
- 性别:
- 来自: 北京
文章分类
最新评论
-
wangzhen199009:
good. Thx for your sharing.
REST和认证 HMAC -
jsshizhan:
你的这个SQL有问题的
数据库中如何使用SQL查询连续数字并且统计连续个数 -
maoghj:
dddddddddddddd
mysql 更改my.cnf 慢查询日志 -
zhoutong123a:
人的贪婪无止境,只能控制,不能满足
招人心得 -
xuerThinkVickie:
...
ZeroClipboard支持IE,firefox,Chrome复制到剪贴板
利用BlazeDS的AMF3数据封装与Flash 进行Socket通讯
AS3的Socket类给我们提供了一个readObject方法和writeObject方法与服务器通讯,可以让我们在协议可读性和传输效率上两个兼顾。如果在网络游戏开发前期你无法确定完全规划好你的协议,那么使用这种方法是一个不错的选择。等到一切调试顺畅了,再在此基础上进行事件类型的抽象。
下面我们利用Adobe的开源项目BlazeDS中提供的类进行AMF3封装与Flash Socket通讯介绍一下这种方式。
原文和介绍见:http://www.iflashigame.com
服务器端的代码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(eventrogressEvent):void {
trace("接收数据");
obj=socket.readObject();
this.dispatchEvent(new Event("recieved"));
}
执行结果:
连接成功
接收数据
闪刀浪子移动到100,100
连接关闭
源文件在这里
AS3的Socket类给我们提供了一个readObject方法和writeObject方法与服务器通讯,可以让我们在协议可读性和传输效率上两个兼顾。如果在网络游戏开发前期你无法确定完全规划好你的协议,那么使用这种方法是一个不错的选择。等到一切调试顺畅了,再在此基础上进行事件类型的抽象。
下面我们利用Adobe的开源项目BlazeDS中提供的类进行AMF3封装与Flash Socket通讯介绍一下这种方式。
原文和介绍见:http://www.iflashigame.com
服务器端的代码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(eventrogressEvent):void {
trace("接收数据");
obj=socket.readObject();
this.dispatchEvent(new Event("recieved"));
}
执行结果:
连接成功
接收数据
闪刀浪子移动到100,100
连接关闭
源文件在这里
发表评论
-
动态备份mysql慢查询日志
2016-07-28 11:22 388set global slow_query_log=0; 引用 ... -
java转义字符串
2015-07-15 15:30 710点的转义:. ==> u002E 美元符号的转义:$ ... -
Hibernate 一对多关联的CRUD__@ManyToOne(cascade=(CascadeType.ALL))
2015-03-31 16:56 740http://blog.csdn.net/sivyer123/ ... -
hadoop分析摘要
2012-12-09 18:44 0引用http://home.cnblogs.com/u/lij ... -
REST和认证 HMAC
2012-12-09 10:31 9024REST和认证 我们在设计REST(Representatio ... -
myeclipse设置tomcat发布目录
2012-07-18 11:00 967... -
htmlparser:使用 HttpClient 和 HtmlParser 实现简易爬虫
2010-01-27 15:29 3247使用 HttpClient 和 HtmlPa ... -
Java发送Http请求,解析html返回
2010-01-27 14:46 2272转载:http://blog.csdn.net/wish_si ... -
eclipse java.lang.OutOfMemoryError: Java heap space 解决方案
2010-01-03 15:22 8019eclipse java.lang.OutOfMemoryEr ... -
抽奖程序
2009-12-11 12:56 1632Random.nextInt(400000) int a; ... -
HttpClient 入门
2009-10-17 02:08 1117HttpClient 是 Apache Jakarta Com ... -
从架构差异看Web高性能开发
2009-09-21 16:46 910一般情况下,架构分两 ... -
Java代码优化
2009-09-21 15:43 1505Java代码优化2008-10-26 22:11一、为什么要优 ... -
移位操作详细解释
2009-09-21 14:52 1205用移位操作替代乘法和除法 考虑下面的代码: for (va ... -
Java中四种XML解析技术不完全评测
2009-04-13 14:03 962在平时工作中,难免会遇到把XML作为数据存储格式。面对目前种类 ... -
最简单的游戏回血逻辑实现(包括源代码)
2009-04-13 13:25 1390http://blog.csdn.net/Mailbomb/a ... -
Java 小例子:通过Socket发送和接收 文件
2009-03-10 13:23 3409引用:http://blog.csdn.net/yid ... -
Java 小例子:数据持久化(保存数据到文件)
2009-03-10 13:03 1458引用:http://blog.csdn.net/yidingh ... -
Flash与JAVA的Socket通信
2008-12-19 17:59 4462Flash与JAVA的Socket通信 import jav ... -
MINA框架
2008-12-19 14:49 3235MINA框架_高占军的个人空间GuolinLee 收录于200 ...
相关推荐
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