webSocket 使用

var webScoket_url = "ws://"+location.host+"/PowerDemo/websocket_login";
            var webSocket = new WebSocket(webScoket_url);
            //js 客户端初始化WebSocket自身事件方法
            function initWebSocket(){
                //接受服务端返回的消息
                webSocket.onerror = function(event) {
                  console.log("webSocket异常",event);
                };
                 
                 //我们创建一个连接到服务器的连接时将会调用此方法。
                webSocket.onopen = function(event) {
                  //onOpen(event)
                  console.log("创建连接打开",event);
                };
                 
                 //接收消息事件。
                webSocket.onmessage = function(event) {
                  onMessage(event)
                };
                
                webSocket.onclose = function(event){
                    console.log("页面的关闭",event);
                    webSocket = null;
                }
            }
            
             
            function onMessage(event) {
               // document.getElementById(‘messages‘).innerHTML +=event.data+‘<br />‘;
               // console.log(event+"==="+event.data);
                commonService.publishNotify("getMessageEvent", event.data);
            }

                /**
              * webSocket.readyState 状态值
                CONNECTING    0    连接还没开启。
                OPEN    1    连接已开启并准备好进行通信。
                CLOSING    2    连接正在关闭的过程中。
                CLOSED    3    连接已经关闭，或者连接无法建立。
              */
             vm.testScoket = function(obj){
                 var json_str = {"type":obj.NUMPLATE};
                 if(webSocket == null){
                    webSocket = new WebSocket(webScoket_url);
                    $timeout(function(){
                        initWebSocket();
                        if(webSocket.readyState == 1){
                               webSocket.send(JSON.stringify(json_str));
                        }
                    },1000)
                }
                else if(webSocket != null && webSocket.readyState == 1){
                    initWebSocket();
                       webSocket.send(JSON.stringify(json_str));
                }
                else if(webSocket.readyState == 2 || webSocket.readyState == 3){
                   webSocket = new WebSocket(webScoket_url);
                   $timeout(function(){
                        initWebSocket();
                        if(webSocket.readyState == 1){
                               webSocket.send(JSON.stringify(json_str));
                        }
                    },1000)
                }
                
                
                //QuestionService.initModal("views/power/failure/msgModal.html","ModalController",null);
             }            

package com.zdwl.scoket;

import java.io.IOException;
import java.util.Date;
import javax.websocket.OnClose;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;
import net.sf.json.JSONObject;
import net.sf.json.JsonConfig;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.servlet.config.annotation.EnableWebMvc;
import com.zdwl.comm.JqgridPage;
import com.zdwl.comm.util.JsonDateValueProcessor;
import com.zdwl.comm.util.SpringUtil;
import com.zdwl.model.vo.power.PowerEvent;
import com.zdwl.service.power.PowerEventQueryServiceImpl;

@Configuration
@EnableWebMvc
@ServerEndpoint(value = "/websocket") 
public class BusPowerWebScoket extends SpringUtil{
    
     @OnMessage
      public void onMessage(String message, Session session)
        throws IOException, InterruptedException {
        PowerEventQueryServiceImpl eventQueryService=(PowerEventQueryServiceImpl)super.getBean("powerEventQueryService");
        //接受前端的web 消息
        System.out.println("接收: " + message);
        JSONObject jo=null;
        try {
            jo = new  JSONObject().fromObject(message);
            System.out.println("==="+jo.get("rows")+"======"+jo.toString());
            PowerEvent event=new PowerEvent();
            String beginTime =jo.get("beginDate")+"";
            String date = null;//shoveFrontSecondForGetDate(5*60);
            event.setBeginDate(date);
            JqgridPage page = new JqgridPage();
            String pageSize = jo.get("rows")+"";
            String curPageNo =jo.get("page")+"";
            if (curPageNo != null) {
                page.setCurPageNo(new Integer(curPageNo));
            }
            if (pageSize != null) {
                page.setPageSize(new Integer(pageSize));
            }
        int sentMessages = 0;
        while(true){
              Thread.sleep(3000);
              eventQueryService.queryRealTimeCurrentInfo(page, event, null);
              JsonConfig jsonConfig = new JsonConfig();
              jsonConfig.registerJsonValueProcessor(Date.class, new JsonDateValueProcessor());
              JSONObject json = JSONObject.fromObject(page,jsonConfig);
              String str = json.toString();
              //发送文本消息
              session.getBasicRemote().sendText(str);
              sentMessages++;
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
      }
       
      @OnOpen
      public void onOpen() {
        System.out.println("客户端链接。。。");
      }
     
      @OnClose
      public void onClose() {
        System.out.println("链接关闭。。。。");
      }
      
    /*public static void main(String[] args) {
        shoveFrontSecondForGetDate(120);
    }*/

    /*public static String shoveFrontSecondForGetDate(int secs){
        Date date = new Date();
        Long ll = date.getTime() - secs*1000L;
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    //    System.out.println("当前时间:"+sdf.format(date));
        date= new Date(ll);
        System.out.println("推前"+secs+"秒的时间:"+sdf.format(date));
        return sdf.format(date);
    }*/
}