springboot+mycat数据库中间件+mysql（一主一备）主从复制（教程）

springboot+mycat数据库中间件+mysql（一主一备）主从复制（教程）

硬件：3台linux系统虚拟主机，Ip分别为192.168.43.23做主库（读写，192.168.43.12备库（读），192.168.43.155（安装mycat数据库中间件）

1.mycat读写分离架构图

主要实现原理：

2. linux下使用yum安装mysql

（mastr192.168.43.23,slave192.168.43.12）

2.1安装mysql 服务器端：

yuminstall mysql-server

yuminstall mysql-devel

2.2编辑mastr192.168.43.23 mysql配置文件

vim /etc/my.conf加入

default-character-set=utf8//设置字符集

server_id=23//服务id

log-bin=mysql-bin//开启日志

2.3编辑slave192.168.43.12配置文件

vim /etc/my.conf 加入

default-character-set=utf8

server_id=12

log-bin=mysql-bin

binlog_do_db=everyday//表示要同步的主机数据库实例是everyday

2.4创建root管理员

mysqladmin -u root password 123456

2.5登录

mysql -uroot -p输入密码即可。

3.开放远程连接权限（开放所有IP以root账号连接）

GRANTALLPRIVILEGESON*.*TO'root'@'%'IDENTIFIEDBY'123456' WITH GRANTOPTION;

4同步主从数据库

 

4.1主服务器给从服务器授权

 

登录mysql主服务器，执行sql:

grant replication slave on *.* to 'root'@'192.168.43.12'identified by '123456';FLUSHPRIVILEGES;

然后执行此语句SHOW MASTER STATUS：

4.2登录mysql从服务器，执行sql

STOP SLAVE;

change master tomaster_host='192.168.43.23',master_user='root',master_password='123456',

master_log_file='mysql-bin.000007',master_log_pos=2070;

START SLAVE;

然后执行该语句：SHOW SLAVE STATUS查询到结果yes,yes 说明同步成功

数据同步原理：通过同步2进制sql文件mysql-bin.000007进行同步，包含delete,insert,update等操作记录。

5.安装mycat数据库中间件

什么是mycat

一个彻底开源的，面向企业应用开发的大数据库集群

支持事务、ACID、可以替代MySQL的加强版数据库

一个可以视为MySQL集群的企业级数据库，用来替代昂贵的Oracle集群

一个融合内存缓存技术、NoSQL技术、HDFS大数据的新型SQLServer

结合传统数据库和新型分布式数据仓库的新一代企业级数据库产品

一个新颖的数据库中间件产品

5.1.安装mycat(192.168.43.155)

解压 tar zxvfMycat-server-1.6-RELEASE-20161028204710-linux.tar.gz -C /usr/local/

移动到/usr/local目录 mv mycat/usr/local

cd /usr/local/mycat/bin

./mycatstart启动
./mycat stop 停止

5.2配置mycat实现读写分离

# vim /usr/local/mycat/conf/server.xml //新增2个账号用来登录mycat,添加以下内容

   //mycat用户名

 mycat //mycat密码

 mydb  //mycat虚拟数据库名

 true  //只读

 

 

 

 mycat

 mydb

 

在这里要注意，默认的虚拟数据名是TESTDB，如果schema.xml里面没有配置testdb，那就要把testdb改成schema.xml里面有的虚拟数据名。这里定义的用户名和密码，虚拟数据库名，并不是在mysql中真实存在的。

：wq 保存退出

vim schema.xml

配置schema.xml

//定义虚拟数据库名mydb
 //真实数据库名test
select user() //真实数据库的连接方式
     //同上

mycat的配置参数，相当的多。重点说一下 balance="1"与writeType="0"

a.balance 属性负载均衡类型，目前的取值有 4 种：

1.balance="0",不开启读写分离机制，所有读操作都发送到当前可用的 writeHost上。

2.balance="1"，全部的 readHost与 stand by writeHost 参与 select 语句的负载均衡，简单的说，当双主双从模式(M1 ->S1 ， M2->S2，并且 M1 与M2 互为主备)，正常情况下， M2,S1,S2 都参与 select 语句的负载均衡。

3.balance="2"，所有读操作都随机的在 writeHost、 readhost 上分发。

4.balance="3"， 所有读请求随机的分发到 wiriterHost对应的 readhost 执行,writerHost 不负担读压力，注意 balance=3 只在 1.4 及其以后版本有， 1.3 没有。

b.writeType属性

负载均衡类型，目前的取值有 3种：

1.writeType="0",所有写操作发送到配置的第一个 writeHost，第一个挂了切到还生存的第二个

writeHost，重新启动后已切换后的为准，切换记录在配置文件中:dnindex.properties.

2.writeType="1"，所有写操作都随机的发送到配置的 writeHost。

3. writeType="2"，没实现。

# ./mycat start

Starting Mycat-server...

 

# netstat -tpnl |grep 8066

tcp 0 0 :::8066 :::* LISTEN 31728/java

 

# ./mycat status


Mycat-server is running (31726).

6 配置完成之后添加数据测试

登录windows系统中的mysql客户端进行连接

mycat连接方式如下：

mycat中间件做读写分离完成

7springboot通过application.yml文件配置mycat连接池

项目目录

项目依赖pom.xml

4.0.0com.sunyardspboot0.0.1-SNAPSHOTorg.springframework.bootspring-boot-starter-parent1.5.3.RELEASEorg.springframework.bootspring-boot-starter-weborg.springframework.bootspring-boot-starter-freemarkermysqlmysql-connector-javaorg.mybatis.spring.bootmybatis-spring-boot-starter1.1.1org.springframework.bootspring-boot-starter-jdbcorg.springframework.bootspring-boot-configuration-processor

application.yml

spring:  
  datasource:  
    url: jdbc:mysql://192.168.43.155:8066/mydb  
    username: mycat  
    password: mycat 
    driverClassName: com.mysql.jdbc.Driver

controller

package com.spboot.controller;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.ModelMap;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.servlet.ModelAndView;

import com.spboot.pojo.Ticket;
import com.spboot.service.TicketService;

@Controller
public class TicketController {

	@Autowired
	private TicketService ticketService;

	@RequestMapping("/getTicketList.do")
	public ModelAndView getTicketList() {
		List ticketList = ticketService.getTicketList();
		ModelAndView mav = new ModelAndView();
		mav.setViewName("index");
		mav.addObject("ticketList", ticketList);
		return mav;
	};

	@RequestMapping("/getFtl.do")
	public ModelAndView getFtl(ModelAndView mav) {
		mav.addObject("name", "ss");
		mav.setViewName("index");
		return mav;
	};

	@RequestMapping("/index")
	public String getFtlt(ModelMap map) {
		map.addAttribute("name", "你妈");
		return "index";
	};

}

service

package com.spboot.service;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.spboot.mapper.TicketMapper;
import com.spboot.pojo.Ticket;
import com.spboot.utils.common.TimeUtils;

@Service
public class TicketService {
	@Autowired
	private TicketMapper ticketMapper;
	public List getTicketList() {
		List ticketList = ticketMapper.getTicketList();
		for (Ticket ticket : ticketList) {
			String beginTimeStr = TimeUtils.getISOTime(ticket.getBeginTime());
			String endTimeStr = TimeUtils.getISOTime(ticket.getEndTime());
			ticket.setBeginTimeStr(beginTimeStr);
			ticket.setEndTimeStr(endTimeStr);
		}
		return ticketList;
	}
}

mapper

package com.spboot.mapper;

import java.util.List;

import org.apache.ibatis.annotations.Select;

import com.spboot.pojo.Ticket;

public interface TicketMapper {
	
    @Select("select * from ticket;")
	List getTicketList();

}

ticket

package com.spboot.pojo;

import java.util.Date;
/**
 * 
 * @ClassName: Ticket 
 * @Description: 车票信息实体类
 * @author wenf.jiao
 * @date 2018年1月14日 下午7:29:17 
 *
 */
public class Ticket {
	/*
	 * 车票ID
	 */
    private Integer ticketID;
    /*
	 * 开车地点
	 */
    private String startting;
    /*
	 * 到站地点
	 */
    private String destination;
    /*
	 * 价钱
	 */
    private Integer price;
    /*
	 * 开车时间
	 */
    private Date beginTime;
    /*
	 * 到站时间
	 */
    private Date endTime;
    /*
  	 * 开车时间字符串
  	 */
      private String beginTimeStr;
      /*
  	 * 到站时间字符串
  	 */
      private String endTimeStr;

    public Integer getTicketID() {
        return ticketID;
    }

    public void setTicketID(Integer ticketID) {
        this.ticketID = ticketID;
    }

    public String getStartting() {
        return startting;
    }

    public void setStartting(String startting) {
        this.startting = startting;
    }

    public String getDestination() {
        return destination;
    }

    public void setDestination(String destination) {
        this.destination = destination;
    }

    public Integer getPrice() {
        return price;
    }

    public void setPrice(Integer price) {
        this.price = price;
    }

    public Date getBeginTime() {
        return beginTime;
    }

    public void setBeginTime(Date beginTime) {
        this.beginTime = beginTime;
    }

    public Date getEndTime() {
        return endTime;
    }

    public void setEndTime(Date endTime) {
        this.endTime = endTime;
    }

	public String getBeginTimeStr() {
		return beginTimeStr;
	}

	public void setBeginTimeStr(String beginTimeStr) {
		this.beginTimeStr = beginTimeStr;
	}

	public String getEndTimeStr() {
		return endTimeStr;
	}

	public void setEndTimeStr(String endTimeStr) {
		this.endTimeStr = endTimeStr;
	}
    
}

index.ftl(模板引擎)

<#list ticketList as ticket>

车票编号	出发地点	目的地	价钱	发车时刻	到达时刻
${ticket.ticketID}	${ticket.startting}	${ticket.destination}	${ticket.price}	${ticket.beginTimeStr}	${ticket.endTimeStr}

全局捕获异常

package com.spboot.spexception;

import java.util.HashMap;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.springframework.core.annotation.AnnotationUtils;
import org.springframework.web.bind.annotation.ControllerAdvice;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.ResponseStatus;

/**
 * 
 * @ClassName: GlobalExceptionHandler 
 * @Description: springboot全局异常捕获
 * @author 
 * @date 2018年1月26日  
 *
 */
@ControllerAdvice
public class GlobalExceptionHandler {
	@ResponseBody
	@ExceptionHandler(Exception.class)
	public Map exceptionHandler(HttpServletRequest request,HttpServletResponse response,Exception e){
		if (AnnotationUtils.findAnnotation(e.getClass(), ResponseStatus.class)!=null) {
			try {
				throw e;
			} catch (Exception e1) {
				e1.printStackTrace();
			}
		}
		Map resMap=new HashMap<>();
		resMap.put("url", request.getRequestURL());
		resMap.put("class",e.getClass());
		resMap.put("cause",e.getCause());
		resMap.put("message",e.getMessage());
		return resMap;
	}
},>,>

application.java

package application;

import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.context.annotation.ComponentScan;
/**
 * 
 * @ClassName: application 
 * @Description: 企业级启动方式
 * @author 
 * @date 2018年1月26日 下午4:27:25 
 *
 */
@ComponentScan(basePackages="com.spboot.*")
@MapperScan(basePackages="com.spboot.*")
@EnableAutoConfiguration
public class Application {
	public static void main(String[] args) {
		SpringApplication.run(Application.class, args);
	}
}

点击右键启动项目，控制台打印如下日志

访问接口

结果页面