当前位置：首页 > article >正文

Apache MINA 使用简单Demo案例

article 2025/1/17 2:00:05

Apache MINA (Multipurpose Infrastructure for Network Applications) 是一个网络应用程序框架，它帮助用户快速开发高性能和高扩展性的网络应用程序。MINA 提供了对TCP/IP, UDP/IP协议的支持，并且可以很容易地被扩展以支持其他的网络协议。
在这里插入图片描述

下面提供一个简单的例子来说明如何使用 Apache MINA 创建客户端和服务端程序。请注意，由于这是一个简化的示例，因此不会包含所有的异常处理和最佳实践代码。在实际的项目中，需要根据需求添加更多的逻辑。

首先，确保已经在项目中包含了 Apache MINA 的依赖项。如果使用的是 Maven 构建工具，可以在 pom.xml 文件中添加如下依赖：

<dependency>
    <groupId>org.apache.mina</groupId>
    <artifactId>mina-core</artifactId>
    <version>2.0.27</version> <!-- 请检查最新版本 -->
</dependency>

服务端编码

创建一个简单的 MINA 服务端需要实现 IoHandler 接口，这是所有 I/O 事件处理器的基础接口。

import org.apache.mina.core.service.IoAcceptor;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;

import java.io.IOException;
import java.net.InetSocketAddress;

public class SimpleServer {

    public static void main(String[] args) throws IOException {
        // 创建一个新的 acceptor 实例
        IoAcceptor acceptor = new NioSocketAcceptor();

        // 设置过滤器，用于编解码消息
        acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(new TextLineCodecFactory()));

        // 设置服务端处理器
        acceptor.setHandler(new SimpleIoHandler());

        // 绑定到端口
        acceptor.bind(new InetSocketAddress(8080));

        System.out.println("服务器已启动，监听端口：8080");
    }
}

// 定义一个简单的处理器类，继承自 IoHandlerAdapter
class SimpleIoHandler extends org.apache.mina.core.service.IoHandlerAdapter {

    @Override
    public void messageReceived(org.apache.mina.core.session.IoSession session, Object message) throws Exception {
        String msg = message.toString();
        System.out.println("收到消息: " + msg);
        session.write("Echo: " + msg); // 发送回执给客户端
    }

    @Override
    public void exceptionCaught(IoSession session, Throwable cause) throws Exception {
        cause.printStackTrace();
        session.closeNow();
    }
}

客户端编码

客户端部分相对简单，只需要连接到指定的服务端地址并发送消息。

import org.apache.mina.core.future.ConnectFuture;
import org.apache.mina.core.service.IoConnector;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.transport.socket.nio.NioSocketConnector;

import java.net.InetSocketAddress;

public class SimpleClient {

    public static void main(String[] args) throws InterruptedException {
        // 创建一个新的 connector 实例
        IoConnector connector = new NioSocketConnector();

        // 设置过滤器，用于编解码消息
        connector.getFilterChain().addLast("codec", new ProtocolCodecFilter(new TextLineCodecFactory()));

        // 连接到服务端
        ConnectFuture connectFuture = connector.connect(new InetSocketAddress("localhost", 8080));
        connectFuture.awaitUninterruptibly(); // 等待连接完成

        // 获取会话对象
        IoSession session = connectFuture.getSession();

        // 发送消息给服务端
        session.write("Hello Server");

        // 关闭连接（为了演示目的，这里直接关闭；实际应用中应有更复杂的逻辑）
        Thread.sleep(5000); // 模拟等待响应
        session.close(true);
    }
}