`
jean7155
  • 浏览: 63102 次
  • 性别: Icon_minigender_2
  • 来自: 上海
社区版块
存档分类
最新评论

Apache Mina的最简单例子

阅读更多
apache mina的下载地址:http://mina.apache.org/mina-project/downloads.html

1. 首先,要在classpath中配置以下的jar文件:
mina-core-2.0.7.jar
mina-example-2.0.7.jar
slf4j-api-1.6.6.jar
slf4j-log4j12-1.6.6.jar
log4j-1.2.17.jar

2. 基本要素:
1) IoFilters
2) codec: ProtocolCodecFactory
3) business logic: IoHandler

2. 基于TCP的服务例子:
1) 服务Server端
定义Server服务的代码
public class DemoTimeServer {

	/**
	 * @param args
	 * @throws IOException 
	 */
	public static void main(String[] args) throws IOException {
		final int PORT = 9123;
		
		// 定义一个接收客户端请求的Acceptor
		IoAcceptor acceptor = new NioSocketAcceptor();
		
		// 1. 定义Logging的IoFilters
		acceptor.getFilterChain().addLast("logger", new LoggingFilter());
		// 2. 定义解析器的IoFilters,将客户端传入的流或协议数据按照定义的解析器进行解析
		acceptor.getFilterChain().addLast("codec",new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("utf-8"))));
		
		// 3. 设置业务处理机制,定义接收连接后的信息接收,信息回复的处理方法
		acceptor.setHandler(new DemoTimeServerHandler());
		//NioSocketAcceptor配置		acceptor.getSessionConfig().setReadBufferSize(2048);
		acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);
		
		//定义完成,绑定端口
		acceptor.bind(new InetSocketAddress(PORT));
	}

}


定义处理Server端业务逻辑的代码
public class DemoTimeServerHandler implements IoHandler {

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

	}

        // 接收到来自客户端的消息后,对消息进行处理,并将处理后的消息回复客户端
	@Override
	public void messageReceived(IoSession session, Object message) throws Exception {
		String str = message.toString();
		if(str.trim().equalsIgnoreCase("quit")){
			session.close(true);
			return;
		}
		Date date = new Date();
		str = str + ", receiving date(" + date.toString() + ")";
		session.write(str);
		System.out.println("message write..." + str + ", writing date(" + date.toString());

	}

	@Override
	public void messageSent(IoSession session, Object message) throws Exception {
		String str = message.toString();
		System.out.println("message sent..." + str);

	}

	@Override
	public void sessionClosed(IoSession session) throws Exception {
		System.out.println("CLOSED " + session.getReadMessages());

	}

	@Override
	public void sessionCreated(IoSession session) throws Exception {
		System.out.println("CREATED " + session.getCreationTime());

	}

	@Override
	public void sessionIdle(IoSession session, IdleStatus status) throws Exception {
		System.out.println("IDEL " + session.getIdleCount(status));

	}

	@Override
	public void sessionOpened(IoSession arg0) throws Exception {
		// TODO Auto-generated method stub

	}

}


2) 客户Client端
定义客户端链接服务端的代码
public class DemoTimeClient {

	/**
	 * @param args
	 * @throws InterruptedException 
	 */
	public static void main(String[] args) throws InterruptedException {

	 // 创建一个客户端连接
     NioSocketConnector connector = new NioSocketConnector();
        
         //1. 定义Logging的 IoFilters
         connector.getFilterChain().addLast("logger", new LoggingFilter());
   	 // 2.定义解析器的IoFilters,将发出的信息按照定义的解析器进行解析
         connector.getFilterChain().addLast("codec",new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("utf-8"))));

   	 // 3.设置业务处理机制,定义链接后的信息发送,接收回复信息的处理方法
     DemoTimeClientHandler handler = new DemoTimeClientHandler("i am jeanjeanfang, hello dear!");
     connector.setHandler(handler);
       
     // 4. 链接服务端
	 IoSession session;
	 for (;;) {
	    
	    	try {
	        
	    		ConnectFuture future = connector.connect(new InetSocketAddress("localhost", 9123));
	            future.awaitUninterruptibly();
	            session = future.getSession();
	            break;
	        } catch (RuntimeIoException e) {
	            System.err.println("Failed to connect.");
	            e.printStackTrace();
	            Thread.sleep(5000);
	        }
	 }

	    // wait until the summation is done
	    session.getCloseFuture().awaitUninterruptibly();
	        
	    connector.dispose();

	}

}



定义客户端和服务端链接后的业务代码
public class DemoTimeClientHandler extends IoHandlerAdapter {
	
	private String message;
	
	public DemoTimeClientHandler(String message){
		this.message = message;
	}
	
        // 接收服务端的回复信息
	@Override
	public void messageReceived(IoSession session, Object message)
			throws Exception {
		System.out.println("message received..."  + message.toString());
		session.close(true);
	}
        // 打开连接后,将数据发送到服务端
	@Override
	public void sessionOpened(IoSession session) throws Exception {
		System.out.println("session opened");
		session.write(message);
	}

	@Override
	public void exceptionCaught(IoSession session, Throwable cause)
			throws Exception {
		System.out.println("exception caught and close session");
		session.close(true);
	}

}



关于IoHandler(摘录自其它资料)
IoHandlerAdpater:
它只是提供了IoHandler中定义的方法体,没有任何的逻辑处理,你可以根据你自己的需求重写该类中的相关方法。这个类在实际的开发中使用的是较多的。我们上面写的例子都是继承于这个类来实现的。

SingleSessionIoHandlerDelegate:
这是一个服务器和客户端只有一个会话时使用的类,在该类的方法中没有提供session的参数,该类在实际的开发中使用的较少,如果需要对该类进行更深入的了解,请参考Mina 1.1.7的API文档。

在Mina提供的IoHandler的具体实现中,大部分的实现类都是继承与IoHandlerApater,IoHandlerAdpater在Mina 1.1.7中的子类有三个:

ChainedIoHandler:这个类主要是用于处理IoHandler的messageReceived事件,它和IoHandlerChain配合使用。当在业务逻辑中有多个IoHandler需要处理时,你可以将你的每个IoHandler添加到IoHandlerChain中,这个和过滤器
链比较相似,关于IoFilter和IoHandlerChain的具体用法和区别会在后续的文档中给出。

StreamIoHandler:该类也是用于处理IoHandler的messageReceived事件,它主要用于文件传输的系统中,比如FTP服务器中,如果需要对该类进行更深入的了解,请参考Mina 1.1.7的API文档。

DemuxingIoHandler:该类主要是用于处理多个IoHandler的messageReceived,由于在TCP/IP协议的数据传输中会出现数据的截断现象(由于socket传输的数据包的长度是固定的,当数据包大于该长度,数据包就会被截断),所以提供这个类主要是保证IoHandler所处理的数据包的完整性,这个和编解码器中的CumulativeProtocolDecoder类似,关于这两个类的具体介绍会在后续的文档中给出。
分享到:
评论

相关推荐

    apache mina 学习笔记三(子项目FtpServer)

    Apache MINA(Multipurpose Infrastructure for Network Applications)是一个Java框架,用于构建高性能、高可用性的网络应用程序。MINA 提供了一种简单而强大的API,开发者可以使用它来处理TCP/IP和UDP/IP协议,如...

    apache mina 框架实例

    **Apache Mina框架实例:** Apache Mina框架的核心思想是基于事件驱动和非阻塞I/O,这使得它在处理大量并发连接时表现出色。在Mina中,开发者可以创建一个服务端来监听特定端口,并接收客户端的连接请求。一旦连接...

    Apache mina源代码框架解析

    在这个文档中,我们将简要分析Mina 2.0框架的源代码,并通过一个简单的时钟服务器示例来了解其工作原理。 首先,我们来看`MinaTimeServer`类。这个类是Mina服务器的主入口点,它创建了一个`NioSocketAcceptor`实例...

    Apache mina框架入门教程

    Apache Mina 框架是一个强大的网络通信应用框架,它主要针对基于TCP/IP和UDP/IP的协议栈,同时也支持Java对象序列化和其他通信方式。Mina 的核心设计目标是帮助开发者快速构建高性能、高可扩展性的网络应用。它采用...

    apache mina详细介绍,适合新手入门mina

    下面是一个简单的 TCPServer 实例,用于演示如何使用 Mina 创建一个基本的服务端: ```java public class MyServer { public static void main(String[] args) { IoAcceptor acceptor = new NioSocketAcceptor();...

    这是Apache Mina Server 2.0的中文参考手册,版本为1.0

    关于压缩包内的文件,"Apache_Mina_Server_2.0中文参考手册V1.0.pdf"无疑是最重要的资源,它包含了详细的理论知识和实例代码。"welcome"系列的文本文件可能是手册中的一些示例,用于演示如何通过Mina发送和接收欢迎...

    Apache Mina

    ### Apache Mina 2.0:构建高性能网络通信应用 #### 概述 Apache Mina,全称为**Multi-protocol network application framework**,是Apache软件基金会下的一款强大的网络通信框架,旨在帮助开发者轻松构建高性能...

    mina HTTP协议实例

    Apache MINA(Multipurpose Infrastructure for Network Applications)是一个Java框架,它提供了高度可扩展的、高性能的网络应用程序开发工具。本文将深入探讨如何使用MINA实现HTTP协议,以及相关的源码分析和实用...

    Mina入门:mina版之HelloWorld

    通过这个简单的“HelloWorld”例子,我们对Mina有了初步的了解,掌握了如何创建服务器和客户端,并实现了基本的通信功能。在深入学习Mina时,可以进一步研究它的高级特性,如线程模型、缓冲区管理、心跳机制等,这些...

    mina开发步骤

    Mina(Multi-threaded IO Network Abstraction)是Apache软件基金会的一个开源项目,它为开发者提供了多种网络通信协议的支持,包括TCP/IP、UDP等,并且具备了事件驱动、异步处理的特点,非常适合构建高效稳定的网络...

    mina入门实例

    【mina入门实例】这篇教程主要介绍了如何入门Apache Mina框架,并通过一个简单的实例来演示其基本用法。Apache Mina是一个高性能、轻量级的网络通信框架,常用于开发网络应用,如TCP/IP和UDP协议的服务端和客户端。 ...

    spring boot 整合mina 串口

    <groupId>org.apache.mina <artifactId>mina-core <version>2.1.7 ``` 2. **创建Mina配置类** 我们需要创建一个配置类,用于配置Mina的串口通信。在配置类中,我们将定义串口的参数,如波特率、校验位、...

    Mina2.0入门

    Apache Mina是一个高度可扩展且功能强大的网络通信框架,它为Java应用程序提供了简单而统一的API来处理TCP/IP、UDP和SSL/TLS协议。Mina2.0作为其最新版本,引入了许多改进和优化,旨在提高性能、稳定性和易用性。这...

    mina 框架demo

    ### Apache Mina框架知识点概述 #### 一、Apache Mina框架简介 Apache Mina是一个用于开发高性能、高可扩展性网络应用的Java框架。它基于Java NIO技术,提供了易于使用的API来简化网络编程任务。Mina的核心优势...

    mina中文开发手册.pdf

    文档中还提供了一个简单的TCPServer实例,演示了如何使用Mina框架来构建一个TCP服务器。在这个例子中,开发者首先需要创建IoService。IoService既可是服务端也可是客户端。这里,我们创建了一个服务端,因此使用了...

    mina2推送demo客户端

    MINA(Multi-purpose Infrastructure for Network Applications)是一个高性能、异步的网络通信框架,由Apache软件基金会开发,主要用于构建网络应用程序,如TCP/IP和UDP/IP协议的应用。MINA2是其第二个主要版本,...

    HPsocket 封包与mina对接

    Apache Mina是一个面向网络应用程序的高级、可伸缩、简单、快速的异步I/O框架。为了与HPsocket进行对接,需要在Mina中设置相应的过滤器和处理器。 1. **创建IoConnector**:首先,创建一个`NioSocketConnector`实例...

    mina框架开发完整架包下载!

    3. **Mina Dependencies**:可能包括Mina框架依赖的其他库,如Apache Commons Logging、SLF4J等,这些库在运行Mina应用时是必需的。 4. **API文档**:详细的API文档帮助开发者了解如何使用Mina框架的各种类和方法,...

Global site tag (gtag.js) - Google Analytics