一步一步在Windows中使用MyCat负载均衡 下篇

本文涉及的产品
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
传统型负载均衡 CLB,每月750个小时 15LCU
简介:

之前在 一步一步在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:\windows\system32>jps
8068
10040 QuorumPeerMain  // 这东西是zk的东西,源码有介绍
10556 Jps

   也可以用自带客户端命令 :  zkCli.cmd -server 127.0.0.1:2181

  关于JPS的东西,可以自己去JAVA_HOME\bin 目录下去看,里面很多命令

  安装好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/

本文转自欢醉博客园博客,原文链接http://www.cnblogs.com/zhangs1986/p/6418898.html如需转载请自行联系原作者


欢醉

相关实践学习
SLB负载均衡实践
本场景通过使用阿里云负载均衡 SLB 以及对负载均衡 SLB 后端服务器 ECS 的权重进行修改,快速解决服务器响应速度慢的问题
负载均衡入门与产品使用指南
负载均衡(Server Load Balancer)是对多台云服务器进行流量分发的负载均衡服务,可以通过流量分发扩展应用系统对外的服务能力,通过消除单点故障提升应用系统的可用性。 本课程主要介绍负载均衡的相关技术以及阿里云负载均衡产品的使用方法。
相关文章
|
负载均衡 大数据 应用服务中间件
10分钟搭建服务器集群——Windows7系统中nginx与IIS服务器搭建集群实现负载均衡
10分钟搭建服务器集群——Windows7系统中nginx与IIS服务器搭建集群实现负载均衡
|
6月前
|
负载均衡 应用服务中间件 Linux
Nginx安装Windows、Linux | 正向代理、反向代理、负载均衡
Nginx安装Windows、Linux | 正向代理、反向代理、负载均衡
175 0
|
负载均衡 应用服务中间件 nginx
10分钟学会windows中iis搭建服务器集群实现负载均衡和nginx代理转发
10分钟学会windows中iis搭建服务器集群实现负载均衡和nginx代理转发
|
负载均衡 应用服务中间件 测试技术
【Nginx】Windows平台下配置Nginx服务实现负载均衡
系统环境:win10 测试用的开发环境和服务类型:VS2022 + DotNet 6 + WebApi
348 0
【Nginx】Windows平台下配置Nginx服务实现负载均衡
|
SQL 负载均衡 关系型数据库
Mycat的读写分离就是负载均衡吗?底层原理是什么?
Mycat的读写分离就是负载均衡吗?底层原理是什么?
155 0
|
关系型数据库 MySQL Java
【mycat】mycat在windows环境下的安装和启动
安装mycat前需要先安装jdk和mysql。mycat1.6版本建议使用的jdk是1.7以上版本,mysql建议使用5.6版本。安装玩jdk和mysql后,进入mycat解压目录下的bin目录,如本文的路径如下: D:\Program Files (x86)\mycat\bin 安装shift键,点击鼠标右键,选择"在此处打开命令窗口"打开命令行窗口(注意需要管理员账户登录,如果不是请使用管理员身份运行cmd打开命令行窗口)。在打开的命令行窗口中执行如下命令安装mycat: mycat.bat install
696 1
|
关系型数据库 MySQL 数据库
Windows上启动Mycat 错误: 找不到或无法加载主类 Files\mycatWin
Windows上启动Mycat 错误: 找不到或无法加载主类 Files\mycatWin
Windows上启动Mycat 错误: 找不到或无法加载主类 Files\mycatWin
|
消息中间件 负载均衡 Kafka
kafka的使用与负载均衡(Windows环境)
kafka的介绍 Kafka是一个分布式的、可分区的、可复制的消息系统。它提供了普通消息系统的功能,但具有自己独特的设计。它可以像消息系统一样读写数据流,并且可以在实时业务的场景中写可靠的流处理应用,并且能安全地存储数据流到分布式、多副本、容错的集群中。
2811 0
|
关系型数据库 MySQL 数据库
Mycat读写分离笔记Windows
Mycat读写分离笔记Windows 自己搭了一个运用Mycat中间件搭建了一个读写分离的demo,昨晚还在奋战当中,因为连接mycat的时候老是报错:No Mycat DataBases selected.尝试了很多的方法,然后还是没有解决。
2853 0