使用mina解析http协议的使用

在使用mina的过程中，我们通常会自定义各种报文，以使用于自己的业务。今天就为大家带来一款类似http协议的解码过程。
mina有自带的解析http数据包的解码类。可以使用maven配置一下内容获取源码：

<dependency><groupId>org.apache.mina</groupId><artifactId>mina-http</artifactId><version>3.0.0-M2</version>
</dependency>

或者下载mina的源码包，查看org.apache.mina.http.HttpServerDecoder类。下面为自己写的解析方法：

package com.server;import java.lang.reflect.Method;
import java.nio.charset.Charset;import org.apache.commons.lang3.StringUtils;
import org.apache.log4j.Logger;
import org.apache.mina.core.buffer.IoBuffer;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.CumulativeProtocolDecoder;
import org.apache.mina.filter.codec.ProtocolDecoderOutput;
import org.apache.mina.filter.codec.textline.LineDelimiter;/*** 解码HTTP协议类* @author Herman.xiong* @date 2015年7月16日09:36:59* @version V3.0* @since Tomcat6.0,Jdk1.6* @copyright Copyright (c) 2015*/
public class HttpServerDecoder extends CumulativeProtocolDecoder {private static final Logger log = Logger.getLogger(HttpServerDecoder.class);private LineDelimiter codecLineDelimiter = null;private Charset charset = null;private static final String MessageLength = "MessageLength";public HttpServerDecoder(Charset charset, LineDelimiter codecLineDelimiter) {this.charset = charset;this.codecLineDelimiter = codecLineDelimiter;}public Charset getCharset() {return charset;}public void setCharset(Charset charset) {this.charset = charset;}public LineDelimiter getCodecLineDelimiter() {return codecLineDelimiter;}public void setCodecLineDelimiter(LineDelimiter codecLineDelimiter) {this.codecLineDelimiter = codecLineDelimiter;}public static void main(String [] args){IoBuffer buf = IoBuffer.allocate(100).setAutoExpand(true);Charset charset = Charset.forName("UTF-8");CharsetEncoder ce=charset.newEncoder();HttpServerDecoder socket=new HttpServerDecoder(Charset.forName("UTF-8"),LineDelimiter.CRLF);try{System.out.println("测试数据，测试数据".getBytes(charset).length);buf.putString("MessageMethod:UserAction", ce);buf.putString(LineDelimiter.CRLF.getValue(), ce);buf.putString("MessageType:GET", ce);buf.putString(LineDelimiter.CRLF.getValue(), ce);buf.putString("Content-Type:text/html; charset=iso-8859-1", ce);buf.putString(LineDelimiter.CRLF.getValue(), ce);buf.putString("Connection:keep-alive", ce);buf.putString(LineDelimiter.CRLF.getValue(), ce);buf.putString("Keep-Alive:200", ce);buf.putString(LineDelimiter.CRLF.getValue(), ce);         buf.putString("CompressType:jzip", ce);buf.putString(LineDelimiter.CRLF.getValue(), ce);buf.putString("Params:id=1&uid=2&name=3", ce);buf.putString(LineDelimiter.CRLF.getValue(), ce);buf.putString("accept-ranges:bytes", ce);buf.putString(LineDelimiter.CRLF.getValue(), ce);buf.putString("DateTime:DateTime", ce);buf.putString(LineDelimiter.CRLF.getValue(), ce);buf.putString("MessageLength:27", ce);buf.putString(LineDelimiter.CRLF.getValue(), ce);//bodybuf.putString("测试数据，测试数据", ce);buf.putString(LineDelimiter.CRLF.getValue(), ce);buf.flip();System.out.println("输出的内容为："+buf.getString(charset.newDecoder()));buf.flip();socket.doDecode(null,buf,null);}catch(Exception e){e.printStackTrace();}}/*** 数据包解码*/protected boolean doDecode(IoSession session, IoBuffer in, ProtocolDecoderOutput out) throws Exception {Map<String,Object> map = (Map<String,Object>) session.getAttribute("pocket");IoBuffer buf = (IoBuffer)session.getAttribute("pocket_state");if(null ==buf)buf = IoBuffer.allocate(100).setAutoExpand(true).setAutoShrink(true);if(null == map)map = new HashMap<String,Object>();Integer len = 0;while (in.hasRemaining()) {len = 0;byte b = in.get();switch (b){case '\r':buf.put(b);break;case '\n':buf.put(b);buf.flip();String msg=buf.getString(charset.newDecoder());String[] arr = msg.split(":");if(StringUtils.isEmpty(map.get("MessageLength"))){if (2 == arr.length && StringUtils.isNotEmpty(arr[0]) && StringUtils.isNotEmpty(arr[1])) {map.put(arr[0],arr[1]);} else {log.error("收到的数据包中存在非法内容!");}if(Constant.HUPU_ZERO.equals(map.get("MessageLength"))){out.write(map);if(in.position()==in.limit()){session.setAttribute("pocket_state", null);session.setAttribute("pocket",null);return true;}map = new HashMap<String,Object>();}}else{map.put(StringUtils.isEmpty(map.get("MessageContent"))?msg:map.get("MessageContent")+msg);len=((null == map.get("MessageContent")) ? StringUtils.EMPTY : String.valueOf(map.get("MessageContent"))).getBytes(charset).length;if(len==Integer.parseInt(map.get("MessageContent"))+2){out.write(map);if(in.position()==in.limit()){session.setAttribute("pocket_state", null);session.setAttribute("pocket",null);return true;}}map = new HashMap<String,Object>();}buf.clear();break;default:buf.put(b);}}if(StringUtils.isEmpty(map.get("MessageLength")) || len<Integer.parseInt(map.get("MessageLength"))){session.setAttribute("pocket",map);session.setAttribute("pocket_state", buf);}return false;}}

欢迎大家关注我的博客！如有疑问,请加QQ群：454796847共同学习！

使用mina解析http协议的使用相关推荐

解析HTTP协议六种请求方法,get,head,put,delete,post有什么区别
转载自解析HTTP协议六种请求方法,get,head,put,delete,post有什么区别标准Http协议支持六种请求方法,即: 1.GET 2.POST 3.PUT 4.Delete 5. ...
腐蚀rust服务器命令_【使用 Rust 写 Parser】2. 解析Redis协议
系列所有文章 https://zhuanlan.zhihu.com/p/115017849zhuanlan.zhihu.com https://zhuanlan.zhihu.com/p/139387 ...
J8583CN解析ISO8583协议报文注意点
最近在做POS接入涉及到如何正确解析ISO8583协议的问题,遇到了一些很讨厌的问题今天将他们总结一下写在博客中,供大家参考. 1. 对于小白首先要了解什么是ISO8583协议,请参考该文章htt ...
【ATE-SENT协议】使用LabVIEW采集并解析SENT协议
SENT协议大多用于车载行程传感器上,具体协议规范这里不讲,不了解的朋友可以看一下其他人的帖子.我这里只讲如何使用LabVIEW及NI硬件采集并解析SENT协议. 硬件采集方案 SENT协议的解析,物 ...
FPGA解析串口协议帧3.0版本，增加了错误重发功能，提供仿真文件以及源码
FPGA解析串口协议帧已经发布2个版本了,分别如下: 版本1:点击查看版本1 版本1详细介绍了串口协议帧的帧组成和设计思想,但设计粗糙,注释不详细: 版本1:点击查看版本2 版本2优化了代码,添加了详 ...
lua语言学习之自定义wireshark插件来解析自定义协议
lua语言学习之自定义wireshark插件来解析自定义协议关于wireshark这个抓包工具关于lua 使用lua写wireshark插件 wireshark接口文档如何在wireshark使 ...
网卡解析arp协议导致ip address ** is already in ues for...
2019独角兽企业重金招聘Python工程师标准>>> #service network restart Bringing up interface eth0: Determini ...
Java 面试知识点解析——网络协议篇
Java 面试知识点解析--网络协议篇前言: 在遨游了一番 Java Web 的世界之后,发现了自己的一些缺失,所以就着一篇深度好文:知名互联网公司校招 Java 开发岗面试知识点解析 ,来好好的对 ...
python模拟gps定位_python解析nmea0183协议获取GPS定位信息
python解析nmea0183协议获取GPS定位信息 nmea0183协议里面定位数据主要在GPRMC报文里面,下面是报文的大体形式: b'$GPRMC,111025.00,A,2517.03374 ...

使用mina解析http协议的使用

使用mina解析http协议的使用相关推荐

最新文章

热门文章