<!DOCTYPE html>
|
<head>
|
<title>socket demo</title>
|
<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
|
<script type="text/javascript" src="https://cdn.staticfile.org/jquery/1.10.2/jquery.min.js"></script>
|
</head>
|
<body>
|
<input type="text" id="msg" />
|
<button id="send">发送</button>
|
</body>
|
</html>
|
<script>
|
$(function()
|
{
|
// 创建socket对象
|
var socket = new WebSocket('ws://127.0.0.1:9501');
|
|
// 打开Socket
|
socket.onopen = function(event)
|
{
|
|
$('#send').on('click', function()
|
{
|
var msg = $('#msg').val();
|
var url = 'application/index/data';
|
var fullData = {
|
url:url,
|
data:{
|
session_id:'1a2e0ca9c7404b765a37a5ab07546fa8',
|
group_id:'1a2e0ca9c7404b765a37a5ab07546fa8',
|
msg:msg
|
}
|
};
|
socket.send(JSON.stringify(fullData));
|
console.log(msg);
|
});
|
var url = 'application/index/reg';
|
var fullData = {
|
url:url,
|
data:{
|
session_id:'1a2e0ca9c7404b765a37a5ab07546fa8',
|
group_id:'1a2e0ca9c7404b765a37a5ab07546fa8'
|
}
|
};
|
// 发送一个初始化消息
|
socket.send(JSON.stringify(fullData));
|
if (socket.readyState == 1) {
|
setInterval(function(){
|
var fullData = {
|
url: 'plumeWSService/cluster/ping',
|
data: 'ping'
|
};
|
socket.send(JSON.stringify(fullData));
|
},1000)
|
}
|
// 监听消息
|
socket.onmessage = function(event) {
|
if(event.data == 'pingpong'){//处理心跳接收事件
|
|
}else{
|
var fullData = JSON.parse(event.data);
|
console.log("客户端监听到的消息:", fullData);
|
}
|
};
|
|
// 监听Socket的关闭
|
socket.onclose = function(event) {
|
console.log("Socket关闭了", event);
|
};
|
|
// 关闭Socket....
|
//socket.close()
|
};
|
});
|
</script>
|