啥都不說，先吐槽，吐槽技術中心，吐槽部門，能不能讓我安安全全的使用，不要扔個個東西來就讓我用，在開發環境沒有kerberos，來了上正式，直接給布上，你讓我這連kerberos都不知道是啥的java開發人員咋搞，完，寫一下自己通過連線池連線存在kerberos認證的impala+kudu資料庫。

先說啥是kerberos：

“Kerberos 服務”是一種客戶機/伺服器體系結構，用於在網路上提供安全事務。該服務可提供功能強大的使用者驗證以及完整性和保密性。通過驗證，可保證網路事務的傳送者和接收者的身份真實。該服務還可以檢驗來回傳遞的資料的有效性（完整性），並在傳輸過程中對資料進行加密（保密性）。使用 Kerberos 服務，可以安全登入到其他計算機、執行命令、交換資料以及傳輸檔案。此外，該服務還提供授權服務，這樣，管理員便可限制對服務和計算機的訪問。而且，作為 Kerberos 使用者，您還可以控制其他使用者對您帳戶的訪問。

解決方式及途徑：

當時先在網上找資料，發現網上沒有連線池連線的，只有通過JDBC直連的，程式碼如下：

public class App4 {
    public static void main(String[] args) throws ClassNotFoundException {
        String driverName="org.apache.hive.jdbc.HiveDriver";
        Class.forName("org.apache.hive.jdbc.HiveDriver");
        String url = "jdbc:hive2://135.12.70.35:21055/;principal=impala/
 
[email protected]";
        
        Configuration conf = new Configuration();
        conf.set("hadoop.security.authentication", "Kerberos");
        try {
            System.setProperty("java.security.krb5.conf", "resource/krb5.conf");
            UserGroupInformation.setConfiguration(conf);
            UserGroupInformation.loginUserFromKeytab("impala/
 
[email protected]", "resource/impala.haproxy.keytab");
        } catch (IOException e) {
            e.printStackTrace();
        }
        try {
            Class.forName(driverName);
            Connection conn = DriverManager.getConnection(url);
            Statement stmt = conn.createStatement();
            String sql = "select * from test1";
            ResultSet rs = stmt.executeQuery(sql);
            while (rs.next()) {
                System.out.println(rs.getInt(1));
            }
            stmt.close();
            rs.close();
            conn.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

通過上面發現，咋的，連線前先驗證，但是連線池的init方法根本不用我寫，這個咋搞，這時候我的思維進入了誤區，想是不是需要修改連線池的原始碼，所以我寫了了類繼承DruidDataSource，重寫了init方法在這上面加上kerberos驗證，但是這種方法能實現，其實很錯誤，這可能我受了傳統資料庫的影響，以為每次建立連線都得驗證，其實kerberos是單點登陸的，是伺服器之間的通訊，後來在領導的指導下，我採用了listener在專案啟動時，對專案啟動時驗證，監聽器如下：

public class GetConnListener implements ServletContextListener{
	private static Logger log = LoggerFactory.getLogger(GetConnListener.class) ;
	private static final  Configuration kuduconf = new Configuration();
	public static void initkerberos() throws IOException
	{
		 File directory = new File("");// 引數為空
	     String courseFile = directory.getCanonicalPath();
		 Configuration	conf = getKuduConf();
	     try {
	            System.setProperty("java.security.krb5.conf", courseFile+"/WebRoot/krb5.conf");
	            UserGroupInformation.setConfiguration(conf);
	            UserGroupInformation.loginUserFromKeytab("[email protected]", courseFile+"/WebRoot/impala.haproxy.keytab");
	        } catch (IOException e) {
	            e.printStackTrace();
	        }
	       log.info("Kerberos驗證程式") ;
	}
	@Override
	public void contextDestroyed(ServletContextEvent arg0) {
		
	}
	@Override
	public void contextInitialized(ServletContextEvent arg0) {
		try {
			initkerberos();
		} catch (IOException e) {
			e.printStackTrace();
		}
		log.info("Kerberos初始化完成") ;
	}
	public static Configuration getKuduConf(){
		kuduconf.set("hadoop.security.authentication", "Kerberos");
		return kuduconf;
	}
}

值得注意的是監聽器的順序，認證的這個監聽器放在最上面，如下：

	<listener>
     			<listener-class>sjgl.system.GetConnListener</listener-class>
  	</listener>
	<!-- Spring監聽配置，Web容器啟動自動裝配ApplicationContext的配置資訊-->
	<listener>
		<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
	</listener>

但是不知道我看kerberos好像24小時失效，然後寫了個定時任務及時認證，但是好像認證一次就不需要重複認證，他自己重新整理，我也沒管，保險起見，排程如下：

@Service
public class reloadkbs {
	private static Logger log = LoggerFactory.getLogger(reloadkbs.class) ;
	@Scheduled(fixedRate = 1000*60*60*23)  
	public void reloadkerberos() throws IOException{
		GetConnListener.initkerberos();
		log.info("Kerberos重新驗證完成") ;
	}
}

但是在使用連線池時也遇到過連線池的問題例如，連線池隔一天斷開，重啟服務正常，錯誤提示：[Request processing failed; nested exception is org.hibernate.exception.GenericJDBCException: could not inspect JDBC autocommit mode] with root cause

java.net.SocketException: Software caused connection abort: socket write error

我按照druid的示例配置了最小連線數，以及檢測連線開啟，但是沒用的？請問怎麼看druid的保持連線池最小連線的檢測日誌輸出？？？我看看有沒有檢測連線。

解決方案：首先更改wait_timeout是不好的。

用如下配置可以解決：

<property name="validationQuery" value="select 1" />
  <property name="testWhileIdle" value="true" />
  <property name="testOnBorrow" value="false" />
  <property name="testOnReturn" value="false" />
  <property name="timeBetweenEvictionRunsMillis" value="600000" />

testWhileIdle：建議配置為true，不影響效能，並且保證安全性。申請連線的時候檢測，如果空閒時間大於

timeBetweenEvictionRunsMillis，執行validationQuery檢測連線是否有效。

testOnBorrow：申請連線時執行validationQuery檢測連線是否有效，做了這個配置會降低效能。

testOnReturn：歸還連線時執行validationQuery檢測連線是否有效，做了這個配置會降低效能

另外：大家七夕快樂，今年七夕我還是一個人。