AS3 客户端 JAVA服务端使用 Socket 连接 AMF传输数据

在进入正题之前,先来电前情提要的说~

一周前,嚷着要做一个【FLASH客户端,JSON数据包,SOCKET连接,MYSQL数据库。ASWING框架。】网游的DreamFairy,在努力奋战3天,结果如下。。。

ASWING用起来很给力,界面很清爽,灵活性很高,还附带一个图形化界面编辑器。但是!很悲催的是采用了ASWING的项目,即使这个项目只有不到10k!它都要编译20秒左右。。。我实在没有耐心,果断放弃ASWING。

JSON可以十分简单的封装一个对象,其优势是没有XML那么复杂的各种节点。但是其实自身的废节点还是很多的说(一个月前,DreamFairy完全没听说过JSON为何物)。但是,之前做聊天室的时候,都是传ooxx=A&xxoo=B 这样的长字符串。确实没JSON封装的好啊。所以就抱了个死理,一定要用JSON做数据包传输。在AS3中只需要一个JSON类即可。但是在JAVA里解析JSON数据包,就需要JSON-LIB和其依赖的4个包。。。我好不容易找齐它们,结果用起来十分的麻烦。最后不得不放弃,难道DreamFairy又要用回ooxx=A&xxoo=B这样来传输数据么?

搜索遍各种后台技术后,发现了一个叫amf的协议。是adobe为flex开发的一种数据传输协议,可以把对象转换为二进制耶。于是果断放弃JSON,采用amf来做数据传输! 下面进入正题。

由于之前完全用过amf,等于是从0开始学了。连续2个通宵查找amf的教程,大部分都是amfphp的。java的资料非常少。在网上找到部分的代码。如下:


[cc lang=”actionscript3″ nowrap=”false”]
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”, “OKD”);
map.put(“x”, “123”);
map.put(“y”, “321”);
try {
amfout.writeObject(map);//实际上是将map对象写入到dataoutstream流中
} 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(5556);//开启服务器进程
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();
serverSocekt.close();

} catch (FileNotFoundException e) {
e.printStackTrace();
}
[/cc]

这段代码确实可以发送一个对象到as3里。as3通过 readObject()既可以接受到此对象。但是,socket是采用tcp-ip协议的,因此无法像udp协议那样发送一个一个数据包。socket是将所有的数据编译成流进行发送,所以一个流中可能包含半个数据包,多余1个数据包这样的情况。俗称粘包。

要避免粘包就自己构建一个抽象的数据包既:包头+数据实体
包头=数据实体长度。这样一个流可以根据包头,正确的拆分成若干数据包了。

下面是我写的数据包代码:
[cc lang=”actionscript3″ nowrap=”false”]
// 创建Map对象、Double对象数组
HashMap map = new HashMap();
map.put(“Event”, “移动”);
map.put(“User”, “苍白的茧”);
map.put(“EndX”, 100);
map.put(“EndY”, 100);

try {
amfout.writeObject(map);
dataoutstream.flush();// 清空缓存
} catch (IOException e) {
e.printStackTrace();
}
//将数据实体转换为二进制流
byte[] body = byteoutStream.toByteArray();

//清空输出流
byteoutStream.reset();

try{
amfout.writeInt(body.length);
dataoutstream.flush();
}catch (IOException e)
{
e.printStackTrace();
}
//将包头转换为二进制流
byte[] head = byteoutStream.toByteArray();// amf3数据

Main.setInfo(“输出包头长度” + head.length);
Main.setInfo(“输出实体长度” + body.length);

OutputStreamWriter osw;// 使用amf3格式将写入流中的数据编码成字节
BufferedWriter bwrite;// 用来封装OutputStreamWriter,以提高效率

try {
serverSocekt = new ServerSocket(8888);// 开启服务器进程
Main.setInfo(“–服务器启动–“);
Main.setInfo(“–等待客户端连接–“);
socket = serverSocekt.accept();
if (socket.isConnected()) {
Main.setInfo(“–新客户端进入–“);
}
// socket.
osw = new OutputStreamWriter(socket.getOutputStream());// 将字符流转化为字节流
bwrite = new BufferedWriter(osw);// 封装osw对象,提高写入的效率
//发送包头
socket.getOutputStream().write(head);
//发送实体
socket.getOutputStream().write(body);
socket.getOutputStream().flush();
socket.getOutputStream().close();

} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
[/cc]

先将对象存进二进制数组中,然后获取这个数组的长度。显然,这样变成 先获取到数据实体,再获取到包头。完全反了。所以在socket.write的时候,更正过来发送。

客户端部分:由于int是一个4字节长度的。先把目前接收到的流存进缓存,然后判断这段流是否大于4字节,如果大于,把前4个字节的数据解析出来,解析后就是包头了,包头包含了这个数据包的长度。从4的位置开始读取包的长度。如果长度不够,继续等待新的流。如果多了,截取,剩下的放回缓存。

这部分代码,是 天地会论坛的 阿伍 写的。我自己偷懒一下,以后有机会再自己写啦!
[cc lang=”actionscript3″ nowrap=”false”]
function readData():void
{
//如果还没读过头部则读一次。
if (! this._isReadHead && socket.bytesAvailable > 4)
{
this._headerBytes.length = 0;
this._headerBytes.position = 0;
socket.readBytes(this._headerBytes, 0, 4);
this._msglen = this._headerBytes.readInt();
//trace(“新的消息长度:” + this.msgLen);
this._isReadHead = true;
}
//如果读了头部,并且当前可读长度大于等于消息长度,则开始读取
if (this._isReadHead && socket.bytesAvailable >= this._msglen)
{
this._inbuffer.length = 0;
this._inbuffer.position = 0;
socket.readBytes(_inbuffer, 0, this._msglen);
this._isReadHead = false;

//读完了,可以去解释了
myObj = this._inbuffer.readObject();
trace(myObj.User);
}

//如果是读过头,则如果当前消息大于消息长度则再次调用读取,否则则判断是否可读头部
if (socket.bytesAvailable > 0 && ! this._isReadHead)
{
this.readData();
}
}
[/cc]
最后附上服务端和客户端的截图:
服务端:

客户端:

啊啊~深夜了,今天先写这些。剩下的以后再写的说。

发表评论

电子邮件地址不会被公开。 必填项已用*标注