Flex的socket与java使用amf3进行通信 收藏
amf3,adobe创立的数据格式由于使用二进制,没有了xml等冗余的字符数据量会少很多!而且很多测试报告均测出amf传递效果很高.
这次是使用Flex的Socket类与java的服务端进行通信,
步骤是:
客户端用socket类连接java服务器,
使用查询字符串进行请求,
java将数据封装为hashmap,最后将hashmap用amfoutputstream输出至flex的客户端
flex对数据进行解码后,即为Object!
以下为详细的代码(呵呵,留个网络比较)
1.先倒入adobe的包到java的工程中!
flex-messaging-core.jar
flex-messaging-common.jar
2.建立好java的socket服务器
包结构: com.sk.socket
package com.sk.socket;
import java.io.IOException;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Scanner;
import com.sk.amf.AmfTool;
public class AmfSocket {
private ServerSocket socket;
private Socket client;
private Scanner in;
private PrintStream out;
private AmfTool tool = new AmfTool();
public AmfSocket(int port) throws IOException {
socket = new ServerSocket(port);
}
public void start() throws IOException{
System.out.println("Amf服务器已启动");
while (true) {
?? client = socket.accept();
?? in = new Scanner(client.getInputStream());
?? out = new PrintStream(client.getOutputStream());
?? boolean done = false;
?? while (!done) {
??? if (in.hasNextLine()) {
???? String line = in.nextLine();
???? if (line.trim().toLowerCase().equals("exit")) {
????? done = true;
???? } else {
????? out();
???? }
??? } else {
???? done = true;
??? }
?? }
?? if(done){
??? client.close();
?? }
}
}
private void out() {
HashMap<String,Object> map = new HashMap<String,Object>();
map.put("n","value");
map.put("keys",map);
try {
?? byte[] bytes = tool.compressOutput(map);
?? out.write(bytes);
?? System.out.println(Arrays.toString(bytes));
} catch (IOException e) {
?? // TODO Auto-generated catch block
?? e.printStackTrace();
}
}
public static void main(String[] args) {
try {
?? new AmfSocket(8888).start();
} catch (IOException e) {
?? // TODO Auto-generated catch block
?? e.printStackTrace();
}
}
}
2.工具类 AmfTool,包结构: com.sk.amf,此工具目的是将java的hashmap变为2进制的数据输出给flex
package com.sk.amf;
import java.io.ByteArrayOutputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.util.zip.Deflater;
import flex.messaging.io.SerializationContext;
import flex.messaging.io.amf.Amf3Output;
public class AmfTool {
private Deflater deflater = new Deflater();
private int cacheSize = 1024;
/**
* 压缩后,进行输入
* @return byte[]
* @throws IOException
*/
public byte[] compressOutput(Object obj) throws IOException{
Amf3Output amfOut = new Amf3Output(new SerializationContext());
ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
DataOutputStream dataOutStream = new DataOutputStream(byteArrayOutputStream);
amfOut.setOutputStream(dataOutStream);
amfOut.writeObject(obj);
amfOut.flush();
dataOutStream.flush();
byte[] msg = byteArrayOutputStream.toByteArray();
msg = compress(msg);
amfOut.close();
dataOutStream.close();
return msg;
}
/**
* 压缩字节
* @param input
* @return
* @throws IOException
*/
private byte[] compress(byte[] input) throws IOException{
deflater.reset();
deflater.setInput(input);
deflater.finish();
ByteArrayOutputStream outputStream = new ByteArrayOutputStream(input.length);
byte[] buf = new byte[cacheSize];
int len;
while(!deflater.finished()){
?? len = deflater.deflate(buf);
?? outputStream.write(buf,len);
}
byte[] tmpByte = outputStream.toByteArray();
outputStream.close();
return tmpByte;
}
}
3. Flex的 socket客户端
在FlexBuilder3中建立一个Flex工程,随后建立一个mxml文件,内容:
<?xml version="1.0" encoding="utf-8"?>
<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" layout="absolute" creationComplete="fun()">
<mx:Script>
<![CDATA[
?? import mx.controls.Alert;
?? private var socket:Socket = new Socket();
?? function fun(){
??? socket.connect("127.0.0.1",8888);
??? socket.addEventListener(Event.CONNECT,conn);
??? socket.addEventListener(ProgressEvent.SOCKET_DATA,showData);
??? socket.addEventListener(Event.CLOSE,disconn);
??? function conn(e){
???? Alert.show("conn");
??? }
??? function disconn(e){
???? Alert.show("disconn");
??? }
??? function showData(e){
???? var msg:String="";
???? while(socket.bytesAvailable){
????? var bytes:ByteArray = new ByteArray();
?????? socket.readBytes(bytes,socket.bytesAvailable);
?????? bytes.uncompress();
????? var obj = bytes.readObject();
?????
????? msg += obj.n+":";
????? msg += obj.keys.n;
???? }
???? result.text += msg;
??? }
?? }
?? function send(){
??? var txt:String = msg.text;
??? socket.writeMultiByte(txt+"n","gbk");
??? socket.flush();
??? msg.text="";
?? }
]]>
</mx:Script>
<mx:TextArea x="10" y="10" width="356" height="325" id="result"/>
<mx:TextArea x="10" y="369" width="282" id="msg"/>
<mx:Button x="300" y="391" label="Send" click="send()"/>
</mx:Application>
4.首先,启动java的服务端,然后,运行Flex客户端...
注意的是:目前貌似只有java的Hashmap可以as3进行通信,因为Hashmap与as3的Object,js的json格式一致(key,value形式)
