2.Mysql集群

Wesley13
• 阅读 606

前言:

Mycat:

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

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

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

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

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

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

......

关于mycat更多的介绍,及文档,请点击Mycat官网

2.Mysql集群

准备工作:

1、安装JDK:参考

2、安装Mycat:参考

3、配置数据库的主从同步:参考

开始搬砖:

1.配置/conf/schema.xml

<?xml version="1.0"?>
<!DOCTYPE mycat:schema SYSTEM "schema.dtd">
<mycat:schema xmlns:mycat="http://io.mycat/">

    <!-- 配置逻辑库XMDB -->
    <schema name="XMDB" checkSQLschema="false" sqlMaxLimit="100" dataNode="dn1" />
    <!-- 映射到你实际数据库中的库名:xm -->
    <dataNode name="dn1" dataHost="node1" database="xm"/>
    <!-- 配置Host,设置数据库的参数 -->
    <dataHost name="node1" maxCon="1000" minCon="10" balance="1" dbType="mysql" dbDriver="native">
        <!-- 心跳检测,来看下面的host是否还可用 -->
        <heartbeat>select user()</heartbeat> 
        <!-- 读写分离 -->
        <writeHost host="192.168.40.3" url="192.168.40.3:3306" user="root" password="123456">
            <readHost  host="192.168.40.3" url="192.168.40.3:3316" user="root" password="123456" />
        </writeHost>
        <writeHost host="192.168.40.3" url="192.168.40.3:3316" user="root" password="123456" />
    </dataHost>

    
    <!--
        <dataHost name="sequoiadb1" maxCon="1000" minCon="1" balance="0" dbType="sequoiadb" dbDriver="jdbc">
        <heartbeat>         </heartbeat>
         <writeHost host="hostM1" url="sequoiadb://1426587161.dbaas.sequoialab.net:11920/SAMPLE" user="jifeng"     password="jifeng"></writeHost>
         </dataHost>

      <dataHost name="oracle1" maxCon="1000" minCon="1" balance="0" writeType="0"     dbType="oracle" dbDriver="jdbc"> <heartbeat>select 1 from dual</heartbeat>
        <connectionInitSql>alter session set nls_date_format='yyyy-mm-dd hh24:mi:ss'</connectionInitSql>
        <writeHost host="hostM1" url="jdbc:oracle:thin:@127.0.0.1:1521:nange" user="base"     password="123456" > </writeHost> </dataHost>

        <dataHost name="jdbchost" maxCon="1000"     minCon="1" balance="0" writeType="0" dbType="mongodb" dbDriver="jdbc">
        <heartbeat>select     user()</heartbeat>
        <writeHost host="hostM" url="mongodb://192.168.0.99/test" user="admin" password="123456" ></writeHost> </dataHost>

        <dataHost name="sparksql" maxCon="1000" minCon="1" balance="0" dbType="spark" dbDriver="jdbc">
        <heartbeat> </heartbeat>
         <writeHost host="hostM1" url="jdbc:hive2://feng01:10000" user="jifeng"     password="jifeng"></writeHost> </dataHost> -->

    <!-- <dataHost name="jdbchost" maxCon="1000" minCon="10" balance="0" dbType="mysql"
        dbDriver="jdbc"> <heartbeat>select user()</heartbeat> <writeHost host="hostM1"
        url="jdbc:mysql://localhost:3306" user="root" password="123456"> </writeHost>
        </dataHost> -->
</mycat:schema>

2.配置/conf/server.xml

  1 <?xml version="1.0" encoding="UTF-8"?>
  2 <!-- - - Licensed under the Apache License, Version 2.0 (the "License"); 
  3     - you may not use this file except in compliance with the License. - You 
  4     may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 
  5     - - Unless required by applicable law or agreed to in writing, software - 
  6     distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT 
  7     WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the 
  8     License for the specific language governing permissions and - limitations 
  9     under the License. -->
 10 <!DOCTYPE mycat:server SYSTEM "server.dtd">
 11 <mycat:server xmlns:mycat="http://io.mycat/">
 12     <system>
 13     <property name="useSqlStat">0</property>  <!-- 1为开启实时统计、0为关闭 -->
 14     <property name="useGlobleTableCheck">0</property>  <!-- 1为开启全加班一致性检测、0为关闭 -->
 15 
 16         <property name="sequnceHandlerType">2</property>
 17       <!--  <property name="useCompression">1</property>--> <!--1为开启mysql压缩协议-->
 18         <!--  <property name="fakeMySQLVersion">5.6.20</property>--> <!--设置模拟的MySQL版本号-->
 19     <!-- <property name="processorBufferChunk">40960</property> -->
 20     <!-- 
 21     <property name="processors">1</property> 
 22     <property name="processorExecutor">32</property> 
 23      -->
 24         <!--默认为type 0: DirectByteBufferPool | type 1 ByteBufferArena-->
 25         <property name="processorBufferPoolType">0</property>
 26         <!--默认是65535 64K 用于sql解析时最大文本长度 -->
 27         <!--<property name="maxStringLiteralLength">65535</property>-->
 28         <!--<property name="sequnceHandlerType">0</property>-->
 29         <!--<property name="backSocketNoDelay">1</property>-->
 30         <!--<property name="frontSocketNoDelay">1</property>-->
 31         <!--<property name="processorExecutor">16</property>-->
 32         <!--
 33             <property name="serverPort">8066</property> <property name="managerPort">9066</property> 
 34             <property name="idleTimeout">300000</property> <property name="bindIp">0.0.0.0</property> 
 35             <property name="frontWriteQueueSize">4096</property> <property name="processors">32</property> -->
 36         <!--分布式事务开关,0为不过滤分布式事务,1为过滤分布式事务(如果分布式事务内只涉及全局表,则不过滤),2为不过滤分布式事务,但是记录分布式事务日志-->
 37         <property name="handleDistributedTransactions">0</property>
 38         
 39             <!--
 40             off heap for merge/order/group/limit      1开启   0关闭
 41         -->
 42         <property name="useOffHeapForMerge">1</property>
 43 
 44         <!--
 45             单位为m
 46         -->
 47         <property name="memoryPageSize">1m</property>
 48 
 49         <!--
 50             单位为k
 51         -->
 52         <property name="spillsFileBufferSize">1k</property>
 53 
 54         <property name="useStreamOutput">0</property>
 55 
 56         <!--
 57             单位为m
 58         -->
 59         <property name="systemReserveMemorySize">384m</property>
 60 
 61 
 62         <!--是否采用zookeeper协调切换  -->
 63         <property name="useZKSwitch">true</property>
 64 
 65 
 66     </system>
 67     
 68     <!-- 全局SQL防火墙设置 -->
 69     <!-- 
 70     <firewall> 
 71        <whitehost>
 72           <host host="127.0.0.1" user="mycat"/>
 73           <host host="127.0.0.2" user="mycat"/>
 74        </whitehost>
 75        <blacklist check="false">
 76        </blacklist>
 77     </firewall>
 78     -->
 79 
 80     <!-- 配置用户 -->
 81     
 82     <user name="root">
 83         <property name="password">123456</property>
 84         <property name="schemas">XMDB</property>
 85         
 86         <!-- 表级 DML 权限设置 -->
 87         <!--         
 88         <privileges check="false">
 89             <schema name="TESTDB" dml="0110" >
 90                 <table name="tb01" dml="0000"></table>
 91                 <table name="tb02" dml="1111"></table>
 92             </schema>
 93         </privileges>        
 94          -->
 95     </user>
 96 
 97     <user name="user">
 98         <property name="password">user</property>
 99         <property name="schemas">XMDB</property>
100         <property name="readOnly">true</property>
101     </user>
102 
103 </mycat:server>

3.开启mycat服务

:mycat start

2.Mysql集群

4.查看开启状况/logs/wrapper.log

日志里会描述开启状况,及异常错误。

2.Mysql集群

 开启成功。

5.连接客户端测试读写分离。

2.Mysql集群

2.Mysql集群

点赞
收藏
评论区
推荐文章
blmius blmius
2年前
MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1
文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s
Jacquelyn38 Jacquelyn38
2年前
2020年前端实用代码段,为你的工作保驾护航
有空的时候,自己总结了几个代码段,在开发中也经常使用,谢谢。1、使用解构获取json数据let jsonData  id: 1,status: "OK",data: 'a', 'b';let  id, status, data: number   jsonData;console.log(id, status, number )
皕杰报表之UUID
​在我们用皕杰报表工具设计填报报表时,如何在新增行里自动增加id呢?能新增整数排序id吗?目前可以在新增行里自动增加id,但只能用uuid函数增加UUID编码,不能新增整数排序id。uuid函数说明:获取一个UUID,可以在填报表中用来创建数据ID语法:uuid()或uuid(sep)参数说明:sep布尔值,生成的uuid中是否包含分隔符'',缺省为
Wesley13 Wesley13
2年前
RAC环境单实例启动数据库收到ORA
     在RAC环境中,如果你在没有启动节点的集群服务的情况下单实例启动数据库,将收到类似如下的报错:\oracle@rhel1u01\$sqlSQL\Plus:Release10.2.0.5.0ProductiononTueApr215:00:272013Copyright(
Stella981 Stella981
2年前
Python3:sqlalchemy对mysql数据库操作,非sql语句
Python3:sqlalchemy对mysql数据库操作,非sql语句python3authorlizmdatetime2018020110:00:00coding:utf8'''
Wesley13 Wesley13
2年前
mysql设置时区
mysql设置时区mysql\_query("SETtime\_zone'8:00'")ordie('时区设置失败,请联系管理员!');中国在东8区所以加8方法二:selectcount(user\_id)asdevice,CONVERT\_TZ(FROM\_UNIXTIME(reg\_time),'08:00','0
Wesley13 Wesley13
2年前
00:Java简单了解
浅谈Java之概述Java是SUN(StanfordUniversityNetwork),斯坦福大学网络公司)1995年推出的一门高级编程语言。Java是一种面向Internet的编程语言。随着Java技术在web方面的不断成熟,已经成为Web应用程序的首选开发语言。Java是简单易学,完全面向对象,安全可靠,与平台无关的编程语言。
Wesley13 Wesley13
2年前
MongoDB 分片管理(一)检查集群状态
一、检查集群状态1.1使用sh.status()查看集群摘要信息1、使用sh.status()可以查看分片信息、数据库信息、集合信息sh.status()如果数据块较多时,使用sh.status(true)又是输出会很多,就不会截断,要使用如下查看2、tooman
Wesley13 Wesley13
2年前
MySQL部分从库上面因为大量的临时表tmp_table造成慢查询
背景描述Time:20190124T00:08:14.70572408:00User@Host:@Id:Schema:sentrymetaLast_errno:0Killed:0Query_time:0.315758Lock_
Python进阶者 Python进阶者
3个月前
Excel中这日期老是出来00:00:00,怎么用Pandas把这个去除
大家好,我是皮皮。一、前言前几天在Python白银交流群【上海新年人】问了一个Pandas数据筛选的问题。问题如下:这日期老是出来00:00:00,怎么把这个去除。二、实现过程后来【论草莓如何成为冻干莓】给了一个思路和代码如下:pd.toexcel之前把这