MyCAT簡易入門

来源:http://www.cnblogs.com/ivictor/archive/2016/01/08/5111495.html
-Advertisement-
Play Games

MyCAT是mysql中間件，前身是阿裡大名鼎鼎的Cobar，Cobar在開源了一段時間後，不了了之。於是MyCAT扛起了這面大旗，在大數據時代，其重要性愈發彰顯。這篇文章主要是MyCAT的入門部署。一、安裝java因Mycat是用java開發的，所以需要在實驗環境下安裝java，官方建議jdk1....


MyCAT是mysql中間件，前身是阿裡大名鼎鼎的Cobar，Cobar在開源了一段時間後，不了了之。於是MyCAT扛起了這面大旗，在大數據時代，其重要性愈發彰顯。這篇文章主要是MyCAT的入門部署。

一、安裝java

因Mycat是用java開發的，所以需要在實驗環境下安裝java，官方建議jdk1.7及以上版本

Java Oracle官方下載地址為：

http://www.oracle.com/technetwork/java/javase/archive-139210.html

 

解壓jdk-7u79-linux-x64.tar.gz文件，並配置java的環境變數

# tar xvf jdk-7u79-linux-x64.tar.gz

# mv jdk1.7.0_79/ /usr/local/

 

編輯/etc/profile文件

# vim /etc/profile  添加如下內容

export JAVA_HOME=/usr/local/jdk1.7.0_79
export PATH=$JAVA_HOME/bin:$PATH
export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar

 

# source /etc/profile --使/etc/profile文件生效

# java -version

java version "1.7.0_79"
Java(TM) SE Runtime Environment (build 1.7.0_79-b15)
Java HotSpot(TM) 64-Bit Server VM (build 24.79-b02, mixed mode)

 

二、安裝MySQL

MySQL官方下載地址如下：

http://dev.mysql.com/downloads/mysql/

裡面有各種版本，包括RPM，二進位，源碼包。

為了方便起見，我這裡選擇是RPM包

# yum install -y mysql-community-server-5.6.26-2.el5.x86_64.rpm

 

啟動MySQL

# /etc/init.d/mysqld start

Starting mysqld (via systemctl):                           [  OK  ]

 

為root賬戶創建密碼

# mysqladmin -u root password "123456"

建議為123456，後面MyCAT配置文件schema.xml中會用到

 

三、安裝MyCAT

創建MyCAT用戶並設置密碼

# useradd mycat

# passwd mycat

 

解壓MyCAT文件

# tar xvf Mycat-server-1.5-alpha-20151221110028-linux.tar.gz

# mv mycat/ /usr/local/

 

設置mycat目錄的屬主和屬組

# chown -R mycat.mycat /usr/local/mycat/

 

四、測試MyCAT

首先在MySQL上創建三個資料庫：db1，db2，db3。

mysql> create database db1;
Query OK, 1 row affected (0.00 sec)

mysql> create database db2;
Query OK, 1 row affected (0.00 sec)

mysql> create database db3;
Query OK, 1 row affected (0.00 sec)

 

啟動mycat服務

# cd /usr/local/mycat/bin/

# ./mycat start

Starting Mycat-server...

查看mycat服務是否啟動

# ps -ef |grep mycat

root       9640   7257  0 22:47 pts/3    00:00:00 grep --color=auto mycat

並沒有啟動

 

查看日誌

# cd /usr/local/mycat/logs/

# cat wrapper.log

STATUS | wrapper  | 2016/01/07 22:44:23 | --> Wrapper Started as Daemon
STATUS | wrapper  | 2016/01/07 22:44:23 | Launching a JVM...
ERROR  | wrapper  | 2016/01/07 22:44:25 | JVM exited while loading the application.
INFO   | jvm 1    | 2016/01/07 22:44:25 | Error: Exception thrown by the agent : java.net.MalformedURLException: Local host name unknown: java.net.UnknownHostException: MySQL-Server1: MySQL-Server1: Name or service not known
STATUS | wrapper  | 2016/01/07 22:44:29 | Launching a JVM...
ERROR  | wrapper  | 2016/01/07 22:44:29 | JVM exited while loading the application.
INFO   | jvm 2    | 2016/01/07 22:44:29 | Error: Exception thrown by the agent : java.net.MalformedURLException: Local host name unknown: java.net.UnknownHostException: MySQL-Server1: MySQL-Server1: Name or service not known
STATUS | wrapper  | 2016/01/07 22:44:34 | Launching a JVM...
ERROR  | wrapper  | 2016/01/07 22:44:34 | JVM exited while loading the application.
INFO   | jvm 3    | 2016/01/07 22:44:34 | Error: Exception thrown by the agent : java.net.MalformedURLException: Local host name unknown: java.net.UnknownHostException: MySQL-Server1: MySQL-Server1: Name or service not known
STATUS | wrapper  | 2016/01/07 22:44:38 | Launching a JVM...
ERROR  | wrapper  | 2016/01/07 22:44:38 | JVM exited while loading the application.
INFO   | jvm 4    | 2016/01/07 22:44:38 | Error: Exception thrown by the agent : java.net.MalformedURLException: Local host name unknown: java.net.UnknownHostException: MySQL-Server1: MySQL-Server1: Name or service not known
STATUS | wrapper  | 2016/01/07 22:44:42 | Launching a JVM...
ERROR  | wrapper  | 2016/01/07 22:44:43 | JVM exited while loading the application.
INFO   | jvm 5    | 2016/01/07 22:44:43 | Error: Exception thrown by the agent : java.net.MalformedURLException: Local host name unknown: java.net.UnknownHostException: MySQL-Server1: MySQL-Server1: Name or service not known
FATAL  | wrapper  | 2016/01/07 22:44:43 | There were 5 failed launches in a row, each lasting less than 300 seconds.  Giving up.
FATAL  | wrapper  | 2016/01/07 22:44:43 |   There may be a configuration problem: please check the logs.
STATUS | wrapper  | 2016/01/07 22:44:43 | <-- Wrapper Stopped

 

根據報錯信息，懷疑主機名沒有綁定

修改hosts文件，綁定主機名

# vim /etc/hosts

127.0.0.1   localhost localhost.localdomain localhost4 localhost4.localdomain4
::1         localhost localhost.localdomain localhost6 localhost6.localdomain6
192.168.244.144 MySQL-Server1

重新啟動mycat服務

# cd /usr/local/mycat/bin/

# ./mycat start

這次mycat正常啟動

# ps -ef |grep mycat

root      10725      1  0 22:54 ?        00:00:00 /usr/local/mycat/bin/./wrapper-linux-x86-64 /usr/local/mycat/conf/wrapper.conf wrapper.syslog.ident=mycat wrapper.pidfile=/usr/local/mycat/logs/mycat.pid wrapper.daemonize=TRUE wrapper.lockfile=/var/lock/subsys/mycat
root      10881   7257  0 22:55 pts/3    00:00:00 grep --color=auto mycat

 

下麵以Travelrecord為例，來進行插入，查詢，路由分析等基本操作。

首先利用mycat連接mysql資料庫

# mysql -utest -ptest -h127.0.0.1 -P8066 -DTESTDB

其中8066是mycat的監聽埠，類似於mysql的3306埠，其中-u，-p，-h分別是用戶名，密碼和主機，-D是連接的邏輯庫。

至於為什麼是這些，這個跟配置文件有關。

紅色部分表明連接的是mycat。

創建Travelrecord表

create table travelrecord (id bigint not null primary key,user_id varchar(100),traveldate DATE, fee decimal,days int);

插入數據

mysql> insert into travelrecord(id,user_id,traveldate,fee,days)  values(1,'Victor',20160101,100,10);
Query OK, 1 row affected (0.00 sec)

mysql> insert into travelrecord(id,user_id,traveldate,fee,days)  values(5000001,'Job',20160102,100,10);
Query OK, 1 row affected (0.00 sec)

mysql> insert into travelrecord(id,user_id,traveldate,fee,days)  values(10000001,'Slow',20160103,100,10);
Query OK, 1 row affected (0.00 sec)

至於ID為什麼取三個值，這個與conf目錄下autopartition-long.txt的定義有關，這個文件主要定義auto-sharding-long的規則。

# range start-end ,data node index
# K=1000,M=10000.
0-500M=0
500M-1000M=1
1000M-1500M=2

我主要是測試在id取不同區間的值時，分片的效果。

下麵來看看分片的效果

mysql> select * from db1.travelrecord;
+----+---------+------------+------+------+
| id | user_id | traveldate | fee  | days |
+----+---------+------------+------+------+
|  1 | Victor  | 2016-01-01 |  100 |   10 |
+----+---------+------------+------+------+
1 row in set (0.00 sec)

mysql> select * from db2.travelrecord;
+---------+---------+------------+------+------+
| id      | user_id | traveldate | fee  | days |
+---------+---------+------------+------+------+
| 5000001 | Job     | 2016-01-02 |  100 |   10 |
+---------+---------+------------+------+------+
1 row in set (0.00 sec)

mysql> select * from db3.travelrecord;
+----------+---------+------------+------+------+
| id       | user_id | traveldate | fee  | days |
+----------+---------+------------+------+------+
| 10000001 | Slow    | 2016-01-03 |  100 |   10 |
+----------+---------+------------+------+------+
1 row in set (0.00 sec)

果然是分配到三個不同的節點上了。

如果想看MyCAT具體會將數據分配到哪個節點上，可通過路由分析。

語法其實蠻簡單，就是SQL語句前加上explain語句。

下麵根據explain命令查看create語句和insert語句具體會分配到哪些Datanode上。

mysql> explain create table travelrecord (id bigint not null primary key,user_id varchar(100),traveldate DATE, fee decimal,days int);
+-----------+-----------------------------------------------------------------------------------------------------------------------+
| DATA_NODE | SQL                                                                                                                   |
+-----------+-----------------------------------------------------------------------------------------------------------------------+
| dn1       | create table travelrecord (id bigint not null primary key,user_id varchar(100),traveldate DATE, fee decimal,days int) |
| dn2       | create table travelrecord (id bigint not null primary key,user_id varchar(100),traveldate DATE, fee decimal,days int) |
| dn3       | create table travelrecord (id bigint not null primary key,user_id varchar(100),traveldate DATE, fee decimal,days int) |
+-----------+-----------------------------------------------------------------------------------------------------------------------+
3 rows in set (0.00 sec)

mysql>  explain insert into travelrecord(id,user_id,traveldate,fee,days)  values(1,'Victor',20160101,100,10);
+-----------+----------------------------------------------------------------------------------------------+
| DATA_NODE | SQL                                                                                          |
+-----------+----------------------------------------------------------------------------------------------+
| dn1       | insert into travelrecord(id,user_id,traveldate,fee,days)  values(1,'Victor',20160101,100,10) |
+-----------+----------------------------------------------------------------------------------------------+
1 row in set (0.01 sec)

mysql> explain insert into travelrecord(id,user_id,traveldate,fee,days)  values(5000001,'Job',20160102,100,10);
+-----------+-------------------------------------------------------------------------------------------------+
| DATA_NODE | SQL                                                                                             |
+-----------+-------------------------------------------------------------------------------------------------+
| dn2       | insert into travelrecord(id,user_id,traveldate,fee,days)  values(5000001,'Job',20160102,100,10) |
+-----------+-------------------------------------------------------------------------------------------------+
1 row in set (0.00 sec)

mysql> explain insert into travelrecord(id,user_id,traveldate,fee,days)  values(10000001,'Slow',20160103,100,10);
+-----------+---------------------------------------------------------------------------------------------------+
| DATA_NODE | SQL                                                                                               |
+-----------+---------------------------------------------------------------------------------------------------+
| dn3       | insert into travelrecord(id,user_id,traveldate,fee,days)  values(10000001,'Slow',20160103,100,10) |
+-----------+---------------------------------------------------------------------------------------------------+
1 row in set (0.00 sec)

 

總結：

關於MyCAT的配置其實是蠻簡單的，最主要的是熟悉各配置文件的規則。以上用戶名，密碼，如何分庫，都是在配置文件中定義的，後續，有時間再一一詳表。

關於配置文件，conf目錄下主要以下三個需要熟悉。

server.xml是Mycat伺服器參數調整和用戶授權的配置文件

schema.xml是邏輯庫定義和表以及分片定義的配置文件

rule.xml是分片規則的配置文件


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • Linux LVM邏輯捲
    概述 LVM的產生是因為傳統的分區一旦分區好後就無法線上擴充空間，也存在一些工具能實現線上擴充空間但是還是會面臨數據損壞的風險；傳統的分區當分區空間不足時，一般的解決辦法是再創建一個更大的分區將原分區卸載然後將數據拷貝到新分區，但是在企業的生產系統往往不允許停機或者允許停機的時間很短，LVM就能.....
  • Ubuntu Desktop 15.10 自帶桌面共用問題修複
    Ubuntu 15.10 (似乎從14.04開始) 的小坑，使用自帶遠程桌面連接出錯，弄得我很不爽，偶爾從 上看到一視頻，解決了。聊以記之。 順便說一下，這個自帶的桌面共用的名字是：vino 原本使用 vnc4server 也挺好，無奈 `lubuntu ubuntu unity` 就是灰屏，...
  • Linux 系統 網路配置
    Linux 系統 網路配置配置Linux系統網路的方法有幾種，這裡介紹本人常用的兩種。第一種：使用命令ifconfig配置，具體用法：Ipconfig ethx x.x.x.x netmask x.x.x.x效果如下圖：通常，此種配置法只是用來測試用，因為重啟機器後，該配置的內容將會失效。第二種方....
  • 2016年準備轉型碼農的第一帖！
    最近準備做一個公司物品申領系統，資料庫的表已經設計好，目前正在搭建開發和運行環境。計劃使用ASP.Net + SQL Server完成此次的設計。以下為會員註冊的存儲過程，預計把註冊頁面中的兩個Text框中的數值作為參數傳入資料庫中，最後返回1或0表示成功/失敗： 1 ALTER procedure...
  • 淺談一下sql 查詢語句的一些問題和優化
    昨天在做一個sql代碼查詢的問題，發現了一些可優化的東西，藉此記錄一下。1，善用with as之前在寫sql 分頁查詢的時候，就只是用嵌套查詢，然後一個普通的關聯幾個表查詢，例如：SELECT * FROM( SELECT TOP 100 lr.SKU,lr.ItemPrice,lr.La...
  • 【mysql】關於checkpoint機制
    一、簡介思考一下這個場景：如果重做日誌可以無限地增大，同時緩衝池也足夠大，那麼是不需要將緩衝池中頁的新版本刷新回磁碟。因為當發生宕機時，完全可以通過重做日誌來恢復整個資料庫系統中的數據到宕機發生的時刻。但是這需要兩個前提條件：1、緩衝池可以緩存資料庫中所有的數據；2、重做日誌可以無限增大因此Chec...
  • SQL Server時間粒度系列----第3節旬、月時間粒度詳解
    本文目錄列表：1、SQL Server旬時間粒度2、SQL Server月有關時間粒度3、SQL Server函數重構4、總結語5、參考清單列表SQL Server旬時間粒度 SQL Server不存在旬這個時間粒度，這個時間粒度在我們國家存在的。一個月分為上、中、下3旬，上旬和中旬均10天，分別對...
  • Oracle的rownum原理和使用
    整理和學習了一下網上高手關於rownum的帖子：參考資料： http://www.cnblogs.com/mabaishui/archive/2009/10/20/1587165.html對於Oracle的rownum問題，很多資料都說不支持>，>=，=，between……and，只能用以上符號（，...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類