应用程序结构
服务端结构
客户端结构
简单的tcp服务器
简单的tcp客户端
简单的udp服务器
简单的udp客户端
总结应用程序结构
一个采用mina框架的应用程序结构如下：
从上图可以看到，mina作为一个中间层连接你的应用程序和网络底层，它可以处理tcp,udp甚至一个串行通信协议（rs-232c)，因此你可以更关注于在mina上面设计应用程序，而不需要了解底层网络通信的复杂性。
下面看看mina的内部：
通常来讲，mina应用程序被分成三层。
i/o 服务 - 真正的i/o操作
i/o 过滤链 - 过滤/传输数据
i/o handler - 在这里完成程序的逻辑
所以，要创建一个mina应用程序，你只需要做：
创建i/o服务 - 选择已经提供的服务（acceptor)或者自己创建的服务
创建过滤链 - 选择已经提供的过滤链或者创建自己定制的过滤链
创建i/ohandler - 写业务逻辑，处理各种不同的消息以上是mina的总体结构，
下面看看服务端的结构：
简单来说就是有一个i/o acceptor在服务端监听即将到来的连接或者数据包，对于一个新的连接到来，一个新的session会被创建，并且由该连接随后到来的请求会在这个session中进行处理。所有的包由session接受，并通过上图指示的过滤链。过滤链被用来修改包的内容（例如转化成objects，添加或者剔除一些信息）。最后这些包交友iohandler处理。另外需要注意的是，当一个连接到来时，一个session就会被建立，而不管这个连接最后有没有成功，session都会被建立。
下面是客户端模型：
客户端跟服务端刚好是一个相反的状态。
其中客户端会有一个ioconnector用来连接上服务端。而所有的处理仍然有iohandler完成。
简单的tcp服务器
下面，创建一个简单的tcp服务器作为演示：首先你需要将一些需要的包导入到ide或者配置你的classpath，具体方法就不详述了，需要的包有：
mina 2.x core
jdk 1.5 or greater
slf4j 1.3.0 or greater
log4j 1.2 users: slf4j-api.jar, slf4j-log4j12.jar, and log4j 1.2.x
log4j 1.3 users: slf4j-api.jar, slf4j-log4j13.jar, and log4j 1.3.x
java.util.logging users: slf4j-api.jar and slf4j-jdk14.jar
important: please make sure you are using the right slf4j-*.jar that matches to your logging framework.
准备工作做完之后，我们开始编写代码
import java.net.inetsocketaddress; import org.apache.mina.core.service.ioacceptor; import org.apache.mina.transport.socket.nio.niosocketacceptor; public class minatimeserver { private static final int port = 9123; public static void main( string[] args ) throws ioexception { ioacceptor acceptor = new niosocketacceptor(); acceptor.bind( new inetsocketaddress(port) ); } }
接下来，我们在上面代码中，添加过滤链的配置。
import java.io.ioexception; import java.net.inetsocketaddress; import java.nio.charset.charset; 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.filter.logging.loggingfilter; import org.apache.mina.transport.socket.nio.niosocketacceptor; public class minatimeserver { public static void main( string[] args ) { ioacceptor acceptor = new niosocketacceptor(); acceptor.getfilterchain().addlast( "logger", new loggingfilter() ); //这里会建立所有的日志信息 acceptor.getfilterchain().addlast( "codec", new protocolcodecfilter( new textlinecodecfactory( charset.forname( "utf-8" )))); //第二个过滤器用来传递数据 acceptor.bind( new inetsocketaddress(port) ); } }
接下来，我们需要定义用来处理消息的handler，这个handler类必须实现iohandler接口。在mina中，这个handler是程序开发的关键，在这个教学中，我们会继承于iohandleradapter。
import java.util.date; import org.apache.mina.core.session.idlestatus; import org.apache.mina.core.service.iohandleradapter; import org.apache.mina.core.session.iosession; public class timeserverhandler extends iohandleradapter { @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(); return; } date date = new date(); session.write( date.tostring() ); system.out.println("message written..."); } @override public void sessionidle( iosession session, idlestatus status ) throws exception { system.out.println( "idle " + session.getidlecount( status )); } }
最后，完整的服务器代码如下：
import java.io.ioexception; import java.net.inetsocketaddress; import java.nio.charset.charset; import org.apache.mina.core.service.ioacceptor; import org.apache.mina.core.session.idlestatus; import org.apache.mina.filter.codec.protocolcodecfilter; import org.apache.mina.filter.codec.textline.textlinecodecfactory; import org.apache.mina.filter.logging.loggingfilter; import org.apache.mina.transport.socket.nio.niosocketacceptor; 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() ); //这里设置handler acceptor.getsessionconfig().setreadbuffersize( 2048 ); //这是设置ssesion缓冲区 acceptor.getsessionconfig().setidletime( idlestatus.both_idle, 10 ); acceptor.bind( new inetsocketaddress(port) ); } }
运行该服务器，然后打开终端输入命令：telnet 127.0.0.1 9123 即可看到，当你输入非“quit” 的任何字符时，服务器都会返回当前的时间到终端来。
简单的tcp客户端
import java.net.inetsocketaddress; import org.apache.mina.core.runtimeioexception; import org.apache.mina.core.future.connectfuture; import org.apache.mina.core.session.iosession; import org.apache.mina.example.sumup.codec.sumupprotocolcodecfactory; import org.apache.mina.filter.codec.protocolcodecfilter; import org.apache.mina.filter.codec.serialization.objectserializationcodecfactory; import org.apache.mina.filter.logging.loggingfilter; import org.apache.mina.transport.socket.nio.niosocketconnector; /** * (<strong>entry point</strong>) starts sumup client. * * @author <a href="http://mina.apache.org">apache mina project</a> */ public class client { private static final string hostname = "localhost"; private static final int port = 8080; private static final long connect_timeout = 30*1000l; // 30 seconds // set this to false to use object serialization instead of custom codec. private static final boolean use_custom_codec = true; public static void main(string[] args) throws throwable { if (args.length == 0) { system.out.println("please specify the list of any integers"); return; } // prepare values to sum up int[] values = new int[args.length]; for (int i = 0; i < args.length; i++) { values[i] = integer.parseint(args[i]); } niosocketconnector connector = new niosocketconnector(); // configure the service. connector.setconnecttimeoutmillis(connect_timeout); if (use_custom_codec) {
connector.getfilterchain().addlast( "codec", new protocolcodecfilter( new sumupprotocolcodecfactory(false))); } else { connector.getfilterchain().addlast( "codec", new protocolcodecfilter( new objectserializationcodecfactory())); } connector.getfilterchain().addlast("logger", new loggingfilter()); connector.sethandler(new clientsessionhandler(values)); iosession session; for (;;) { try { connectfuture future = connector.connect(new inetsocketaddress( hostname, port)); 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(); } }
udp的例子不写了，需要的话到apache官网去看看。
http://mina.apache.org/mina-project/userguide/ch2-basics/sample-udp-client.html
以上就是apache mina 学习笔记(2) - 基础的内容。