文档章节

Netty进阶篇之websocket发送消息(8)

木九天
 木九天
发布于 07/23 21:35
字数 913
阅读 36
收藏 3

序言:Netty进阶篇之简单版websocket发消息(7) 大概和下面的代码就成相似,只不过上一篇博客更加简单一些。

1、pom文件

<dependency>
    <groupId>io.netty</groupId>
    <artifactId>netty-all</artifactId>
    <version>4.1.25.Final</version>
</dependency>

2、index.html

<!DOCTYPE html>
<html>
   <head>
      <meta charset="utf-8" />
      <title></title>
   </head>
   <body>
      <div>发送消息:</div>
      <input type="text" id="msgContent"/>
      <input type="button" value="点我发送" onclick="CHAT.chat()"/>
      
      <div>接受消息:</div>
      <div id="receiveMsg" style="background-color: gainsboro;"></div>
      
      <script type="application/javascript">
         
         window.CHAT = {
            socket: null,
            init: function() {
               if (window.WebSocket) {
                  CHAT.socket = new WebSocket("ws://192.168.31.160:8088/ws");
                  CHAT.socket.onopen = function() {
                     console.log("连接建立成功...");
                  },
                  CHAT.socket.onclose = function() {
                     console.log("连接关闭...");
                  },
                  CHAT.socket.onerror = function() {
                     console.log("发生错误...");
                  },
                  CHAT.socket.onmessage = function(e) {
                     console.log("接受到消息:" + e.data);
                     var receiveMsg = document.getElementById("receiveMsg");
                     var html = receiveMsg.innerHTML;
                     receiveMsg.innerHTML = html + "<br/>" + e.data;
                  }
               } else {
                  alert("浏览器不支持websocket协议...");
               }
            },
            chat: function() {
               var msg = document.getElementById("msgContent");
               CHAT.socket.send(msg.value);
            }
         };
         CHAT.init();
      </script>
   </body>
</html>

3、main函数

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;

public class WSServer {

   public static void main(String[] args) throws Exception {
      
      //定义一对线程组 
      // 主线程组, 用于接受客户端的连接,但是不做任何处理,跟老板一样,不做事      
      EventLoopGroup mainGroup = new NioEventLoopGroup();
      // 从线程组, 老板线程组会把任务丢给他,让手下线程组去做任务
      EventLoopGroup subGroup = new NioEventLoopGroup();
      
      try {
         // netty服务器的创建, ServerBootstrap 是一个启动类
         ServerBootstrap server = new ServerBootstrap();
         server.group(mainGroup, subGroup)    // 设置主从线程组
            .channel(NioServerSocketChannel.class)    // 设置nio的双向通道
            .childHandler(new WSServerInitialzer());  //// 子处理器,用于处理workerGroup
         
         // 启动server,并且设置8088为启动的端口号,同时启动方式为同步
         ChannelFuture future = server.bind(8088).sync();
         
         future.channel().closeFuture().sync();
      } finally {
         // 监听关闭的channel,设置位同步方式
         mainGroup.shutdownGracefully();
         subGroup.shutdownGracefully();
      }
   }
}

4、初始化类

import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.http.HttpObjectAggregator;
import io.netty.handler.codec.http.HttpServerCodec;
import io.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler;
import io.netty.handler.stream.ChunkedWriteHandler;

public class WSServerInitialzer extends ChannelInitializer<SocketChannel> {

   @Override
   protected void initChannel(SocketChannel ch) throws Exception {
      ChannelPipeline pipeline = ch.pipeline();
      
      // websocket 基于http协议,所以要有http编解码器
      pipeline.addLast(new HttpServerCodec());
      // 对写大数据流的支持 
      pipeline.addLast(new ChunkedWriteHandler());
      // 对httpMessage进行聚合,聚合成FullHttpRequest或FullHttpResponse
      // 几乎在netty中的编程,都会使用到此hanler
      pipeline.addLast(new HttpObjectAggregator(1024*64));
      
      // ====================== 以上是用于支持http协议    ======================
      
      // ====================== 以下是支持httpWebsocket ======================
      
      /**
       * websocket 服务器处理的协议,用于指定给客户端连接访问的路由 : /ws
       * 本handler会帮你处理一些繁重的复杂的事
       * 会帮你处理握手动作: handshaking(close, ping, pong) ping + pong = 心跳
       * 对于websocket来讲,都是以frames进行传输的,不同的数据类型对应的frames也不同
       */
      pipeline.addLast(new WebSocketServerProtocolHandler("/ws"));
      
      // 自定义的handler
      pipeline.addLast(new ChatHandler());
   }
}

5、助手类

import io.netty.channel.Channel;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.channel.group.ChannelGroup;
import io.netty.channel.group.DefaultChannelGroup;
import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
import io.netty.util.concurrent.GlobalEventExecutor;

/**
 * 
 * @Description: 处理消息的handler
 * TextWebSocketFrame: 在netty中,是用于为websocket专门处理文本的对象,frame是消息的载体
 */
public class ChatHandler extends SimpleChannelInboundHandler<TextWebSocketFrame> {

   // 用于记录和管理所有客户端的channle
   private static ChannelGroup clients = 
         new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);
   
   @Override
   protected void channelRead0(ChannelHandlerContext ctx, TextWebSocketFrame msg) 
         throws Exception {
      // 获取客户端传输过来的消息
      String content = msg.text();
      System.out.println("接受到的数据:" + content);

      //类似于for循环
      clients.writeAndFlush(
            new TextWebSocketFrame(
                  "[服务器在]" + LocalDateTime.now() 
                  + "接受到消息, 消息为:" + content));
   }

   /**
    * 当客户端连接服务端之后(打开连接)
    * 获取客户端的channle,并且放到ChannelGroup中去进行管理
    */
   @Override
   public void handlerAdded(ChannelHandlerContext ctx) throws Exception {
      clients.add(ctx.channel());
   }

   @Override
   public void handlerRemoved(ChannelHandlerContext ctx) throws Exception {
      // 当触发handlerRemoved,ChannelGroup会自动移除对应客户端的channel
//    clients.remove(ctx.channel());
      System.out.println("客户端断开,channle对应的长id为:" 
                     + ctx.channel().id().asLongText());
      System.out.println("客户端断开,channle对应的短id为:" 
                     + ctx.channel().id().asShortText());
   }
}

6、测试

运行index.html

发送消息,如下server端返回消息

 

© 著作权归作者所有

木九天

木九天

粉丝 187
博文 224
码字总数 171159
作品 0
海淀
程序员
私信 提问
Kotlin + Netty 在 Android 上实现 Socket 的服务端

一. 背景 最近的一个项目:需要使用 Android App 作为 Socket 的服务端,并且一个端口能够同时监听 TCP/Web Socket 协议。 自然而然,项目决定采用 Netty 框架。Netty 服务端在收到客户端发来...

Tony沈哲
08/11
0
0
八问WebSocket协议:为你快速解答WebSocket热门疑问

本文由“小姐姐养的狗”原创发布于“小姐姐味道”公众号,原题《WebSocket协议 8 问》,收录时有优化和改动。感谢原作者的分享。 一、引言 WebSocket是一种比较新的协议,它是伴随着html5规范...

JackJiang2011
04/25
0
0
八问WebSocket协议:为你快速解答WebSocket热门疑问

一、引言 WebSocket是一种比较新的协议,它是伴随着html5规范而生的,虽然还比较年轻,但大多主流浏览器都已经支持。它使用方面、应用广泛,已经渗透到前后端开发的各种场景中。 对http一问一...

首席大胸器
04/25
98
0
[Java] Netty Websocket Server Javascript Client

WebSocket协议的出现无疑是 HTML5 中最令人兴奋的功能特性之一,它能够很好地替代Comet技术以及Flash的XmlSocket来实现基于HTTP协议的双向通信。目前主流的浏览器,如Chrome、Firefox、IE10、...

长平狐
2012/11/19
843
1
Node.js实现WebSocket聊天室的例子

对于聊天室,大家应该都不陌生,笔者也写过很多关于聊天室的例子。 本节,我们将演示如何通过Node.js来实现一个WebSocket聊天服务器的例子。 使用ws创建WebSokcet服务器 Node.js原生API并未提...

waylau
06/03
27
0

没有更多内容

加载失败,请刷新页面

加载更多

怎样在磁盘上查找MySQL表的大小?这里有答案

导读 我想知道 MySQL 表在磁盘上占用多少空间,但看起来很琐碎。不应该在 INFORMATION_SCHEMA.TABLES 中提供这些信息吗?没那么简单! 我想知道 MySQL 表在磁盘上占用多少空间,但看起来很琐碎...

问题终结者
25分钟前
6
0
jQuery load() 方法实现加载远程数据

jQuery load() 方法是简单但强大的 AJAX 方法。load() 方法从服务器加载数据,并把返回的数据放入被选元素中。 语法: $(selector).load(URL,data,callback);必需的 URL 参数规定您希望加载的...

前端老手
26分钟前
5
0
Spring Boot缓存实战 Redis 设置有效时间和自动刷新缓存-2

问题 上一篇Spring Boot Cache + redis 设置有效时间和自动刷新缓存,时间支持在配置文件中配置,说了一种时间方式,直接扩展注解的Value值,如: @Override@Cacheable(value = "people#${s...

xiaolyuh
34分钟前
9
0
怎样在磁盘上查找MySQL表的大小?这里有答案

我想知道 MySQL 表在磁盘上占用多少空间,但看起来很琐碎。不应该在 INFORMATION_SCHEMA.TABLES 中提供这些信息吗?没那么简单! 我想知道 MySQL 表在磁盘上占用多少空间,但看起来很琐碎。不应...

Linux就该这么学
59分钟前
5
0
Redis

一、Redis支持的几种数据类型:字符串、List、SET、HASH、ZSET 二、Redis的缓存技术主要是为了降低关系数据库的负载并减少网站成本 三、在Redis里面,被MULTI命令和EXEC命令包围的所有命令会...

BobwithB
今天
4
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部