http://www.himigame.com/apache-mina/831.html

：（作者新浪微博： @李华明Himi )
转载自【黑米GameDev街区】 原文链接: http://www.himigame.com/apache-mina/831.html
　　　　　　　　　　　　　　　　

Hibernate系列学习阶段到此结束了，那么紧接着进入Apache Mina的开发学习，很多童鞋在微薄和QQ中疑问Himi为什么突然脱离游戏开发了，嘿嘿，其实可能更多的童鞋已经看出来了，Himi在偏向服务器Server端开发了，Hibernate、MySQL等都是为了Server端Mina开发而做的铺垫，当前的Apache Mina才是Himi真正的目的。哈哈。Himi的技术目标是“一个人能做出一个网游～”,OK.不多说其他的了，开始Himi的Apache mina开发之旅吧。

对于Apache Mina不太连接的童鞋，请移步到如下百度百科连接进行学习了解：

http://baike.baidu.com/view/2668084.htm

首先建立一个new project（Server端），这里Himi使用IDE是 eclipse；

OK，首先我们这里先配置下环境：对于Mina的日志输出使用的是slf4j，对于slf4j在开发Hibernate的时候已经很熟悉了，不需要再介绍了。另外一方面就是加入mina的core核心jar包；

1. mina-core.jar         2. slf4j-api.jar         3.slf4j-simple.jar

然后我们首先创建两个类：

HimiObject.java

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
/**
 * @author Himi
 */
  
import java.io.Serializable;
  
public class HimiObject implements Serializable{
  
    public HimiObject(int id,String name){
        this.id=id;
        this.name=name;
    }
  
    private int id;
  
    private String name;
  
    public int getId() {
        return id;
    }
    public void setId(int id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
  
}

这个类是个消息Object，它用于server与client端的交互的数据，它需要序列化，所以我们使用Serializable接口；至于在mina框架中起到什么作用这个后续来说；

ClientMinaServerHanlder.java

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
/**
 * @author Himi
 */
  
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;
  
public class ClientMinaServerHanlder extends IoHandlerAdapter {
  
    private int count = 0;
  
    // 当一个新客户端连接后触发此方法.
    public void sessionCreated(IoSession session) {
        System.out.println("新客户端连接");
    }
  
    // 当一个客端端连结进入时 @Override
    public void sessionOpened(IoSession session) throws Exception {
        count++;
        System.out.println("第 " + count + " 个 client 登陆！address： : "
                + session.getRemoteAddress());
  
    }
  
    // 当客户端发送的消息到达时:
    @Override
    public void messageReceived(IoSession session, Object message)
            throws Exception {
        // // 我们己设定了服务器解析消息的规则是一行一行读取,这里就可转为String:
        // String s = (String) message;
        // // Write the received data back to remote peer
        // System.out.println("收到客户机发来的消息: " + s);
        // // 测试将消息回送给客户端 session.write(s+count); count++;
  
        HimiObject ho = (HimiObject) message;
        System.out.println(ho.getName());
  
        ho.setName("serverHimi");
        session.write(ho);
  
    }
  
    // 当信息已经传送给客户端后触发此方法.
    @Override
    public void messageSent(IoSession session, Object message) {
        System.out.println("信息已经传送给客户端");
  
    }
  
    // 当一个客户端关闭时
    @Override
    public void sessionClosed(IoSession session) {
        System.out.println("one Clinet Disconnect !");
    }
  
    // 当连接空闲时触发此方法.
    @Override
    public void sessionIdle(IoSession session, IdleStatus status) {
        System.out.println("连接空闲");
    }
  
    // 当接口中其他方法抛出异常未被捕获时触发此方法
    @Override
    public void exceptionCaught(IoSession session, Throwable cause) {
        System.out.println("其他方法抛出异常");
    }
  
}

本类主要是继承IoHandlerAdapter并且重写其类的一些函数，至于每个函数的作用Himi都已经在代码中加以注视；本类的作用：

此类是用以处理消息的也可说是个消息处理器，当客户端有消息传给server端的时候，或者server端传递给Client端的时候（Client端也会有个消息处理器）都会通过消息处理器进行处理。

OK，下面我们来书写server端的main函数类：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
/**
 * @author Himi
 */
  
import java.io.IOException;
import java.net.InetSocketAddress;
  
import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.serialization.ObjectSerializationCodecFactory;
import org.apache.mina.transport.socket.SocketAcceptor;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
  
public class MinaServer {
  
    /**
     * @param args
     */
  
    public static void main(String[] args) {
        //创建一个非阻塞的server端Socket ，用NIO
        SocketAcceptor acceptor = new NioSocketAcceptor();
  
        /*---------接收字符串---------*/
//      //创建一个接收数据过滤器
//      DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();
//      //设定过滤器一行行(/r/n)的读取数据
//      chain.addLast("mychin", new ProtocolCodecFilter(new TextLineCodecFactory()   ));
        /*---------接收对象---------*/
        //创建接收数据的过滤器
        DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();
        //设定这个过滤器将以对象为单位读取数据
        ProtocolCodecFilter filter= new ProtocolCodecFilter(new ObjectSerializationCodecFactory());
        chain.addLast("objectFilter",filter);
  
        //设定服务器消息处理器
        acceptor.setHandler(new ClientMinaServerHanlder());
        //服务器绑定的端口
        int bindPort = 9988;
        //绑定端口，启动服务器
        try {
            acceptor.bind(new InetSocketAddress(bindPort));
        } catch (IOException e) {
            System.out.println("Mina Server start for error!"+bindPort);
            e.printStackTrace();
        }
        System.out.println("Mina Server run done! on port:"+bindPort);
    }
}

IoService 是负责底层通讯接入，而 IoHandler 是负责业务处理的。那么 MINA 架构图中的 IoFilter 作何用途呢？答案是你想作何用途都可以。但是有一个用途却是必须的，那就是作为 IoService 和 IoHandler 之间的桥梁。IoHandler 接口中最重要的一个方法是 messageReceived，这个方法的第二个参数是一个 Object 型的消息，总所周知，Object 是所有 Java 对象的基础，那到底谁来决定这个消息到底是什么类型呢？这个取决于我们后面设定的过滤器！

对于在mina中建立一个server，步骤如下：

1. 建立一个SockerAcceptor ，除了启动server之外它还可以为我们可以生成过滤器DefaultIoFilterChainBuilder、设置消息处理器等功能；

2.设置过滤器

3. 设置消息处理器

其实很容易不是么？ 哈哈；

OK，这里多说一些：

对于消息处理器 DefaultIoFilterChainBuilder，它的作用是用于设定收发的形式，例如：

   //创建一个接收数据过滤器
DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();
//设定过滤器一行行(/r/n)的读取数据
chain.addLast("mychin", new ProtocolCodecFilter(new TextLineCodecFactory()   ));

这样设置一个过滤器作用是将来自客户端输入的信息转换成一行行的文本后传递给 IoHandler，因此我们可以在 messageReceived 中直接将 msg 对象强制转换成 String 对象。

ps.而如果我们不提供任何过滤器的话，那么在 messageReceived 方法中的第二个参数类型就是一个 byte 的缓冲区，对应的类是 org.apache.mina.common.ByteBuffer。虽然你也可以将解析客户端信息放在 IoHandler 中来做，但这并不是推荐的做法，使原来清晰的模型又模糊起来，变得 IoHandler 不只是业务处理，还得充当协议解析的任务。

mina自身带有一些常用的过滤器，例如LoggingFilter（日志记录）、BlackListFilter（黑名单过滤）、CompressionFilter（压缩）、SSLFilter（SSL加密）等。

当我们设置如下：

1
2
3
4
5
//创建接收数据的过滤器
        DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();
        //设定这个过滤器将以对象为单位读取数据
        ProtocolCodecFilter filter= new ProtocolCodecFilter(new ObjectSerializationCodecFactory());
        chain.addLast("objectFilter",filter);

这样以来我们server可以收发Object对象啦；

1
acceptor.setHandler(new ClientMinaServerHanlder());

这里是设置消息处理器，绑定在我们的ClientMinaServerHanlder类上，其实mina对于收发处理已经完全交给开发者来进行处理，所以至于在消息处理器如何编写和处理就放任不会管了；

OK，现在我们可以run一下启动server端了；

当然我们现在也可以来测试了，当前我们还没有书写Client端的代码，所以我们使用terminal终端进行测试，OK，打开你的terminal

然后输入  telnet localhost 9988

观察服务器打印：

OK，没有任何问题；但是这时候大家不要在终端书写内容给server，因为我们server的消息处理器中的接受Client的函数中做了如下处理：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
// 当客户端发送的消息到达时:
    @Override
    public void messageReceived(IoSession session, Object message)
            throws Exception {
        // // 我们己设定了服务器解析消息的规则是一行一行读取,这里就可转为String:
        // String s = (String) message;
        // // Write the received data back to remote peer
        // System.out.println("收到客户机发来的消息: " + s);
        // // 测试将消息回送给客户端 session.write(s+count); count++;
  
        HimiObject ho = (HimiObject) message;
        System.out.println(ho.getName());
  
        ho.setName("serverHimi");
        session.write(ho);
  
    }

Himi这里server处理client端发来的数据处理函数(如上代码)中，当Client发送数据过来的时候，将消息message强制转换成了一个HimiObject对象，然后改个name重写发给Client端，但是由于Client端是使用终端模拟登陆根本无法接受这个对象，所以会出异常；

但是到这里大家应该懂得，HimiObject类的作用了；哈哈

下面我们来书写Client客户端，对于建立一个Client端，其实步骤雷同，步骤如下：

1 . 建立一个NioSocketConnector对象；

2. 设定过滤器

3. 设定消息处理器

代码如下：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
/**
 * @author Himi
 */
import java.net.InetSocketAddress;
  
import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
import org.apache.mina.core.future.ConnectFuture;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.serialization.ObjectSerializationCodecFactory;
import org.apache.mina.transport.socket.nio.NioSocketConnector;
  
public class MainClient {
    public static void main(String[] args) {
        // 创建一个tcp/ip 连接
        NioSocketConnector connector = new NioSocketConnector();
  
        /*---------接收字符串---------*/
        // //创建接收数据的过滤器
        // DefaultIoFilterChainBuilder chain = connector.getFilterChain();
        // // 设定这个过滤器将一行一行(/r/n)的读取数据
        // chain.addLast("myChin", new ProtocolCodecFilter(
        // new TextLineCodecFactory()));
        /*---------接收对象---------*/
        // 创建接收数据的过滤器
        DefaultIoFilterChainBuilder chain = connector.getFilterChain();
        // 设定这个过滤器将以对象为单位读取数据
        ProtocolCodecFilter filter = new ProtocolCodecFilter(
                new ObjectSerializationCodecFactory());
        // 设定服务器端的消息处理器:一个SamplMinaServerHandler对象,
        chain.addLast("objectFilter",filter);
  
        // 设定服务器端的消息处理器:一个 SamplMinaServerHandler 对象,
        connector.setHandler(new ClientMinaServerHanlder());
        // Set connect timeout.
        connector.setConnectTimeoutCheckInterval(30);
        // 连结到服务器:
        ConnectFuture cf = connector.connect(new InetSocketAddress("localhost",
                9988));
        // Wait for the connection attempt to be finished.
        cf.awaitUninterruptibly();
        cf.getSession().getCloseFuture().awaitUninterruptibly();
        connector.dispose();
  
    }
}

不多说了，很eazy：那么我们继续看Clent端的消息处理器以及HimiObject：

ClentMinaServerHanlder：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
/**
 * @author Himi
 */
  
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;
  
public class ClientMinaServerHanlder extends IoHandlerAdapter {
    // 当一个客端端连结到服务器后
    @Override
    public void sessionOpened(IoSession session) throws Exception {
//      session.write("我来啦........");
        HimiObject ho = new HimiObject(1,"Himi");
        session.write(ho);
    }
  
    // 当一个客户端关闭时
    @Override
    public void sessionClosed(IoSession session) {
        System.out.println("I'm Client &&  I closed!");
    }
  
    // 当服务器端发送的消息到达时:
    @Override
    public void messageReceived(IoSession session, Object message)
            throws Exception {
//      // 我们己设定了服务器解析消息的规则是一行一行读取,这里就可转为 String:
//      String s = (String) message;
//      // Write the received data back to remote peer
//      System.out.println("服务器发来的收到消息: " + s);
//      // 测试将消息回送给客户端 session.write(s);
  
        HimiObject ho = (HimiObject) message;
        System.out.println(ho.getName());
  
    }
}

Client的HimiObject与服务器Server的HimiObejct类一模一样！

可能有童鞋不理解为什么server端与client的HimiObject一模一样，这里Himi说下，通过Client端的消息处理器可以看出，当我们Client端连接到服务器后，首先会写给Server端一个HimiObject对象！那么服务器之前说过了，接受到Client端的消息后首先将消息强制转换成HimiObject对象然后处理；

既然Client端发的是Object，那么当然我们的服务器也要有对应的此Object对象才可以，否则如何获取这个Object?  大家应该很容易理解；

OK，不多说直接运行Client端，观察结果：

OK，结果正常。

    Client与Server消息逻辑如下：

1. Client->传递HimiObject给Server

2. Server端接受message强制转换HimiObject，并且设置其name为serverHimi，然后再传递给Client

3. 客户端接受message强制转换HimiObject，然后获取此类的name打印出来！

搭建Apache Mina框架并实现Server与Client端的简单消息传递相关推荐

  1. 【Apache Mina2.0开发之一】搭建Apache Mina框架并实现Server与Client端的简单消息传递！

    Hibernate系列学习阶段到此结束了,那么紧接着进入Apache Mina的开发学习,很多童鞋在微薄和QQ中疑问Himi为什么突然脱离游戏开发了,嘿嘿,其实可能更多的童鞋已经看出来了,Himi在偏 ...

  2. 【Apache Mina2.0开发之一】搭建Apache Mina框架并实现Server与Client端消息传递

    Hibernate系列学习阶段到此结束了,那么紧接着进入Apache Mina的开发学习,很多童鞋在微薄和QQ中疑问Himi为什么突然脱离游戏开发了,嘿嘿,其实可能更多的童鞋已经看出来了,Himi在偏 ...

  3. Mina框架并实现Server与Client端的简单消息传递！

    Hibernate系列学习阶段到此结束了,那么紧接着进入Apache Mina的开发学习,很多童鞋在微薄和QQ中疑问Himi为什么突然脱离游戏开发了,嘿嘿,其实可能更多的童鞋已经看出来了,Himi在偏 ...

  4. Apache MINA框架快速入门

    一.为什么要用MINA框架 Apache Mina是一个网络通信应用框架,是基于TCP/IP.UDP/IP协议栈的通信框架,Mina 的异步IO 默认使用的是JAVA NIO 作为底层支持,具有高性能 ...

  5. Apache MiNa 实现多人聊天室

    Apache MiNa 实现多人聊天室 开发环境: System:Windows JavaSDK:1.6 IDE:eclipse.MyEclipse 6.6 开发依赖库: Jdk1.4+.mina-c ...

  6. java mina框架实例_Apache Mina框架实践

    1.为什么要用Apache Mina框架 ApacheMina Server 是一个网络通信应用框架,Mina 可以帮助我们快速开发高性能.高扩展性的网络通信应用,Mina 提供了事件驱动.异步(Mi ...

  7. mysql数据实时同步：Canal安装部署、kafka安装、zk安装、mysql安装、Canal Server+Canal Client HA，Canal+mysql+Kafka，相关验证（学习笔记）

    目录 Canal安装部署 1.1. 服务器准备 1.2. 设置主机名并配置hosts 1.3. 免密设置 1.4. 设置ntp时间 1.5. 关闭防火墙 1.6. 关闭selinux 1.7. 安装J ...

  8. Apache NIO 框架 Mina 使用中出现 too many open files 有关...

    2019独角兽企业重金招聘Python工程师标准>>> 时间: 2013-04-08 17:01:26.0 分类:  软件工程/管理 /  开发方法 /  文章 Apache NIO ...

  9. Apache MINA简介

    简介: Apache MINA(Multipurpose Infrastructure for Network Applications) 是一个网络应用框架,有助于用户非常方便地开发高性能.高伸缩性 ...

最新文章

  1. java编写数字金字塔_用JAVA写数字金字塔
  2. Scala与Java交互
  3. 产品助理要练哪些姿势，才能看上去舞步优雅？
  4. 丑憨批的爬虫笔记1（导学+requests））
  5. Solr分组聚合查询之Group
  6. Request_原理
  7. kaggle api下载自定义数据到colab上面
  8. PHP精美列表商城发卡网站源码响应式
  9. 七岁OpenStack热情不减 如此执着为哪般？
  10. 快速搭建开发环境（Vs Code）
  11. 写代码质量改善java计划151建议——导航开始
  12. Linux操作系统教学进度计划表
  13. DSP开发，使用CCS软件建立工程以及烧录
  14. 1、曾经风光无限的jsp，为什么现在很少有人使用了？
  15. 人工智能如何改变人类生活
  16. python django 商品进销存管理系统（毕设、课设、学习）
  17. R语言︱机器学习模型评估方案（以随机森林算法为例）
  18. tmp ubuntu 自动删除吗_如何清理/tmp？
  19. AtCoder题解 —— AtCoder Regular Contest 108 —— A - Sum and Product
  20. python风控模型举例_一文搞定风控模型6大核心指标（附代码）

热门文章

  1. iOS之深入解析Runtime的Method-Swizzling方法交换的妙用和底层原理
  2. iOS经典面试题之分析self class与super class的区别和底层原理
  3. OpenGL ES之GLSL实现索引绘制及渲染纹理和颜色混合
  4. 76. 最小覆盖子串
  5. 2016\Province_C_C++_C\1 报纸页数
  6. 大端和小端的判断及转换
  7. 【Qt】Qt工程管理
  8. 【ARM】Tiny4412裸板编程之LED(二)
  9. 【嵌入式】C语言高级编程-地址对齐(07)
  10. 【ARM】ARM流水线技术