利用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

相关文章

Spring 请求之传递 JSON 数据的操作方法

《Spring请求之传递JSON数据的操作方法》JSON就是一种数据格式,有自己的格式和语法,使用文本表示一个对象或数组的信息,因此JSON本质是字符串,主要负责在不同的语言中数据传递和交换,这... 目录jsON 概念JSON 语法JSON 的语法JSON 的两种结构JSON 字符串和 Java 对象互转

C++如何通过Qt反射机制实现数据类序列化

《C++如何通过Qt反射机制实现数据类序列化》在C++工程中经常需要使用数据类,并对数据类进行存储、打印、调试等操作,所以本文就来聊聊C++如何通过Qt反射机制实现数据类序列化吧... 目录设计预期设计思路代码实现使用方法在 C++ 工程中经常需要使用数据类,并对数据类进行存储、打印、调试等操作。由于数据类

SpringBoot使用GZIP压缩反回数据问题

《SpringBoot使用GZIP压缩反回数据问题》:本文主要介绍SpringBoot使用GZIP压缩反回数据问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录SpringBoot使用GZIP压缩反回数据1、初识gzip2、gzip是什么,可以干什么?3、Spr

QT进行CSV文件初始化与读写操作

《QT进行CSV文件初始化与读写操作》这篇文章主要为大家详细介绍了在QT环境中如何进行CSV文件的初始化、写入和读取操作,本文为大家整理了相关的操作的多种方法,希望对大家有所帮助... 目录前言一、CSV文件初始化二、CSV写入三、CSV读取四、QT 逐行读取csv文件五、Qt如何将数据保存成CSV文件前言

SpringBoot集成Milvus实现数据增删改查功能

《SpringBoot集成Milvus实现数据增删改查功能》milvus支持的语言比较多,支持python,Java,Go,node等开发语言,本文主要介绍如何使用Java语言,采用springboo... 目录1、Milvus基本概念2、添加maven依赖3、配置yml文件4、创建MilvusClient

SpringValidation数据校验之约束注解与分组校验方式

《SpringValidation数据校验之约束注解与分组校验方式》本文将深入探讨SpringValidation的核心功能,帮助开发者掌握约束注解的使用技巧和分组校验的高级应用,从而构建更加健壮和可... 目录引言一、Spring Validation基础架构1.1 jsR-380标准与Spring整合1

通过Spring层面进行事务回滚的实现

《通过Spring层面进行事务回滚的实现》本文主要介绍了通过Spring层面进行事务回滚的实现,包括声明式事务和编程式事务,具有一定的参考价值,感兴趣的可以了解一下... 目录声明式事务回滚:1. 基础注解配置2. 指定回滚异常类型3. ​不回滚特殊场景编程式事务回滚:1. ​使用 TransactionT

MySQL 中查询 VARCHAR 类型 JSON 数据的问题记录

《MySQL中查询VARCHAR类型JSON数据的问题记录》在数据库设计中,有时我们会将JSON数据存储在VARCHAR或TEXT类型字段中,本文将详细介绍如何在MySQL中有效查询存储为V... 目录一、问题背景二、mysql jsON 函数2.1 常用 JSON 函数三、查询示例3.1 基本查询3.2

SpringBatch数据写入实现

《SpringBatch数据写入实现》SpringBatch通过ItemWriter接口及其丰富的实现,提供了强大的数据写入能力,本文主要介绍了SpringBatch数据写入实现,具有一定的参考价值,... 目录python引言一、ItemWriter核心概念二、数据库写入实现三、文件写入实现四、多目标写入

Java中使用Hutool进行AES加密解密的方法举例

《Java中使用Hutool进行AES加密解密的方法举例》AES是一种对称加密,所谓对称加密就是加密与解密使用的秘钥是一个,下面:本文主要介绍Java中使用Hutool进行AES加密解密的相关资料... 目录前言一、Hutool简介与引入1.1 Hutool简介1.2 引入Hutool二、AES加密解密基础