`

mina 心跳机制 ieRequest isResponse到底什么时候调用

 
阅读更多

上下文设置:

服务器端基于Mina开发,心跳包25秒发一次0D+0A,客户端收到后,回0D-0A

因为客户端设置了60秒一次心跳包,所以心跳包有服务器端先发起。

 

 

客户端心跳过滤器代码:(服务器端代码就不贴了,差不多的)

package com.mina.client;

import java.text.SimpleDateFormat;
import java.util.Date;

import org.apache.mina.core.buffer.IoBuffer;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.keepalive.KeepAliveFilter;
import org.apache.mina.filter.keepalive.KeepAliveMessageFactory;
import org.apache.mina.filter.keepalive.KeepAliveRequestTimeoutHandler;

public class MyKeepAliveFilter extends KeepAliveFilter {

	public MyKeepAliveFilter() {
		super(new KeepAliveMessageFactoryImpl(), IdleStatus.BOTH_IDLE, new ExceptionHandler(), 60, 70);
		this.setForwardEvent(false); //此消息不会继续传递,不会被业务层看见
	}

	
}


class ExceptionHandler implements KeepAliveRequestTimeoutHandler {   
    public void keepAliveRequestTimedOut(KeepAliveFilter filter, IoSession session) throws Exception {
    	System.out.println("心跳超时");
		session.close(true);
    }
}

class KeepAliveMessageFactoryImpl implements KeepAliveMessageFactory {
	private static final byte int_req = '+'; // 2B
	private static final byte int_rep = '-'; // 2D
	
	private static final IoBuffer KAMSG_REQ = IoBuffer.wrap(new byte[]{0x0D, '+', 0x0A});   
    private static final IoBuffer KAMSG_REP = IoBuffer.wrap(new byte[]{0x0D, '-', 0x0A});  
	
	
    /**
     * 此方法为发心跳包,发+
     */
	@Override
	public Object getRequest(IoSession arg0) {
		System.out.println();
		System.out.println(new SimpleDateFormat("yyyyMMdd-HH:mm:ss-SSS").format(new Date()) + " 发心跳包+:" + KAMSG_REQ.duplicate());
		return KAMSG_REQ.duplicate();
	}

	
	/**
	 * 收到对方的心跳包后,此方法回心跳包,回-
	 */
	@Override
	public Object getResponse(IoSession arg0, Object arg1) {
		System.out.println();
		System.out.println(new SimpleDateFormat("yyyyMMdd-HH:mm:ss-SSS").format(new Date()) + " 回心跳包-:" + KAMSG_REP.duplicate());
		return KAMSG_REP.duplicate();
	}

	
	/**
	 * 是否是心跳请求包,不管是对方的还是自己的
	 */
	@Override
	public boolean isRequest(IoSession session, Object message) {
		if(!(message instanceof IoBuffer)) {
    		return false;
    	}
		
		IoBuffer realMessage = (IoBuffer)message;
		System.out.println();
		if(realMessage.limit() != 3) {
    		System.out.println(new SimpleDateFormat("yyyyMMdd-HH:mm:ss-SSS").format(new Date()) + " isRequest limit不等于3,RETURN FALSE: message长度:" + realMessage.limit() + " : " + realMessage);
    		return false;
    	} else {
    		System.out.println(new SimpleDateFormat("yyyyMMdd-HH:mm:ss-SSS").format(new Date()) + " isRequest limit等于3, message长度:" + realMessage.limit() + " : " + realMessage);
    	}
    	
    	if (realMessage.remaining() != 3) {
    		return false;
    	}
    	
    	byte[] b = new byte[3];
    	realMessage.get(b);
    	
        boolean result = (b[1] == int_req);
        
        System.out.println(new SimpleDateFormat("yyyyMMdd-HH:mm:ss-SSS").format(new Date()) + " isRequest 判断是否为+:" + result);
        realMessage.rewind(); // 把pos重新设为0  
        
		return result;
	}

	
	
	/**
	 * 判断是否是心跳响应包,不管是对方的,还是自己的
	 */
	@Override
	public boolean isResponse(IoSession session, Object message) {
		if(!(message instanceof IoBuffer)) {
    		return false;
    	}
		
		IoBuffer realMessage = (IoBuffer)message;
		System.out.println();
		if(realMessage.limit() != 3) {
    		System.out.println(new SimpleDateFormat("yyyyMMdd-HH:mm:ss-SSS").format(new Date()) + " isResponse limit不等于3,RETURN FALSE: message长度:" + realMessage.limit() + " : " + realMessage);
    		return false;
    	} else {
    		System.out.println(new SimpleDateFormat("yyyyMMdd-HH:mm:ss-SSS").format(new Date()) + " isResponse limit等于3, message长度:" + realMessage.limit() + " : " + realMessage);
    	}
    	
    	if (realMessage.remaining() != 3) {
    		return false;
    	}
    	
    	byte[] b = new byte[3];
    	realMessage.get(b);
    	
        boolean result = (b[1] == int_rep);
        System.out.println(new SimpleDateFormat("yyyyMMdd-HH:mm:ss-SSS").format(new Date()) + " isResponse 判断是否为-:" + result);
        realMessage.rewind(); // 把pos重新设为0  
        
		return result;
	}
	
}

 

 

输出的日志:

20141113-15:49:00-778 isRequest limit等于3, message长度:3 : HeapBuffer[pos=0 lim=3 cap=2048: 0D 2B 0A]
20141113-15:49:00-779 isRequest 判断是否为+:true

20141113-15:49:00-779 回心跳包-:HeapBuffer[pos=0 lim=3 cap=3: 0D 2D 0A]

20141113-15:49:00-780 isResponse limit等于3, message长度:3 : HeapBuffer[pos=0 lim=3 cap=2048: 0D 2B 0A]
20141113-15:49:00-780 isResponse 判断是否为-:false

20141113-15:49:00-781 isRequest limit等于3, message长度:3 : HeapBuffer[pos=0 lim=3 cap=2048: 0D 2B 0A]
20141113-15:49:00-781 isRequest 判断是否为+:true

20141113-15:49:00-782 isRequest limit等于3, message长度:3 : HeapBuffer[pos=0 lim=3 cap=3: 0D 2D 0A]
20141113-15:49:00-783 isRequest 判断是否为+:false

20141113-15:49:00-783 isResponse limit等于3, message长度:3 : HeapBuffer[pos=0 lim=3 cap=3: 0D 2D 0A]
20141113-15:49:00-783 isResponse 判断是否为-:true

20141113-15:49:25-794 isRequest limit等于3, message长度:3 : HeapBuffer[pos=0 lim=3 cap=1024: 0D 2B 0A]
20141113-15:49:25-795 isRequest 判断是否为+:true

20141113-15:49:25-795 回心跳包-:HeapBuffer[pos=0 lim=3 cap=3: 0D 2D 0A]

20141113-15:49:25-796 isResponse limit等于3, message长度:3 : HeapBuffer[pos=0 lim=3 cap=1024: 0D 2B 0A]
20141113-15:49:25-796 isResponse 判断是否为-:false

20141113-15:49:25-797 isRequest limit等于3, message长度:3 : HeapBuffer[pos=0 lim=3 cap=1024: 0D 2B 0A]
20141113-15:49:25-797 isRequest 判断是否为+:true

20141113-15:49:25-798 isRequest limit等于3, message长度:3 : HeapBuffer[pos=0 lim=3 cap=3: 0D 2D 0A]
20141113-15:49:25-798 isRequest 判断是否为+:false

20141113-15:49:25-799 isResponse limit等于3, message长度:3 : HeapBuffer[pos=0 lim=3 cap=3: 0D 2D 0A]
20141113-15:49:25-799 isResponse 判断是否为-:true

 

有此得出

以上可得出:
对方是25秒一次心跳包,发+,我方60秒发+
如果对方先发心跳包,我方回心跳-后,如果心跳一直维持,我方就不会再主动发出+,除非超过设定的60秒的时候。
本地收到消息后
1、走isRequest,发现传递进来的数据为+,则return true,getResponse()回-
2、走isResponse,发现传递进来的数据为+,则return false
3、走isRequest,发现传递进来的数据为+,则return true,但没有回-
4、走isRequest,发现传递进来的数据为-,则return faslse
5、走isResponse,发现传递进来的数据位-,则 return true,但没有回+

 

 

如果本地先发心跳包

发+

isRequest 传进来+,对方收到+后,回-
isRequest 传进来-
isResopnse 传进来-
isResponse 传进来-
isResponse 传进来-

 

分享到:
评论

相关推荐

    Mina开源框架 心跳机制详解

    在Mina框架中,心跳机制扮演着至关重要的角色,它确保了网络连接的健康性和可靠性。心跳机制是网络通信中的一个基本概念,主要用来检测客户端与服务器之间的连接是否依然活跃,防止因网络延迟或数据包丢失导致的假死...

    mina心跳包机制

    mina心跳包机制是Apache Mina框架中的一个关键特性,它用于维持网络连接的活跃状态,确保数据能够在客户端和服务端之间顺畅地传输。Mina是一个高度可扩展的Java网络应用框架,广泛应用于各种分布式系统和网络服务,...

    mina连接 mina心跳连接 mina断线重连

    在本文中,我们将深入探讨Mina的核心概念,包括连接管理、心跳机制以及断线重连策略。 首先,让我们理解"Mina连接"。在Mina中,连接是指客户端与服务端之间建立的通信链路。它支持多种传输协议,如TCP/IP(Socket)...

    MINA 心跳协议Demo

    MINA框架提供了心跳机制的内置支持,使得开发者可以轻松地在应用中集成这一功能。 在描述中,“使用MINA自带的心跳协议编写的心跳的Demo”表明这是一个演示如何在MINA中实现心跳检查的实际代码示例。通常,心跳协议...

    mina 心跳

    "Mina心跳"是指在MINA框架中实现的一种机制,用于确保网络连接的活跃性和数据传输的可靠性。心跳在分布式系统、网络通信和实时应用程序中扮演着关键角色,因为它们可以检测并处理网络延迟、断开连接或其它通信问题。...

    mina2 实例程序(socket通讯调用远程方法)

    《mina2实现Socket通信调用远程方法详解》 在当今的分布式系统中,远程方法调用(Remote Method Invocation,RMI)是常见的通信方式之一,它允许程序在不同的网络节点间透明地调用方法,极大地简化了分布式应用的...

    mina新手教程源码 mina+springboot+idea最简单的案例。

    mina新手案例,mina新手教程源码 mina+springboot最简单的案例。用的IDEA * mina服务端 * 1、添加@Controller注解和 @PostConstruct注解,代表启动springboot项目时也调用该类下的该方法, * 启动springboot项目...

    mina仿qq聊天功能,自定义协议,协议的编码和解码详解,发送xml对象json,mina开发大全,详细api,mina心跳

    mina仿qq聊天功能,自定义协议,协议的编码和解码详解,发送xml对象json,mina开发大全,详细api ...mina开发的在线聊天工具,mina仿qq功能,mina自定义协议,可以仿http请求,mina心跳等技术大全,mina功能大揭密

    JAVA 通信框架MINA(包含心跳)

    Apache MINA 是一个开发高性能和高可伸缩性网络应用程序的网络应用框架。它提供了一个抽象的事件驱动的异步 API,可以使用 TCP/IP、UDP/IP、串口和虚拟机内部的管道等传输方式。Apache MINA 可以作为开发网络应用...

    Mina开发实例(服务端、客户端)DEMO

    Apache Mina是一个高度可扩展的网络通信框架,它允许开发者创建高性能、高效率的服务端和客户端应用程序。在Java世界中,Mina以其简洁的API和灵活性而受到青睐,尤其适用于处理大量的并发连接,如TCP/IP和UDP协议。...

    mina的高级使用,mina文件图片传送,mina发送文件,mina报文处理,mina发送xml和json

    Apache Mina是一个开源的网络通信应用框架,主要应用于Java平台,它为高性能、高可用性的网络应用程序提供了基础架构。在本文中,我们将深入探讨Mina的高级使用,特别是在文件图片传送、文件发送、XML和JSON报文处理...

    Mina+Socket通信

    Mina提供了丰富的过滤器和事件机制,可以方便地扩展和定制通信行为。而Socket则更底层,需要开发者自行处理这些细节。 文件"MinaSocket"可能包含了实现上述功能的详细代码,包括服务端的Acceptor配置、过滤器设置、...

    apache-mina-2.0.4.rar_apache mina_mina

    Apache Mina是一个高性能、异步事件驱动的网络应用程序框架,用于快速开发可维护的高性能协议服务器和客户端。这个"apache-mina-2.0.4.rar"压缩包包含的是Apache Mina 2.0.4版本的源代码,是深入理解和定制Mina的...

    MINA长连接框架实现通讯

    7. **异常处理和心跳机制**:为了保证网络连接的稳定性,MINA提供了异常处理机制,当检测到网络异常时,可以及时通知并采取相应的恢复措施。同时,心跳机制(Heartbeat)是长连接中常用的一种维持连接活跃的技术,...

    MINA_API+MINA_DOC+mina

    学习MINA API,开发者可以掌握异步网络编程的核心技巧,理解MINA如何通过事件驱动和过滤器链机制来提高网络应用的效率。同时,MINA支持多种协议,如TCP、UDP、SSL/TLS等,使得它在各种网络通信场景下都具有广泛的...

    springboot整合mina

    在实际开发中,你可能还需要考虑异常处理、心跳机制、连接管理、性能优化等方面的问题。这些都可以通过Mina提供的API和SpringBoot的特性来进一步完善。记得根据项目需求调整配置和代码,以满足特定场景下的功能需求...

    MINA2.0用户手册中文随笔翻译

    BIO 是阻塞式的 IO 模式,当读、写或者在 socket 上做任何操作的时候,被调用的操作将会阻塞调用者,知道操作完成。 而 NIO 是非阻塞式的 IO 模式,当你有很多的 socket 连接时,NIO 能帮你更好的处理它们:你不...

    mina服务器和客服端实现

    - **性能优化**:Mina支持多种优化策略,如缓冲区管理、心跳机制和线程池配置等,可以根据实际需求进行调整。 - **日志与调试**:Mina集成了常见的日志框架,如Log4j和SLF4J,便于追踪程序运行状态。同时,通过...

    Mina开发之客户端

    例如,可以使用心跳机制保持长连接的活性,或者使用线程池来优化并发处理能力。 总之,Mina为客户端开发提供了一套强大的工具,通过其灵活的过滤器系统和高效的I/O模型,能够帮助开发者快速构建高性能的网络应用。...

    Android-MinaSocket一款基于Mina的Socket长连接库

    - **心跳机制**:为了检测连接是否断开,通常需要设置心跳包,定时发送和接收,防止连接因长时间无数据传输而被网络中间设备关闭。 - **线程安全**:在多线程环境下,需确保所有操作都是线程安全的,避免并发问题。...

Global site tag (gtag.js) - Google Analytics