WebSocket 的一些简单页面推送使用

因为做通信项目的时候,需要实时获取每个分机的当前状态,发现websocket还不错,知识对浏览器的要求比较高,

针对特定用户推送消息,网上有一些

public class GetHttpSessionConfigurator  extends ServerEndpointConfig.Configurator{

@Override
 public void modifyHandshake(ServerEndpointConfig config,HandshakeRequest request,HandshakeResponse response){
  HttpSession httpSession = (HttpSession)request.getHttpSession();
  config.getUserProperties().put(HttpSession.class.getName(),httpSession);
  }
 
}

//@ServerEndpoint(value="/websocket",configurator=GetHttpSessionConfigurator.class)

在open方法加入参数,进行实现,最后发现获取不到session,为null。 然后通过他们说的在监听器内,把session也加入,最后可以获取session,却发现用户的session会改变

两个httpSession 不是一个值,放来放入的也不见啦。实在没办法用啦下面的法子。。。。。。。。

实际点,代码奉上:

jsp:

<script type="text/javascript">
var BASE_PATH="${pageContext.request.contextPath}";//项目名称
var iphost="${iphost}";//服务器ip+端口
var session="${session}";//针对特定用户推送时,实在找不到方法只能笨点,把每个用户放去缓存,通过后台闯入页面
var ws;
$(function(){
    ws = new WebSocket("ws://"+iphost+"/${pageContext.request.contextPath }/websocket?"+session);
    ws.onopen = function(evn){
        //console.log(evn);
    };
    ws.onmessage = function(evn){              
        var data = evn.data+‘‘;
        //console.log(data);
        if(data.indexOf("挂机原因")>-1){
         UIkit.modal.alert(evn.data);
        }else if(data.indexOf("来电弹屏")>-1){
         var tpphone=data.replace("来电弹屏", "");
         var rw=document.body.clientWidth-800;
      var rh=document.body.clientHeight-600;
      window.open(BASE_PATH+‘/main/asterisktest/bomb?phone=‘+tpphone,"","toolbar=yes, location=yes, directories=no, status=no, menubar=yes, scrollbars=yes, resizable=no, copyhistory=yes, width=800, height=600,top="+rh+", left="+rw);

}else{
        var json=eval(‘(‘+data+‘)‘);      
        var div = $("#"+json["id"]);
        div.html(json["statusname"]);
        }
    };
    ws.onclose = function(evn){
        //console.log("关闭");
    };
    ws.onError=function(evn){
     // console.log(‘Error occured: ‘ + evt.data);
      };
});
</script>

java:

//@ServerEndpoint(value="/websocket",configurator=GetHttpSessionConfigurator.class)
@ServerEndpoint(value="/websocket")
public class WebSocket  {
  public WebSocket(){
        
     }
  //给所有的用户推送消息
  public static void broadcastAll(JSONObject jsono){ 
 
   ListIterator it=WEBApp.AppSession.listIterator();
            while(it.hasNext()){
               try { 
                ((Session)it.next()).getBasicRemote().sendText(jsono.toString()); 
                   
                } catch (Exception e) {

e.printStackTrace();

}

}

}
     //给指定用户发送消息
   public static void broadcast(String key,String value){
    MapCacheUtil mapc=MapCacheUtil.getInstance();
    try {
     if(mapc.getWebsession(key)!=null){
    mapc.getWebsession(key).getBasicRemote().sendText(value);
     }
   } catch (IOException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }
   }
 
 
     @OnOpen//,EndpointConfig config
     public void onopen(Session session){
         System.out.println("连接成功");
         MapCacheUtil mapc=MapCacheUtil.getInstance();
         mapc.putWebsession(session.getQueryString(), session);
         try {
          WEBApp.AppSession.add(session);                    
             session.getBasicRemote().sendText("hello client...");
         } catch (IOException e) {
             e.printStackTrace();
         }
     }
     @OnClose
     public void onclose(Session session){
      WEBApp.AppSession.remove(session);
         System.out.println(session.getId()+"close....");
        
     }
      @OnMessage     
     public void onsend(Session session,String msg){
         try {      
     session.getBasicRemote().sendText(msg);
    
         } catch (IOException e) {
             e.printStackTrace();
         }
     }

//保存所有Websocket Session 的值

public class WEBApp {

public static Vector<javax.websocket.Session>
AppSession=new Vector<javax.websocket.Session>();

}

也没什么经验,不足的大家提出建议,起码功能实现啦。。

时间: 2024-10-09 23:07:48

WebSocket 的一些简单页面推送使用的相关文章

Spring之WebSocket网页聊天以及服务器推送

Spring之WebSocket网页聊天以及服务器推送 转自:http://www.xdemo.org/spring-websocket-comet/ /Springframework /Spring之WebSocket网页聊天以及服务器推送 1. WebSocket protocol 是HTML5一种新的协议.它实现了浏览器与服务器全双工通信(full-duplex). 2. 轮询是在特定的的时间间隔(如每1秒),由浏览器对服务器发出HTTP request,然后由服务器返回最新的数据给客服端

nodejs实现简单消息推送

server1.js var http = require('http'); var express = require('express'); var sio = require('socket.io'); var app = express(); app.use(express.static(__dirname + '/')); var server = http.createServer(app); server.listen(3001, '127.0.0.1'); var io = si

dwr进行页面推送简单实例

实现功能:sendMsg.jsp发送一个消息到后台,后台将消息推送到showMsg.jsp页面. 1.web.xml 配置,在web.xml里面添加如下内容: <!-- 使用DWR进行页面消息推送 --> <servlet> <display-name>DWR Servlet</display-name> <servlet-name>dwr-invoker</servlet-name> <servlet-class>org

netty websocket 简单消息推送demo

今天心情很不好!!! 原因保密. 这篇是基于"netty与websocket通信demo". 错误想法:大量客户请求,共用一个worker,来实现推送. 正确作法:应该是对Channel对应的ChannelGroup进行操作,来实现推送. 一个Channel可以划分到多个ChannelGroup中. PushServerChannelHandler和DynMessage这两个类最重要,其实类基本没变. package org.sl.demo.chatserver; import jav

Android中脱离WebView使用WebSocket实现群聊和推送功能

WebSocket是Web2.0时代的新产物,用于弥补HTTP协议的某些不足,不过他们之间真实的关系是兄弟关系,都是对socket的进一步封装,其目前最直观的表现就是服务器推送和聊天功能.更多知识参考:如何理解 TCP/IP, SPDY, WebSocket 三者之间的关系? 今天的重点是讲如何在Android中脱离WebView使用WebSocket,而不是在Web浏览器使用,如果是在Web浏览器中使用,网上已经太多教程.框架和demo,没必要讲. 到目前为止我个人认为安卓端比较好用的WebS

iOS关于UITabView和UIAlertController,UIAlertAction以及UINavigation,值修改的传递页面推送

关于UITabView和UIAlertController,UIAlertAction以及UINavigation,值修改的传递 集合嵌套集合的操作 声明 两个必须的的代理 实现部分代码 - (void)viewDidLoad { [super viewDidLoad]; // 创建一个TabView self.tabv = [[UITableView alloc] initWithFrame:self.view.frame style:UITableViewStyleGrouped]; sel

websocket+redis实现即时消息推送思路

消息实时推送场景: 1,第一阶段可以实现消息群发功能 场景:根据应用类型,服务端发送消息,客户端及时收取消息.如同qq有时会弹出新闻小窗 2,第二阶段可以根据办理业务,单点推送 场景:手机用户办理一笔业务时,及时推送反馈.办理情况,如同招商银行按时推送信用卡还款信息,催你还钱,该还多少钱. 3,可以将邮件,短信推送这些有共性的东西整合为一个整体 设计思路: 1.服务端发送消息(含标题,内容),标题按照一定规则存入redis,内容存入oracle(内容不多,访问量大,并发量高时内容存入redis也

WebSocket实现Java后台消息推送

1.什么是WebSocket WebSocket协议是基于TCP的一种新的网络协议.它实现了浏览器与服务器全双工(full-duplex)通信——允许服务器主动发送信息给客户端. 2.实现原理 在实现websocket连线过程中,需要通过浏览器发出websocket连线请求,然后服务器发出回应,这个过程通常称为“握手” .在 WebSocket API,浏览器和服务器只需要做一个握手的动作,然后,浏览器和服务器之间就形成了一条快速通道.两者之间就直接可以数据互相传送. 3.优点 在以前的消息推送

WebSocket接收音频,并推送到声卡上

使用信息 import com.fasterxml.jackson.databind.ObjectMapper; import com.google.common.collect.ImmutableMap; import lombok.extern.slf4j.Slf4j; import org.apache.commons.text.StringEscapeUtils; import org.java_websocket.client.WebSocketClient; import org.j