利用AMF数据封装与Flash 进行Socket通讯

2024-02-17 22:59

本文主要是介绍利用AMF数据封装与Flash 进行Socket通讯,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

为什么80%的码农都做不了架构师?>>>   hot3.png

AS3的Socket类给我们提供了一个readObject方法和writeObject方法与服务器通讯,可以让我们在协议可读性和传输效率上两个兼 顾。如果在网络游戏开发前期你无法确定完全规划好你的协议,那么使用这种方法是一个不错的选择。等到一切调试顺畅了,再在此基础上进行事件类型的抽象。

下面我们利用Adobe的开源项目BlazeDS中提供的类进行AMF3封装与Flash Socket通讯介绍一下这种方式。

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;// 设置流的编码格式为amf3amfout.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"));
}



转载于:https://my.oschina.net/fir01/blog/468005

这篇关于利用AMF数据封装与Flash 进行Socket通讯的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/719252

相关文章

使用Jackson进行JSON生成与解析的新手指南

《使用Jackson进行JSON生成与解析的新手指南》这篇文章主要为大家详细介绍了如何使用Jackson进行JSON生成与解析处理,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1. 核心依赖2. 基础用法2.1 对象转 jsON(序列化)2.2 JSON 转对象(反序列化)3.

揭秘Python Socket网络编程的7种硬核用法

《揭秘PythonSocket网络编程的7种硬核用法》Socket不仅能做聊天室,还能干一大堆硬核操作,这篇文章就带大家看看Python网络编程的7种超实用玩法,感兴趣的小伙伴可以跟随小编一起... 目录1.端口扫描器:探测开放端口2.简易 HTTP 服务器:10 秒搭个网页3.局域网游戏:多人联机对战4.

C#使用SQLite进行大数据量高效处理的代码示例

《C#使用SQLite进行大数据量高效处理的代码示例》在软件开发中,高效处理大数据量是一个常见且具有挑战性的任务,SQLite因其零配置、嵌入式、跨平台的特性,成为许多开发者的首选数据库,本文将深入探... 目录前言准备工作数据实体核心技术批量插入:从乌龟到猎豹的蜕变分页查询:加载百万数据异步处理:拒绝界面

Python使用自带的base64库进行base64编码和解码

《Python使用自带的base64库进行base64编码和解码》在Python中,处理数据的编码和解码是数据传输和存储中非常普遍的需求,其中,Base64是一种常用的编码方案,本文我将详细介绍如何使... 目录引言使用python的base64库进行编码和解码编码函数解码函数Base64编码的应用场景注意

Java进行文件格式校验的方案详解

《Java进行文件格式校验的方案详解》这篇文章主要为大家详细介绍了Java中进行文件格式校验的相关方案,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录一、背景异常现象原因排查用户的无心之过二、解决方案Magandroidic Number判断主流检测库对比Tika的使用区分zip

Java使用Curator进行ZooKeeper操作的详细教程

《Java使用Curator进行ZooKeeper操作的详细教程》ApacheCurator是一个基于ZooKeeper的Java客户端库,它极大地简化了使用ZooKeeper的开发工作,在分布式系统... 目录1、简述2、核心功能2.1 CuratorFramework2.2 Recipes3、示例实践3

Java利用JSONPath操作JSON数据的技术指南

《Java利用JSONPath操作JSON数据的技术指南》JSONPath是一种强大的工具,用于查询和操作JSON数据,类似于SQL的语法,它为处理复杂的JSON数据结构提供了简单且高效... 目录1、简述2、什么是 jsONPath?3、Java 示例3.1 基本查询3.2 过滤查询3.3 递归搜索3.4

SpringBoot中封装Cors自动配置方式

《SpringBoot中封装Cors自动配置方式》:本文主要介绍SpringBoot中封装Cors自动配置方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录SpringBoot封装Cors自动配置背景实现步骤1. 创建 GlobalCorsProperties

MySQL大表数据的分区与分库分表的实现

《MySQL大表数据的分区与分库分表的实现》数据库的分区和分库分表是两种常用的技术方案,本文主要介绍了MySQL大表数据的分区与分库分表的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有... 目录1. mysql大表数据的分区1.1 什么是分区?1.2 分区的类型1.3 分区的优点1.4 分

Mysql删除几亿条数据表中的部分数据的方法实现

《Mysql删除几亿条数据表中的部分数据的方法实现》在MySQL中删除一个大表中的数据时,需要特别注意操作的性能和对系统的影响,本文主要介绍了Mysql删除几亿条数据表中的部分数据的方法实现,具有一定... 目录1、需求2、方案1. 使用 DELETE 语句分批删除2. 使用 INPLACE ALTER T