修改版本号以及启动前检测数据库是否正常启动

Administrator

2022-12-01 0ef5416a3042cec209053de412d3a2ff051b3ab1

修改版本号以及启动前检测数据库是否正常启动

 BattMonitor_FGCD-A059NT_Four/config.xml

@@ -2,7 +2,7 @@

<root>
  <mysql_ramdb_recreate_en>false</mysql_ramdb_recreate_en>
  <mysql_server_ip>192.168.10.79</mysql_server_ip>
  <mysql_server_ip>127.0.0.1</mysql_server_ip>
  <!--SOURCE_BATTDATA_TYPE_FBSDEV = 0-->
  <!--SOURCE_BATTDATA_TYPE_SQLSERVER = 1-->
  <!--SOURCE_BATTDATA_TYPE_C_INTERFACE = 2-->

 BattMonitor_FGCD-A059NT_Four/log4j2_battmonitor_fgcd_x64.xml

@@ -24,7 +24,13 @@
                <SizeBasedTriggeringPolicy size="20MB"/>

            </Policies>

            <!--保存日志文件个数-->

            <DefaultRolloverStrategy max="9"/>

            <!-- 删除策略配置 -->

            <DefaultRolloverStrategy max="5">

                <Delete basePath="${LOG_HOME}/" maxDepth="1">

                    <IfFileName glob="*.log.gz"/>

                    <IfLastModified age="7d"/>

                </Delete>

            </DefaultRolloverStrategy>

        </RollingFile>



        <!--error级别日志输出-->

@@ -37,7 +43,13 @@
                <TimeBasedTriggeringPolicy />

                <SizeBasedTriggeringPolicy size="20MB"/>

            </Policies>

            <DefaultRolloverStrategy max="9"/>

            <!-- 删除策略配置 -->

            <DefaultRolloverStrategy max="5">

                <Delete basePath="${LOG_HOME}/" maxDepth="1">

                    <IfFileName glob="*.log.gz"/>

                    <IfLastModified age="7d"/>

                </Delete>

            </DefaultRolloverStrategy>

        </RollingFile>

        

    </Appenders>


 BattMonitor_FGCD-A059NT_Four/src/main/main_Monitor_FGCD_A059NT.java

@@ -1,5 +1,7 @@
package main;



import java.sql.Connection;

import java.sql.SQLException;

import java.util.TimeZone;



import org.apache.logging.log4j.LogManager;

@@ -8,7 +10,6 @@
import com.battmonitor.base.AppParam;

import com.battmonitor.data.BattData_RT_Array;

import com.battmonitor.sql.MysqlConnPool;

import com.battmonitor.sql.Sql_Mysql;

import com.batttest.BattDataTestPro_Thread;

import com.config.AppConfig;

import com.dev.btse.comm.BattRealDataPro_Thread;

@@ -29,6 +30,7 @@
    private static MysqlConnPool GB_MysqlConnPool;

    private static BattData_RT_Array GB_DataArray;

    private static AppParam GB_App_Param;

    private static Logger logger;

    /*********************************************************************************************/

    /*********************************************************************************************/

    static {

@@ -44,7 +46,7 @@
        String ver = m_Version;

        MysqlServer_Port = DEF_MysqlServerFBS9100S_Port;

        

        Logger logger = LogManager.getLogger(main_Monitor_FGCD_A059NT.class);

        logger = LogManager.getLogger(main_Monitor_FGCD_A059NT.class);

        /*

        logger.debug("This is debug.");

        logger.info("This is an info.");

@@ -63,19 +65,7 @@
        logger.info("正在连接数据库 DBserver IP：" + m_AppConfig.getMysqlServerIp() + ", port: " + MysqlServer_Port);

        

        //初始化连接池中的各种参数信息

        GB_MysqlConnPool = new MysqlConnPool(m_AppConfig.getMysqlServerIp(), MysqlServer_Port, 
                                                m_AppConfig.getMysqlConnCountMax());

		
        Sql_Mysql sql_ck = new Sql_Mysql(GB_MysqlConnPool.getConn());

        try {

            if(null != sql_ck.mysql_con) {

                logger.info("成功连接数据库" 
                            + " DBserver IP：" + m_AppConfig.getMysqlServerIp() 
                            + ", port: " + MysqlServer_Port);

            }

        } finally {

            sql_ck.close_con();

        }

        checkingMySQLServerStart();

        logger.info("/****************************************************************/");

        /*

        try {

@@ -162,4 +152,38 @@
        }

        /*********************************************************************************/

    }

	
    public static void checkingMySQLServerStart(){

        logger.info(" MySQL server_source_ip："+m_AppConfig.getMysqlServerIp()+"\t server_source_port"+MysqlServer_Port);			
        //初始化连接池中的各种参数信息        m_AppConfig.getMysqlServerIp()

        GB_MysqlConnPool = new MysqlConnPool(m_AppConfig.getMysqlServerIp(), MysqlServer_Port, 5);

        while(true){

            Connection conn = null;

            try {

                logger.info(" 开始检测数据库连接 ");

                conn =  GB_MysqlConnPool.getMysqlConn();

                if(conn != null){

                    logger.info("检测数据库连接成功 ");

                    break;

                }else {

                    logger.info("连接数据库失败,稍后重新连接....");

                }

            } catch (Exception e) {

                try {

                    Thread.sleep(1000);

                } catch (InterruptedException e1) {

                    e1.printStackTrace();

                }

                System.out.println(" MySQL not Start ... ");

            } finally {

                if(conn != null) {

                    try {

                        conn.close();

                    } catch (SQLException e) {

                        e.printStackTrace();

                    }

                }

            }

        }

    }

}