文档章节

Spring+Websocket实现消息的推送

ldl123292
 ldl123292
发布于 2014/08/19 15:41
字数 1057
阅读 123399
收藏 265

Websocet服务端实现

WebSocketConfig.java

@Configuration
@EnableWebMvc
@EnableWebSocket
public class WebSocketConfig extends WebMvcConfigurerAdapter implements WebSocketConfigurer {
    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(systemWebSocketHandler(),"/webSocketServer").addInterceptors(new WebSocketHandshakeInterceptor());

        registry.addHandler(systemWebSocketHandler(), "/sockjs/webSocketServer").addInterceptors(new WebSocketHandshakeInterceptor())
                .withSockJS();
    }

    @Bean
    public WebSocketHandler systemWebSocketHandler(){
        return new SystemWebSocketHandler();
    }

}
不要忘记在springmvc的配置文件中配置对此类的自动扫描

<context:component-scan base-package="com.ldl.origami.websocket" />

@Configuration

@EnableWebMvc
@EnableWebSocket
这三个大致意思是使这个类支持以@Bean的方式加载bean,并且支持springmvc和websocket,不是很准确大致这样,试了一下@EnableWebMvc不加也没什么影响,@Configuration本来就支持springmvc的自动扫描


registry.addHandler(systemWebSocketHandler(),"/webSocketServer").addInterceptors(new WebSocketHandshakeInterceptor())
用来注册websocket server实现类,第二个参数是访问websocket的地址



registry.addHandler(systemWebSocketHandler(), "/sockjs/webSocketServer").addInterceptors(new WebSocketHandshakeInterceptor())
                .withSockJS();
    }
这个是使用Sockjs的注册方法


首先SystemWebSocketHandler.java


public class SystemWebSocketHandler implements WebSocketHandler {

    private static final Logger logger;

    private static final ArrayList<WebSocketSession> users;

    static {
        users = new ArrayList<>();
        logger = LoggerFactory.getLogger(SystemWebSocketHandler.class);
    }

    @Autowired
    private WebSocketService webSocketService;

    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        logger.debug("connect to the websocket success......");
        users.add(session);
        String userName = (String) session.getAttributes().get(Constants.WEBSOCKET_USERNAME);
        if(userName!= null){
            //查询未读消息
            int count = webSocketService.getUnReadNews((String) session.getAttributes().get(Constants.WEBSOCKET_USERNAME));

            session.sendMessage(new TextMessage(count + ""));
        }
    }

    @Override
    public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {

        //sendMessageToUsers();
    }

    @Override
    public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
        if(session.isOpen()){
            session.close();
        }
        logger.debug("websocket connection closed......");
        users.remove(session);
    }

    @Override
    public void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {
        logger.debug("websocket connection closed......");
        users.remove(session);
    }

    @Override
    public boolean supportsPartialMessages() {
        return false;
    }

    /**
     * 给所有在线用户发送消息
     *
     * @param message
     */
    public void sendMessageToUsers(TextMessage message) {
        for (WebSocketSession user : users) {
            try {
                if (user.isOpen()) {
                    user.sendMessage(message);
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    /**
     * 给某个用户发送消息
     *
     * @param userName
     * @param message
     */
    public void sendMessageToUser(String userName, TextMessage message) {
        for (WebSocketSession user : users) {
            if (user.getAttributes().get(Constants.WEBSOCKET_USERNAME).equals(userName)) {
                try {
                    if (user.isOpen()) {
                        user.sendMessage(message);
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
                break;
            }
        }
    }
}



相关内容大家一看就能明白,就不多解释了


然后WebSocketHandshakeInterceptor.java


public class WebSocketHandshakeInterceptor implements HandshakeInterceptor {

    private static Logger logger = LoggerFactory.getLogger(HandshakeInterceptor.class);
    @Override
    public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Map<String, Object
                > attributes) throws Exception {
        if (request instanceof ServletServerHttpRequest) {
            ServletServerHttpRequest servletRequest = (ServletServerHttpRequest) request;
            HttpSession session = servletRequest.getServletRequest().getSession(false);
            if (session != null) {
                //使用userName区分WebSocketHandler,以便定向发送消息
                String userName = (String) session.getAttribute(Constants.SESSION_USERNAME);
                attributes.put(Constants.WEBSOCKET_USERNAME,userName);
            }
        }
        return true;
    }

    @Override
    public void afterHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Exception exception) {

    }
}

这个的主要作用是取得当前请求中的用户名,并且保存到当前的WebSocketHandler中,以便确定WebSocketHandler所对应的用户,具体可参考HttpSessionHandshakeInterceptor

用户登录建立websocket连接

index.jsp

<script type="text/javascript" src="http://localhost:8080/Origami/websocket/sockjs-0.3.min.js"></script>
        <script>
            var websocket;
            if ('WebSocket' in window) {
                websocket = new WebSocket("ws://localhost:8080/Origami/webSocketServer");
            } else if ('MozWebSocket' in window) {
                websocket = new MozWebSocket("ws://localhost:8080/Origami/webSocketServer");
            } else {
                websocket = new SockJS("http://localhost:8080/Origami/sockjs/webSocketServer");
            }
            websocket.onopen = function (evnt) {
            };
            websocket.onmessage = function (evnt) {
                $("#msgcount").html("(<font color='red'>"+evnt.data+"</font>)")
            };
            websocket.onerror = function (evnt) {
            };
            websocket.onclose = function (evnt) {
            }

        </script>


使用sockjs时要注意

1、这两个的写法

<script type="text/javascript" src="http://localhost:8080/Origami/websocket/sockjs-0.3.min.js"></script>
websocket = new SockJS("http://localhost:8080/Origami/sockjs/webSocketServer");
2、web.xml中
<web-app version="3.0" xmlns="http://java.sun.com/xml/ns/javaee"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_1.xsd">
version
web-app_3_1.xsd
这两个的版本都要是3.0+


然后在这个servlet中加入

<async-supported>true</async-supported>


<servlet>
		<servlet-name>appServlet</servlet-name>
		<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
		<init-param>
			<param-name>contextConfigLocation</param-name>
			<param-value>classpath*:servlet-context.xml</param-value>
		</init-param>
		<load-on-startup>1</load-on-startup>
        <async-supported>true</async-supported>
	</servlet>

然后所有的filter中也加入

<async-supported>true</async-supported>


3、添加相关依赖

<dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-annotations</artifactId>
            <version>2.3.0</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-core</artifactId>
            <version>2.3.1</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
            <version>2.3.3</version>
        </dependency>
好了,现在websocket可以正常建立起来了



返回用户未读的消息

当连接建立后,会进入SystemWebSocketHandler的afterConnectionEstablished方法,代码看上边,取出WebSocketHandshakeInterceptor中保存的用户名

查询信息后使用session.sendMessage(new TextMessage(count + ""));返回给用户,从哪来回哪去


服务端推送消息给用户

@Controller
public class AdminController {

    static Logger logger = LoggerFactory.getLogger(AdminController.class);

    @Autowired(required = false)
    private AdminService adminService;

    @Bean
    public SystemWebSocketHandler systemWebSocketHandler() {
        return new SystemWebSocketHandler();
    }


    @RequestMapping("/auditing")
    @ResponseBody
    public String auditing(HttpServletRequest request){
        //无关代码都省略了
        int unReadNewsCount = adminService.getUnReadNews(username);
        systemWebSocketHandler().sendMessageToUser(username, new TextMessage(unReadNewsCount + ""));
        return result;
    }
}

在这里可以使用sendMessageToUser给某个用户推送信息,也可以使用sendMessageToUsers给所有用户推送信息

© 著作权归作者所有

共有 人打赏支持
ldl123292
粉丝 43
博文 9
码字总数 4973
作品 0
朝阳
程序员
私信 提问
加载中

评论(90)

大飞v1哥
大飞v1哥
webSocketServer 这个类里面写的是什么?
d
defi2015

引用来自“大_于”的评论

有demo下载么?

引用来自“ldl123292”的评论

https://github.com/wsldl123292/Origami这个项目的一部分,搜一下这几个类

引用来自“大_于”的评论

弄了一個demo,總是連不上 14-Sep-2014 18:38:08.106 WARNING [http-nio-8084-exec-4] org.springframework.web.servlet.PageNotFound.noHandlerFound No mapping found for HTTP request with URI [/SpringWebSocketPush/sockjs/websck/info] in DispatcherServlet with name 'dispatcher' 1

引用来自“ldl123292”的评论

是否是你请求的地址和你注册的sockjs的地址不一致

引用来自“大_于”的评论

是少了一个依赖。已经搞定了,多谢分享。
请问少了什么依赖?怎么解决的?
d
defi2015

引用来自“大_于”的评论

有demo下载么?

引用来自“ldl123292”的评论

https://github.com/wsldl123292/Origami这个项目的一部分,搜一下这几个类

引用来自“大_于”的评论

弄了一個demo,總是連不上 14-Sep-2014 18:38:08.106 WARNING [http-nio-8084-exec-4] org.springframework.web.servlet.PageNotFound.noHandlerFound No mapping found for HTTP request with URI [/SpringWebSocketPush/sockjs/websck/info] in DispatcherServlet with name 'dispatcher' 1

引用来自“ldl123292”的评论

是否是你请求的地址和你注册的sockjs的地址不一致

引用来自“大_于”的评论

是少了一个依赖。已经搞定了,多谢分享。
请问少了什么依赖?怎么解决的?
d
defi2015

引用来自“大_于”的评论

有demo下载么?

引用来自“ldl123292”的评论

https://github.com/wsldl123292/Origami这个项目的一部分,搜一下这几个类

引用来自“大_于”的评论

弄了一個demo,總是連不上 14-Sep-2014 18:38:08.106 WARNING [http-nio-8084-exec-4] org.springframework.web.servlet.PageNotFound.noHandlerFound No mapping found for HTTP request with URI [/SpringWebSocketPush/sockjs/websck/info] in DispatcherServlet with name 'dispatcher' 1

引用来自“ldl123292”的评论

是否是你请求的地址和你注册的sockjs的地址不一致

引用来自“大_于”的评论

是少了一个依赖。已经搞定了,多谢分享。
你好 你发布git上的demo也是报这个错 请问少了什么依赖?
哎呀喂耶
哎呀喂耶
WebSocket connection to 'ws://127.0.0.1:8080/springExercise/myHandler' failed: Error during WebSocket handshake: Unexpected response code: 403 浏览器测试提示这个错误,后台报Did not find handler method for [/myHandler],怎么解决呢?
startshineye
startshineye

引用来自“不会飞的菜鸟”的评论

请教一下大家,这里的webSocketServer 是指向的哪里啊?代码里找不到对应的地方。
一直报这个错误:failed: Error during WebSocket handshake: Unexpected response code: 404

if ('WebSocket' in window) {
websocket = new WebSocket("ws://localhost:8080/Origami/webSocketServer");
} else if ('MozWebSocket' in window) {
websocket = new MozWebSocket("ws://localhost:8080/Origami/webSocketServer");
} else {
websocket = new SockJS("http://localhost:8080/Origami/sockjs/webSocketServer");
}



你解决了吗?我也出现这个问题了?
最爱xiaoyu77
最爱xiaoyu77
用户管理需要写入数据库么?
z
zhoucanji
不错,我学习了。但是,能更详细点,就更好13
不会飞的菜鸟
请教一下大家,这里的webSocketServer 是指向的哪里啊?代码里找不到对应的地方。
一直报这个错误:failed: Error during WebSocket handshake: Unexpected response code: 404

if ('WebSocket' in window) {
websocket = new WebSocket("ws://localhost:8080/Origami/webSocketServer");
} else if ('MozWebSocket' in window) {
websocket = new MozWebSocket("ws://localhost:8080/Origami/webSocketServer");
} else {
websocket = new SockJS("http://localhost:8080/Origami/sockjs/webSocketServer");
}



骑白马的公主
我喜欢代码简洁易读,服务稳定的推送服务,前段时间研究了一下goeasy,后台推送只需要两行代码, js前端推送也只需要3,4行,而且文档齐全,还提供了后台查询信息收发情况,所以我觉得GoEasy推送服务是个不错的选择。
快速入门:https://goeasy.io/www/started
GoEasy web实时推送官网:https://goeasy.io
1. 引入goeasy.js
2. 客户端订阅,
Var goeasy = new GoEasy({appkey:’your appkey’});
goeasy.subscribe(channel:”your channel”, onMessage:function(message){alert(‘received message’+ message.content)})
3. 三种推送方式
a.Javascript:
goeasy.publish({channel:’your channel’, message:’your publish msg’});

b.Java SDK:
GoEasy goeasy = new GoEasy(“appkey”);
goeasy.publish(“your channel”,”your msg”);

c.RestAPI: https://goeasy.io/goeasy/publish

三步轻松实现web推送及接收
工信部放大招:将统一 Android 消息推送标准

由于一些特殊的原因,在国内的用户无法享受到谷歌安卓系统提供的 GMS 消息推送服务,不少国产安卓软件接收消息依靠后台服务存在,也由此出现了用户反映的耗电以及占用内存问题,不过未来这一...

王练
2017/06/04
7.8K
50
如何通过个推SDK实现IM功能

产品上线4年多以来,个推已经服务了逾19万app开发者和35万app,助推了无数拥有亿级用户量的合作伙伴应用精细化运营。 但是,大多数开发者都不了解,用个推的推送SDK还可以实现IM功能。作为曾...

个推
2015/08/10
1K
0
京东京麦商家开放平台的消息推送架构演进之路

本文来自京东商城京麦平台组开发工程师曹德然的技术分享,感谢作者。 1、前言 京麦实时消息推送是京东的京麦商家开放平台的核心组成部分。从消息源到消息中心再到触达用户,以及最终根据消息...

JackJiang2011
2018/01/10
0
0
与此同时,各终端厂商实现推送通道接口和功能统一

  与此同时,各终端厂商实现推送通道接口和功能统一,方便开发者接入。另外,第三方推送服务商原则上也遵循统一推送的标准,保证服务一致性,降低开发者学习成本。   例如,通过推送消息...

晨晨尖端科技前沿
2017/06/04
0
0
Service Worker学习与实践(三)——消息推送

在上一篇文章Service Worker学习与实践(二)——PWA简介中,已经讲到的起源,优势与劣势,并通过一个简单的例子说明了如何在桌面端和移动端将一个安装到桌面上,这篇文章,将通过一个例子阐...

counterxing
2018/11/20
0
0

没有更多内容

加载失败,请刷新页面

加载更多

2018年度中国IT行业杰出人物奖出炉

近日,由51CTO主办的《中国企业“IT印象◆创新IT,赋能未来”年终评选》活动评选榜单正式揭晓,平安科技首席产品官兼平安云事业部总经理区海鹰荣获“2018年度中国IT行业杰出人物奖”。本届评...

linuxCool
58分钟前
3
0
企业级java springcloud b2bc商城系统开源源码二次开发(三)SpringBoot用JdbcTemplates访问Mysql

准备工作 jdk 1.8 maven 3.0 idea mysql 初始化mysql: -- create table `account`DROP TABLE `account` IF EXISTSCREATE TABLE `account` ( `id` int(11) NOT NULL AUTO_INCREMENT,......

sccspuercode
58分钟前
1
0
React 世界的一等公民 - 组件

Choerodon猪齿鱼平台使用 React 作为前端应用框架,对前端的展示做了一定的封装和处理,并配套提供了前端组件库Choerodon UI。结合实际业务情况,不断对组件优化设计,提高代码质量。 本文将...

Choerodon
今天
2
0
Redis数据分片方案实践

Twemproxy的介绍 Twitter的Twemproxy (https://github.com/twitter/twemproxy)是目前市面上用的最广的使用做多的用来做redis集群服务。由于redis是单线程,而且官方的cluster 还不是很稳定和...

Linux就该这么学
今天
1
0
IntelliJ IDEA显示类继承关系图

打开java类 - 右键 - show diagram - 类图关系

Danni3
今天
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部