cmppinit.java

短信平台CMPP30 的JAVA程序,(含SQL数据库)

            maxMsgLenAscii = Integer.parseInt(node.getFirstChild().getNodeValue());
            if(internalDebugMode)
                System.out.println("maxMsgLenAscii:" + maxMsgLenAscii);
        } else
        if(node.getNodeName().equals("maxMsgLenOther"))
        {
            maxMsgLenOther = Integer.parseInt(node.getFirstChild().getNodeValue());
            if(internalDebugMode)
                System.out.println("maxMsgLenOther:" + maxMsgLenOther);
        } else
        if(node.getNodeName().equals("version"))
        {
            version = node.getFirstChild().getNodeValue();
            if(internalDebugMode)
                System.out.println("version:" + version);
        } else
        if(node.getNodeName().equals("activeTestWaitedTime"))
        {
            activeTestWaitedTime = Integer.parseInt(node.getFirstChild().getNodeValue());
            if(internalDebugMode)
                System.out.println("activeTestWaitedTime:" + activeTestWaitedTime + "s");
        } else
        if(node.getNodeName().equals("activeTestReSendTime"))
        {
            activeTestReSendTime = Integer.parseInt(node.getFirstChild().getNodeValue());
            if(internalDebugMode)
                System.out.println("activeTestReSendTime:" + activeTestReSendTime + "s");
        } else
        if(node.getNodeName().equals("activeTestMaxSendCounts"))
        {
            activeTestMaxSendCounts = Integer.parseInt(node.getFirstChild().getNodeValue());
            if(internalDebugMode)
                System.out.println("activeTestMaxSendCounts:" + activeTestMaxSendCounts);
        } else
        if(node.getNodeName().equals("packetsReSendTime"))
        {
            packetsReSendTime = Integer.parseInt(node.getFirstChild().getNodeValue());
            if(internalDebugMode)
                System.out.println("packetsReSendTime:" + packetsReSendTime + "s");
        } else
        if(node.getNodeName().equals("packetsMaxSendCounts"))
        {
            packetsMaxSendCounts = Integer.parseInt(node.getFirstChild().getNodeValue());
            if(internalDebugMode)
                System.out.println("packetsMaxSendCounts:" + packetsMaxSendCounts);
        } else
        if(node.getNodeName().equals("socketTimeOut"))
        {
            socketTimeOut = Integer.parseInt(node.getFirstChild().getNodeValue());
            if(internalDebugMode)
                System.out.println("socketTimeOut:" + socketTimeOut + "s");
        } else
        if(node.getNodeName().equals("slideWindowSize"))
        {
            slideWindowSize = Integer.parseInt(node.getFirstChild().getNodeValue());
            if(internalDebugMode)
                System.out.println("slideWindowSize:" + slideWindowSize);
        } else
        if(node.getNodeName().equals("sendQueueCapacity"))
        {
            sendQueueCapacity = Integer.parseInt(node.getFirstChild().getNodeValue());
            if(internalDebugMode)
                System.out.println("sendQueueCapacity:" + sendQueueCapacity);
        } else
        if(node.getNodeName().equals("activeTestThreadSleepTime"))
        {
            activeTestThreadSleepTime = Integer.parseInt(node.getFirstChild().getNodeValue());
            if(internalDebugMode)
                System.out.println("activeTestThreadSleepTime:" + activeTestThreadSleepTime + "ms");
        } else
        if(node.getNodeName().equals("sendThreadSleepTime"))
        {
            sendThreadSleepTime = Integer.parseInt(node.getFirstChild().getNodeValue());
            if(internalDebugMode)
                System.out.println("sendThreadSleepTime:" + sendThreadSleepTime + "ms");
        } else
        if(node.getNodeName().equals("recvThreadSleepTime"))
        {
            recvThreadSleepTime = Integer.parseInt(node.getFirstChild().getNodeValue());
            if(internalDebugMode)
                System.out.println("recvThreadSleepTime:" + recvThreadSleepTime + "ms");
        } else
        {
            if(!node.getNodeName().equals("isDebugMode"))
                break MISSING_BLOCK_LABEL_2243;
            if(node.getFirstChild().getNodeValue().trim().equals("true"))
                isDebugMode = true;
            else
                isDebugMode = false;
            if(internalDebugMode)
                System.out.println("isDebugMode:" + isDebugMode);
        }
        try
        {
        }
        catch(NullPointerException npe)
        {
            hasNullPointerException = true;
            if(internalDebugMode)
            {
                System.out.println("CMPPAPIs::getNodeData::NullPointerException");
                npe.printStackTrace(System.out);
            }
        }
        catch(NumberFormatException nfe)
        {
            hasNumberFormatException = true;
            if(internalDebugMode)
                System.out.println("CMPPAPIs::getNodeData::NumberFormatException");
            nfe.printStackTrace();
            Logger.writeLog(-1, "在读取初始化文件中xml数据并将其转化为整数时发生NumberFormatException!", "cmpp");
        }
        if(node.hasChildNodes())
        {
            for(int i = 0; i < node.getChildNodes().getLength(); i++)
                getNodeData(node.getChildNodes().item(i));

        }
        return;
    }

    public int getPacketsMaxSendCounts()
    {
        return packetsMaxSendCounts;
    }

    public int getPacketsReSendTime()
    {
        return packetsReSendTime * 1000;
    }

    public int getReConnectWaitedTime()
    {
        return reConnectWaitedTime * 1000;
    }

    public int getRecvThreadSleepTime()
    {
        return recvThreadSleepTime;
    }

    public int getSendQueueCapacity()
    {
        return sendQueueCapacity;
    }

    public int getSendThreadSleepTime()
    {
        return sendThreadSleepTime;
    }

    public int getSlideWindowSize()
    {
        return slideWindowSize;
    }

    public int getSocketTimeOut()
    {
        return socketTimeOut * 1000;
    }

    public String getSpId()
    {
        return spId;
    }

    public String getSpPwd()
    {
        return spPwd;
    }

    public String getVersion()
    {
        return version;
    }

    public boolean hasTwoPort()
    {
        return mtPort != moPort;
    }

    public int init(String cmppInitFile)
    {
        int result;
        DOMParser parser;
        result = 0;
        parser = new DOMParser();
        parser.setFeature("http://xml.org/sax/features/validation", false);
        parser.setFeature("http://apache.org/xml/features/continue-after-fatal-error", false);
        parser.setErrorHandler(new MyErrorHandle());
        parser.parse(cmppInitFile);
        Document document = parser.getDocument();
        getNodeData(document.getDocumentElement());
        if(hasNullPointerException)
            return -4;
        if(hasNumberFormatException)
            return -3;
        hostIp = gatewayHost;
        if(hostIp != null && hostIp.trim().length() != 0)
            break MISSING_BLOCK_LABEL_119;
        Logger.writeLog(-2, "初始化文件中数据无效--Invalid HostIp-长度为0，CMPP通信模块初始化失败！", "cmpp");
        return -8;
        if(mtPort > 0 && moPort > 0 && activeTestWaitedTime > 0 && activeTestReSendTime > 0 && activeTestMaxSendCounts > 0 && packetsReSendTime > 0 && packetsMaxSendCounts > 0 && reConnectWaitedTime >= 0 && slideWindowSize > 0 && sendQueueCapacity > 0 && socketTimeOut > 0 && activeTestThreadSleepTime >= 0 && sendThreadSleepTime >= 0 && recvThreadSleepTime >= 0)
            break MISSING_BLOCK_LABEL_230;
        Logger.writeLog(-2, "初始化文件中数据无效--包含负数或0，CMPP通信模块初始化失败！", "cmpp");
        return -9;
        try
        {
        }
        catch(SAXException se)
        {
            Logger.writeLog(-2, "初始化时遇到SAX_EXCEPTION--XML文件的格式不合法，CMPP通信模块初始化失败！请检查初始化文件的有效性！", "cmpp");
            result = -10;
            return result;
        }
        catch(IOException ie)
        {
            Logger.writeLog(-2, "初始化时遇到IO_EXCEPTION-找不到文件（" + cmppInitFile + "）-CMPP通信模块初始化失败！", "cmpp");
            result = -11;
            return result;
        }
        catch(Exception e)
        {
            Logger.writeLog(-2, "初始化时遇到EXCEPTION--CMPP通信模块初始化失败!\n" + e.toString(), "cmpp");
            result = -12;
            return result;
        }
        return result;
    }

    public boolean isDebugMode()
    {
        return isDebugMode;
    }

    public static void main(String args[])
    {
        CMPPInit init2 = new CMPPInit();
        init2.init("./config/CMPP3_0Config.xml");
    }
}