Erlang与ActionScript3采用JSON格式进行Socket通讯

http://hideto.iteye.com/blog/235811

需要下载as3corelib来为ActionScript3处理JSON codec

server.erl

Java代码  

1. -module(server).
2. -export([start/0,start/1,process/1]).
3. -define(defPort, 8888).
4. start() -> start(?defPort).
5. start(Port) ->
6. case gen_tcp:listen(Port, [binary, {packet, 0}, {active, false}]) of
7. {ok, LSock} -> server_loop(LSock);
8. {error, Reason} -> exit({Port,Reason})
9. end.
10. %% main server loop - wait for next connection, spawn child to process it
11. server_loop(LSock) ->
12. case gen_tcp:accept(LSock) of
13. {ok, Sock} ->
14. spawn(?MODULE,process,[Sock]),
15. server_loop(LSock);
16. {error, Reason} ->
17. exit({accept,Reason})
18. end.
19. %% process current connection
20. process(Sock) ->
21. Req = do_recv(Sock),
22. io:format("~p~n", [Req]),
23. {ok, D, []} = rfc4627:decode(Req),
24. {obj, [{"name", _Name}, {"age", Age}]} = D,
25. Name = binary_to_list(_Name),
26. io:format("Name: ~p, Age: ~p~n", [Name, Age]),
27. Resp = rfc4627:encode({obj, [{"name", ‘Hideto2‘}, {"age", 24}]}),
28. do_send(Sock,Resp),
29. gen_tcp:close(Sock).
30. %% send a line of text to the socket
31. do_send(Sock,Msg) ->
32. case gen_tcp:send(Sock, Msg) of
33. ok -> ok;
34. {error, Reason} -> exit(Reason)
35. end.
36. %% receive data from the socket
37. do_recv(Sock) ->
38. case gen_tcp:recv(Sock, 0) of
39. {ok, Bin} -> binary_to_list(Bin);
40. {error, closed} -> exit(closed);
41. {error, Reason} -> exit(Reason)
42. end.

Person.as

Java代码  

1. package
2. {
3. public class Person
4. {
5. public var name:String;
6. public var age:int;
7. public function Person()
8. {
9. }
10. }
11. }

Client.as

Java代码  

1. package {
2. import com.adobe.serialization.json.JSON;
3. import flash.display.Sprite;
4. import flash.events.*;
5. import flash.net.Socket;
6. import flash.text.*;
7. public class Client extends Sprite
8. {
9. private var socket:Socket;
10. private var myField:TextField;
11. private var send_data:Person;
12. public function Client()
13. {
14. socket = new Socket();
15. myField = new TextField();
16. send_data = new Person();
17. send_data.name = "Hideto";
18. send_data.age = 23;
19. socket.addEventListener(ProgressEvent.SOCKET_DATA, onSocketData);
20. socket.connect("localhost", 8888);
21. socket.writeUTFBytes(JSON.encode(send_data));
22. socket.flush();
23. myField.x = 20;
24. myField.y = 30;
25. myField.text = "test";
26. myField.autoSize = TextFieldAutoSize.LEFT;
27. addChild(myField);
28. }
29. private function onSocketData(event:ProgressEvent):void {
30. while(socket.bytesAvailable) {
31. var recv_data:* = JSON.decode(socket.readUTFBytes(socket.bytesAvailable));
32. myField.text = "Name: " + recv_data.name + ", age: " + recv_data.age.toString();
33. }
34. }
35. }
36. }

运行Erlang服务器端：

Java代码  

1. Eshell> c(server).
2. Eshell> server:start().
3. "{\"name\":\"Hideto\",\"age\":23}"
4. Name: "Hideto", Age: 23

这里打印出了Erlang Socket Server接收到的AS3 Client发过来的JSON decode过的一个person对象

运行AS3客户端： 
client.html上首先显示“test”，然后异步处理完Socket消息发送和接受后，decode Erlang Server端发过来的person对象，将页面上的TextField替换为“Name: Hideto2, age: 24”