日期:2014-05-20 浏览次数:20981 次
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();