1.该队列应该解决了添加和取出处理的锁的问题。LinkedBlockingQueue add poll
2.关于心跳命令的发送机制
当其他命令在规定时间里都没有发出和收到情况下才会发出
该命令的设计应当能保证不会堆积到命令队列中
该命令应当能控制命令发送的间隔时间
3.关于命令队列普通命令
应当有快速队列和慢速队列的概念
应当有处理组合命令的能力
4.关于Loop 逻辑的设计
当遇到需要定时轮询的命令（进度问询），不应当开启计时器，应当在命令队列中解决，根据业务type码 和 上一次这个命令的发送时间 来决定当下时间点需要不需要发此命令.
所以当有轮询业务时 需要在 loop 中补全业务逻辑。
5.连接断开
状态恢复成init ，业务根据需要设定对应的逻辑(一般 clear)。命令队列对应逻辑设计。
代码如何高内聚低耦合
处理接口：
public interface IO {
void handleCommand(TCommand command) throws IOException;
}
处理命令：
public interface TAction {//命令集合 可以执行多个command
void exec(IO io) throws IOException;
void reset();
}
public abstract class TCommand implements TAction {//每一个命令的基类
public long lastCommand = System.currentTimeMillis();
public long runTime = 0L; // cmd 下发时间
public static final String defaultRes = " "; // 返回值截取长度(32)
public TCommand() {
}
public abstract void exec(IO io);
public abstract String encodeCommand();
public boolean needRes() {
runTime = System.currentTimeMillis();
return true;
}
public boolean isEndWith() {
return false;
}
public byte[] getRes() {
return defaultRes.getBytes();
}
public void decodeData(String b) {
}
}
处理
loop{
action = fastQueue.poll(30, TimeUnit.MILLISECONDS);
if (action != null) {
action.exec(this);
} else {
SystemClock.sleep(10); // 命令时间间隔
}
doCheckLoop(this)
}
doCheckLoop(IO io){
//根据当前的业务状态 和 检查的命令上次的执行成功时间来决定要不要下检查的命令 不需要直接return
//可以写对应的 业务manager 去管理自己的业务
switch(当前业务的码){
}
协议的格式：
out ：16字节的byte
in ：多行
网友评论