全网整合营销服务商

电脑端+手机端+微信端=数据同步管理

免费咨询热线:400-708-3566

Java中websocket消息推送的实现代码

一.服务层

package com.demo.websocket;
import java.io.IOException;
import java.util.Iterator;
import java.util.concurrent.ConcurrentLinkedQueue;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.CloseStatus;
import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketSession;
import org.springframework.web.socket.config.annotation.EnableWebSocket;
import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;
import org.springframework.web.socket.handler.TextWebSocketHandler;
@Configuration
@EnableWebSocket
public class websocketListener implements WebSocketConfigurer, ServletContextListener{
  private ConcurrentLinkedQueue<WebSocketSession> sessions = new ConcurrentLinkedQueue<WebSocketSession>();
  private WebSocketHandlerTest handler;
  @Override
  public void contextDestroyed(ServletContextEvent arg0) {
    // TODO Auto-generated method stub
  }
  @Override
  public void contextInitialized(ServletContextEvent arg0) {
    // TODO Auto-generated method stub
  }
  @Override
  public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
    handler = new WebSocketHandlerTest();
    registry.addHandler(handler, "/ws/notifymessage.ws");
    registry.addHandler(handler, "/ws/sockjs/notifymessage.ws").withSockJS();
    new Thread(handler).start();
  }
  class WebSocketHandlerTest extends TextWebSocketHandler implements Runnable{
    @Override
    public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
      sessions.remove(session);
    }
    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
      sessions.add(session);
    }
    @Override
    protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
      super.handleTextMessage(session, message);
    }
    @Override
    public void run() {
      System.out.println("等待推送....");
      try {
        int i = 0;
        for (;;) {
          synchronized (this) {
            try {
              Thread.sleep(3000);
            } catch (InterruptedException e) {
              // TODO Auto-generated catch block
              e.printStackTrace();
            }
          }
          if(i%10==0){
            nofity("消息推送测试......");
            System.out.println("推送消息了....");
          }else{
            System.out.println("本次不推送消息了....");
          }
          i++;
        }
      } catch (IOException e) {
        e.printStackTrace();
        System.out.println("失败....");
      }
    }
    private void nofity(String message) throws IOException {
      Iterator<WebSocketSession> iterator = sessions.iterator();
      while (iterator.hasNext()) {
        WebSocketSession session = iterator.next();
        synchronized(session){
          if(session.isOpen()){
            session.sendMessage(new TextMessage(message));
          }else{
            iterator.remove();
          }
        }
      }
    }
  }
}

二.前台界面监听

<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title>Insert title here</title>
</head>
<body>
websocket测试界面
</body>
<script type="text/javascript">
var websocketPath = "localhost:8080/demo-web";
if ('WebSocket' in window) {
  websocket = new WebSocket("ws://"+websocketPath+"/ws/notifymessage.ws");
} else if ('MozWebSocket' in window) {
  websocket = new MozWebSocket("ws://"+websocketPath+"/ws/notifymessage.ws");
} else {
  websocket = new SockJS("ws://"+websocketPath+"/ws/notifymessage.ws");
}
websocket.onopen = function (evnt) {
};
websocket.onmessage = function (evnt) {
  console.log(evnt);
};
websocket.onerror = function (evnt) {
};
websocket.onclose = function (evnt) {
}
</script>
</html>

注意web.xml中配置DispatcherServlet控制器

spring-servlet.xml空文件

<servlet>
    <servlet-name>spring</servlet-name>
    <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
    <init-param>
      <param-name>contextConfigLocation</param-name>
      <param-value>/WEB-INF/spring-servlet.xml</param-value>
    </init-param>
    <load-on-startup>1</load-on-startup>
  </servlet>
  <servlet-mapping>
    <servlet-name>spring</servlet-name>
    <url-pattern>*.ws</url-pattern>
  </servlet-mapping>

以上所述是小编给大家介绍的Java中websocket消息推送的实现代码,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对网站的支持!


# websocket  # 消息推送  # java WebSocket实现聊天消息推送功能  # java后端+前端使用WebSocket实现消息推送的详细流程  # Java应用层协议WebSocket实现消息推送  # Java实现使用Websocket发送消息详细代码举例  # 小编  # 在此  # 给大家  # 所述  # 给我留言  # 感谢大家  # 疑问请  # 有任何  # TODO  # void  # contextDestroyed  # method  # stub  # Auto  # generated  # Override  # implements  # private  # public  # websocketListener 


相关文章: 在线制作视频网站免费,都有哪些好的动漫网站?  制作旅游网站html,怎样注册旅游网站?  Bpmn 2.0的XML文件怎么画流程图  建站之星导航菜单设置与功能模块配置全攻略  如何挑选最适合建站的高性能VPS主机?  微信推文制作网站有哪些,怎么做微信推文,急?  深圳网站制作设计招聘,关于服装设计的流行趋势,哪里的资料比较全面?  小说建站VPS选用指南:性能对比、配置优化与建站方案解析  金*站制作公司有哪些,金华教育集团官网?  娃派WAP自助建站:免费模板+移动优化,快速打造专业网站  胶州企业网站制作公司,青岛石头网络科技有限公司怎么样?  如何用y主机助手快速搭建网站?  代购小票制作网站有哪些,购物小票的简要说明?  黑客如何通过漏洞一步步攻陷网站服务器?  h5在线制作网站电脑版下载,h5网页制作软件?  阿里云网站制作公司,阿里云快速搭建网站好用吗?  如何通过IIS搭建网站并配置访问权限?  如何获取免费开源的自助建站系统源码?  济南专业网站制作公司,济南信息工程学校怎么样?  一键网站制作软件,义乌购一件代发流程?  在线ppt制作网站有哪些,请推荐几个好的课件下载的网站?  长春网站建设制作公司,长春的网络公司怎么样主要是能做网站的?  打鱼网站制作软件,波克捕鱼官方号怎么注册?  建站VPS能否同时实现高效与安全翻墙?  如何高效利用亚马逊云主机搭建企业网站?  无锡制作网站公司有哪些,无锡优八网络科技有限公司介绍?  高防服务器租用指南:配置选择与快速部署攻略  网站制作费用多少钱,一个网站的运营,需要哪些费用?  如何用wdcp快速搭建高效网站?  定制建站策划方案_专业建站与网站建设方案一站式指南  如何在万网开始建站?分步指南解析  制作ppt免费网站有哪些,有哪些比较好的ppt模板下载网站?  网站制作大概多少钱一个,做一个平台网站大概多少钱?  如何在沈阳梯子盘古建站优化SEO排名与功能模块?  建站中国官网:模板定制+SEO优化+建站流程一站式指南  C++中的Pimpl idiom是什么,有什么好处?(隐藏实现)  Python多线程使用规范_线程安全解析【教程】  如何在云主机快速搭建网站站点?  英语简历制作免费网站推荐,如何将简历翻译成英文?  专业商城网站制作公司有哪些,pi商城官网是哪个?  建站之星后台密码遗忘或太弱?如何重置与强化?  网站制作软件免费下载安装,有哪些免费下载的软件网站?  如何在IIS中配置站点IP、端口及主机头?  油猴 教程,油猴搜脚本为什么会网页无法显示?  香港服务器网站测试全流程:性能评估、SEO加载与移动适配优化  矢量图网站制作软件,用千图网的一张矢量图做公司app首页,该网站并未说明版权等问题,这样做算不算侵权?应该如何解决?  建站之星代理商如何保障技术支持与售后服务?  建站之星如何实现PC+手机+微信网站五合一建站?  网站制作与设计教程,如何制作一个企业网站,建设网站的基本步骤有哪些?  国美网站制作流程,国美电器蒸汽鍋怎么用官方网站? 

您的项目需求

*请认真填写需求信息,我们会在24小时内与您取得联系。