mysql主从搭建及java读写分离demo
下载mysql版本5.6
建议到mysql官方下载：https://dev.mysql.com/downloads/mysql/5.6.html#downloads
我的百度网盘也可下载：https://pan.baidu.com/s/1etS7z8CsRlyb_FlLSErxYA
提取码：ff64
文件名为：mysql-5.6.12-linux-glibc2.5-x86_64.tar.gz
添加用户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
注意：安装过程可能出现错误，需要分析逐一解决，常见错误有：
1、解决Can’t locate ExtUtils/MakeMaker.pm in @INC
解决方法：https://blog.csdn.net/celeste7777/article/details/77117371
yum install perl-ExtUtils-MakeMaker
2、gcc未安装错误：
解决方法：
https://blog.csdn.net/btt2013/article/details/78138045
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）：
代码我的github上可以直接下载：
https://github.com/sijunx/mySpider
代码比较多，需要简单搜索下
数据库连接设置
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();
}
}
在applicationContext.xml中设置bean:multipleDataSource