- 浏览: 89332 次
- 性别:
- 来自: 深圳
文章分类
最新评论
mina 自己带的FilterChain codec是非常好用,但是在实际网络应用中还是有他的局限性,如编写基于CMPP、SGIP的短信系统。
下面我编写的一个自己FilterChain例子,方便以后查看和其他的人查阅(哎,网上的mina资料少的可怜)
1.mina服务器类
package Minatest; import java.net.InetSocketAddress; import org.apache.mina.common.DefaultIoFilterChainBuilder; import org.apache.mina.common.IdleStatus; import org.apache.mina.common.IoAcceptor; import org.apache.mina.common.IoAcceptorConfig; import org.apache.mina.common.IoHandler; import org.apache.mina.common.IoSession; import org.apache.mina.filter.LoggingFilter; import org.apache.mina.filter.codec.ProtocolCodecFilter; import org.apache.mina.transport.socket.nio.SocketAcceptor; import org.apache.mina.transport.socket.nio.SocketAcceptorConfig; public class MinaServer { /** * @param args * @throws Exception * zxp * */ public static void main(String[] args) throws Exception { IoAcceptor acceptor=new SocketAcceptor(); IoAcceptorConfig config=new SocketAcceptorConfig(); //config.setDisconnectOnUnbind(true); DefaultIoFilterChainBuilder d= config.getFilterChain(); //d.addLast("codec", new ProtocolCodecFilter(new TextLineCodecFactory( Charset.forName("UTF-8")))); //d.addFirst("a", ); InetSocketAddress address=new InetSocketAddress(9000); acceptor.bind(address, new MinaServer().new server(), config); } public class server implements IoHandler { public void exceptionCaught(IoSession arg0, Throwable arg1) throws Exception { // TODO Auto-generated method stub System.out.println("异常:"+arg1); arg1.fillInStackTrace(); } public void messageReceived(IoSession arg0, Object arg1) throws Exception { // TODO Auto-generated method stub System.out.println("收到信息"); SendMessages send=(SendMessages)arg1; System.out.println(send.msg); //收到客户端的消息 为0表示刚刚发送的测试消息发送成功 (这个流程是针对CMPP协议,对于普通的来说没意义) if(send.msg.equals("0")){ this.sessionClosed(arg0); } } //信息发送成功后触发的事件 public void messageSent(IoSession arg0, Object arg1) throws Exception { // TODO Auto-generated method stub System.out.println("发送信息"); } public void sessionClosed(IoSession arg0) throws Exception { // TODO Auto-generated method stub System.out.println("session 关闭"); arg0.close(); } public void sessionCreated(IoSession arg0) throws Exception { // TODO Auto-generated method stub System.out.println("session 建立"); } public void sessionIdle(IoSession arg0, IdleStatus arg1) throws Exception { // TODO Auto-generated method stub System.out.println("session 空闲"); if(arg1==IdleStatus.BOTH_IDLE){ // //自定义发送类 // SendMessages send= new SendMessages(); // send.setMsg("Hi!客户端你空闲咯!"); // this.sendMessage(arg0, send); } } public void sessionOpened(IoSession arg0) throws Exception { // TODO Auto-generated method stub System.out.println("session 打开"); //arg0.setIdleTime(IdleStatus.BOTH_IDLE, 10); arg0.getFilterChain().addFirst("a", new ProtocolCodecFilter(new TestProtocolCodecFactory())); arg0.getFilterChain().addLast("logger", new LoggingFilter()); //发送条测试消息 SendMessages send= new SendMessages(); send.setMsg("Hi!客户端你好!"); this.sendMessage(arg0, send); } private void sendMessage(IoSession arg0, Object arg1){ arg0.write(arg1); } } }
2.mina客户端类
package Minatest; import java.net.InetSocketAddress; import java.nio.charset.Charset; import org.apache.mina.common.DefaultIoFilterChainBuilder; import org.apache.mina.common.IdleStatus; import org.apache.mina.common.IoConnector; import org.apache.mina.common.IoConnectorConfig; import org.apache.mina.common.IoHandler; import org.apache.mina.common.IoSession; import org.apache.mina.filter.codec.ProtocolCodecFactory; import org.apache.mina.filter.codec.ProtocolCodecFilter; import org.apache.mina.filter.codec.textline.TextLineCodecFactory; import org.apache.mina.transport.socket.nio.SocketConnector; import org.apache.mina.transport.socket.nio.SocketConnectorConfig; public class MinaClient { /** * @param args * zxp * */ public static void main(String[] args) { // TODO Auto-generated method stub IoConnector connector=new SocketConnector(); IoConnectorConfig config=new SocketConnectorConfig(); //config.setConnectTimeout(1); //DefaultIoFilterChainBuilder d= config.getFilterChain(); //d.addLast("codec", new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8")))); InetSocketAddress address=new InetSocketAddress("127.0.0.1",9000); connector.connect(address, new MinaClient().new client(), config); } public class client implements IoHandler{ public void exceptionCaught(IoSession arg0, Throwable arg1) throws Exception { // TODO Auto-generated method stub System.out.println("客户端异常:"+arg1); arg0.close(); } public void messageReceived(IoSession arg0, Object arg1) throws Exception { // TODO Auto-generated method stub System.out.println("客户端收到消息"); SendMessages send=(SendMessages) arg1; System.out.println(send.getMsg()); if(send.msg!=null){ send.setMsg("0"); this.sendMessages(arg0,send); } } public void messageSent(IoSession arg0, Object arg1) throws Exception { // TODO Auto-generated method stub //不能用这个方法发送信息,要不死循环 //arg0.getw } public void sessionClosed(IoSession arg0) throws Exception { // TODO Auto-generated method stub System.out.println("客户端关闭"); arg0.close(); } public void sessionCreated(IoSession arg0) throws Exception { // TODO Auto-generated method stub System.out.println("客户端建立"); //arg0.getFilterChain() } public void sessionIdle(IoSession arg0, IdleStatus arg1) throws Exception { // TODO Auto-generated method stub System.out.println("客户端空闲"); if(arg1==IdleStatus.BOTH_IDLE){ this.messageSent(arg0, "空闲测试"); SendMessages send=new SendMessages(); send.setMsg("aaaaa"); this.sendMessages(arg0, send); } } public void sessionOpened(IoSession arg0) throws Exception { // TODO Auto-generated method stub System.out.println("客户端打开"); //10秒内没有读写就设置为空闲通道 arg0.setIdleTime(IdleStatus.BOTH_IDLE, 10); //自定义包解析 //ProtocolCodecFactory codec=new TestProtocolCodecFactory(); //arg0.getFilterChain().addFirst("test", new ProtocolCodecFilter(codec)); arg0.getFilterChain().addLast("a", new ProtocolCodecFilter(new TestProtocolCodecFactory())); } private void sendMessages(IoSession arg0, Object arg1){ System.out.println("sendMessages 发送"); arg0.write(arg1); } } }
3.工厂类
package Minatest; import org.apache.mina.filter.codec.demux.DemuxingProtocolCodecFactory; public class TestProtocolCodecFactory extends DemuxingProtocolCodecFactory { public TestProtocolCodecFactory(){ super.register(TestDecoder.class); super.register(TestEncoder.class); } }
4.编码类
package Minatest; import java.util.Collections; import java.util.HashSet; import java.util.Hashtable; import java.util.Set; import org.apache.mina.common.ByteBuffer; import org.apache.mina.common.IoSession; import org.apache.mina.filter.codec.ProtocolEncoderOutput; import org.apache.mina.filter.codec.demux.MessageEncoder; public class TestEncoder implements MessageEncoder { /** * 编码消息 * zxp * */ public void encode(IoSession session, Object message, ProtocolEncoderOutput out) throws Exception { SendMessages msg=(SendMessages)message; ByteBuffer b=ByteBuffer.allocate(msg.getmsgleng()); b.setAutoExpand(true); //编码消息 msg.encoder(b); //b.putInt(97); //b.put("a".getBytes()); b.flip(); out.write(b); } /** * 获取编码自定义消息类型(多个) * */ public Set<Class<?>> getMessageTypes() { Set<Class<?>> set=new HashSet<Class<?>>(); set.add(SendMessages.class); //返回指定映射的不可修改视图 即只读 return Collections.unmodifiableSet(set); } }
5.解码类
package Minatest; import org.apache.mina.common.ByteBuffer; import org.apache.mina.common.IoSession; import org.apache.mina.filter.codec.ProtocolDecoderOutput; import org.apache.mina.filter.codec.demux.MessageDecoder; import org.apache.mina.filter.codec.demux.MessageDecoderResult; public class TestDecoder implements MessageDecoder { /** * 检查指定的缓冲区decodable解码器 * zxp */ public MessageDecoderResult decodable(IoSession arg0, ByteBuffer arg1) { //包的长度是否大于0 if(arg1.remaining()<=0){ return MessageDecoderResult.NOT_OK; } return MessageDecoderResult.OK; } /** * 解码二进制或协议的具体内容到更高级别的消息对象 * (non-Javadoc) * @see org.apache.mina.filter.codec.demux.MessageDecoder#decode(org.apache.mina.common.IoSession, org.apache.mina.common.ByteBuffer, org.apache.mina.filter.codec.ProtocolDecoderOutput) */ public MessageDecoderResult decode(IoSession arg0, ByteBuffer arg1, ProtocolDecoderOutput arg2) throws Exception { //解码 byte[] b=new byte[arg1.limit()]; arg1.get(b); System.out.println("decode:"+arg1.position()); SendMessages send=new SendMessages(); String s=new String(b); send.setMsg(s); arg2.write(send); return MessageDecoderResult.OK; } /** * 解码完成后调用的方法 * */ public void finishDecode(IoSession arg0, ProtocolDecoderOutput arg1) throws Exception { } }
6.自定义消息类
package Minatest; import org.apache.mina.common.ByteBuffer; public class SendMessages implements java.io.Serializable { public String msg="0"; public String getMsg() { return msg; } public void setMsg(String msg) { this.msg = msg; } public int getmsgleng(){ return msg.getBytes().length; } public void encoder(ByteBuffer b){ b.put(msg.getBytes()); //b.putInt(1); } }
发表评论
-
EJB3的Remote和Local区别
2011-02-25 22:21 13731.@Remote 注释指明实现的接口是远程接口,@Loc ... -
Annotation 详解
2010-02-09 09:12 935Annotation能够对程序注入 ... -
Jetty在AIX上发布的WEB应用性能极差但在SUSE上是OK的,不知道是什么原因
2010-01-20 22:55 1202创建了一个WEB应用,使用Jetty6发布到AIX P6 ... -
JavaNIO 入门
2010-01-13 16:19 800Java NIO非堵塞应用通常 ... -
FTP上传文件源码
2010-01-12 21:11 1089import java.io.File; import ja ... -
FTP下载文件
2010-01-12 21:03 1055import java.io.DataInputStream; ... -
使用http协议访问服务
2010-01-08 21:12 939import java.io.BufferedReader; ... -
Java程序员必须了解的GC工作原理
2009-12-22 15:37 918一个优秀的Java程序员必 ... -
Java IO
2009-12-12 22:09 916一. Input和Output 1. stream ... -
Chain of Responsibility(职责链)
2009-12-12 19:51 1565Chain of Responsibility定义Chain ... -
WebSrvice 简单客户端
2009-12-12 17:18 1118WebSrvice简单客户端: --------------- ...
相关推荐
不使用Servlet Filter接口,自定义FilterChain处理多个Filter执行顺序问题
在 Servlet API 中定义了三个接口类来开供开发人员编写 Filter 程序:Filter, FilterChain, FilterConfig。 Filter 程序是一个实现了 Filter 接口的 Java 类,与 Servlet 程序相似,它由 Servlet 容器进行调用和...
简单的责任链代码 博文链接:https://liucunzhi.iteye.com/blog/1636463
* 当前类名:FilterChain.java * 项目名称:JavaStudy * 创建时间:2011-12-28 */ package org.java.com.design.filter; import java.util.ArrayList; import java.util.List; public class FilterChain ...
* 当前类名:FilterChain.java * 项目名称:JavaStudy * 创建时间:2011-12-28 */ package org.java.com.design.filter; import java.util.ArrayList; import java.util.List; public class FilterChain ...
JSP 开发中过滤器filter设置编码格式的实现方法 我们知道为了避免提交数据的乱码问题,需要在每次使用请求之前设置编码格式。在你复制粘贴了无数次request.setCharacterEncoding(“gb2312”);后,有没有想要一劳永逸...
public void doFilter ServletRequest sRequest ServletResponse sResponse FilterChain chain throws IOException ServletException { HttpServletRequest request HttpServletRequest sRequest; String ...
import javax.servlet.FilterChain; import javax.servlet.FilterConfig; import javax.servlet.ServletException; import javax.servlet.ServletRequest; import javax.servlet.ServletResponse; import javax....
b、doFilter(ServletRequest,ServletResponse,FilterChain): 这个方法完成实际的过滤操作,当客户请求访问于过滤器关联的URL时,Servlet容器将先调用过滤器的doFilter方法。FilterChain参数用于访问后续过滤器。 ...
用户可以把自己过滤器加入FilterChain中。 你可以实现DocumentFilter接口定制自己的功能,系统实现提供了一个LinkLocalizer实现,用于替换相对连接。 FilterChain filters=new FilterChain(); DocumentFilter ...
CXF 是以消息处理为中心的,熟悉 JSP/Servlet 的开发者可以将拦截器视为 CXF 架构中的“Filter”,拦截器链也与“FilterChain”类似。通过拦截器,开发者可以方便地在消息传递、 处理的整个过程中对 CXF 进行扩展。...
MVC模式(model view controller) 模型:封装应用程序的数据和业务逻辑(POJO...对于servlet来说,拦截资源不是其所擅长的filter中的filterchain,这个API是servlet所没有的 Struts2中最主要的一个就是过滤器filter
public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException { if (encoding != null) { request.setCharacterEncoding(encoding); ...
2. FilterChain接口中仅定义一个方法:public void doFilter(ServletRequest req,ServletResponse res),该方法的作用是。() (1分) A.用于将请求/响应继续沿过滤器链向后传给下一个过滤器。如果调用该方法的过滤...
JAVA配置跨越访问Filter APP要访问WEB系统,需要进行跨域设置 关键: public void doFilter(ServletRequest req, ServletResponse res, FilterChain chain) throws IOException, ServletException {}
FilterChain chain) throws IOException, ServletException { HttpServletRequest request = (HttpServletRequest) req; HttpServletResponse response = (HttpServletResponse) res; HttpSession session ...
FilterChain FilterConfig GenericServlet HttpServlet HttpServletRequest HttpServletRequestWrapper HttpServletResponse HttpServletResponseWrapper HttpSession HttpSessionActivationListener ...
培训主要学习以下几个知识点: 1.Filter简介 2.Filter基本工作原理 3.Filter的主要作用及Filter API 4.Filter接口 5.FilterChain接口 6.FilterConfig接口 7.Filter的部署 8.Filter的典型应用
import javax.servlet.FilterChain; import javax.servlet.FilterConfig; import javax.servlet.ServletException; import javax.servlet.ServletRequest; import javax.servlet.ServletResponse; import javax....
javax.servlet.FilterChain javax.servlet.http.Cookie javax.servlet.FilterConfig javax.servlet.ServletConfig javax.servlet.GenericServlet javax.servlet.ServletContext javax.servlet.ServletRequest javax....