Java使用分布式实现数据库读写分离的示例代码

public class DBUtil {
    private static final String MASTER_URL = "jdbc:mysql://localhost:3306/master_db";
    private static final String SLAVE_URL = "jdbc:mysql://localhost:3307/slave_db";

    // 主库数据源
    private static DataSource masterDataSource;

    // 从库数据源
    private static DataSource slaveDataSource;

    // 初始化方法，在系统启动时执行
    public void init() throws Exception {
        masterDataSource = createDataSource(MASTER_URL, "root", "");
        slaveDataSource = createDataSource(SLAVE_URL, "root", "");
        System.out.println("DBUtil initialized.");
     }

     // 创建指定URL、用户名和密码的数据源对象
     private DataSource createDataSource(String url, String username, String password) throws Exception {
         BasicDataSource dataSource = new BasicDataSource();
         dataSource.setDriverClassName("com.mysql.jdbc.Driver");
         dataSource.setUrl(url);
         dataSource.setUsername(username);
         dataSource.setPassword(password);
         return dataSource;
      }

      // 获取可用的Connection对象
      public Connection getConnection(boolean isReadOnly) throws SQLException{
          if(isReadOnly){
              return slaveDatasource.getConnection();
          }else{
              return masterDatasource.getConnection();
          }
       }
}

[mysqld]
log-bin=mysql-bin
server-id=1

GRANT REPLICATION SLAVE ON *.* TO 'slave_user'@'%' IDENTIFIED BY 'password';
FLUSH PRIVILEGES;

[mysqld]
server-id=2

CHANGE MASTER TO MASTER_HOST='192.168.0.100',MASTER_USER='slave_user',
MASTER_PASSWORD='password',MASTER_LOG_FILE='mysql-bin.xxxxxx',MASTER_LOG_POS=xxx;
START SLAVE;