一.服务层
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小时内与您取得联系。