zoukankan      html  css  js  c++  java
  • websocket聊天体验

    light-example-4j/websocket目录有client-to-server、peer-to-peer两个示例项目,解决了我的两个问题:在线聊天、日志查看。

    在线聊天,后续可以支持:最近历史、表情+图片

    .addPrefixPath("/ws/chat", websocket(new WebSocketConnectionCallback() {
         @Override
         public void onConnect(WebSocketHttpExchange exchange, WebSocketChannel channel) {
             channel.getReceiveSetter().set(new AbstractReceiveListener() {
                 @Override
                 protected void onFullTextMessage(WebSocketChannel channel, BufferedTextMessage message) {
                     Set<WebSocketChannel> peerConnections = channel.getPeerConnections();
                     String msg = channel.getSourceAddress()+"/"+peerConnections.size()+": "+message.getData();
                     peerConnections.parallelStream().forEach(c -> WebSockets.sendText(msg, c, null));
                     log.info(msg);//可以看到当前有多少人
                 }
             });
             channel.resumeReceives();
         }
    }))

    日志查看:使用Tailer、TailerListenerAdapter,把日志信息推送给浏览器。

    image

  • 相关阅读:
    Rust 变量
    Rust-lang(hello world 续)
    Rust-lang(hello world)
    Java 1.8 ASM ClassReader failed to parse class file
    Sqoop使用笔记
    Jstorm
    从flume到kafka,日志收集
    vim-3-插件管理
    vim-2-使用进阶
    Git-Repo-Gerrit-1-Git介绍,安装和配置
  • 原文地址:https://www.cnblogs.com/xingqi/p/11012833.html
Copyright © 2011-2022 走看看