\u56e0\u4e3a\u9879\u76ee\u4e2d\u6709\u591a\u4e2acobar\u8282\u70b9\uff0c\u73b0\u5728\u53ea\u662f\u8fde\u63a5\u7684\u5355\u4e00cobar\u8282\u70b9\uff0c\u60f3\u4fee\u6539\u4e3a\u8fde\u63a5\u591a\u4e2acobar\u8282\u70b9\uff0c\u5931\u8d25\u540e\uff0c\u81ea\u52a8\u5207\u6362\u81f3\u5176\u5b83\u8282\u70b9\u3002<\/p>\n
\u539f\u6765\u770bdruid\u65f6\uff0c\u5370\u8c61\u4e2d\u6709druid-ha\uff0c\u9ad8\u9ad8\u5174\u5174\u62ff\u8fc7\u6765\u7528\uff0c\u53d1\u73b0\u65e0\u6cd5\u4f7f\u7528\uff0c\u518d\u770b\u6e90\u7801\uff0c\u53d1\u73b0\u6839\u672c\u5c31\u6ca1\u5b9e\u73b0\u561b\u3002<\/p>\n
\u5728\u7f51\u4e0a\u641c\u7d22\u4e86\u4e0b\uff0c\u76f8\u5173\u7684\u8d44\u6e90\u4e5f\u4e0d\u662f\u975e\u5e38\u591a\u3002<\/p>\n
\u597d\u5728\u9700\u6c42\u5f88\u7b80\u5355\u53ef\u4ee5\u81ea\u5df2\u6765\u9020\u4e2a\u8f6e\u5b50\u3002<\/p>\n
\u4ee3\u7801\u5982\u4e0b\uff1a<\/p>\n
package cn.joylab.game.util;\r\n\r\nimport java.sql.Connection;\r\nimport java.util.List;\r\n\r\nimport javax.sql.DataSource;\r\n\r\nimport org.apache.commons.lang.math.RandomUtils;\r\nimport org.apache.commons.logging.Log;\r\nimport org.apache.commons.logging.LogFactory;\r\nimport org.springframework.jdbc.datasource.AbstractDataSource;\r\n\r\npublic class HADataSource extends AbstractDataSource {\r\n\r\n\tprivate List<DataSource> targetDataSources;\r\n\tprivate int index = RandomUtils.nextInt(2);\r\n\r\n\tpublic List<DataSource> getTargetDataSources() {\r\n\t\treturn targetDataSources;\r\n\t}\r\n\r\n\tpublic void setTargetDataSources(List<DataSource> targetDataSources) {\r\n\t\tthis.targetDataSources = targetDataSources;\r\n\t}\r\n\r\n\tpublic Connection getConnection() {\r\n\t\tlog.info("getConnection()");\r\n\t\tfor (int m = 0; m < targetDataSources.size(); m++) {\r\n\t\t\ttry {\r\n\t\t\t\tDataSource dataSource = targetDataSources.get(index);\r\n\t\t\t\tConnection conn = dataSource.getConnection();\r\n\t\t\t\tlog.info("getConnenction success from index : " + index);\r\n\t\t\t\treturn conn;\r\n\t\t\t} catch (Exception e) {\r\n\t\t\t\tindex = (++index) % targetDataSources.size();\r\n\t\t\t\tlog.error("ERROR", e);\r\n\t\t\t}\r\n\t\t}\r\n\t\tthrow new RuntimeException("db connection error");\r\n\t}\r\n\r\n\tpublic Connection getConnection(String username, String password) {\r\n\t\tlog.info("getConnection() with username and password");\r\n\t\treturn null;\r\n\t}\r\n\r\n\tprivate static final Log log = LogFactory.getLog(HADataSource.class);\r\n}<\/pre>\n\u53ea\u662f\u7b80\u5355\u7684\u8fdb\u884c\u4e0bdatasource\u7684\u5207\u6362\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"
\u56e0\u4e3a\u9879\u76ee\u4e2d\u6709\u591a\u4e2acobar\u8282\u70b9\uff0c\u73b0\u5728\u53ea\u662f\u8fde\u63a5\u7684\u5355\u4e00cobar\u8282\u70b9\uff0c\u60f3\u4fee\u6539\u4e3a\u8fde\u63a5\u591a …<\/p>\n