1、common模块优化代码； 2、通信中间件优化代码，队列遍历由递归调用改为while循环，原因是队列数据量大时递归调易产生栈溢出，HashTabl...

liurunyu

2023-12-19 7f5d914898c9d05942705ce7d80c0d14a8174df8

 pipIrr-platform/pipIrr-mw/pipIrr-mw-accept/src/main/java/com/dy/aceMw/server/tasks/FromRtuConstantTask.java

@@ -17,24 +17,63 @@
     * 在单线程环境中运行
     */
    @Override
    public Integer excute() {
    public Integer execute() {
        try{
            return dealRtuUpData() ;
            dealRtuUpData() ;
        }catch(Exception e){
            log.error(e);
        }
        return null ;
        return RtuDataCache.size()>0?0:1 ;
    }

    /**
     * 处理上行数据
     */
    public Integer dealRtuUpData() {
    public void dealRtuUpData() {
        Node first = RtuDataCache.getFirstQueueNode() ;
        if(first != null){
            Node last = RtuDataCache.getLastQueueNode() ;
            while (last != null){
                last = this.doDealRtuUpData(first, last);
            }
        }
    }

    /**
     * 处理缓存的上行数据节点
     * @param first 第一个节点
     * @param last 最后一个节点
     */
    private Node doDealRtuUpData(Node first, Node last){
        if(last != null){
            if(first != last){
                //在dealNode方法中，可能要把last从队列中移除，这时last.pre为空，所以提前把last.pre取出来
                Node pre = last.pre ;
                dealNode(last) ;
                return pre ;
            }else{
                //停止
                return null ;
            }
        }else{
            return null ;
        }
    }


    ////////////////////////////////////////////////
    //
    //以下实现，采用了递归调用，当队列缓存结点很多时，会产生栈溢出异常
    //
    ////////////////////////////////////////////////
    /**
     * 处理上行数据
     */
    public Integer dealRtuUpData_() {
        Node first = RtuDataCache.getFirstQueueNode() ;
        if(first != null){
            Integer count = RtuDataCache.size() ;
            Node last = RtuDataCache.getLastQueueNode() ;
            this.doDealRtuUpData(first, last);
            this.doDealRtuUpData_(first, last);
            return count ;
        }
        return null ;
@@ -45,18 +84,15 @@
     * @param first 第一个节点
     * @param last 最后一个节点
     */
    private void doDealRtuUpData(Node first, Node last){
    private void doDealRtuUpData_(Node first, Node last){
        if(last != null){
            //在dealNode方法中，可能要把last从队列中移除，这时last.pre为空，所以提前把last.pre取出来
            Node pre = last.pre ;
            dealNode(last) ;
            if(first != null && first != last){
            if(first != last){
                doDealRtuUpData(first, pre) ;
            }else if(first != null && first == last){
            }else{
                //停止
            }else if(first == null){
                //这种情况不会存在
                doDealRtuUpData(null, pre) ;
            }
        }
    }