是不是多线程公用一个session了,导致buffer 序列化失败
Successfully reconnected and subscribed xxxx:8903/DemoStreamjavaStreamingApi
java.io.EOFException
at com.xxdb.io.AbstractExtendedDataInputStream.readUnsignedByte(AbstractExtendedDataInputStream.java:116)
at com.xxdb.io.AbstractExtendedDataInputStream.readBoolean(AbstractExtendedDataInputStream.java:21)
at com.xxdb.streaming.client.MessageParser.run(MessageParser.java:68)
at java.lang.Thread.run(Thread.java:748)