美文网首页
Spring集成 Mina

Spring集成 Mina

作者: 仩渧哋寵 | 来源:发表于2020-09-24 11:17 被阅读0次

参考:http://mina.apache.org/mina-project/userguide/ch17-spring-integration/ch17-spring-integration.html
本文演示了如何将MINA应用程序与Spring集成。我在博客上写了这篇文章,尽管把它放在这里,但实际上是这些信息所属的地方。可以在将Apache MINA与Spring集成中找到原始副本。

应用结构

我们将采用具有以下构造的标准MINA应用程序

  • 一个处理程序
  • 两个过滤器-日志记录过滤器和ProtocolCodec过滤器
  • NioDatagram套接字

初始化码

让我们先来看代码。为了简单起见,我们省略了粘合代码。

public void initialize() throws IOException {

    // Create an Acceptor
    NioDatagramAcceptor acceptor = new NioDatagramAcceptor();

    // Add Handler
    acceptor.setHandler(new ServerHandler());

    acceptor.getFilterChain().addLast("logging",
                new LoggingFilter());
    acceptor.getFilterChain().addLast("codec",
                new ProtocolCodecFilter(new SNMPCodecFactory()));

    // Create Session Configuration
    DatagramSessionConfig dcfg = acceptor.getSessionConfig();
        dcfg.setReuseAddress(true);
        logger.debug("Starting Server......");
        // Bind and be ready to listen
        acceptor.bind(new InetSocketAddress(DEFAULT_PORT));
        logger.debug("Server listening on "+DEFAULT_PORT);
}

整合过程

要与Spring集成,我们需要执行以下操作:

  • 设置IO处理程序
  • 创建过滤器并添加到链中
  • 创建套接字并设置套接字参数

注意:最新的MINA版本没有特定于Spring的软件包,如其早期版本。该程序包现在称为Integration Beans,以使该实现适用于所有DI框架。

让我们看一下Spring xml文件。请注意,我已经从xml中删除了通用部分,并且只放置了实现该实现所需的特定内容。该示例源自MINA版本随附的聊天示例。请参考聊天附带的xml示例。

现在让我们把东西拉在一起

让我们在spring上下文文件中设置IO处理程序

    <!-- The IoHandler implementation -->
    <bean id="trapHandler" class="com.ashishpaliwal.udp.mina.server.ServerHandler">

让我们创建过滤器链

    <bean id="snmpCodecFilter" class="org.apache.mina.filter.codec.ProtocolCodecFilter">
      <constructor-arg>
        <bean class="com.ashishpaliwal.udp.mina.snmp.SNMPCodecFactory" />
      </constructor-arg>
    </bean>

    <bean id="loggingFilter" class="org.apache.mina.filter.logging.LoggingFilter" />

    <!-- The filter chain. -->
    <bean id="filterChainBuilder" class="org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder">
      <property name="filters">
        <map>
          <entry key="loggingFilter" value-ref="loggingFilter"/>
          <entry key="codecFilter" value-ref="snmpCodecFilter"/>
        </map>
      </property>
    </bean>

在这里,我们创建IoFilter的实例。看到对于ProtocolCodec工厂,我们使用了构造函数注入。日志过滤器的创建很简单。定义了要使用的过滤器的bean之后,我们现在创建要用于实现的过滤器链。我们定义一个ID为“ FilterChainBuidler”的bean,并向其中添加定义的过滤器。我们已经准备就绪,我们只需要创建Socket并调用bind

让我们完成创建套接字和完成链的最后一部分

    <bean class="org.springframework.beans.factory.config.CustomEditorConfigurer">
        <property name="customEditors">
          <map>
            <entry key="java.net.SocketAddress">
              <bean class="org.apache.mina.integration.beans.InetSocketAddressEditor" />
            </entry>
          </map>
        </property>
    </bean>

    <!-- The IoAcceptor which binds to port 161 -->
    <bean id="ioAcceptor" class="org.apache.mina.transport.socket.nio.NioDatagramAcceptor" init-method="bind" destroy-method="unbind">
      <property name="defaultLocalAddress" value=":161" />
      <property name="handler" ref="trapHandler" />
      <property name="filterChainBuilder" ref="filterChainBuilder" />
    </bean>    

现在,我们创建ioAcceptor,设置IO处理程序和Filter Chain。现在,我们必须编写一个函数以使用Spring读取此文件并启动我们的应用程序。这是代码

    public void initializeViaSpring() throws Exception {
        new ClassPathXmlApplicationContext("trapReceiverContext.xml");
    }

相关文章

网友评论

      本文标题:Spring集成 Mina

      本文链接:https://www.haomeiwen.com/subject/wrezyktx.html