java主从服务器的配置
2024-04-16 21:52:24
1.主从服务器的配置及实现原理
（1）主从服务的配置设计图
（2）主重服务器的配置
1.主服务器的配置
1.1打开配置文件
vim /etc/ my.cnf
2.2修改配置文件
server-id=1
log-bin=master-bin
log-bin-index=master-bin.index
2.3重启服务器
service mysqld restart
2.4查看服务器是否执行成功
SHOW MASTER STATUS
2.从服务器的配置
1.1打开配置文件
vim /etc/ my.cnf
2.2修改配置文件
server-id=2
relay-log-index=slave-relay-bin.index
relay-log=slave-relay-bin
2.3重启服务器
/etc/init.d/mysql stop
/etc/init.d/mysql start
2.4查看服务器是否执行成功
SHOW MASTER STATUS
2.5配置主服务的相关内容
create user repl;GRANT REPLICATION SLAVE ON *.* TO 'repl'@'115.28.159.6' IDENTIFIED BY 'mysql'flush privileges;
3.主从服务器的连接
3.1. 打开数据库（从服务器）
mysql -uroot -proot
3.2. 从库连接主库
change master to master_host='120.73.23.86' ,master_port=3306,master_user='repl',master_password='mysql',master-log-file='master-bin.000001',master_log_pos=0
**主ip ：120.73.23.86 主端口：master_port **
3.3. 查询从库状态(不正常)
show slave status \G;
出现以上：不能够正常同步
3.3.1 停止主重同步
stop slave;
3.4. 查询从库状态(正常)
4.数据远程导入到远程服务器上
4.1本地数据导入成本地文件
mysqldump -uroot -p o2o>o2o.sql
4.2导入到远程服务器上面
scp o2o.sql root@120.24.64.163:/root
4.3导入到远程服务器上面
//连接远程数据库
mysql -uroot -proot
//显示数据库信息
show databases;
//创建数据库
create database o2o;
//使用数据库
use o2o;
//引用o2o文件
source ~/o2o.sql
5.给主库设置用户，并设置访问权限
//创建用户，并赋予增、删、改、查的权限
GRANT select ,insert,update,delete ON *.* TO 'work'@'%' IDENTIFIED BY '230230' WITH GRANT OPTION//刷新权限
flush privileges;
（3）配置java代码
3.1 配置本地路由
1.DynamicDataSource.java文件
package com.imooc.o2o.dao.split;import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;public class DynamicDataSource extends AbstractRoutingDataSource{@Overrideprotected Object determineCurrentLookupKey() {return DynamicDataSourceHolder.getDbType();}}
2.DynamicDataSourceHolder.java文件
package com.imooc.o2o.dao.split;import org.slf4j.Logger;
import org.slf4j.LoggerFactory;public class DynamicDataSourceHolder {private static Logger logger=LoggerFactory.getLogger(DynamicDataSourceHolder.class);private static ThreadLocal<String> contextHolder=new ThreadLocal<String>();public static final String DB_MASTER="master";public static final String DB_SLAVE="slave";/*** 获取连接类型* @return*/public static String getDbType() {String db=contextHolder.get();if(db==null) {db=DB_MASTER;}return db;}/**** 设置连接类型* @param str*/public static void setDbType(String str) {logger.debug("所使用的数据源为："+str);contextHolder.set(str);}/***清理连接类型*/public static void clearDbType() {contextHolder.remove();}
}3.2 配置拦截器
package com.imooc.o2o.dao.split;import java.util.Locale;
import java.util.Properties;import org.apache.ibatis.executor.Executor;
import org.apache.ibatis.executor.keygen.SelectKeyGenerator;
import org.apache.ibatis.mapping.BoundSql;
import org.apache.ibatis.mapping.MappedStatement;
import org.apache.ibatis.mapping.SqlCommandType;
import org.apache.ibatis.plugin.Interceptor;
import org.apache.ibatis.plugin.Intercepts;
import org.apache.ibatis.plugin.Invocation;
import org.apache.ibatis.plugin.Plugin;
import org.apache.ibatis.plugin.Signature;
import org.apache.ibatis.session.ResultHandler;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.transaction.support.TransactionSynchronization;
import org.springframework.transaction.support.TransactionSynchronizationManager;@Intercepts({@Signature(type=Executor.class,method = "update",args = {MappedStatement.class,Object.class}),@Signature(type=Executor.class,method = "query",args = {MappedStatement.class,Object.class,ResultHandler.class})})
public class DynamicDataSourceInterceptor implements Interceptor{private static Logger logger=LoggerFactory.getLogger(DynamicDataSourceInterceptor.class);private static final String REGEX=".*insert\\u0020.|.*delete\\u0020.*|.*update\\u0020.*";/*** 拦截的方法*/public Object intercept(Invocation invocation) throws Throwable {boolean synchronizationActive=TransactionSynchronizationManager.isActualTransactionActive();Object[] objects=invocation.getArgs();MappedStatement ms=(MappedStatement)objects[0];String lookupKey=DynamicDataSourceHolder.DB_MASTER;if(!synchronizationActive) {//读方法if(ms.getSqlCommandType().equals(SqlCommandType.SELECT)) {//selectKey为自增id查询主键（SELECT LAST_INSERT_ID()）方法，使用主库if(ms.getId().contains(SelectKeyGenerator.SELECT_KEY_SUFFIX)) {lookupKey=DynamicDataSourceHolder.DB_MASTER;}else{BoundSql boundSql=ms.getSqlSource().getBoundSql(objects[2]);String sql=boundSql.getSql().toLowerCase(Locale.CHINA).replace("[\\t\\n\\r]", " ");if(sql.matches(REGEX)){lookupKey=DynamicDataSourceHolder.DB_MASTER;}else{lookupKey=DynamicDataSourceHolder.DB_SLAVE;}}}}else{lookupKey=DynamicDataSourceHolder.DB_MASTER;}logger.debug("设置方法[{}] use [{}] Strategy,SqlCommanType[{}]..",ms.getId(),lookupKey,ms.getSqlCommandType().name());DynamicDataSourceHolder.setDbType(lookupKey);return invocation.proceed();}/**** 返回封装好的对象*/public Object plugin(Object target) {if(target instanceof Executor) {return Plugin.wrap(target, this);}else {return target;}}public void setProperties(Properties properties) {// TODO Auto-generated method stub}}
3.3 配置主从数据库配置文件（jdbc.properties）
jdbc.driver=com.mysql.jdbc.Driver
jdbc.slave.url=jdbc:mysql://115.28.159.6:3306/o2o?useUnicode=true&characterEncoding=utf8
jdbc.master.url=jdbc:mysql://120.24.64.163:3306/o2o?useUnicode=true&characterEncoding=utf8
jdbc.usesname=root
jdbc.password=123
3.4 配置spring整合mybatis的配置文件（spring-dao.xml）
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context.xsd"><!-- 配置整合mybatis过程 --><!-- 1.配置数据库相关参数properties的属性：${url} --><context:property-placeholder location="classpath:jdbc.properties"/><!-- <bean class="com.imooc.myo2o.util.EncryptPropertyPlaceholderConfigurer"><property name="locations"><list><value>classpath:jdbc.properties</value><value>classpath:redis.properties</value></list></property><property name="fileEncoding" value="UTF-8" /></bean> --><!-- 修改部分 --><!-- 2.数据库连接池 --><bean id="abstractDataSource" abstract="true"class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close"><!-- c3p0连接池的私有属性 --><property name="maxPoolSize" value="30" /><property name="minPoolSize" value="10" /><!-- 关闭连接后不自动commit --><property name="autoCommitOnClose" value="false" /><!-- 获取连接超时时间 --><property name="checkoutTimeout" value="10000" /><!-- 当获取连接失败重试次数 --><property name="acquireRetryAttempts" value="2" /></bean><bean id="master" parent="abstractDataSource"><!-- 配置连接池属性 --><property name="driverClass" value="${jdbc.driver}" /><property name="jdbcUrl" value="${jdbc.master.url}" /><property name="user" value="${jdbc.usesname}" /><property name="password" value="${jdbc.password}" /></bean><bean id="slave" parent="abstractDataSource"><!-- 配置连接池属性 --><property name="driverClass" value="${jdbc.driver}" /><property name="jdbcUrl" value="${jdbc.slave.url}" /><property name="user" value="${jdbc.usesname}" /><property name="password" value="${jdbc.password}" /></bean><!-- 配置动态数据源，这儿targetDataSources就是路由数据源所对应的名称 --><bean id="dynamicDataSource" class="com.imooc.o2o.dao.split.DynamicDataSource"><property name="targetDataSources"><map><!-- value-ref与上面配置保持一致 key与实体类中保持一致--><entry value-ref="master" key="master"></entry><entry value-ref="slave" key="slave"></entry></map></property></bean><bean id="dataSource" class="org.springframework.jdbc.datasource.LazyConnectionDataSourceProxy"><property name="targetDataSources"><ref bean="dynamicDataSource"/></property></bean><!-- 3.配置SqlSessionFactory对象 --><bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"><!-- 注入数据库连接池 --><property name="dataSource" ref="dataSource" /><!-- 配置MyBaties全局配置文件:mybatis-config.xml --><property name="configLocation" value="classpath:mybatis-config.xml" /><!-- 扫描entity包 使用别名 --><property name="typeAliasesPackage" value="com.imooc.o2o.entity" /><!-- 扫描sql配置文件:mapper需要的xml文件 --><property name="mapperLocations" value="classpath:mapper/*.xml" /></bean><!-- 4.配置扫描Dao接口包，动态实现Dao接口，注入到spring容器中 --><bean class="org.mybatis.spring.mapper.MapperScannerConfigurer"><!-- 注入sqlSessionFactory --><property name="sqlSessionFactoryBeanName" value="sqlSessionFactory" /><!-- 给出需要扫描Dao接口包 --><property name="basePackage" value="com.imooc.o2o.dao" /></bean>
</beans>
3.5配置mybatis-config.xml文件
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd"><configuration><!-- 配置全局变量 --><settings><!-- 使用jdbc的useGeneratedKeys获取数据库自增主键值 --><setting name="useGeneratedKeys" value="true"/><!-- 使用列标签替换列别名 默认；true --><setting name="useColumnLabel" value="true"/><!-- 开启驼峰命名转换 --><setting name="mapUnderscoreToCamelCase" value="true"/></settings><!--配置拦截器 --><plugins><plugin interceptor="com.imooc.o2o.dao.split.DynamicDataSourceInterceptor"></plugin></plugins></configuration>
java主从服务器的配置相关推荐
- java导出服务器已经配置好的excel模板
采用springboot的项目架构. 目录结构 1. 前台代码(设置一个按钮) <!DOCTYPE html> <html lang="en" xmlns:th= ...
- mysql服务器架构_Mysql的主从服务器架构配置
所谓主从Mysql服务器架构,就是在主服务器上的操作同时也拷贝一份到从服务器上来. 接下来我使用两台机器做一下这个过程, 复制的作用: 1.数据分部 2.实现读的负载均衡 3.备份(本身不能备份,但是 ...
- linux怎么配置mysql数据库服务器_linux下指定mysql数据库服务器主从同步的配置实例...
一. 概念:① 数据库同步 (主从同步 --- 主数据库写的同时 往从服务器写数据) ② 数据库同步 (主主同步 --- 两台数据库服务器互相写数据) 二. 举例数据库服务器(A) 主数据库 ...
- JAVA EE Eclipse下配置Tomcat服务器
在进行Java web编程之前,必须要进行web服务器的配置,这里选择在Java EE(版本) Eclipse中进行服务器的配置.当然了,在安装Java EE Eclipse之前要先安装JDK,并且要 ...
- mySQL5.5服务配置_配置mysql5.5主从服务器(转)
教程开始: 一.安装MySQL 说明:在两台MySQL服务器192.168.21.169和192.168.21.168上分别进行如下操作,安装MySQL 5.5.22 二.配置MySQL主服务器(19 ...
- mysql主备数据库配置文档_MySQL数据库配置主从服务器实现双机热备实例教程
网站:bbs.osyunwei.com 程序在:Web服务器192.168.21.129上面 数据库在:MySQL服务器192.168.21.169上面 实现目的:增加一台MySQL备份服务器(192 ...
- [Domino]Java访问Domino必需配置的服务器设置
[Domino]Java访问Domino必需配置的服务器设置 编写者<?xml:namespace prefix = o ns = "urn:schemas-microsoft-com ...
- mysql8.0主从配置,MySQL 8.0主从服务器（Master-Slave）配置
一.介绍 MySQL 主从复制的方式有多种,本文主要演示基于基于日志(binlog)的主从复制方式. MySQL 主从复制(也称 A/B 复制) 的原理: Master将数据改变记录到二进制日志(bi ...
- linux本地mysql与服务器同步数据_linux下指定mysql数据库服务器主从同步的配置实例...
一. 概念:① 数据库同步 (主从同步 --- 主数据库写的同时 往从服务器写数据) ② 数据库同步 (主主同步 --- 两台数据库服务器互相写数据) 二. 举例数据库服务器(A) 主数据库 ...
最新文章
- 使用c#实现tcp的连接和发送接收数据
- C#访问网络共享文件夹，带用户名密码域，解决电脑重启后访问不到网络文件夹
- 迷茫的未来，我们需要做些什么呢？
- 用正交变换化二次型为标准形的具体步骤
- PDU （协议数据单元）
- 随着“造车时代”的企业网络推广之下，富士康也想入圈造车？
- poj 1637(混合图求欧拉回路)
- 设计模式:享元模式(Flyweight Pattern)
- 优秀自我简介200字_急需稿件，稿费200元起/篇 | 公众号【深夜秘杏酱】长期征稿（可签约）...
- 笔记本电脑风扇声音大_笔记本风扇噪音太大？教你怎么降低笔记本风扇噪音
- linux+yum安装终端php,centos下yum搭建安装linux+apache+mysql+php环境教程
- 为DPDK eal动态库添加新函数 ld不过的问题
- 验证码这种反人类的存在，浪费全球人口15万小时，有办法取缔吗？
- 计算机专业社会调研怎么写,计算机专业调研论文提纲格式 计算机专业调研论文提纲怎么写...
- HTTP GET 请求在请求体中带参数的问题
- 【数据库】一对一、一对多、多对多关系
- html页面实现图片滚动
- 爱奇艺校招map优先队列笔试题字符串的价值
- C#中实现两个程序的通信
- 直播带货代运营公司9人被抓