Mina2 与 Mina1变化

Posted 2020-09-13 学无止境

一、包与类名。

1、所有类和方法严格使用驼峰法命名。例：SSLFilter 更名为 SslFilter。NIO传输类在命名时增加 Nio 前缀。因为NIO 并不是 socket/datagram 传输的实现，NIO 的所有传输类前缀增加 Nio 。之前Java代码：

 

[java] view plain copy

 

 

1. SocketAcceptor acceptor = new SocketAcceptor();  

修改之后的代码：

 

 

[java] view plain copy

 

 

1. SocketAcceptor acceptor = new NiosocketAcceptor();  

 2、Filter 类被重新整理进多重子包内。例如，StreamWriteFilter 被移动到 org.apache.mina.filter.stream ，*.support 的所有包被移动到其父包中。

 

二、Buffers。

因为MINA ByteBuffer 与JDK中NIO ByteBuffer 同名，ByteBuffer 被重命名为 IoBuffer。不仅使类名简化，也使类名称更加明确。放弃 Buffer 池，默认使用IoBuffer.allocate(int) 来分配 heap buffer。acquire() 与 release() 两个方法将不再容易发生错误，可以调用 free()方法。在大多数JVM中，框架内置的IoBuffer 性能更加强劲稳定。

Direct buffer 池是Mina 早期特性之一，现在主流JVM的 direct buffers 的表现比heap buffers 差，此外 direct buffer memory 的最大值没有正确设定时，不可预期的 outofmemoryError 也经常出现，所以新的版本 buffer类型由 direct 改为 heap 。heap buffers 不需要池化，PooledBufferAllocator 也被除掉了，相应的ByteBuffer.acquire()  release()也被除掉了。 但是如果使用的速度太快，分配 heap buffers也会成为瓶颈，因为分配字节数据要将所有的元素都置为0，这个操作消耗内存带宽。 CachedBufferAllocator 是针对这种情况使用的，但是大多数情况，还是使用默认的 SimpleBufferAllocator 。

三、启动与配置。

1、IoService 配置简化，1.x版本中邮多种方式配置IoService 和它的子接口 IoAcceptor 和 IoConnector 两种方法：在调用bind() 或 connect() 时，具体指定一个 ioServiceConfig

 

[java] view plain copy

 

 

1.         acceptor = new SocketAcceptor();  
2.         SocketAcceptorConfig cfg = new SocketAcceptorConfig();  
3.         cfg.getFilterChain().addLast( "codec", new ProtocolCodecFilter(MinaUAEncoder.class,MinaUADecoder.class));  
4.         acceptor.bind( new InetSocketAddress(address, port), new DirectClientSessionHandler(), cfg);  

或者 IoService.defaultConfig 属性，此时不需要指定 IoServiceConfig

[java] view plain copy

 

 

1. acceptor = new SocketAcceptor();  
2.         acceptor.getDefaultConfig().setReuseAddress(true);  
3.         acceptor.bind(new InetSocketAddress("127.0.0.1", 8888), myHandler);  

Mina2 简化了网络应用程序的启动，

 

[java] view plain copy

 

 

1. //Create acceptor  
2.         IoAcceptor acceptor = new NioSocketAcceptor();  
3.         acceptor.getFilterChain().addLast("logger", new LoggingFilter());  
4.         acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8"))));  
5.         acceptor.setHandler(new HelloWorldServerHandler());  
6.         //configurate the buffer size and the iddle time  
7.         acceptor.getSessionConfig().setReadBufferSize(2048);  
8.         acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);  
9.         try {  
10.             acceptor.bind(new InetSocketAddress(PORT));  
11.         } catch (IOException e) {  
12.             e.printStackTrace();  
13.         }  

四、线程。

 

ThreadModel 被移除了，最初引入ThreadModel 是为了简化 ioService 预定义的线程模式，配置线程模式却变得非常简单以至于不能引入新的组件，与其易用性相比，线程模式带来了更多的混乱。

ExecutorFilter使用一个特定的Executor实现来维系事件顺序。
在1.x中，可以使用任意的Executor实现来来维系事件顺序，但2.x提供了两个新的
ThreadPoolExecutor实现，OrderedThreadPoolExecutor和UnorderedThreadPoolExecutor，ExecutorFilter维系事件顺序，当以下两种情况：当使用默认构造方法时，ExecutorFilter创建一个OrderedThreadPoolExecutor，或者明确指明使用OrderedThreadPoolExecutor时
OrderedThreadPoolExecutor和UnorderedThreadPoolExecutor内部使用了一些架构来防止发生OutOfMemoryError，所以你应该尽量使用这两个类而不是其他Executor的实现。

五、协议编解码。

DemuxingProtocolCodecFactory被重写了。
新增了DemuxingProtocolEncoder和DemuxingProtocolDecoder两个类，DemuxingProtocolCodecFactory只是这两个类的外壳。register()方法被重命名为addMessageEncoder()和addMessageDecoder()，这个变化使混合使用多个encoders和decoders变得更加自由。
MessageEncoder接口也发生了改变，MessageEncoder.getMessageTypes()被移除了，当你调用addMessageEncoder()，你只需要指明信息的类型，encoder就可以进行正确的编码了。

六、集成。

JMX集成被重新设计。

spring 集成被简化。

七、其他。

TransportType 更名为 TransportMetadata 

TransportType 改名是因为它的角色是元数据而不仅仅是一种枚举。

IoSessionLogger 被重新设计。

IoSessionLogger 实现了 SLF4Logger接口，所以可以像声明简单SLF4Logger实例一样声明它，这个变化使你不必向其他不必要的部分暴露 IoSessionLogger 对象。在使用 MDC 时，请考虑使用简单的 MdclnjectionFilter