文档章节

Websocket(4)处理类

o
 osc_pn11u1x9
发布于 2018/08/06 09:39
字数 164
阅读 5
收藏 0

精选30+云产品,助力企业轻松上云!>>>

5、处理类

public class MyWebSocketHandler extends TextWebSocketHandler {
    
    protected Log log = Log.getInstance(MyWebSocketHandler.class);
    

    private static final ArrayList<WebSocketSession> users = new ArrayList<WebSocketSession>();
    
    @Override
    protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
      System.out.println("进入了工具类");
      System.out.println("接收数据:"+message.getPayload().toString());
   // 处理消息 msgContent消息内容
      TextMessage textMessage = new TextMessage("abc");
      session.sendMessage(textMessage);
    }

    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {

        log.info("connect websocket success.......");

        users.add(session);
    }
    @Override
    public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
        // TODO Auto-generated method stub
        
    }

    @Override
    public void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {
        // TODO Auto-generated method stub
        log.info("connect websocket closed.......");
         
        users.remove(session);
    }
    
    // 给所有用户发送 信息
    public void sendMsgToAllUsers(WebSocketMessage<?> message) throws Exception{
 
        for (WebSocketSession user : users) {
            user.sendMessage(message);
        }
 
    }

    protected void handlePingMessage(WebSocketSession session) throws Exception {
        byte[] array = new byte[1];
        array[0] = 1;
        ByteBuffer buffer = ByteBuffer.wrap(array);
        PingMessage pingMessage = new PingMessage(buffer);
        session.sendMessage(pingMessage);
    }
}

 

o
粉丝 0
博文 500
码字总数 0
作品 0
私信 提问
加载中
请先登录后再评论。
SpringMVC开放WebSocket接口

在开发过程中,时常遇到需要前后端实时通讯的需求。比如客户和客服的在线沟通。而通常会有使用轮询的方式,每隔几秒钟发送一次HTTP请求,来检查客户或客服有没有发送新的消息。这是因为HTTP请...

HellerZhang
2019/08/16
969
0
Spring消息之WebSocket

一、WebSocket简介 WebSocket 的定义?WebSocket是HTML5下一种全双工通信协议。在建立连接后,WebSocket服务器端和客户端都能主动的向对方发送和接收数据,就像Socket一样。 WebSocket 的由来...

jmcui
2018/05/06
0
0
WebSocket整合SSM(Spring,Struts2,Maven)

一、WebSocket与HTTP长轮询   WebSocket 属于HTML5 规范的一部分,提供的一种在单个 TCP 连接上进行全双工通讯的协议。允许服务端主动向客户端推送数据。在 WebSocket API 中,浏览器和服务...

osc_x2c17gwy
2019/01/17
9
0
WebSocket介绍

WebSocket介绍   WebSocket协议是一种双向通信协议,它建立在TCP之上,同http一样通过TCP来传输数据,但是它和http最大的不同有两点:1.WebSocket是一种双向通信协议,在建立连接后,WebSo...

CraneH
2013/04/27
881
0
springboot情操陶冶-web配置(四)

承接前文springboot情操陶冶-web配置(三),本文将在DispatcherServlet应用的基础上谈下websocket的使用 websocket websocket的简单了解可见维基百科WebSocket,在笔者看来其大多数应用在web...

osc_nrpjz96n
2018/09/14
0
0

没有更多内容

加载失败,请刷新页面

加载更多

Linux安装redis服务器和部署

Linux安装redis和部署 第一步:下载安装包 wget http://download.redis.io/releases/redis-5.0.5.tar.gz 访问https://redis.io/download 到官网进行下载。这里下载最新的5.0.5版本. 第二步:...

osc_3ytpwpyb
27分钟前
23
0
IF函数,根据条件设定输入内容

if函数通常用于条件判断,根据判断结果执行相应命令。 1.函数解释: IF(logical_test, [value_if_true], [value_if_false]) logical_test 必需。 计算结果为 TRUE 或 FALSE 的任何值或表达式...

osc_sumf8h95
29分钟前
9
0
Pytorch自定义dataloader以及在迭代过程中返回image的name

pytorch官方给的加载数据的方式是已经定义好的dataset以及loader,如何加载自己本地的图片以及label? 形如数据格式为 image1 label1 image2 label2 ... imagen labeln 实验中我采用的数据的...

osc_l8u38961
30分钟前
6
0
灯塔

\[love\ and \ share \] 我怎么感觉变成了好东西推荐呢?算了,本来也差不多 还没写完,想到再更 有好看玩的能不能评论一下,qwq 动漫 大多是些国漫,多在\(b\)站、腾讯视频、盗版小网站能够...

osc_dc6pbw3x
31分钟前
17
0
网易首页 」 网易手机 」 正文 苹果超薄触摸显示技术专利曝光:重新定义轻薄

最近,苹果公司的新屏幕专利技术已经曝光。特别是苹果公司的新型超薄触摸技术,它可以降低显示器的结构水平,消除多余的电路,并使屏幕更薄。该专利表明,这项新技术适用于iPhone,iPad,App...

osc_opzpp18v
33分钟前
7
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部