MINA核心结构和处理消息的逻辑流程

1.MINA 核心结构

img

IoService

最底层的是IOService,负责具体的IO相关工作。这一层的典型代表有IOSocketAcceptor和IOSocketChannel,分别对应TCP协议下的服务端和客户端的IOService。IOService的意义在于隐藏底层IO的细节,对上提供统一的基于事件的异步IO接口。每当有数据到达时,IOService会先调用底层IO接口读取数据,封装成IoBuffer,之后以事件的形式通知上层代码,从而将Java NIO的同步IO接口转化成了异步IO。所以从图上看,进来的low-level IO经过IOService层后变成IO Event。

具体的代码可以参考org.apache.mina.core.polling.AbstractPollingIoProcessor的私有内部类Processor。

IoFilterChain

Mina的设计理念之一就是业务代码和数据包处理代码分离,业务代码只专注于业务逻辑,其他的逻辑如:数据包的解析,封装,过滤等则交由IoFilterChain来处理。IoFilterChain可以看成是Mina处理流程的扩展点。这样的划分使得结构更加清晰,代码分工更明确。开发者通过往Chain中添加IoFilter,来增强处理流程,而不会影响后面的业务逻辑代码。

IoHandler

IoHandler是实现业务逻辑的地方,需要有开发者自己来实现这个接口。IoHandler可以看成是Mina处理流程的终点,每个IoService都需要指定一个IoHandler。

IoSession

IoSession是对底层连接的封装,一个IoSession对应于一个底层的IO连接(在Mina中UDP也被抽象成了连接)。通过IoSession,可以获取当前连接相关的上下文信息,以及向远程peer发送数据。发送数据其实也是个异步的过程。发送的操作首先会逆向穿过IoFilterChain,到达IoService。但IoService上并不会直接调用底层IO接口来将数据发送出去,而是会将该次调用封装成一个WriteRequest,放入session的writeRequestQueue中,最后由IoProcessor线程统一调度flush出去。所以发送操作并不会引起上层调用线程的阻塞。

2.MINA处理消息的逻辑流程

第1种:

  • IOAcceptor 监听网络数据包传入的连接;
  • 为每个新的连接(Connection)创建一个session,同一个端口+ip的后续请求将通过session进行处理;
  • 同一个session收到的所有数据,通过过滤链进行过滤.通过PacketEncoder/Decoder进行有效的编码,解码处理(负责把底层传输的对象拼装为更高一层的对象方便后续的处理,最后传输的数据被交给IOHandler);
  • 最后根据自己的业务需求完成Handler的业务逻辑处理.

第2种:

通过SocketAcceptor 同客户端建立连接;

连接建立之后 I/O的读写交给了I/O Processor线程,I/O Processor是多线程的;

通过I/O Processor 读取的数据经过IoFilterChain里所有配置的IoFilter, IoFilter 进行消息的过滤,格式的转换,在这个层面可以制定一些自定义的协议;

最后 IoFilter 将数据交给 Handler 进行业务处理,完成了整个读取的过程;

写入过程也是类似,只是刚好倒过来,通过IoSession.write 写出数据,然后Handler进行写入的业务处理,处理完成后交给IoFilterChain,进行消息过滤和协议的转换,最后通过 I/O Processor 将数据写出到 socket 通道。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/555451.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

linux shell文件锁,shell脚本实现文件锁功能

1.背景当多个进程可能会对同样的数据执行操作时,这些进程需要保证其它进程没有在操作,以免损坏数据。通常,这样的进程会使用一个“锁文件”,也就是建立一个文件来告诉别的进程自己在运行,如果检测到那个文件存在则认为…

java 图片操作技术之RGB的获取

/*** 名词解释:* 饱和度是指色彩的鲜艳程度,也称色彩的纯度。* 灰度:使用黑色调表示物体,即用黑色为基准色,不同的饱和度的黑色来显示图像。* 像素:如同摄影的相片一样,数码影像也具有连续性的浓淡阶调&…

SpringBoot使用Mina框架进行服务端与客户端数据通信

pom.xml引入 <dependency><groupId>org.apache.mina</groupId><artifactId>mina-core</artifactId><version>2.1.3</version> </dependency> <dependency><groupId>org.apache.mina</groupId><artifact…

linux sh expr冒号,linux expr命令参数及用法详解

expr命令一般用于整数值&#xff0c;但也可用于字符串。一般格式为&#xff1a;#expr argument operator argumentexpr也是一个手工命令行计数器。#$expr 10 1020#$expr 1500 9002500#$expr 30 / 310#$expr 30 / 3 / 25(注意运算符左右都有空格)使用乘号时&#xff0c;必须用…

TortoiseSVN忽略文件或文件夹

TortoiseSVN忽略文件或文件夹 方法一&#xff1a; 选择项目目录—>右键–选择TortoiseSVN–Properties 1.svn:ignore&#xff1a;必须每个工作目录都要设置 2.global-ignores&#xff1a;只需要配置一次 添加内容: .settings .settings/* target target/* .classpath .p…

Showdoc使用——接口文档

一、到showdoc官方注册账号 官方地址https://www.showdoc.com.cn/ 登录并创建一个项目,如图&#xff1a; 二、下载showdoc环境 再项目设置中有开发api,点开如下&#xff1a; 其中就是官方教程&#xff0c;简单全面。showdoc基础就是使用官方脚本 https://git-scm.com/downloa…

usb转并口支持linux,使用PCI转并口实现SJF刷写嵌入式开发板

本文内容遵从CC版权协议, 可以随意转载, 但必须以超链接形式标明文章原始出处和作者信息及版权声明网址: http://www.penglixun.com/tech/embedded/sjf_board_usingpci_to_ltp.html整理电脑文件发现曾经写的这个文档&#xff0c;怕找不到了&#xff0c;丢这吧。引言&#xff1a…

软件概要设计与详细设计的区别

概要设计与详细设计的区别 概要设计就是设计软件的结构&#xff0c;包括组成模块&#xff0c;模块的层次结构&#xff0c;模块的调用关系&#xff0c;每个模块的功能等等。同时&#xff0c;还要设计该项目的应用系统的总体数据结构和数据库结构&#xff0c;即应用系统要存储什…

linux下c语言俄罗斯方块,c语言做俄罗斯方块

我来对这段程序做一下注释&#xff1a;#include /*标准库*/#include /*绘图库*/#include /*BIOS库&#xff0c;输入输出&#xff0c;BIOS时间等*/#define mDRAW 5 /*各种消息的宏定义*/#define mLINE 6#define mADOWN 7#define mGEN 8#define mLEFT 75#define mRIGHT 77#define…

8款JVM性能调优监控工具(提高开发效率)

在平时的开发当中我们总是会遇到各种各样的问题&#xff0c;比如说内存泄漏、死锁、CPU等。遇到问题不可怕&#xff0c;关键是我们如何去排查这些错误&#xff0c;对症下药才是根本。不过对于很多人来说&#xff0c;往往找不到这些问题的根本所在&#xff0c;因此这篇文章主要是…

linux的静态编译elf无法调试,[翻译]自己动手编写一个Linux调试器系列之4 ELF文件格式与DWARF调试格式 by lantie@15PB...

自己动手编写一个Linux调试器系列之4 ELF文件格式与DWARF调试格式 by lantie15PB在上一节中&#xff0c;你已经听说了DWARF调试格式&#xff0c;它是程序的调试信息&#xff0c;是一种可以更好理解源码的方式&#xff0c;而不只是解析程序。今天我们将讨论源代码级调试信息的细…

SpringBoot踩坑记录 Invalid bound statement (not found)引发的一些列问题

SpringBoot踩坑记录 Invalid bound statement (not found)引发的一些列问题 当你开开心心搭建了一个SpringBoot项目&#xff0c;用插件生成了entity、dao、mapper&#xff0c;写下第一个Controller准备试一下&#xff0c;结果却发现一条简单的查询报错了。 {"timestamp…

Linux检查wlan0是否存在,linux - airmon-ng将wlan0更改为wlan0mon但不恢复[​​关闭] - 堆栈内存溢出...

我有同样的问题关闭wlan0mon(但在Kali Linux&#xff0c;而不是Ubuntu)&#xff0c;我相信我的一位同事因此而锁定了几个适配器。 但是&#xff0c;从2016年4月14日开始&#xff0c;Colin在2016年4月14日的优秀答案中纠正了我的硬件问题(ALFA AWUS036NHA)&#xff0c;而无需两次…

Java中switch参数传null会引起异常——Java 语法糖

问题 switch 参数不能是null&#xff0c;swicth(null)会报java.lang.NullPointerException异常 查找原因 为什么会这样呢&#xff0c;查找一下原因&#xff1a; 找到编译后的class文件&#xff0c;就明白了 总结&#xff1a; switch 是一个语法糖。switch语句是先计算 par…

linux head命令作用,Linux查看文件内容之head命令

1. head命令简介本文主要介绍head命令的作用与常用使用方法&#xff0c;该命令和tail命令相反&#xff0c;head默认显示用来显示文本开头&#xff0c;而tail默认显示结尾某个数量的文字区块。2. head命令选项-q 隐藏文件名-v 显示文件名-c 显示字节数-n 显示的行数3. 常见使用方…

java.util.concurrent.TimeUnit

JavaAPI&#xff1a;https://docs.oracle.com/javase/8/docs/api/index.html 1 TimeUnit api&#xff1a;https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/TimeUnit.html TimeUnit是java.util.concurrent包下面的一个类&#xff1b;TimeUnit 是Java枚举应用场…

c语言数组宏定义标识符,C语言学习笔记--预编译/宏定义/数组/参数传递/函数指针...

目录预编译值传递、指针传递、引用传递数组typedef 函数指针预编译预编译又叫预处理。预编译不是编译&#xff0c;而是编译前的处理。这个操作是在正式编译之前由系统自动完成的。#define 和 #include 一样&#xff0c;都是以“#”开头的。凡是以“#”开头的均为预处理指令。#d…

凑钱系统C语言,C语言课程设计报告书凑钱程序.doc

C语言课程设计报告书凑钱程序西北师范大学知行学院计算机与电子信息工程系课程设计报告书课程名称: C语言程序设计专 业: 电子信息工程课题名称: 凑钱程序班 级: 13电本班学 号: 201392170114姓 名&#xff1a; 秦波指导教师: 柴西林二○一三 ——二○一四 学年 第一学期基于C语…

SpringBoot使用jasypt加解密密码

在我们的服务中不可避免的需要使用到一些秘钥&#xff08;数据库、redis等&#xff09;&#xff1b;使用过SpringBoot配置文件的朋友都知道&#xff0c;资源文件中的内容通常情况下是明文显示&#xff0c;安全性就比较低一些。打开application.properties或application.yml&…

android 写字体投影,android-给字体设置投影

1&#xff0c;在代码中添加文字阴影TextView 有一个方法/*** Gives the text a shadow of the specified radius and color, the specified* distance from its normal position.** attr ref android.R.styleable#TextView_shadowColor* attr ref android.R.styleable#TextView…