100分!求.net进行AMF3编码和解码的源代码
谁有源代码,共享一下啊!!
[解决办法]
你好.能分享一下源代码吗?
[解决办法]
AMF3
是什么东西》?
[解决办法]
接过
[解决办法]
楼主能否共享下源码?
[解决办法]
java版实例
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连接关闭
[解决办法]
顶