一步一步在Windows中使用MyCat负载均衡 下篇
之前在 一步一步在Windows中使用MyCat负载均衡 上篇 中已经讲了如何配置出MyCat。下面讲其相关的使用。
五、配置MyCat-eye
对于MyCat监控官网还提供一个MyCat-eye web系统来展示它的运行情况。
MyCat发展到目前的版本,已经不是一个单纯的MySQL代理了,它的后端可以支持MySQL、SQL Server、Oracle、DB2、PostgreSQL等主流数据库,也支持MongoDB这种新型NoSQL方式的存储,未来还会支持更多类型的存储。而在最终用户看来,无论是那种存储方式,在MyCat里,都是一个传统的数据库表,支持标准的SQL语句进行数据的操作,这样一来,对前端业务系统来说,可以大幅降低开发难度,提升开发速度 MyCAT-WEB就是基于mycat的一个性能监控工具,方便大家更有效的使用mycat管理mycat监控mycat,让大家的mycat工作更加高效。
下载:http://dl.mycat.io/
运行eye之前还需要安 zookeeper,所以先安装 zookeeper ,
解压到 D:zookeeper-3.4.6
到目录conf 下创建 zoo.cfg 文件,默认就是加载这个文件,文件内容 我直接copy 的sample里面的
#zoo.cfg 的内容
# 心跳检查的时间 2秒
tickTime=2000
# 初始化时 连接到服务器端的间隔次数,总时间10*2=20秒
initLimit=10
# ZK Leader 和follower 之间通讯的次数,总时间5*2=10秒
syncLimit=5
# 存储内存中数据库快照的位置,如果不设置参数,更新事务日志将被存储到默认位置。
dataDir=D:\zookeeper-3.4.6\zkdata
# 错误日志的存放位置
dataLogDir=F:\zookeeper-3.4.6\logs
# ZK 服务器端的监听端口
clientPort=2181
然后 cd 到bin 目录下 执行zkServer.cmd 就启动成功了。
注意:dataDir 和 dataLogDir 目录不会自动创建,得手动创建才能启动。
可以用netstat -ano|findstr "2181" 看看是否OK。
也可以用JPS 查看启动的JAVA 进程的情况,会出现这样
C:windowssystem32>jps
8068
10040 QuorumPeerMain // 这东西是zk的东西,源码有介绍
10556 Jps
也可以用自带客户端命令 : zkCli.cmd -server 127.0.0.1:2181
关于JPS的东西,可以自己去JAVA_HOMEbin 目录下去看,里面很多命令
安装好zookeeper后,启动MyCat
windows启动
启动start.bat
inux启动
启动start.sh
打开mycat-web窗口 输入网址:http://localhost:8082/mycat/
若没配置好zookeeper会出现下面的页面
当配置好后会出现:
添加mycat服务,用户名,密码为之前配置的mycat ,123456,保存
还可以添加对mysql的监控,在mysql管理中添加。
对SQL的监控我这测试了几天,还没数据,可能哪里配置没有加,所以后面再处理。eye具体的使用资料网上不是很多,需要自己探索。
六、在NET中使用MyCat
由于MyCAT与MySQL协议有些许差异,开发者可能不能够直接使用Oracle官方提供的Mysql.Data(ADO层)来与MyCAT直接连接,因此我们专门为.NET开发者设计了针对MyCAT优化过的ADO层驱动,即Pomelo.Data.MyCat,开发者通过使用MyCatConnection、MyCatCommand类可以实现对MyCAT的连接与查询。下面将展示一个简短的使用MyCat for ADO.NET来向MyCAT写入数据。
在vs中nuget引入Pomelo.Data.MyCat,但安装报下面的错
错误提示net框架4.5版本低了,所以调到4.6。
MyCatConnection, MyCatCommand等内容在命名空间 Pomelo.Data.MyCat 中. 按照常规的ADO.NET开发流程即可实现对MyCAT的操作。
Pomelo.Data.MyCat的使用与mysql一致:
封装基础代码:
private static readonly string connectionString = "server=localhost;database=TESTDB;uid=mycat;pwd=123456";
/// <summary>
/// 执行SQL语句,返回影响的记录数
/// </summary>
/// <param name="SQLString">SQL语句</param>
/// <returns>影响的记录数</returns>
public static int ExecuteSql(string SQLString, params MyCatParameter[] cmdParms)
{
using (MyCatConnection connection = new MyCatConnection(connectionString))
{
using (MyCatCommand cmd = new MyCatCommand())
{
try
{
PrepareCommand(cmd, connection, null, SQLString, cmdParms);
int rows = cmd.ExecuteNonQuery();
cmd.Parameters.Clear();
return rows;
}
catch (MyCatException e)
{
throw e;
}
}
}
}
/// <summary>
/// 执行查询语句,返回DataSet
/// </summary>
/// <param name="SQLString">查询语句</param>
/// <returns>DataSet</returns>
public static DataSet Query(string SQLString)
{
using (MyCatConnection connection = new MyCatConnection(connectionString))
{
DataSet ds = new DataSet();
try
{
connection.Open();
MyCatDataAdapter command = new MyCatDataAdapter(SQLString, connection);
command.Fill(ds, "ds");
}
catch (MyCatException ex)
{
throw new Exception(ex.Message);
}
return ds;
}
}
private static void PrepareCommand(MyCatCommand cmd, MyCatConnection conn, MyCatTransaction trans, string cmdText, MyCatParameter[] cmdParms)
{
if (conn.State != ConnectionState.Open)
conn.Open();
cmd.Connection = conn;
cmd.CommandText = cmdText;
if (trans != null)
cmd.Transaction = trans;
cmd.CommandType = CommandType.Text;//cmdType;
if (cmdParms != null)
{
foreach (MyCatParameter parameter in cmdParms)
{
if ((parameter.Direction == ParameterDirection.InputOutput || parameter.Direction == ParameterDirection.Input) &&
(parameter.Value == null))
{
parameter.Value = DBNull.Value;
}
cmd.Parameters.Add(parameter);
}
}
}
插入数据:
string name = textBox1.Text;
if (string.IsNullOrEmpty(name)) return;
StringBuilder strSql = new StringBuilder();
strSql.Append("insert into hotnews(");
strSql.Append("newsname)");
strSql.Append(" values (");
strSql.Append("@newsname)");
MyCatParameter[] parameters = {
new MyCatParameter("@newsname", MyCatDbType.VarChar,100),
};
parameters[0].Value = name;
int rows = ExecuteSql(strSql.ToString(), parameters);
if (rows > 0)
{
label1.Text = "添加成功";
}
else
{
label1.Text = "添加失败";
}
查询数据:
StringBuilder strSql = new StringBuilder();
strSql.Append("select * ");
strSql.Append(" FROM hotnews ");
DataSet ds = Query(strSql.ToString());
dataGridView1.DataSource = ds.Tables[0];
七、注意
MyCat 主键ID自增长配置,但保存时还是会出现下面的情况,当还是没指定ID时,插入的ID还是下面的ID会导致插入失败,因此想做分布式最好是将ID设置为自己生成GUID,这样不管哪个库都是全局唯一。若还是想自增型,可以参考园友这篇:MyCat 主键ID自增长配置
需要提醒的是MyCat不仅用于MySQL,而且支持Oracle、DB2、SQL Server、PostgreSQL等
基于心跳的自动故障切换,支持读写分离,支持MySQL主从,以及galera cluster集群
支持单库内部任意join,支持跨库2表join,甚至基于caltlet的多表join
支持数据的多片自动路由与聚合,支持sum,count,max等常用的聚合函数,支持跨库分页
更多功能请参考官网
MyCat官网:http://www.mycat.org.cn/
- 【Java学习笔记之二十五】初步认知Java内部类
- AIM Tech Round 4 (Div. 2)(A,暴力,B,组合数,C,STL+排序)
- 【Java学习笔记之三十】详解Java单例(Singleton)模式
- 基于Windows下处理Java错误:编码GBK的不可映射字符的解决方案
- 浅析ASCII、Unicode和UTF-8三种常见字符编码
- 【Java学习笔记之三十一】详解Java8 lambda表达式
- 2017 Multi-University Training Contest - Team 9 1003&&HDU 6163 CSGO【计算几何】
- 【Code】关关的刷题日记21——Leetcode 485. Max Consecutive Ones
- 2017 Multi-University Training Contest - Team 9 1002&&HDU 6162 Ch’s gift【树链部分+线段树】
- 【Java学习笔记之三十二】浅谈Java中throw与throws的用法及异常抛出处理机制剖析
- Linux上访问SQL Server数据库
- 2017 Multi-University Training Contest - Team 9 1001&&HDU 6161 Big binary tree【树形dp+hash】
- 【Java学习笔记之三十三】详解Java中try,catch,finally的用法及分析
- 【Java学习笔记之二十九】Java中的"equals"和"=="的用法及区别
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 【Tomcat源码解析】第一章:如何搭建源码阅读环境
- LD_PRELOAD 后门 | Linux 后门系列
- 如何利用k8s拉取私有仓库镜像
- rsyslog queue队列权威指南
- 用LOL获得BUFF场景来看待Guava之事件总线
- 文件&目录小技巧 | Linux后门系列
- 从0到1开发测试平台(十)后端增加登录token返回
- rsyslog磁盘辅助(Disk-Assisted)模式踩坑记
- Guava字符串的处理
- Phishing
- Guava Cache用法介绍(极简版)
- Linux Netcat 命令——网络工具中的瑞士军刀
- __all__ 是干嘛用的?
- 业务视角谈谈Kafka(第一篇)
- 面试必问:session,cookie和token的区别