关于MINA框架中报文读取的问题

0 0

关于MINA框架中报文读取的问题10

小弟在做项目的时候遇到了一个棘手的问题，希望各位大神出手相助！

如题，用的是MINA框架，读取短报文的时候没任何问题，但是在读取较长的报文的时候，老是会少读点东西，例如XML形式的字符串的某个标签。

下面是解码器：

package mds.gps.mina;

import java.nio.ByteBuffer;

import mds.gps.utils.HexUtil;

import org.apache.mina.core.buffer.IoBuffer;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.ProtocolDecoder;
import org.apache.mina.filter.codec.ProtocolDecoderOutput;

import com.sun.org.apache.bcel.internal.generic.NEW;

/**
 * MINA解码器
 * 
 * @author Administrator
 * 
 */
public class MyTextLineDecoder implements ProtocolDecoder {

	IoBuffer buf = IoBuffer.allocate(8192).setAutoExpand(true).setAutoShrink(true);
	public void decode(IoSession session, IoBuffer in,
			ProtocolDecoderOutput output) throws Exception {
		System.out.println(in.capacity());
		ByteBuffer receiveBytes;
		buf.flip();
		
		//字符串拼接缓冲
		String cache=MinaClient.getStrRec();
		
		//
		while (in.hasRemaining()) {
			byte b = in.get();
			 if (b == '\n') {
			 buf.flip();
			 byte[] bytes = new byte[buf.limit()];
			 buf.get(bytes);
			 String message =cache+new String(bytes,"gbk")+"\n";
			 cache=message;
			 MinaClient.setStrRec(cache);
			 
			 //读到这个标签就结束，输出
			 if(cache.contains("</package>")){
				 output.write(cache);
				 MinaClient.setStrRec("");
				 cache="";
			 }
			 buf.clear();
			 buf.flip();
			 buf = IoBuffer.allocate(8192).setAutoExpand(true).setAutoShrink(true);
			 } else {
				 buf.put(b);
			 }
		}
	}

	public void dispose(IoSession arg0) throws Exception {
		System.out.println("disposedisposedisposedisposedisposedisposedisposedisposedisposedisposedisposedisposedispose");
	}

	public void finishDecode(IoSession arg0, ProtocolDecoderOutput arg1)
			throws Exception {
		System.out.println("finishDecodefinishDecodefinishDecodefinishDecodefinishDecodefinishDecodefinishDecodefinishDecode");
	}

}

接下来是读取的xml形式的字符串，总是少读一标签导致解析出错：

<?xml version="1.0" encoding="utf-8"?>
<package>
    <head>
        <version>1</version>
        <message>ResGetDepartmentList</message>
        <session>f6a9f429d2e54e9782740bad6c84c4ab</session>
        <workflow>67606</workflow>
    </head>
    <body>
        <departmentlist><department><id>1</id>
                <name>绿源</name>
                <father>0</father>
            </department>
            <department><id>2</id>
                <name>绿源测试</name>
                <father>1</father>
            </department>
            <department><id>3</id>
                <name>经销商2</name>
                <father>1</father>
            </department>
            <department><id>4</id>
                <name>经销商3</name>
                <father>1</father>
            </department>
            <department><id>8</id>
                <name>qqqqqqqq</name>
                <father>1</father>
            </department>
            <department><id>9</id>
                <name>ww</name>
1</father><!--就是这儿-->
            </department>
            <department><id>10</id>
                <name>111111</name>
                <father>1</father>
            </department>
            <department><id>16</id>
                <name>jrx</name>
                <father>10</father>
            </department>
            <department><id>17</id>
                <name>hhhhh</name>
                <father>10</father>
            </department>
            <count>9</count>
        </departmentlist>
    </body>
</package>

本来是用普通的socket输入流开了个线程接收报文的，一切正常，后来改用MINA框架，出了这个问题。其他部分应该都没错，问题应该就出在解码器上，请大家帮忙看下，感激不尽！