windevent.java

自己实现的基于串口通讯发送短消息的低层协议JAVA代码

package com.jzl.sirius.at.event;

import java.nio.ByteBuffer;

import com.jzl.sirius.at.ATConstants;
import com.jzl.sirius.at.util.StringMatch;

public class WINDEvent extends MutiableEvent {
    private boolean eventStarted = false;
    private StringMatch startMatch = new StringMatch(ATConstants.CRLF + "+WIND:");
    private StringMatch endMatch   = new StringMatch(ATConstants.CRLF);
    
    private StringBuffer sb = new StringBuffer();
    
    // 事件解析结果属性
    private int event = -1;
    private int idx   = -1; 
    
    public void reset() {
        super.reset();
        eventStarted = false;
        event = -1;
        idx   = -1;
        sb = new StringBuffer();
    }
    
    public boolean match(char ch) {
        eventStarted = startMatch.match(ch);
        return eventStarted;
    }
    
    private void decodeResponse() {
        int index = sb.indexOf(ATConstants.CRLF);
        if (index == -1) 
            return;
        
        try {
            String str = sb.substring(0, index);
            index = str.indexOf(',');
            if (index == -1) {
                event = Integer.parseInt(str.trim());
            }
            else {
                event = Integer.parseInt(str.substring(0, index).trim());
                idx   = Integer.parseInt(str.substring(index + 1).trim());
            }
        }
        catch(Exception ex) {
        }
    }
    
    public boolean readResponse(ByteBuffer buffer) {
        while(buffer.hasRemaining()){
            
            char ch = (char)buffer.get();
            if (eventStarted) {
                sb.append(ch);
                if (endMatch.match(ch)) {
                    // 事件结束，进行结果解析
                    
                    decodeResponse();
                    finish();
                    return true;
                }
            }
            else 
                match(ch);
        }
        
        return false;
    }

    public int getEvent() {
        return event;
    }

    public int getIdx() {
        return idx;
    }
    
    public Object clone() throws CloneNotSupportedException {
        WINDEvent obj = (WINDEvent)super.clone();
        obj.sb.append(sb);
        obj.eventStarted = eventStarted;
        obj.event = event;
        obj.idx = idx;
        
        return obj;
    }


}