mysql主從搭建及java讀寫分離demo
下載mysql版本5.6
新增使用者mysql和組myGroup
useradd mysql
groupadd myGroup
usermod -G myGroup mysql
初始化mysql使用者名稱密碼:
passwd mysql
解壓mysql
下載好的檔案儲存到到/usr/local/目錄
tar -zxvf mysql-5.6.12-linux-glibc2.5-x86_64.tar.gz
重新命名目錄(命名為：mysql)
cd /usr/local
mv mysql-5.6.12-linux-glibc2.5-x86_64 mysql
改變目錄許可權
chown -R mysql:myGroup /usr/local/mysql
注意:-R引數表示遞迴改變，也即子目錄的許可權同樣改變
安裝mysql
/usr/local/mysql/scripts/mysql_install_db --user=mysql --basedir=/usr/local/mysql --datadir=/usr/local/mysql/data
yum install perl-ExtUtils-MakeMaker
yum -y install gcc
yum -y install gcc-c++
新增mysql啟動服務
cp /usr/local/mysql/support-files/mysql.server /etc/init.d/mysql
修改mysql配置
vi /usr/local/mysql/my.cnf
注意：埠號，服務號，binlog, relay-log都要開啟(以下為slave的配置)
[mysqld]
log_bin=/usr/local/mysql/data/mysql-bin
relay_log=slave-relay-bin
relay_log_index=slave-relay-bin.index
port =3307
server_id =890
新增環境變數
vi /etc/profile
新增環境變數
export MYSQL_HOME=/usr/local/mysql
PATH=PATH
文字有點失真，以圖片為準：
生效環境變數：
source /etc/profile
注意：安裝了mysql以後，建議重啟下伺服器（若為環境變數的生效，則不需要重啟）
設定資料庫root密碼
登入資料庫（注意：首次登入不需要輸入密碼，登入以後設定root密碼）：
mysql -u root -p
use mysql;
UPDATE user SET password=PASSWORD(‘123456’) WHERE user=‘root’;
flush privileges;
注意：flush執行以後密碼設定才能生效
主庫增加mysql使用者名稱的訪問許可權
進入主庫伺服器
cd /usr/local/mysql/bin
注意：執行以下命令後，輸入上步已經設定好的root密碼
mysql -u root -p
建立使用者：mysql
create user mysql;
設定mysql使用者的登入密碼：
UPDATE user SET password=PASSWORD(‘123456’) WHERE user=‘mysql’;
生效設定（這步別忘記嘍，否則無效）
flush privileges;
另外一臺從機器遠端連線測試下：
cd /usr/local/mysql/bin
mysql -h 121.175.107.11 -P 3306 -u mysql -p
檢視主庫的binlog偏移量position：
cd /usr/local/mysql/bin
mysql -u root -p
show master status;
開啟slave同步
進入從伺服器
cd /usr/local/mysql/bin
mysql -u root -p
注意：1、假設主伺服器的IP：192.168.0.104
2、master伺服器產生的日誌master-bin序號為為如上截圖001780
3、日誌偏移位置：16258
change master to master_host=‘192.168.0.104’,
master_port=3306,
master_user=‘mysql’,
master_password=‘123456’,
master_log_file=‘mysql-bin.001780’,
master_log_pos=16612;
啟動Slave開啟同步
start slave;
show slave status\G;
注意：如果slave_io_running和slave_sql_running都為yes，那麼表明可以成功同步了。
io狀態為no的常見問題分析：
1、檢查master的日誌的序號和偏移量，從庫連線master指定引數確認一致。
java主從讀寫分離（springMVC、Druid）：
資料庫連線設定
application.properties配置：
#Settings for DB
jdbc.driverClassName=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://121.40.187.38:3306/spider-dev?useUnicode=true&characterEncoding=UTF-8
jdbc.url_ut=jdbc:mysql://121.40.187.38:3306/spider-dev?useUnicode=true&characterEncoding=UTF-8
jdbc.username=root
jdbc.password=11111
jdbc.url_slave=jdbc:mysql://134.175.107.11:3307/spider-dev?useUnicode=true&characterEncoding=UTF-8
jdbc.username_slave=root
jdbc.password_slave=11111
jdbc.initialSize=5
jdbc.maxTotal=10
jdbc.maxWaitMillis=60000
jdbc.maxIdle=3
jdbc.minIdle=1
jdbc.removeAbandonedOnMaintenance=true
jdbc.removeAbandonedTimeout=60
jdbc.timeBetweenEvictionRunsMillis=30000
jdbc.numTestsPerEvictionRun=2
jdbc.testOnBorrow=true
jdbc.testOnReturn=true
jdbc.maxActive=10
資料來源（德魯伊Druid）配置
<bean id="baseDataSource" abstract="true" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
<property name="driverClassName" value="${jdbc.driverClassName}" />
<!--<property name="removeAbandonedOnMaintenance" value="${mogo.hulu.jdbc.removeAbandonedOnMaintenance}" />-->
<property name="removeAbandonedTimeout" value="${jdbc.removeAbandonedTimeout}" />
<property name="timeBetweenEvictionRunsMillis" value="${jdbc.timeBetweenEvictionRunsMillis}" />
<!--<property name="numTestsPerEvictionRun" value="${mogo.hulu.jdbc.numTestsPerEvictionRun}" />-->
<property name="testOnBorrow" value="${jdbc.testOnBorrow}" />
<property name="testOnReturn" value="${jdbc.testOnReturn}" />
<property name="testWhileIdle" value="true" />
<property name="validationQuery" value="select 'x' " />
<property name="logAbandoned" value="true" />
<!-- 開啟Druid的監控統計功能 -->
<!-- <property name="proxyFilters">
<list>
<ref bean="log-filter" />
<ref bean="stat-filter" />
<ref bean="wall-filter" />
</list>
</property> -->
</bean>
<!--定義資料來源 DBCP 連線池 -->
<bean id="dataSource" parent="baseDataSource">
<property name="url" value="${jdbc.url}" />
<property name="username" value="${jdbc.username}" />
<property name="password" value="${jdbc.password}" />
<property name="initialSize" value="${jdbc.initialSize}" />
<property name="minIdle" value="${jdbc.minIdle}" />
<property name="maxActive" value="${jdbc.maxActive}" />
</bean>
<!--定義資料來源 DBCP 連線池 -->
<bean id="dataSource_slave" parent="baseDataSource">
<property name="url" value="${jdbc.url_slave}" />
<property name="username" value="${jdbc.username_slave}" />
<property name="password" value="${jdbc.password_slave}" />
<property name="initialSize" value="${jdbc.initialSize}" />
<property name="minIdle" value="${jdbc.minIdle}" />
<property name="maxActive" value="${jdbc.maxActive}" />
</bean>
<!-- 多資料來源配置 -->
<bean id="multipleDataSource" class="com.mgzf.sdk.datasource.multi.MultiDataSource" primary="true">
<property name="targetDataSources">
<map key-type="java.lang.String">
<entry value-ref="dataSource" key="dataSource" />
<entry value-ref="dataSource_slave" key="dataSource_slave" />
</map>
</property>
<!-- 預設使用原來的資料來源 -->
<property name="defaultTargetDataSource" ref="dataSource_slave" />
</bean>
切換從庫（java程式碼）
@Service
public class DemoTestServiceImpl implements IDemoTestService{
@Autowired
private SpiderReverseIndexDAO spiderReverseIndexDAO;
@Override
public void testHello(){
//切換從庫
MultiDataSourceContextHolder.setDbType("dataSource_slave");
System.out.println("dao 切從庫 開始");
List<SpiderReverseIndexEntity> dataList = spiderReverseIndexDAO.findListByWord("網頁");
System.out.println("dataList:"+dataList.get(0).getTitle());
System.out.println("dao 切從庫 結束");
}
}
切換從庫（本地縣城變數）
package com.mgzf.sdk.datasource.multi;
public class MultiDataSourceContextHolder {
public static ThreadLocal contextHolder = new ThreadLocal();
public static ThreadLocal datasourceHolder = new ThreadLocal();
public static final String DEFAULT_DATA_SOURCE = “dataSource”;
public MultiDataSourceContextHolder() {
}
public static void setDbType(String dbType) {
contextHolder.set(dbType);
}
public static String getDbType() {
if (contextHolder.get() == null) {
contextHolder.set("dataSource");
}
return (String)contextHolder.get();
}
public static void setDatasource(String url) {
datasourceHolder.set(url);
}
public static String getDatasource() {
return (String)datasourceHolder.get();
}
public static void clearDbType() {
contextHolder.remove();
datasourceHolder.remove();
}
}