上下文设置:
服务器端基于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心跳包机制是Apache Mina框架中的一个关键特性,它用于维持网络连接的活跃状态,确保数据能够在客户端和服务端之间顺畅地传输。Mina是一个高度可扩展的Java网络应用框架,广泛应用于各种分布式系统和网络服务,...
在本文中,我们将深入探讨Mina的核心概念,包括连接管理、心跳机制以及断线重连策略。 首先,让我们理解"Mina连接"。在Mina中,连接是指客户端与服务端之间建立的通信链路。它支持多种传输协议,如TCP/IP(Socket)...
MINA框架提供了心跳机制的内置支持,使得开发者可以轻松地在应用中集成这一功能。 在描述中,“使用MINA自带的心跳协议编写的心跳的Demo”表明这是一个演示如何在MINA中实现心跳检查的实际代码示例。通常,心跳协议...
"Mina心跳"是指在MINA框架中实现的一种机制,用于确保网络连接的活跃性和数据传输的可靠性。心跳在分布式系统、网络通信和实时应用程序中扮演着关键角色,因为它们可以检测并处理网络延迟、断开连接或其它通信问题。...
《mina2实现Socket通信调用远程方法详解》 在当今的分布式系统中,远程方法调用(Remote Method Invocation,RMI)是常见的通信方式之一,它允许程序在不同的网络节点间透明地调用方法,极大地简化了分布式应用的...
mina新手案例,mina新手教程源码 mina+springboot最简单的案例。用的IDEA * mina服务端 * 1、添加@Controller注解和 @PostConstruct注解,代表启动springboot项目时也调用该类下的该方法, * 启动springboot项目...
mina仿qq聊天功能,自定义协议,协议的编码和解码详解,发送xml对象json,mina开发大全,详细api ...mina开发的在线聊天工具,mina仿qq功能,mina自定义协议,可以仿http请求,mina心跳等技术大全,mina功能大揭密
Apache MINA 是一个开发高性能和高可伸缩性网络应用程序的网络应用框架。它提供了一个抽象的事件驱动的异步 API,可以使用 TCP/IP、UDP/IP、串口和虚拟机内部的管道等传输方式。Apache MINA 可以作为开发网络应用...
Apache Mina是一个开源的网络通信应用框架,主要应用于Java平台,它为高性能、高可用性的网络应用程序提供了基础架构。在本文中,我们将深入探讨Mina的高级使用,特别是在文件图片传送、文件发送、XML和JSON报文处理...
Apache Mina是一个高度可扩展的网络通信框架,它允许开发者创建高性能、高效率的服务端和客户端应用程序。在Java世界中,Mina以其简洁的API和灵活性而受到青睐,尤其适用于处理大量的并发连接,如TCP/IP和UDP协议。...
Mina提供了丰富的过滤器和事件机制,可以方便地扩展和定制通信行为。而Socket则更底层,需要开发者自行处理这些细节。 文件"MinaSocket"可能包含了实现上述功能的详细代码,包括服务端的Acceptor配置、过滤器设置、...
Apache Mina是一个高性能、异步事件驱动的网络应用程序框架,用于快速开发可维护的高性能协议服务器和客户端。这个"apache-mina-2.0.4.rar"压缩包包含的是Apache Mina 2.0.4版本的源代码,是深入理解和定制Mina的...
7. **异常处理和心跳机制**:为了保证网络连接的稳定性,MINA提供了异常处理机制,当检测到网络异常时,可以及时通知并采取相应的恢复措施。同时,心跳机制(Heartbeat)是长连接中常用的一种维持连接活跃的技术,...
学习MINA API,开发者可以掌握异步网络编程的核心技巧,理解MINA如何通过事件驱动和过滤器链机制来提高网络应用的效率。同时,MINA支持多种协议,如TCP、UDP、SSL/TLS等,使得它在各种网络通信场景下都具有广泛的...
BIO 是阻塞式的 IO 模式,当读、写或者在 socket 上做任何操作的时候,被调用的操作将会阻塞调用者,知道操作完成。 而 NIO 是非阻塞式的 IO 模式,当你有很多的 socket 连接时,NIO 能帮你更好的处理它们:你不...
在实际开发中,你可能还需要考虑异常处理、心跳机制、连接管理、性能优化等方面的问题。这些都可以通过Mina提供的API和SpringBoot的特性来进一步完善。记得根据项目需求调整配置和代码,以满足特定场景下的功能需求...
- **性能优化**:Mina支持多种优化策略,如缓冲区管理、心跳机制和线程池配置等,可以根据实际需求进行调整。 - **日志与调试**:Mina集成了常见的日志框架,如Log4j和SLF4J,便于追踪程序运行状态。同时,通过...
例如,可以使用心跳机制保持长连接的活性,或者使用线程池来优化并发处理能力。 总之,Mina为客户端开发提供了一套强大的工具,通过其灵活的过滤器系统和高效的I/O模型,能够帮助开发者快速构建高性能的网络应用。...
- **心跳机制**:为了检测连接是否断开,通常需要设置心跳包,定时发送和接收,防止连接因长时间无数据传输而被网络中间设备关闭。 - **线程安全**:在多线程环境下,需确保所有操作都是线程安全的,避免并发问题。...