AMF3简单封装用例

逍遥公子

import java.io.*;
import java.net.*;
import flex.messaging.io.SerializationContext;
import flex.messaging.io.amf.Amf3Output;
import flex.messaging.io.amf.Amf3Input;

\**
* @author じ☆ve弦

*\
public class AMF3 {

private SerializationContext sc = null;

private Amf3Output amfout = null;

private Amf3Input amfin = null;

public AMF3() {
  
  //System.out.println("创建AMF3数据处理对象");
  
  sc = new SerializationContext();
}


public void sendAmfData(Object objout,Socket socket){
  
  //System.out.println("AMF3_发送数据对象");
  
  if(sc != null){
   
   if(amfout == null){
   
    amfout = new Amf3Output(sc);
   
   }
  }
  
  ByteArrayOutputStream baos = new ByteArrayOutputStream();
  
  DataOutputStream dos = new DataOutputStream(baos);
  
  amfout.setOutputStream(dos);
  
  try {
   
   amfout.writeObject(objout);
   amfout.flush();
   
  } catch (IOException e) {
   
   System.out.println("异常：服务器写入错误[OBJ]！");
   
  }
  
  byte[] buf = baos.toByteArray();
  
  try {
   
   OutputStream os = socket.getOutputStream();
   
   os.write(buf);
   
   
  } catch (IOException e) {
   
   System.out.println("异常：服务器写入错误[BUF]！");
  }
}


public Object receiveAmfData(Socket socket){
  
  //System.out.println("AMF3_接收数据对象");
  
  if(sc != null){
   
   if(amfin == null){
   
    amfin = new Amf3Input(sc);
   
   }
  }
  
  byte[] buf = new byte[1024];
  
  ByteArrayInputStream bais = new ByteArrayInputStream(buf);
  
  DataInputStream dis = new DataInputStream(bais);
  
  amfin.setInputStream(dis);
  
  try {
   
   InputStream is = socket.getInputStream();
   
   is.read(buf);
   
  } catch (IOException e) {
   
   System.out.println("异常：服务器读取错误[BUF]！");
   
  }
  
  Object objin = null;
  
  try {
   
   objin = amfin.readObject();
   
  } catch (ClassNotFoundException e) {
   
   e.printStackTrace();
   
  } catch (IOException e) {
   
   System.out.println("异常：服务器读取错误[OBJ]！");
   
  }
  
  return objin;
}

}

发送数据对象的方法：sendAmfData(Object objout,Socket socket):void
接收数据对象的方法：receiveAmfData(Socket socket):Object