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><p id="socketStatus"></p><input type="text" id="inputMessage" value="hello websocket"><input type="text" id="to" value="Bill"><button id="sendButton">send</button><button id="sendButtonjson">sendjson</button></body>{% block link %} ? ?{% endblock %} ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?
</html>
<script type="text/javascript">? ? //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>
~ ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ??~ ? ? ? ? ? ? ? ? ? ?