这篇文章主要为大家展示了“heisenberg怎么配置”,内容简而易懂,条理清晰,希望能够帮助大家解决疑惑,下面让小编带领大家一起研究并学习一下“heisenberg怎么配置”这篇文章吧。
首先核心配置就三个文件server.xml,schema.xml,rule.xml,还有hsb.properties,用于对应用服务器配置
hsb的目录结构如下:
heisenberg
/bin 启动脚本所在目录
/conf classpath所在目录
默认配置文件所在 对应的hsb.properties和log4j.xml必须要在conf下
server.xml,schema.xml,rule.xml 这三个默认在下面
/lib
/logs 默认日志所在目录
startup.sh -h可以显示对应的参数
startup.sh -c 可以指定对应的配置folder,比如有几套系统,-l 可以指定输出日志目录,和之前一样
server.xml
<?xml version="1.0" encoding="UTF-8"?> <heisenberg:server xmlns:heisenberg="https://github.com/brucexx/heisenberg"> <!-- 系统参数定义,服务端口、管理端口,处理器个数、线程池等。 --> <system> <property name="serverPort">4320</property> <property name="managerPort">4321</property> <property name="initExecutor">16</property> <property name="timerExecutor">4</property> <property name="managerExecutor">4</property> <property name="processors">8</property> <property name="processorHandler">16</property> <property name="processorExecutor">16</property> <property name="clusterHeartbeatUser">_HEARTBEAT_USER_</property> <property name="clusterHeartbeatPass">_HEARTBEAT_PASS_</property> <property name="dataNodeHeartbeatPeriod">15000</property> </system> <!--用户名密码等 --> <user name="pay"> <property name="password">brucexx</property> <property name="schemas">wms_shard</property> </user> <!-- <user name="pay"> <property name="needEncrypt">true</property> <property name="password">lTrRlcGA0jOuucx8z4pCKj1Qg4GuqQNj2FDT2x9B4P4TEO/O5kj9TxPgzT2JgqY6jo8XsVSvzVqZ4W5DJc1gCA==</property> <property name="schemas">wms_shard</property> </user> --> </heisenberg:server>
其实加密密码是动态的,大家可根据自己的安全级别来设定,但是要指定hsb.properties里的公钥
publicKey=xxxxx
大家如果要使用,可以下载源码 查看EncryptGen这个文件去生成对应的密文,加密方法RSA 位数512,至于如何生成对应的密钥对,我这里就不说了
schema.xml
<?xml version="1.0" encoding="UTF-8"?> <heisenberg:schema xmlns:heisenberg="https://github.com/brucexx/heisenberg"> <schema name="wms_shard"> <table name="t_asset_deal_type" dataNode="wmsDN$0-99" rule="rule1" /> <table name="t_supplier_account_info" dataNode="wmsDN$0-99" rule="rule1" /> <table name="t_user_account_info" dataNode="wmsDN$0-99" rule="rule1" /> <table name="t_user_bank_sign_request_info" dataNode="wmsDN$0-99" rule="rule2" /> <table name="t_user_bind_bank_info" dataNode="wmsDN$0-99" rule="rule1" /> <table name="t_user_fund_sign_request_info" dataNode="wmsDN$0-99" rule="rule2" /> <table name="t_user_id_map" dataNode="wmsDN$0-99" rule="rule3" /> <table name="t_user_investment_info" dataNode="wmsDN$0-99" rule="rule4" /> <table name="t_cert_info_upload_log" dataNode="wmsDN_Single" rule="rule5" /> <table name="t_cert_file_upload_summary_info" dataNode="wmsDN_Single" rule="rule6" /> <table name="t_user_bind_card_replace_info" dataNode="wmsDN_Single" rule="rule7" /> <table name="t_province_city_info" dataNode="wmsDN_Single" rule="rule7" /> </schema> <dataNode name="wmsDN"> <property name="dataSource"> <dataSourceRef>wmsDS$0-99</dataSourceRef> </property> <property name="poolSize">256</property> <property name="heartbeatSQL">select user()</property> </dataNode> <dataSource name="wmsDS" type="mysql"> <property name="location"> <location>127.0.0.1:5506/wms_db_$00-99</location> </property> <property name="user">work_pay</property> <property name="password">123456</property> </dataSource> <!-- 单库的 --> <dataNode name="wmsDN_Single"> <property name="dataSource"> <dataSourceRef>wmsDS_Single</dataSourceRef> </property> <property name="poolSize">256</property> <property name="heartbeatSQL">select user()</property> </dataNode> <dataSource name="wmsDS_Single" type="mysql"> <property name="location"> <location>127.0.0.1:5506/wms_db</location> </property> <property name="user">work_pay</property> <property name="password">123456</property> </dataSource> </heisenberg:schema>
里面的密码也是支持加密的,和server.xml里一样,加个neeEncrypt,这里不再累述
rule.xml
<?xml version="1.0" encoding="UTF-8"?> <rule> <tableRule name="rule1"> <columns>F_USER_ID</columns> <dbRuleList> <dbRule><![CDATA[ #set($sub_str=$F_USER_ID%1000+"") $!stringUtil.substring($stringUtil.alignRights($sub_str,3,"0"),0,2)]]> </dbRule> </dbRuleList> <tbRuleList> <tbRule><![CDATA[ #set($sub_str=$F_USER_ID%1000+"") #set($sub_str=$stringUtil.alignRights($sub_str,3,"0")) #set($db_flag=$stringUtil.substring($sub_str,0,2)) #set($tb_flag=$stringUtil.substring($sub_str,2)) #set($prefix="_"+$db_flag+"_"+$tb_flag)## $!prefix]]> </tbRule> </tbRuleList> <tbPrefix> <![CDATA[ def map = [:]; for (int i=0; i<100; i++) { def list = []; for (int j=0; j<10; j++) { def k=i<10?"0"+i:i; list.add("_"+k+"_"+j); } map.put(i,list); }; return map; ]]> </tbPrefix> </tableRule> <tableRule name="rule2"> <columns>F_APPLICATION_NO</columns> <dbRuleList> <dbRule><![CDATA[ $!stringUtil.substring($F_APPLICATION_NO,-3,-1)]]> </dbRule> </dbRuleList> <tbRuleList> <tbRule><![CDATA[ #set($db_flag=$!stringUtil.substring($F_APPLICATION_NO,-3,-1)) #set($tb_flag=$!stringUtil.substring($F_APPLICATION_NO,-1)) #set($prefix="_"+$db_flag+"_"+$tb_flag)## $!prefix]]> </tbRule> </tbRuleList> <tbPrefix> <![CDATA[ def map = [:]; for (int i=0; i<100; i++) { def list = []; for (int j=0; j<10; j++) { def k=i<10?"0"+i:i; list.add("_"+k+"_"+j); } map.put(i,list); }; return map; ]]> </tbPrefix> </tableRule> <tableRule name="rule3"> <columns>F_UID</columns> <dbRuleList> <dbRule><![CDATA[ #set($sub_str=$F_UID%1000+"") $!stringUtil.substring($stringUtil.alignRights($sub_str,3,"0"),0,2)]]> </dbRule> </dbRuleList> <tbRuleList> <tbRule><![CDATA[ #set($sub_str=$F_UID%1000+"") #set($sub_str=$stringUtil.alignRights($sub_str,3,"0")) #set($db_flag=$stringUtil.substring($sub_str,0,2)) #set($tb_flag=$stringUtil.substring($sub_str,2)) #set($prefix="_"+$db_flag+"_"+$tb_flag)## $!prefix]]> </tbRule> </tbRuleList> <tbPrefix> <![CDATA[ def map = [:]; for (int i=0; i<100; i++) { def list = []; for (int j=0; j<10; j++) { def k=i<10?"0"+i:i; list.add("_"+k+"_"+j); } map.put(i,list); }; return map; ]]> </tbPrefix> </tableRule> <tableRule name="rule4"> <columns>F_CERTIFICATE_CODE</columns> <dbRuleList> <dbRule><![CDATA[ #set($db_flag=$!stringUtil.crc32($F_CERTIFICATE_CODE)) $!stringUtil.substring($db_flag,-3,-1)]]> </dbRule> </dbRuleList> <tbRuleList> <tbRule><![CDATA[ #set($sub_str=$!stringUtil.crc32($F_CERTIFICATE_CODE)) #set($db_flag=$!stringUtil.substring($sub_str,-3,-1)) #set($tb_flag=$!stringUtil.substring($sub_str,-1)) #set($prefix="_"+$db_flag+"_"+$tb_flag)## $!prefix]]> </tbRule> </tbRuleList> <tbPrefix> <![CDATA[ def map = [:]; for (int i=0; i<100; i++) { def list = []; for (int j=0; j<10; j++) { def k=i<10?"0"+i:i; list.add("_"+k+"_"+j); } map.put(i,list); }; return map; ]]> </tbPrefix> </tableRule> <tableRule name="rule5"> <columns>F_SP_ID</columns> <dbRuleList> <dbRule><![CDATA[0]]> </dbRule> </dbRuleList> <tbRuleList> <tbRule><![CDATA[ #set($tb_flag=$F_SP_ID+"") #set($prefix="_"+$tb_flag)## $!prefix]]> </tbRule> </tbRuleList> <tbPrefix> <![CDATA[ def map = [:]; def list = []; for (int i=0; i<100; i++) { list.add("_"+i); }; map.put(0,list); return map; ]]> </tbPrefix> </tableRule> <tableRule name="rule6"> <columns>F_USER_ID</columns> <dbRuleList> <dbRule><![CDATA[ #set($sub_str=$F_USER_ID%1000+"") $!stringUtil.substring($stringUtil.alignRights($sub_str,3,"0"),0,2)]]> </dbRule> </dbRuleList> <tbRuleList> <tbRule><![CDATA[$!prefix]]> </tbRule> </tbRuleList> <tbPrefix> </tbPrefix> </tableRule> <tableRule name="rule7"> <columns>F_FAKE_PARTITION_ID</columns> <dbRuleList> <dbRule><![CDATA[ #set($sub_str=$F_FAKE_PARTITION_ID%1000+"") $!stringUtil.substring($stringUtil.alignRights($sub_str,3,"0"),0,2)]]> </dbRule> </dbRuleList> <tbRuleList> <tbRule><![CDATA[$!prefix]]> </tbRule> </tbRuleList> <tbPrefix> </tbPrefix> </tableRule> </rule>
大家对号入坐,自己看
然后一个表里有多个字段想命中,
<tableRule name="rule1" forceHit="true"> <columns>F_TRANS_ID,F_BUYER_USER_ID</columns> <dbRuleList> <dbRule><![CDATA[$!stringUtil.substring($F_TRANS_ID,-3,-1)]]></dbRule> <dbRule><![CDATA[ #set($sub_str=$F_BUYER_USER_ID%1000+"") $!stringUtil.substring($stringUtil.alignRights($sub_str,3,"0"),0,2)]]> </dbRule> </dbRuleList> <tbRuleList> <tbRule><![CDATA[ #set($db_flag=$!stringUtil.substring($F_TRANS_ID,-3,-1)) #set($tb_flag=$!stringUtil.substring($F_TRANS_ID,-1)) #set($prefix="_"+$db_flag+"_"+$tb_flag)## $!prefix]]> </tbRule> <tbRule><![CDATA[ #set($sub_str=$F_BUYER_USER_ID%1000+"") #set($sub_str=$stringUtil.alignRights($sub_str,3,"0")) #set($db_flag=$stringUtil.substring($sub_str,0,2)) #set($tb_flag=$stringUtil.substring($sub_str,2)) #set($prefix="_"+$db_flag+"_"+$tb_flag)## $!prefix]]> </tbRule> </tbRuleList> <tbPrefix> <![CDATA[ def map = [:]; for (int i=0; i<100; i++) { def list = []; for (int j=0; j<10; j++) { def k=i<10?"0"+i:i; list.add("_"+k+"_"+j); } map.put(i,list); }; return map; ]]> </tbPrefix> </tableRule>
以上是“heisenberg怎么配置”这篇文章的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注亿速云行业资讯频道!
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。