转载:Apache Mina 入门实例
2015-12-02 11:36
399 查看
以下是这个教程需要准备的东西:
MINA 2.0.7 Core
JDK 1.5 或更高
SLF4J 1.3.0 或更高
Log4J 1.2 用户: slf4j-api.jar, slf4j-log4j12.jar, 和Log4J 1.2.x
Log4J 1.3 用户: slf4j-api.jar, slf4j-log4j13.jar, 和Log4J 1.3.x
java.util.logging 用户: slf4j-api.jar 和slf4j-jdk14.jar
重要提醒:请确认你使用的
slf4j-*.jar和你的logging框架匹配。举个板栗,slf4j-log4j12.jar 和 log4j-1.3.x.jar 是不能混在一起用的,否则会出问题。
创建一个MINA时间服务
We will begin by creating a file called MinaTimeServer.java我们创建一个文件名为
MinaTimeServer.java,文件内容如下:
publicclassMinaTimeServer{publicstaticvoid main(String[] args ){//还没有东西呢}}
上面的代码应该不用解释了吧,为了创建我们的服务,我们需要一个监听传入连接的对象,由于我们的项目是基于TCP/IP,所以需要一个
SocketAcceptor对象来帮我们处理。
import org.apache.mina.core.service.IoAcceptor;import org.apache.mina.transport.socket.nio.NioSocketAcceptor;publicclassMinaTimeServer{publicstaticvoid main(String[] args ){IoAcceptor acceptor =newNioSocketAcceptor();}}
创建好后,我们可以定义处理请求的类,和指定监听的端口等。
接下来,我们需要在配置里添加几个过滤器。第一个是
logger,这个过滤器用来记录所有的信息,比如创建session(会话),接收消息,发送消息,关闭会话等。第二个是
ProtocolCodecFilter(协议编解码过滤器).这个过滤器用来转换二进制或协议的专用数据到消息对象中, 反之亦然。我们这里使用一个已经存在的
TextLine工厂,因为我们这里只处理一些文字消息(你不需要再去写编解码部分)。
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;publicclassMinaTimeServer{publicstaticvoid main(String[] args ){IoAcceptor acceptor =newNioSocketAcceptor(); acceptor.getFilterChain().addLast("logger",newLoggingFilter()); acceptor.getFilterChain().addLast("codec",newProtocolCodecFilter(newTextLineCodecFactory(Charset.forName("UTF-8"))));}}
For this tutorial, we will extend the class IoHandlerAdapter. This is a class that follows the adapter design pattern which simplifies the amount of code that needs to be written in order to satisfy the requirement of passing in a class that implements the IoHandler interface.
接下来我们需要创建一个
handler来实时处理客户端的连接和请求,这个
handler类必须实现
IoHandler这个接口。对于所有使用MINA的程序来说,主要的负荷都在这个文件,它为所有客户端请求提供服务。在这个例子中,我们将扩展
IoHandlerAdapter类。这是一个遵从适配器模式的类,帮我们简化了很多为了去实现
IoHandler接口的代码。
import java.io.IOException;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;publicclassMinaTimeServer{publicstaticvoid main(String[] args )throwsIOException{IoAcceptor acceptor =newNioSocketAcceptor(); acceptor.getFilterChain().addLast("logger",newLoggingFilter()); acceptor.getFilterChain().addLast("codec",newProtocolCodecFilter(newTextLineCodecFactory(Charset.forName("UTF-8")))); acceptor.setHandler(newTimeServerHandler());}}
现在我们要添加一些
NioSocketAcceptor配置,这将允许我们设置特殊的socket设置来接收客户端的连接。
import java.io.IOException;import java.nio.charset.Charset;import org.apache.mina.core.session.IdleStatus;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;publicclassMinaTimeServer{publicstaticvoid main(String[] args )throwsIOException{IoAcceptor acceptor =newNioSocketAcceptor(); acceptor.getFilterChain().addLast("logger",newLoggingFilter()); acceptor.getFilterChain().addLast("codec",newProtocolCodecFilter(newTextLineCodecFactory(Charset.forName("UTF-8")))); acceptor.setHandler(newTimeServerHandler()); acceptor.getSessionConfig().setReadBufferSize(2048); acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE,10);}}
这有两行新代码,这些方法是用来为会话设置
IoHandler,输入缓冲区的大小和空闲等待时间。
需要指定缓冲区大小来告诉底层操作系统为传入的数据分配多少的空间。第二行指定多少时间没有读写操作就进入空闲状态。
handler的代码如下:
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;publicclassTimeServerHandlerextendsIoHandlerAdapter{@Overridepublicvoid exceptionCaught(IoSession session,Throwable cause )throwsException{ cause.printStackTrace();}@Overridepublicvoid messageReceived(IoSession session,Object message )throwsException{String str = message.toString();if( str.trim().equalsIgnoreCase("quit")){ session.close();return;}Date date =newDate(); session.write( date.toString());System.out.println("Message written...");}@Overridepublicvoid sessionIdle(IoSession session,IdleStatus status )throwsException{System.out.println("IDLE "+ session.getIdleCount( status ));}}
这个类中一般有
exceptionCaught,
messageReceived和
sessionIdle这几个方法。
exceptionCaught应该总是在
handler中定义,来处理一些异常情况,否则异常信息将无法捕捉。
exceptionCaught方法简单地打印了错误的堆栈跟踪和关闭会话。对于大多数程序,这将是标准的做法,除非处理程序可以从异常状态中恢复。
messageReceived 方法来处理从客户端接收到的数据,这里是将当前时间返回给客户端,当收到
quit时,会话将被关闭,也会返回一个当前时间给客户端。根据所使用的协议编解码器,
object这个参数传递的类型有所不同,以及返回的数据时的
session.write(Object)也不同。如果不指定协议的编解码器,你将收到一个类型为
IoBuffer的对象,返回的数据也要求是
IoBuffer。
The sessionIdle method will be called once a session has remained idle for the amount of time specified in the call acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE, 10 );.
sessionIdle方法将定时调用一次会话,保持空闲状态。通过调用
acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE, 10 );来设定时间间隔。
所有剩下要做的就是定义套接字地址,该服务器将侦听,实际接入时才会启动服务。
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;publicclassMinaTimeServer{privatestaticfinalint PORT =9123;publicstaticvoid main(String[] args )throwsIOException{IoAcceptor acceptor =newNioSocketAcceptor(); acceptor.getFilterChain().addLast("logger",newLoggingFilter()); acceptor.getFilterChain().addLast("codec",newProtocolCodecFilter(newTextLineCodecFactory(Charset.forName("UTF-8")))); acceptor.setHandler(newTimeServerHandler()); acceptor.getSessionConfig().setReadBufferSize(2048); acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE,10); acceptor.bind(newInetSocketAddress(PORT));}}
到了这里后,服务端的操作就已经完成了,客户端可参考附件中代码,里面包含了完整的实例,来源自/detail/2587287562.html。
代码结构
效果
客户端
服务端
相关文章推荐
- ApacheTiles实战
- 重要开源协议的比较(BSD,Apache,GPL,LGPL,MIT) – 整理
- 使用Apache Tiles3.x构建界面布局
- Apache CXF实现Web Service(2)——不借助重量级Web容器和Spring实现一个纯的JAX-RS(RESTful) web service
- jetty部署出现org.apache.jasper.JasperException: PWC6345: There is an error in invoking javac. A full JD
- Apache的IP访问控制
- Apache配置缺失msvcr100.dll msvcr110.dll
- Web性能压力测试工具之ApacheBench(ab)详解
- Apache Shiro的(what、why、who)保护你的应用程序
- Apache Shiro权限管理框架的初次认识
- Apache CXF实现Web Service(1)——不借助重量级Web容器和Spring实现一个纯的JAX-WS web service
- java.lang.NoClassDefFoundError: org/apache/log4j/Level
- LAMP 1.2 Apache编译安装问题解决
- Linux Apache上实现Web页面访问权限控制
- apache 配置
- web服务器熟悉(apache编译)
- org/apache/commons/lang/exception/NestableRuntimeException错误
- Hadoop: LongWritable cannot be cast to org.apache.hadoop.io.IntWritable
- Apache配置防盗链
- Apache配置静态缓存