1

アプリケーションの継続性の概念をテスト/POC する方法。アプリケーションが接続を取得できず、プールから取得しようとするように、接続を保持するコードを作成しようとしました。これがアプリケーションの継続性をテストする正しい方法ではないことは確かですが、適切なシナリオを作成する方法がわかりません。

トランザクションの進行中にデータベースをダウンさせる唯一の方法ですか?

以下のコードを使用して、毎回新しい接続でプロシージャが 20 スレッドで 20 回呼び出される AC をシミュレートしました。私は、1 つのスレッドが接続を待って接続を待ち、時間内に接続を取得できなかったためにタイムアウトし、接続を取得するために引退するシナリオを作成しています。IS これは適切な AC テストです。(以下はテストクラスです)

package com.ac;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Statement;

import oracle.ucp.jdbc.PoolDataSourceFactory;
import oracle.ucp.jdbc.PoolDataSource;
import oracle.ucp.jdbc.ValidConnection;

import java.sql.ResultSet;

public class App {

    public static void main(String[] args) {
        try {
            new App().acSimulation();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public void acSimulation() throws Exception{

            final PoolDataSource  pds = PoolDataSourceFactory.getPoolDataSource();
            pds.setConnectionFactoryClassName("oracle.jdbc.replay.OracleDataSourceImpl");

            System.out.println("connection factory set");

            String URL = "jdbc:oracle:thin:@(DESCRIPTION = (TRANSPORT_CONNECT_TIMEOUT=3) (RETRY_COUNT=20)(FAILOVER=ON) " +
             " (ADDRESS = (PROTOCOL = TCP)(HOST = localhost)(PORT = 1521)) (CONNECT_DATA = " +
             " (SERVER = DEDICATED) (SERVICE_NAME=orcl)))";
            System.out.println("Using URL\n" + URL);
            pds.setURL(URL);
            pds.setUser("system");
            pds.setPassword("oracle");

            pds.setInitialPoolSize(1);
            pds.setMinPoolSize(1);
            pds.setMaxPoolSize(3);
            pds.setConnectionWaitTimeout(10);
            // RAC Features
            pds.setConnectionPoolName("Application Continuity Pool");
            pds.setFastConnectionFailoverEnabled(true);
            // use srvctl config nodeapps to get the ONS ports on the cluster
//          pds.setONSConfiguration("nodes=192.168.100.30:6200,192.168.100.32:6200");

            System.out.println("pool configured, trying to get a connection");

//          final Connection conn = null;


            final Connection conn = pds.getConnection();

            if (conn == null || !((ValidConnection) conn).isValid())  {

              System.out.println("connection is not valid");
              throw new Exception ("invalid connection obtained from the pool");
            }

            if ( conn instanceof oracle.jdbc.replay.ReplayableConnection ) {
              System.out.println("got a replay data source");
            } else {
              System.out.println("this is not a replay data source. Why not?");
            }

            System.out.println("got a connection! Getting some stats if possible");
            oracle.ucp.jdbc.JDBCConnectionPoolStatistics stats = pds.getStatistics();
            System.out.println("\tgetAvailableConnectionsCount() " + stats.getAvailableConnectionsCount());
            System.out.println("\tgetBorrowedConnectionsCount() " + stats.getBorrowedConnectionsCount() );
            System.out.println("\tgetRemainingPoolCapacityCount() " + stats.getRemainingPoolCapacityCount());
            System.out.println("\tgetTotalConnectionsCount() " + stats.getTotalConnectionsCount());

            System.out.println(((oracle.ucp.jdbc.oracle.OracleJDBCConnectionPoolStatistics)pds.getStatistics()).getFCFProcessingInfo());

            System.out.println("Now working");

            int i=0;
            while(i < 20){
                new Runnable() {
                    public void run() {                     
                        try {
                            seperateInstance(conn, pds);
                        } catch (SQLException e) {
                            e.printStackTrace();
                        }
                    }
                }.run();
                i++;
            }
    }

    private void seperateInstance(Connection conn, PoolDataSource pds) throws SQLException{
        java.sql.CallableStatement cstmt = null;
        oracle.ucp.jdbc.JDBCConnectionPoolStatistics stats = pds.getStatistics();

            conn = pds.getConnection();

            cstmt = conn.prepareCall("{call P_M_emp(?,?)}");
            cstmt.setLong(1, 1);
            cstmt.setString(2, "TEST");
            cstmt.execute();
            System.out.println("Statement executed. Now closing down");
            System.out.println("Almost done! Getting some more stats if possible");

            stats = pds.getStatistics();
            System.out.println("\tgetAvailableConnectionsCount() " + stats.getAvailableConnectionsCount());
            System.out.println("\tgetBorrowedConnectionsCount() " + stats.getBorrowedConnectionsCount() );
            System.out.println("\tgetRemainingPoolCapacityCount() " + stats.getRemainingPoolCapacityCount());
            System.out.println("\tgetTotalConnectionsCount() " + stats.getTotalConnectionsCount());

            System.out.println(((oracle.ucp.jdbc.oracle.OracleJDBCConnectionPoolStatistics)pds.getStatistics()).getFCFProcessingInfo());
            try {
                Thread.currentThread().sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("Closing connection "+ conn);
            cstmt.close();
            conn.close();
            conn = null;

    }

}

以下のサイトからコードを入手し、少し修正してスレッドを追加し、AC をシミュレートしました。しかし、再生可能なデータソースを取得できません。

https://martincarstenbach.wordpress.com/2013/12/13/playing-with-application-continuity-in-rac-12c/

4

1 に答える 1