ClickHouse集群测试
本测试采用ReplicatedMergeTree + Distributed引擎作为集群结构的引擎
需要注意的是ReplicatedMergeTree('zk路径,如果要相互复制,这里必须一样', '副本名称, 必须不一样', 剩下的就是分区和主键,以及索引粒度)

[root@node100 ~]# clickhouse-client -m --password UHXQQmhb
ClickHouse client version 1.1.54385.
Connecting to localhost:9000.
Connected to ClickHouse server version 1.1.54385.
localhost :) create database ontime; #所有节点执行
localhost :) use ontime; #所有节点执行
localhost :) CREATE TABLE ontime (FlightDate Date,Year UInt16) ENGINE = ReplicatedMergeTree('/clickhouse/tables/ontime/shard1','1',FlightDate,(Year, FlightDate),8192); #分片1的第1个副本执行
localhost :) CREATE TABLE ontime (FlightDate Date,Year UInt16) ENGINE = ReplicatedMergeTree('/clickhouse/tables/ontime/shard1','2',FlightDate,(Year, FlightDate),8192); #分片1的第2个副本执行
localhost :) CREATE TABLE ontime (FlightDate Date,Year UInt16) ENGINE = ReplicatedMergeTree('/clickhouse/tables/ontime/shard2','1',FlightDate,(Year, FlightDate),8192); #分片2的第1个副本执行
localhost :) CREATE TABLE ontime (FlightDate Date,Year UInt16) ENGINE = ReplicatedMergeTree('/clickhouse/tables/ontime/shard2','2',FlightDate,(Year, FlightDate),8192); #分片2的第2个副本执行
localhost :) CREATE TABLE ontime_all (FlightDate Date,Year UInt16) ENGINE= Distributed(test_ck_cluster, ontime, ontime, rand()); #所有节点

在100向本地表写入数据
172.16.120.100 :) insert into ontime (FlightDate,Year)values('2001-10-12',2001);

可以发现100和101两个节点的本地表均可查询到数据
172.16.120.100 :) select * from ontime;
SELECT *
FROM ontime
┌─FlightDate─┬─Year─┐
│ 2001-10-12 │ 2001 │
└────────────┴──────┘
172.16.120.101 :) select * from ontime;
SELECT *
FROM ontime
┌─FlightDate─┬─Year─┐
│ 2001-10-12 │ 2001 │
└────────────┴──────┘

在100和102两个节点分别查询分布式表也可以查询到数据
172.16.120.100 :) select * from ontime_all;
SELECT *
FROM ontime_all
┌─FlightDate─┬─Year─┐
│ 2001-10-12 │ 2001 │
└────────────┴──────┘
1 rows in set. Elapsed: 0.003 sec.
172.16.120.102 :) select * from ontime_all;
SELECT *
FROM ontime_all
┌─FlightDate─┬─Year─┐
│ 2001-10-12 │ 2001 │
└────────────┴──────┘
1 rows in set. Elapsed: 0.004 sec.

同样在102节点的本地表写入数据,102和103节点本地表可查询到数据, 101和102两个节点的分布式表同样可以查询到数据
172.16.120.102 :) insert into ontime (FlightDate,Year)values('1987-07-05',1987);
INSERT INTO ontime (FlightDate, Year) VALUES
Ok.
1 rows in set. Elapsed: 0.054 sec.
172.16.120.102 :) select * from ontime;
SELECT *
FROM ontime
┌─FlightDate─┬─Year─┐
│ 1987-07-05 │ 1987 │
└────────────┴──────┘
1 rows in set. Elapsed: 0.030 sec.
172.16.120.103 :) select * from ontime;
SELECT *
FROM ontime
┌─FlightDate─┬─Year─┐
│ 1987-07-05 │ 1987 │
└────────────┴──────┘
1 rows in set. Elapsed: 0.002 sec.

172.16.120.100 :) select * from ontime_all;
SELECT *
FROM ontime_all
┌─FlightDate─┬─Year─┐
│ 2001-10-12 │ 2001 │
└────────────┴──────┘
┌─FlightDate─┬─Year─┐
│ 1987-07-05 │ 1987 │
└────────────┴──────┘
2 rows in set. Elapsed: 0.004 sec.

172.16.120.102 :) select * from ontime_all;
SELECT *
FROM ontime_all
┌─FlightDate─┬─Year─┐
│ 1987-07-05 │ 1987 │
└────────────┴──────┘
┌─FlightDate─┬─Year─┐
│ 2001-10-12 │ 2001 │
└────────────┴──────┘
2 rows in set. Elapsed: 0.005 sec.

删除数据
localhost :) select * from ontime_all;
SELECT *
FROM ontime_all
┌─FlightDate─┬─Year─┐
│ 2001-10-18 │ 2001 │
└────────────┴──────┘
┌─FlightDate─┬─Year─┐
│ 2001-10-12 │ 2001 │
│ 2001-10-13 │ 2001 │
│ 2001-10-14 │ 2001 │
│ 2001-10-15 │ 2001 │
│ 2001-10-16 │ 2001 │
└────────────┴──────┘
┌─FlightDate─┬─Year─┐
│ 2001-10-17 │ 2001 │
└────────────┴──────┘
┌─FlightDate─┬─Year─┐
│ 2001-10-19 │ 2001 │
└────────────┴──────┘
┌─FlightDate─┬─Year─┐
│ 1987-07-05 │ 1987 │
└────────────┴──────┘
9 rows in set. Elapsed: 0.008 sec.

localhost :) ALTER table ontime DROP PARTITION '198707';
ALTER TABLE ontime
DROP PARTITION '198707'
Ok.
0 rows in set. Elapsed: 0.133 sec.

localhost :) select * from ontime_all;
SELECT *
FROM ontime_all
┌─FlightDate─┬─Year─┐
│ 2001-10-18 │ 2001 │
└────────────┴──────┘
┌─FlightDate─┬─Year─┐
│ 2001-10-12 │ 2001 │
│ 2001-10-13 │ 2001 │
│ 2001-10-14 │ 2001 │
│ 2001-10-15 │ 2001 │
│ 2001-10-16 │ 2001 │
└────────────┴──────┘
┌─FlightDate─┬─Year─┐
│ 2001-10-19 │ 2001 │
└────────────┴──────┘
┌─FlightDate─┬─Year─┐
│ 2001-10-17 │ 2001 │
└────────────┴──────┘
8 rows in set. Elapsed: 0.005 sec.

经过测试
所有副本节点均可本地表和分布式表均可读写数据

评论

  1. leven
    4年前
    2018-8-01 16:49:41

    可以将配置给出来吗?

    • Huang Jinqiang
      博主
      leven
      4年前
      2018-8-04 10:16:43

      参考集群安装那篇文章

  2. 3年前
    2019-4-28 17:24:07

    哇 学习了~~

  3. krisc
    已编辑
    2年前
    2020-12-08 15:52:35

    两个ontime,不好区分,要不要改一下,不然不知道配置取的是哪个

  4. krisc
    2年前
    2020-12-10 15:10:24

    如果三个节点,两两一个分片,数据会怎么同步呢?

    • Huang Jinqiang
      博主
      krisc
      2年前
      2020-12-16 18:31:00

      三个节点可以2*3这样清楚一点,也就是2个分片,每个分片三个节点

      • sunsk
        Huang Jinqiang
        1年前
        2021-9-29 9:22:35

        2*3是3备份的意思吗?

        • Huang Jinqiang
          博主
          sunsk
          5月前
          2022-5-06 15:01:51

          2*3是集群有2个分片,每个分片由3个节点组成(即3个副本),当然2*2也可以

发送评论 编辑评论


				
|´・ω・)ノ
ヾ(≧∇≦*)ゝ
(☆ω☆)
(╯‵□′)╯︵┴─┴
 ̄﹃ ̄
(/ω\)
∠( ᐛ 」∠)_
(๑•̀ㅁ•́ฅ)
→_→
୧(๑•̀⌄•́๑)૭
٩(ˊᗜˋ*)و
(ノ°ο°)ノ
(´இ皿இ`)
⌇●﹏●⌇
(ฅ´ω`ฅ)
(╯°A°)╯︵○○○
φ( ̄∇ ̄o)
ヾ(´・ ・`。)ノ"
( ง ᵒ̌皿ᵒ̌)ง⁼³₌₃
(ó﹏ò。)
Σ(っ °Д °;)っ
( ,,´・ω・)ノ"(´っω・`。)
╮(╯▽╰)╭
o(*////▽////*)q
>﹏<
( ๑´•ω•) "(ㆆᴗㆆ)
😂
😀
😅
😊
🙂
🙃
😌
😍
😘
😜
😝
😏
😒
🙄
😳
😡
😔
😫
😱
😭
💩
👻
🙌
🖕
👍
👫
👬
👭
🌚
🌝
🙈
💊
😶
🙏
🍦
🍉
😣
Source: github.com/k4yt3x/flowerhd
颜文字
Emoji
小恐龙
花!
上一篇
下一篇