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();