java mina框架实例_MINA框架简介和一个简单的例子

基于MINA框架快速开发网络应用程序1.MINA框架简介MINA(MultipurposeInfrastructureforNetworkApplications)是用于开发高性能和高可用性的网络应用程序的基础框架。通过使用MINA框架可以可以省下处理底层I/O和线程并发等复杂工作,开发人员能够把更多的精力投入到业务设计和开发当中。MINA框架的应用比较广泛,应用的开源项目有Apache…

大家好,又见面了,我是你们的朋友全栈君。

基于MINA框架快速开发网络应用程序

1.MINA框架简介

MINA(Multipurpose Infrastructure for Network Applications)是用于开发高性能和高可用性的网络应用程序的基础框架。通过使用MINA框架可以可以省下处理底层I/O和线程并发等复杂工作,开发人员能够把更多的精力投入到业务设计和开发当中。MINA框架的应用比较广泛,应用的开源项目有Apache Directory、AsyncWeb、Apache Qpid、QuickFIX/J、Openfire、SubEthaSTMP、red5等。MINA框架当前稳定版本是1.1.6,最新的2.0版本目前已经发布了M1版本。

MINA框架的特点有:基于java NIO类库开发;采用非阻塞方式的异步传输;事件驱动;支持批量数据传输;支持TCP、UDP协议;控制反转的设计模式(支持Spring);采用优雅的松耦合架构;可灵活的加载过滤器机制;单元测试更容易实现;可自定义线程的数量,以提高运行于多处理器上的性能;采用回调的方式完成调用,线程的使用更容易。

2.MINA框架的常用类

类NioSocketAcceptor用于创建服务端监听;

类NioSocketConnector用于创建客户端连接;

类IoSession用来保存会话属性和发送消息;

类IoHandlerAdapter用于定义业务逻辑,常用的方法有:

方法 定义

sessionCreated() 当会话创建时被触发

sessionOpened() 当会话开始时被触发

sessionClosed() 当会话关闭时被触发

sessionIdle() 当会话空闲时被触发

exceptionCaught() 当接口中其他方法抛出异常未被捕获时触发此方法

messageRecieved() 当接收到消息后被触发

messageSent() 当发送消息后被触发

3.服务端应用开发示例

下面将以MINA2.0M1版本为基础,通过一个范例来演示一下如何使用MINA框架进行开发。开发环境为jdk6.0,开发工具NetBeans6.0,所需jar包slf4j-api.jar、slf4j-jdk14.jar、MINA-core-2.0.0-M1.jar。

首先定义一个业务逻辑处理器TimeServerHandler,继承自IoHandlerAdapter,实现的功能有:当客户端创建会话时会显示客户端设备的IP和端口;当客户端输入quit时结束会话;客户端输入其它内容时则向客户端发送当前时间。代码如下:

public class TimeServerHandler extends IoHandlerAdapter {

@Override

public void sessionCreated(IoSession session) {

// 显示客户端的ip和端口

System.out.println(session.getRemoteAddress().toString());

}

@Override

public void messageReceived(IoSession session, Object message)

throws Exception {

String str = message.toString();

System.out.println(“message=”+str);

if (str.trim().equalsIgnoreCase(“quit”)) {

session.close();// 结束会话

return;

}

Date date = new Date();

session.write(date.toString());// 返回当前时间的字符串

System.out.println(“Message written…”);

}

}

再定义一个类MinaTimeServer用来启动服务端:

public class MinaTimeServer {

private static final int PORT = 9123;// 定义监听端口

public static void main(String[] args) throws IOException {

IoAcceptor acceptor = new NioSocketAcceptor();

acceptor.getFilterChain().addLast(“logger”, new LoggingFilter());

acceptor.getFilterChain().addLast(“codec”,new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName(“UTF-8”))));// 指定编码过滤器

acceptor.setHandler(new TimeServerHandler());// 指定业务逻辑处理器

acceptor.setDefaultLocalAddress(new InetSocketAddress(PORT));// 设置端口号

acceptor.bind();// 启动监听

}

}

4.测试

首先运行MinaTimeServer,启动服务端,接着在命令行运行“telnet 127.0.0.1 9123”,来登录,这时会看到服务端输出如下:

2008-2-21 16:15:29 org.apache.MINA.filter.logging.LogLevel$4 log

/10.64.2.137:4140 IP和端口号

信息: CREATED

2008-2-21 16:15:29 org.apache.MINA.filter.logging.LogLevel$4 log

信息: OPENED 在客户端输入回车,在客户端可以看到服务端返回当前的时间:

Thu Feb 21 16:20:14 CST 2008

服务端输出:

2008-2-21 16:20:14 org.apache.MINA.filter.logging.LogLevel$4 log

信息: RECEIVED: HeapBuffer[pos=0 lim=2 cap=2048: 0D 0A] 接收收到回车符

Message written…

2008-2-21 16:20:14 org.apache.MINA.filter.logging.LogLevel$4 log

信息: SENT: HeapBuffer[pos=0 lim=29 cap=30: 54 68 75 20 46 65 62 20 32 31 20 31 36 3A 32 30…]

2008-2-21 16:20:14 org.apache.MINA.filter.logging.LogLevel$4 log

信息: SENT: HeapBuffer[pos=0 lim=0 cap=0: empty] 5.客户端开发示例

首先定义类TimeClientHandler来处理消息接收事件:

class TimeClientHandler extends IoHandlerAdapter {

public TimeClientHandler() {

}

@Override

public void messageReceived(IoSession session, Object message)

throws Exception {

System.out.println(“message=” + message);// 显示接收到的消息

}

}

接着定义MinaTimeClient类用于连接服务端,并向服务端发送消息:

public class MinaTimeClient {

public static void main(String[] args) {

// 创建客户端连接器.

NioSocketConnector connector = new NioSocketConnector();

connector.getFilterChain().addLast(“logger”, new LoggingFilter());

connector.getFilterChain().addLast(“codec”,new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName(“UTF-8”)))); // 设置编码过滤器

connector.setConnectTimeout(30);

connector.setHandler(new TimeClientHandler());// 设置事件处理器

ConnectFuture cf = connector.connect(new InetSocketAddress(“127.0.0.1”,9123));// 建立连接

cf.awaitUninterruptibly();// 等待连接创建完成

cf.getSession().write(“hello”);// 发送消息

cf.getSession().write(“quit”);// 发送消息

cf.getSession().getCloseFuture().awaitUninterruptibly();// 等待连接断开

connector.dispose();

}

}

6.总结

通过上述示例可以了解到:使用MINA框架来开发的网络应用程序代码结构更清晰;MINA框架完成了底层的线程管理;MINA内置的编码器可以满足大多数用户的需求,省去了开发人员消息编码解码的工作。具称使用MINA开发服务器程序的性能已经逼近使用 C/C++ 语言开发的网络服务。因此,建议在网络应用程序开发过程中尝试使用MINA框架来提高我们的开发效率和应用程序的执行效率。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/127309.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 2016年总结-JAVA程序员

    2016年总结-JAVA程序员

    2020年11月12日
  • 优先级队列(Priority Queue)「建议收藏」

    优先级队列(Priority Queue)「建议收藏」优先级队列(PriorityQueue)注:队列是一种特征为FIFO的数据结构,每次从队列中取出的是最早加入队列中的元素。但是,许多应用需要另一种队列,每次从队列中取出的应是具有最高优先权的元素,这种队列就是优先级队列(PriorityQueue),也称为优先权队列。1.优先级队列的概念1.1优先级队列的定义优先级队列是不同于先进先出队列的另一种队列。每次从队列中取出的是具有最高优先权的元素。

  • Mac(OSX)下媲美XShell的神器Termius「建议收藏」

    Mac(OSX)下媲美XShell的神器Termius「建议收藏」文章目录简介特点软件环境配置配置项配置密钥配置说明配置主机配置项简介XShell的大名不用多说,称它为Windows平台最好用的远程终端不为过吧。唯一不足的地方就是它只有Windows版本。所以今天跟大家介绍一款全平台的远程终端——Termius。Termius不仅涵盖了Windows、Linux、OSX,还变态得支持Android和iOS(以后在地铁、公交上都可以随时拿出手机来排查线上问题啦…………

  • 一致性hash算法 java实现_一致性hash算法实现

    一致性hash算法 java实现_一致性hash算法实现一致性hash算法是分布式中一个常用且好用的分片算法、或者数据库分库分表算法。现在的互联网服务架构中,为避免单点故障、提升处理效率、横向扩展等原因,分布式系统已经成为了居家旅行必备的部署模式,所以也产出了几种数据分片的方法:1.取模,2.划段,3.一致性hash前两种有很大的一个问题就是需要固定的节点数,即节点数不能变,不能某一个节点挂了或者实时增加一个节点,变了分片规则就需要改变,需要迁…

  • EL表达式判断Map是否为空和map的取值[通俗易懂]

    EL表达式判断Map是否为空和map的取值[通俗易懂]判断Map是否为空1.在JSP页面中引入sun的核心标签库   @ taglib uri=”http://java.sun.com/jstl/core_rt” prefix=”c” %>2.在JSP页面中引入sun的函数标签库   @ taglib uri=”http://java.sun.com/jsp/jstl/functions”  prefix=”

  • 如何查看端口号被占用情况_怎么查端口被哪个程序占用了

    如何查看端口号被占用情况_怎么查端口被哪个程序占用了最近在工作上Ranorex自动化测试工具老是连不上服务器,经检查发现服务器的端口号(7266)被其他测试工具占用。可以在命令窗口上输入netstat-ano查看本机的所有端口号以及对应的进程占用程序(PID)。打开任务管理器,找到与端口对应的PID,将其关闭,最后重启。…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号