mutitypeevent.java

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

package com.jzl.sirius.at.event;

import java.nio.ByteBuffer;
import java.util.ArrayList;

import com.jzl.sirius.at.ATEvent;

public class MutiTypeEvent extends ATEvent {
    
    private boolean eventStarted  = false;
    private Condition condition;
    private MutiableEvent[] types;
    private ArrayList<MutiableEvent> events = new ArrayList<MutiableEvent>();
    private MutiableEvent event;
    
    public MutiTypeEvent(MutiableEvent[] types, Condition condition) {
        this.condition = condition;
        this.types = types;
    }
    
    public ATEvent[] getEvents() {
        return (ATEvent[])events.toArray(new ATEvent[0]);
    }
    
    
    public boolean readResponse(ByteBuffer buffer) {

        while(buffer.hasRemaining()){
            if (eventStarted) {
                boolean ret = event.readResponse(buffer);
                if (ret){
                    try {
                        events.add((MutiableEvent)event.clone());
                    }
                    catch(Exception ex) {
                    }
                    
                    if (condition.isConditional(event)) {
                        event.reset();
                        finish();
                        return true;
                    }
                    
                    event.reset();
                    eventStarted = false;
                    continue;
                }
                
            }
            else {
                char ch = (char)buffer.get();
                for (int i = 0; i < types.length; i++) {
                    if (types[i].match(ch)) {
                        event = types[i];
                        eventStarted = true;
                        
                        break;
                    }
                }
            }
        }
        
        return false;
    }
    
}