misultin集群(两节点通信)，测试websocket通信

langzhe

浏览: 281806 次
性别:
来自: 北京

最近访客更多访客>>

WoKo_Jb

perfect_control

u012781923

apple8422

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

博客分类：

misultin

websocket

这几天需要对misultin做一个简单的测试

就想到了rpc关键代码 rpc:multicall([node()|nodes()], misultin_websocket_sessions_example, rpc, [Data]),

顺便看了一眼rpc源代码，原来也是调用了otp中的gen_server中的方法

% callback on received websockets data

% ets:new(s,[named_table,public]).

handle_websocket(Ws) ->

io:format("~p Ws=~p~n", [?LINE, Ws]),

receive

{browser, "token:"++User} ->

Ws:send(["received '", User, "'"]),

ets:insert(s, {User, Ws}),

handle_websocket(Ws);

{browser, Data} ->

Ws:send(["received '", Data, "'"]),

%rpc(Data),

rpc:multicall([node()|nodes()], misultin_websocket_sessions_example, rpc, [Data]),

handle_websocket(Ws);

_Ignore ->

handle_websocket(Ws)

after 60000 ->

handle_websocket(Ws)

end.

rpc(Data) ->

ListWs = ets:tab2list(s),

[W:send(["From ':", Data, "'"]) || {_N, W}<-ListWs].

test js

<html>

<body>

<button id="sendButtonjson">sendjson</button>

</body>

{% block link %}

{% endblock %}

</html>

//alert(window.WebSocket);

socket = new WebSocket("ws://192.168.18.119:8001/test", "some_service_name");

socket.onopen = function(){

//alert("connected");

//socket.send("accepting....");

updateSocketStatus("Connected to WebSocket ");

};

socket.onmessage = function(e){

//alert("message");

//alert(e.data);

updateSocketStatus(e.data);

//updateSocketStatus("update to WebSocket "+e);

//updateSocketStatus("update to WebSocket "+dataReturned(e.data));

};

socket.onclose = function(e){

// alert("close");

//alert(typeof(e));

updateSocketStatus("close "+e.data);

};

function updateSocketStatus(message){

msg = document.getElementById("socketStatus").innerHTML +"</br>"+ message;

document.getElementById("socketStatus").innerHTML = msg;

}

/**

window.onload = function(){

document.getElementById("sendButton").onclick = function() {

var message = document.getElementById("inputMessage").value;

socket.send(message);

}

document.getElementById("sendButtonjson").onclick = function() {

var to = document.getElementById("to").value;

//var txt = '{"message" : [{ "to":"Bill" , "text":"Gates" }]}';

var txt = 'direct_messages/new/{ "to":"'+ to + '" , "text":"Gates" }';

socket.send(txt);

}

};

</script>

0
顶

4
踩

分享到：

apns推送 | riak erlanl client search 新特性

2012-10-16 15:14
浏览 841
评论(0)
分类:编程语言
查看更多

发表评论

您还没有登录,请您登录后再发表评论

最近访客更多访客>>

博主相关

文章分类

社区版块

存档分类

最新评论