java自学网VIP

Java自学网

 找回密码
 立即注册

QQ登录

只需一步,快速开始

查看: 2630|回复: 0

《大规模分布式存储系统》第11章 质量保证、运维及实践【11.2】

[复制链接]
  • TA的每日心情
    开心
    2021-5-25 00:00
  • 签到天数: 1917 天

    [LV.Master]出神入化

    2025

    主题

    3683

    帖子

    6万

    积分

    管理员

    Rank: 9Rank: 9Rank: 9

    积分
    66345

    宣传达人突出贡献优秀版主荣誉管理论坛元老

    发表于 2017-3-15 18:18:57 | 显示全部楼层 |阅读模式
    11.2 使用与运维
    ) E5 Z: B& D2 ]. P& z) m  cOceanBase不是设计出来的,而是在使用过程中不断进化出来的。因此,系统使
    + O9 \6 F6 P4 M+ N用以及运维的方便性至关重要。2 Z( J* V5 t, Q
    OceanBase的使用者是业务系统开发人员,并交由专门的OceanBase DBA来运; Q. B* u9 h/ R3 |3 @
    维。为了方便业务使用,OceanBase实现了SQL接口且兼容MySQL协议,从而融入到* r) O# J$ G! N7 F! [
    MySQL开源生态圈。MySQL大部分管理工具,例如MySQL客户端,MySQL admin,9 ?5 y% `2 F2 C; U2 o+ T
    能够在OceanBase系统中直接使用。另外,OceanBase将系统运维、监控相关的内部; {3 i* Z- M6 k$ e
    信息存放到内部的系统表中,从而方便运维、监控系统获取。( w# P1 p. ?& W$ X* ^
    11.2.1 使用- [* ~" h/ U' p5 y) E6 l& w* E
    OceanBase早期版本只允许通过Java或者C API接口访问,新版本增加了SQL支1 n9 c$ {) W1 d: I
    持,且兼容MySQL客户端访问协议。OceanBase推荐用户使用SQL,但老应用仍然可
    ! V' |$ P' P; E8 z9 _以使用以前的Java API访问OceanBase。下面介绍几个访问与使用场景。8 O4 Y7 g1 n! _  f
    1.MySQL客户端连接
    # N2 x% U% f' `# k( Q5 y如图11-4所示,使用者采用MySQL客户端连接OceanBase。通过MySQL客户端可
    # j: G' ~( L/ h4 M+ I以查看系统已有的表格、表格schema,执行select、update、insert、delete等SQL语0 ^: _# G" J; E3 E/ U0 B# X$ j! i
    句,查看系统内部状态,以及发送OceanBase集群运维命令。图中首先通过create
    & t5 e; a) }- q$ ?/ btable命令创建一张名称为test的表格,表格包含两列:id和name,其中id为主键。接( W! v# i0 K2 [. l6 L
    着,往表格中写入两行记录(1,"alice"),(2,"bob")。最后,通过select语句读; T' r" _% G( v4 `
    取这两行数据。0 k+ n: ?) J0 J1 |9 I
    图 11-4 采用MySQL客户端连接OceanBase
    2 [0 j8 J1 E5 G; Z$ q2.JDBC访问(JDBC template)2 O$ N6 V- E- x* X/ \2 }, q0 [
    Java应用通过标准JDBC访问OceanBase,代码如下所示:4 P0 i2 H+ ]5 {* m3 y! z
    ObGroupDataSource groupSource=new OBGroupDataSource();
    & ~% s% L; T% X. R6 R9 @groupSource.setUserName("user");//设置用户名! ]8 m# K: C0 {8 Z* F
    groupSource.setPasswd("pass");//设置密码
    ! e& r% k. _4 k  h- L# D( R% _  w1 ~8 ZgroupSource.setDbName("test");//OceanBase不支持db,这里可以填任意值
    7 g% z: x# X  N5 o5 Z; HgroupSouorce.setConfigURL(ob_addr_url);//设置OceanBase集群的地址9 o5 O7 w5 F7 t/ l' E' \. b% A
    groupSource.init();//初始化data source
    6 ?7 s# n3 r" q: M5 h* EJdbcTemplate jtp=new JdbcTemplate();
    $ q; e% ]2 ~( M1 \( g5 [7 hjtp.setDataSource(groupSource);//设置jdbc template依赖的data source, r4 q. X7 W1 H
    String sql="select 1 from dual";
    9 I% n4 G" ~" J+ \* t# J/ @" Pint ret=jtp.queryForInt(sql);//执行SQL查询
    4 h; J) M% ]1 j% J3.Spring集成" A" X: P, j' T' h2 Y% J
    可以通过将OceanBase DataSource集成到Spring中,配置如下:
    3 Z) b2 x8 F2 d* Q. D<bean id="groupDataSource"
    4 J( Y* j) c# iclass="com.alipay.oceanbase.ObGroupDataSource"1 G$ v1 V# T3 n; }" ^) q0 f
    init-method="init"># K1 c6 I. L. r+ n, ~* d" X
    <property name="username"value="user"/>4 @# {8 v6 R, b( P( I3 T% o
    <property name="passwd"value="pass"/>, q; b) M8 [% y, V' ^& W$ c/ E
    <property name="dbName"value="test"/>7 |( O' e( {8 S$ i
    <property name="configURL"value=ob_addr_url/>
    6 C- _& p+ N# U3 R' U</bean># d7 ~! l+ D8 g) P. @8 x1 l2 w/ l& q- G
    4.C客户端# g% }8 F  _! f0 A$ v
    C应用通过OceanBase C客户端访问OceanBase,使用方式与MySQL C客户端完全
    * T8 N. e+ P' Z' _' I0 x一致,代码如下:* R- D9 a+ e$ S1 t1 m
    MYSQL mysql;4 P2 I9 s6 Z6 I. P9 A
    mysql_init(&mysql); //初始化
    7 X# D) l( Y3 x. S( R1 k  n0 n0 ymysql_real_connect(&mysql,ob_url,ob_user,ob_pass,NULL,0,NULL,0); //连接
    7 F8 I& M" B9 t: y: s6 VOceanBase数据库- i7 S/ E  F4 m( S7 V' n
    mysql_real_query(&mysql,sql,strlen(sql)); //执行SQL查询- Q( ~6 Y/ w& x) g' B# u
    MYSQL_RES*res=mysql_store_result(&mysql); //获取SQL查询结果集
    2 G' ?$ _3 t) g4 F3 u//处理SQL查询返回的结果集$ ~" @, o; j9 v: a/ q( N6 L9 h. }
    while(MYSQL_ROW row=mysql_fetch_row(res)) //从结果集读取一行数据1 ?; n% m6 d0 B8 C8 W
    {
    8 a! V' x! s$ P* p! x4 g# c: I//处理结果集中的一行结果; t  r1 G  o! S. m
    }
    # z/ m  F2 t9 }mysql_free_result(res); //释放结果集
    % Y9 D+ p0 ~) `+ @4 @# z* smysql_close(&mysql); //关闭连接5 T; s/ P; D4 A
    当然,应用可能会在客户端维护OceanBase连接池,Java应用还可能会使用其他
    8 n( U' e! b: ~( {; s持久层框架,例如iBatis。由于OceanBase兼容JDBC和MySQL C客户端,使用MySQL3 D5 S" O( `9 M! A+ K
    的应用无须修改代码就能接入OceanBase。
    * V1 v2 h7 V0 k$ W4 T* `' v11.2.2 运维4 p) F6 d: X7 _0 s0 `- m' N4 h4 m
    OceanBase内部实现了系统表机制,用于存储监控以及运维相关的信息。内部系
    : x8 [  r! w+ L统表包含的内容如下:. r3 I. a3 S( B# L
    ●数据字典:表格的定义以及表格之间的关系、用户以及权限信息;
    " J# ^6 o' [" O. A2 F7 N# Z5 Q' W- Q●服务器列表:集群中每种角色所在的服务器列表;
    7 I4 _* ?8 |) g1 o7 G3 M: W% l●配置信息:集群中每台服务器的配置信息;
    7 c" G( f$ f! U: D●内部状态:每台服务器的读写次数、读写延时、缓存命中率、子表个数、内
    & T/ i- X& ^& m" M存、磁盘、CPU使用情况、请求关键路径时间消耗,每日合并状态等;
    / B5 q+ e: ?1 r3 f) O基于内部系统表,可以开发各种方便的OceanBase运维功能,如OceanBase数据, M! S7 u4 @7 M5 k+ `
    库会话(Session)管理,读写性能实时监控工具、监控平台等。
    ' T. v4 Z, Q& ^: ]. O# \  r图11-5是OceanBase某线上应用平均读取延时的监控图,包括单行读取平均延时
    ! ^9 }) y4 U) P1 z9 W(average_succ_get_time)以及多行扫描平均延时(average_succ_scan_time)两个指. y. G5 S0 I# }* P% \+ P- R
    标,且单位均为微秒。监控图包含三种数据:当前数据(currval),昨天数据
    $ m9 _; r6 B. ?! R(lastval)以及上周数据(baseval),便于对比。由于监控、运维工具变化较快,这+ A; q7 R7 v6 B; h: c
    里不做太多介绍。, D& t# \* i# v; ]6 e/ D
    图 11-5 OceanBase某线上应用读取延时
    % a% p" m9 S# `4 _9 F
    4 a$ O2 g+ D8 O9 j7 X, s3 o$ p% d" p6 L; P9 n

    ; F; R! K. s" R8 u* Y/ t5 z
    回复

    使用道具 举报

    您需要登录后才可以回帖 登录 | 立即注册

    本版积分规则

    QQ|Archiver|手机版|小黑屋|Java自学网

    GMT+8, 2024-11-21 20:37 , Processed in 0.139894 second(s), 30 queries .

    Powered by Javazx

    Copyright © 2012-2022, Javazx Cloud.

    快速回复 返回顶部 返回列表