环保212协议解析java

package com.hj212.format.segment.core; import static com.hj212.format.segment.core.SegmentToken.*; import static com.hj212.format.segment.core.feature.SegmentParserFeature.*; import java.io.Closeable; import java.io.IOException; import java.io.PushbackReader; import java.io.Reader; import java.nio.CharBuffer; import java.util.Optional; import java.util.Stack; import java.util.concurrent.atomic.AtomicReference; import com.hj212.format.segment.base.cfger.Configurator; import com.hj212.format.segment.base.cfger.Configured; import com.hj212.stream.reader.core.ReaderStream; /** * Created by xiaoyao9184 on 2018/1/3. */ @SuppressWarnings("incomplete-switch") public class SegmentParser implements Closeable, Configured<SegmentParser> { // private ParseContext context; protected PushbackReader reader; private int parserFeature; private SegmentToken currentToken; private Stack<String> path; public SegmentParser(Reader reader){ this.reader = new PushbackReader(reader,3); this.path = new Stack<>(); } //TODO config // public SegmentParser(PackParser packParser) throws IOException, SegmentFormatException { // super(null); // char[] sc = packParser.readSegmentOnly(); // CharArrayReader reader = new CharArrayReader(sc); // super.reader = reader; // } /** * 读取KEY * @return KEY * @throws IOException */ public String readKey() throws IOException { return readPathKey(false); } /** * 读取一部分KEY * @return 部分KEY * @throws IOException */ public String readPathKey() throws IOException { return readPathKey(true); } /** * 读取KEY * @param supportSubKey true：遇到‘-’结束 * @return KEY * @throws IOException */ private String readPathKey(boolean supportSubKey) throws IOException { //当前Token switch (currentToken){ case END_KEY: throw new IOException("Cant read key after END_KEY token!"); case END_OBJECT_VALUE: //“&&”字符串后面跟着“,”“;”认为是相同的，需要读出来， // 避免被认为是当前是孤立KEY ReaderStream.of(reader) .next() .when(END_SUB_ENTRY::isSame) .then(() -> currentToken = END_SUB_ENTRY) .when(END_ENTRY::isSame) .then(() -> currentToken = END_ENTRY) .done() .match(); break; } CharBuffer buffer = CharBuffer.allocate(10); //之后的Token int len = ReaderStream.of(reader) .next() .when(NOT_AVAILABLE::isSame) .then(() -> currentToken = NOT_AVAILABLE) //perfect .when(c -> supportSubKey && END_PART_KEY.isSame(c)) .then(() -> currentToken = END_PART_KEY) .when(END_KEY::isSame) .then() .next(2) .when(START_OBJECT_VALUE::isSame) .then(() -> currentToken = START_OBJECT_VALUE) .done() .back() .then(() -> currentToken = END_KEY) .when(END_SUB_ENTRY::isSame) .then(() -> { //Missing '=' core value if(!ALLOW_ISOLATED_KEY.enabledIn(parserFeature)){ throw new IOException("Missing '=' between key and (null)value"); } //NULL Value currentToken = SegmentToken.END_SUB_ENTRY; }) .when(END_ENTRY::isSame) .then(() -> { //Missing '=' core value if(!ALLOW_ISOLATED_KEY.enabledIn(parserFeature)){ throw new IOException("Missing '=' between key and (null)value"); } //NULL Value currentToken = SegmentToken.END_ENTRY; }) //key&& //也许是缺少= START_OBJECT_VALUE //也许是NullValue END_OBJECT_VALUE .when(START_OBJECT_VALUE::isStart) .then() .next() .when(START_OBJECT_VALUE::isStart) .then(() -> { if(path.empty()){ //Missing '=' if(!ALLOW_KEY_NOT_CLOSED.enabledIn(parserFeature)){ throw new IOException("Missing '=' between key and (object)value"); } //Object Value currentToken = SegmentToken.START_OBJECT_VALUE; }else{ //NULL Value currentToken = SegmentToken.END_OBJECT_VALUE; } }) .done() .back() .then(() -> { if(!IGNORE_INVAILD_SYMBOL.enabledIn(parserFeature)){ throw new IOException("Invaild symbol '&' in key"); } //Ignore Invaild symbol }) .done() .read(buffer); if(currentToken == END_OBJECT_VALUE){ path.pop(); } if(len == 0){ return null; } buffer.rewind(); String result = buffer.toString().substring(0,len); if(currentToken == START_OBJECT_VALUE){ path.push(result); } return result; // mode = SegmentMode.KEY; // StringWriter sw = new StringWriter(); // int i; // while((i = reader.next()) != -1) { // char c = (char)i; // // if(supportSubKey && // END_PART_KEY.isSame(c)){ // //End of Main Key // currentToken = END_PART_KEY; // break; // }else if(SegmentToken.END_KEY.isSame(c)){ // //End of Key // reader.mark(-0); // char[] c2 = new char[2]; // reader.next(c2); // if(SegmentToken.START_OBJECT_VALUE.isSame(c2)){ // currentToken = SegmentToken.START_OBJECT_VALUE; // break; // } // reader.reset(); // currentToken = SegmentToken.END_KEY; // break; // }else if(SegmentToken.END_SUB_ENTRY.isStart(c)){ // //Missing '=' core value // if(!ALLOW_ISOLATED_KEY.enabledIn(parserFeature)){ // // } // //NULL Value // currentToken = SegmentToken.END_SUB_ENTRY; // break; // }else if(SegmentToken.END_ENTRY.isStart(c)){ // //Missing '=' core value // if(!ALLOW_ISOLATED_KEY.enabledIn(parserFeature)){ // // } // //NULL Value // currentToken = SegmentToken.END_ENTRY; // break; // }else if(SegmentToken.END_OBJECT_VALUE.isStart(c)){ // int finalI = i;