当前位置:首页 > 服务端 > Netty下的WebSocket心跳检测

Netty下的WebSocket心跳检测

2022年11月09日 13:39:02服务端9

什么是心跳检测

心跳机制是定时发送一个自定义的结构体(心跳包),让对方知道自己还活着,以确保连接的有效性的机制。

在WebSocket中即判断套接字是否已经与服务器断开,无法使用,此时要清理服务器的该套接字进程以免浪费资源。

心跳包就是客户端定时发送简单的信息给服务器端告诉它还在正常运行。

实例

比如针对客户端每个连接,服务器都会接收并存入一个容器进行统一管理。

客户端的正常结束,服务器会自动清理。

但某些特殊情况下,服务器无法识别。比如打开飞行模式后,关闭客户端,关闭飞行模式,重新打开客户端,

此时容器中并没有清理客户端,而此时又创建了一个客户端连接。

实现

首先创建一个handler,实现心跳。仅检测读写空闲

import io.netty.channel.*;
import io.netty.handler.timeout.IdleState;
import io.netty.handler.timeout.IdleStateEvent;

/**
 * @Author Sakura
 * @Date 5/8/2019
 * 用于检测channel心跳的handler
 **/
public class HeartBeatHandler extends ChannelInboundHandlerAdapter {


    @Override
    public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {

        //判断evt是否是IdleStateEvent(用于触发用户事件,包含读空闲/写空闲/读写空闲)
        if(evt instanceof IdleState){
            IdleStateEvent idleStateEvent = (IdleStateEvent) evt;

            if(idleStateEvent.state() == IdleState.READER_IDLE){
                System.out.println("进入读空闲...");
            }else if(idleStateEvent.state() == IdleState.WRITER_IDLE){
                System.out.println("进入写空闲...");
            }else if(idleStateEvent.state() == IdleState.ALL_IDLE){
                System.out.println("进入读写空闲...");

                Channel channel = ctx.channel();
                //关闭无用channel,避免浪费资源
                channel.close();
            }
        }
    }
}

后在初始化器中添加handler

package com.imooc.netty;

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;
import io.netty.handler.timeout.IdleStateHandler;

/**
 * @Author Sakura
 * @Date 5/8/2019
 **/
public class WSServerInitializer extends ChannelInitializer<SocketChannel> {
    protected void initChannel(SocketChannel socketChannel) throws Exception {

        ChannelPipeline pipeline = socketChannel.pipeline();

        //=============================增加心跳支持============================

        //对客户端,如果在60秒内没有向服务端发送心跳,就主动断开
        //三个参数分别为读/写/读写的空闲,我们只针对读写空闲检测
        pipeline.addLast(new IdleStateHandler(2,4,60));

        pipeline.addLast(new HeartBeatHandler());

    }
}

初始化器是在ServerBootstrap里启动的

package com.imooc.netty;

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;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.stereotype.Component;

/**
 * @Author Sakura
 * @Date 5/8/2019
 **/

@Component
public class WSServer {

    public static class SingletionWSServer{

        static final WSServer instance = new WSServer();
    }

    public static WSServer getInstance(){
        return SingletionWSServer.instance;
    }

    private EventLoopGroup mainGroup;
    private EventLoopGroup subGroup;
    private ServerBootstrap server;
    private ChannelFuture future;

    public WSServer(){
        mainGroup = new NioEventLoopGroup();
        subGroup = new NioEventLoopGroup();
        server = new ServerBootstrap();

        server.group(mainGroup,subGroup)
                .channel(NioServerSocketChannel.class)
                .childHandler(new WSServerInitializer());
    }

    public void start(){
        this.future = server.bind(8088);
        System.err.println("netty websocket server 启动完毕...");
    }

}

接着在前端的WebSocket的onopen事件中定时发送一条数据就好了,对该数据不做处理,让服务器知道有请求发送,客户端还在就好了。

//后端每60秒检测一次,这里只要小于60秒就行了
socket.onopen:function(){
    setInterval("CHAT.keepalive()", 50000);
}

keepalive: function() {
	// 构建对象
	var dataContent = "test alive";
	// 发送心跳
	socket.send(dataContent);
}

 

作者:清欢Viki
来源链接:https://blog.csdn.net/weixin_42089175/article/details/99466397

版权声明:
1、JavaClub(https://www.javaclub.cn)以学习交流为目的,由作者投稿、网友推荐和小编整理收藏优秀的IT技术及相关内容,包括但不限于文字、图片、音频、视频、软件、程序等,其均来自互联网,本站不享有版权,版权归原作者所有。

2、本站提供的内容仅用于个人学习、研究或欣赏,以及其他非商业性或非盈利性用途,但同时应遵守著作权法及其他相关法律的规定,不得侵犯相关权利人及本网站的合法权利。
3、本网站内容原作者如不愿意在本网站刊登内容,请及时通知本站(javaclubcn@163.com),我们将第一时间核实后及时予以删除。


本文链接:https://www.javaclub.cn/server/68841.html

标签: Netty
分享给朋友:

“Netty下的WebSocket心跳检测” 的相关文章

Springboot+Netty集成protobuf开发服务器

原文地址:http://t.csdn.cn/pkPl9 作者:全栈小定^.^ 来源链接:https://blog.csdn.net/dingdingdandang/article/details/124261130...

springboot整合netty

springboot整合netty

Spring框架核心技术 Netty文献资料 目录 前言 正文 代码 新建一个springboot项目,在pom文件中添加netty依赖: 新建netty服务 netty调用所需的服务类...

Java高并发网络编程(五)Netty应用

Java高并发网络编程(五)Netty应用

推送系统   一、系统设计             二、拆包和粘包 粘包、拆包表现形式 现在假设客户端向服务端连续发送了两个数据包...

springboot整合netty(二)

springboot整合netty(二)

目录 前言 正文 代码 1. 新建一个springboot项目,在pom文件中添加netty依赖: 2.新建netty服务 3.netty调用...

netty初步使用与了解

netty初步使用与了解

概述 就我个人的感受来说netty是一个nio的封装框架,他能够很简洁的进行tcp udp协议的开发使用。所以对于netty的使用大部分是基于rpc框架的开发 比如duboo.。 rpc 与webService rpc简称远程方法调用 通过tcp udp web...

java高并发实战Netty+协程(Fiber)|系列1|事件驱动模式和零拷贝

java高并发实战Netty+协程(Fiber)|系列1|事件驱动模式和零拷贝

今天开始写一些高并发实战系列。 本系列主要讲两大主流框架: Netty和Quasar(java纤程库) 先介绍netty吧,netty是业界比较成熟的高性能异步NIO框架。 简单来说,它就是对NIO2的封装,但提供了更好用,bug更少的API。 为什么ne...

Netty+SpringBoot写一个基于Http协议的文件服务器

本文参考《Netty权威指南》NettyApplication package com.xh.netty; import org.springframework.boot.SpringApplication; import org.springframework.bo...

Netty粘包/拆包(一)

Netty粘包/拆包(一)

TCP出现粘包拆包原因有三个: 1.应用程序write写入的字节大小大于套接口发送缓冲区大小; 2.进行MSS(最大报文长度)大小的TCP分段(TCP报文长度-TCP头部长度>MSS的时候将发生拆包); 3.以太网帧的payload大于MTU(最大数据包大...

netty-搭建简单http服务器

netty-搭建简单http服务器

netty中提供了许多定义好的协议,如HTTP编解码器,我们利用它可以快速地开发一个基于netty的web服务器。 package com.throne.netty.test1.protocol; import io.netty.bootstra...

学习“闪电侠”的Netty系列源码博文笔记

学习“闪电侠”的Netty系列源码博文笔记

1、netty的reactor线程在添加一个任务的时候被创建,该线程实体为 FastThreadLocalThread,最后线程执行主体为NioEventLoop的run方法。   2、reactor线程大概做的事情分为对三个步骤不断循环  ...

发表评论

访客

◎欢迎参与讨论,请在这里发表您的看法和观点。