Amoeba

article/2025/9/13 14:44:26

1.介绍

Amoeba是mysql代理,增强mysql。类似的产品还有MyCat (mysql代理)

2.资源:点击打开链接c82k

3.准备:amoeba是基于java的所以必须有jdk

4.上传amoeba

5.解压tar包

6.配置文件


amoeba配置文件两个

dbServers.xml  多个数据源,多个数据库

amoeba.xml 启动参数,谁负责读,谁负责写,谁负责负载均衡

##################################dbServers.xml-start######################################

<?xml version="1.0"encoding="gbk"?>

 

<!DOCTYPE amoeba:dbServers SYSTEM"dbserver.dtd">

<amoeba:dbServersxmlns:amoeba="http://amoeba.meidusa.com/">

 

        <!--

           EachdbServer needs to be configured into a Pool,

           Ifyou need to configure multiple dbServer with load balancing that can besimplified by the following configuration:

            add attribute with name virtual ="true" in dbServer, but the configuration does not allow the elementwith name factoryConfig

            such as 'multiPool' dbServer  

       -->

      

    <dbServername="abstractServer" abstractive="true"><--建立抽象server动态代理-->

       <factoryConfigclass="com.meidusa.amoeba.mysql.net.MysqlServerConnectionFactory">

           <propertyname="manager">${defaultManager}</property>

           <propertyname="sendBufferSize">64</property>

           <propertyname="receiveBufferSize">128</property>

             

           <!--mysql port ,所有的主从复制的数据库的用户名和密码都要用一套-->

           <propertyname="port">3306</property>

          

           <!--mysql schema默认的要去检查schema,一般是test的数据库默认不变 -->

           <propertyname="schema">test</property>

          

           <!--mysql user,用户名默认都是root -->

           <propertyname="user">root</property>

          

           <!--  mysql password ,密码是root-->

           <propertyname="password">root</property>

          

       </factoryConfig>

 

       <poolConfigclass="com.meidusa.amoeba.net.poolable.PoolableObjectPool">

           <propertyname="maxActive">500</property>

           <propertyname="maxIdle">500</property>

           <propertyname="minIdle">10</property>

           <propertyname="minEvictableIdleTimeMillis">600000</property>

           <propertyname="timeBetweenEvictionRunsMillis">600000</property>

           <propertyname="testOnBorrow">true</property>

           <propertyname="testOnReturn">true</property>

           <propertyname="testWhileIdle">true</property>

       </poolConfig>

    </dbServer>

 

    <dbServername="master"  parent="abstractServer"><-默认继承了上面的abstractServer,所以是公用一套上面的配置--->

       <factoryConfig>

           <!--mysql ip 主的ip地址-->

           <propertyname="ipAddress">192.168.170.43</property>

       </factoryConfig>

    </dbServer>

   

    <dbServername="slave"  parent="abstractServer">

       <factoryConfig>

           <!--mysql ip -->

           <propertyname="ipAddress">192.168.170.85</property>

       </factoryConfig>

    </dbServer>

   

    <dbServername="multiPool" virtual="true"><--多个池-->

       <poolConfigclass="com.meidusa.amoeba.server.MultipleServerPool">

           <!--Load balancing strategy(负载均衡算法): 1=ROUNDROBIN轮询 , 2=WEIGHTBASED权重 , 3=HA高可用-->

           <propertyname="loadbalance">1</property>

          

           <!--Separated by commas,such as: server1,server2,server1配置那个数据库是负责读数据的 -->

           <propertyname="poolNames">master,slave</property>

       </poolConfig>

    </dbServer>

      

</amoeba:dbServers>

##################################dbServers.xml-end######################################

##################################amoeba.xml-end######################################

<?xml version="1.0"encoding="gbk"?>

 

<!DOCTYPE amoeba:configuration SYSTEM"amoeba.dtd">

<amoeba:configurationxmlns:amoeba="http://amoeba.meidusa.com/">

 

    <proxy>

   

       <!--service class must implements com.meidusa.amoeba.service.Service -->

       <servicename="Amoeba for Mysql"class="com.meidusa.amoeba.net.ServerableConnectionManager">

           <!--port ,amoeba的端口-->

           <propertyname="port">8066</property>

          

           <!--bind ipAddress ,绑定地址,谁可以访问amoeba,如果要让所有的主机都可以访问,就不需要设置-->

           <!--

           <propertyname="ipAddress">127.0.0.1</property>

            -->

          

           <propertyname="manager">${clientConnectioneManager}</property>

          

           <propertyname="connectionFactory">

              <beanclass="com.meidusa.amoeba.mysql.net.MysqlClientConnectionFactory">

                  <propertyname="sendBufferSize">128</property>

                  <propertyname="receiveBufferSize">64</property>

              </bean>

           </property>

          

           <propertyname="authenticator">

              <beanclass="com.meidusa.amoeba.mysql.server.MysqlClientAuthenticator">

                 

                  <propertyname="user">root</property><-访问amoeba的用户名和密码--->

                 

                  <propertyname="password">root</property>

                 

                  <propertyname="filter">

                     <beanclass="com.meidusa.amoeba.server.IPAccessController">

                         <propertyname="ipFile">${amoeba.home}/conf/access_list.conf</property>

                     </bean>

                  </property>

              </bean>

           </property>

          

       </service>

      

       <!--server class must implements com.meidusa.amoeba.service.Service 阿米巴监控的,不需要监控默认不修改-->

       <servicename="Amoeba Monitor Server"class="com.meidusa.amoeba.monitor.MonitorServer">

           <!--port -->

           <!--  default value: random number

           <propertyname="port">9066</property>

           -->

           <!--bind ipAddress -->

           <propertyname="ipAddress">127.0.0.1</property>

           <propertyname="daemon">true</property>

           <propertyname="manager">${clientConnectioneManager}</property>

           <propertyname="connectionFactory">

              <beanclass="com.meidusa.amoeba.monitor.net.MonitorClientConnectionFactory"></bean>

           </property>

          

       </service>

      

       <runtimeclass="com.meidusa.amoeba.mysql.context.MysqlRuntimeContext">

           <!--proxy server net IO Read thread size这些事实时运行的配置,默认不用改 -->

           <propertyname="readThreadPoolSize">20</property>

          

           <!--proxy server client process thread size -->

           <propertyname="clientSideThreadPoolSize">30</property>

          

           <!--mysql server data packet process thread size -->

           <propertyname="serverSideThreadPoolSize">30</property>

          

           <!--per connection cache prepared statement size -->

           <propertyname="statementCacheSize">500</property>

          

           <!--query timeout( default: 60 second , TimeUnit:second) -->

           <propertyname="queryTimeout">60</property>

       </runtime>

      

    </proxy>

   

    <!--

       EachConnectionManager will start as thread

       managerresponsible for the Connection IO read , Death Detection

    -->

    <connectionManagerList>

       <connectionManagername="clientConnectioneManager" class="com.meidusa.amoeba.net.MultiConnectionManagerWrapper">

           <propertyname="subManagerClassName">com.meidusa.amoeba.net.ConnectionManager</property>

           <!--

             default value is avaliable Processors

           <propertyname="processors">5</property>

            -->

       </connectionManager>

       <connectionManagername="defaultManager"class="com.meidusa.amoeba.net.MultiConnectionManagerWrapper">

           <propertyname="subManagerClassName">com.meidusa.amoeba.net.AuthingableConnectionManager</property>

          

           <!--

             default value is avaliable Processors

           <propertyname="processors">5</property>

            -->

       </connectionManager>

    </connectionManagerList>

   

       <!--default using file loader 指定刚刚配置过的dbServer.xml文件,将配置文件读入-->

    <dbServerLoaderclass="com.meidusa.amoeba.context.DBServerConfigFileLoader">

       <propertyname="configFile">${amoeba.home}/conf/dbServers.xml</property>

    </dbServerLoader>

   

    <queryRouterclass="com.meidusa.amoeba.mysql.parser.MysqlQueryRouter">

       <propertyname="ruleLoader">

           <beanclass="com.meidusa.amoeba.route.TableRuleFileLoader">

              <propertyname="ruleFile">${amoeba.home}/conf/rule.xml</property>

              <propertyname="functionFile">${amoeba.home}/conf/ruleFunctionMap.xml</property>

           </bean>

       </property>

       <propertyname="sqlFunctionFile">${amoeba.home}/conf/functionMap.xml</property>

       <propertyname="LRUMapSize">1500</property>

       <propertyname="defaultPool">master</property><--默认池只有master能写,所以要配主-->

      

 

       <propertyname="writePool">master</property><--master能写,所以要配主-->

       <propertyname="readPool">multiPool</property><--dbServer.xml中配置过能写的数据库,把他的属性写过来-->

 

       <propertyname="needParse">true</property>

    </queryRouter>

</amoeba:configuration>


##################################amoeba.xml-end######################################

7. 打开8066端口

/sbin/iptables -I INPUT -p tcp --dport 8066 -j ACCEPT

/etc/rc.d/init.d/iptables save      #修改生效

/etc/init.d/iptables status         #查看配置

8.启动和关闭amoeba

启动:./bin/amoeba start 或 ./bin/amoeba start &


关闭:

./bin/amoeba stop


9.启动报错


是因为jdk默认(128k)的栈太小了,而根据上述报错,栈需要228k才行

默认配置Xss比较小128k,启动时提示太小,则修改/amoeba/bin/amoeba文件,修改为256k即可。

DEFAULT_OPTS="-server -Xms256m-Xmx256m -Xss256k"

再次启动,ok


检查是否启动成功


10.使用第三方软件链接amoeba


使用主从复制的bug来检查是链接到了主还是从,将主数据库和从数据库中各添加一条独特的数据

11.如果链接上amoeba后发现查不出数据


根据状态可知主从配置失败了,需要从新配置


从错误可知,主键重了,重新配置

1)将从停了

2)到主上查看位置pos


重新执行挂接命令


启动从服务


验证


然后根据那个bug来看,经过amoeba链接的是从还是主


上图链接的是主

修改的话修改的是主数据库



http://chatgpt.dhexx.cn/article/l4TaPcFj.shtml

相关文章

Mysql基于Amoeba_读写分离搭架

一、Amoeba简介 Amoeba是一个以MySQL为底层数据存储&#xff0c;并对应用提供MySQL协议接口的proxy。它集中地响应应用的请求&#xff0c;依据用户事先设置的规则&#xff0c;将SQL请求发送到特定的数据库上执行。基于此可以实现负载均衡、读写分离、高可用性等需求&#xff0…

mysql基于Amoeba(变形虫)实现读写分离

一&#xff0c;Amoeba介绍 1、什么是amoeba&#xff1f; ​ Amoeba(变形虫)项目&#xff0c;专注 分布式数据库 proxy 开发。座落与Client、DB Server(s)之间。对客户端透明。具有负载均衡、高可用性、sql过滤、读写分离、可路由相关的query到目标数据库、可并发请求多台数据…

Amoeba:开源的分布式数据库Porxy解决方案

什么是Amoeba? Amoeba(变形虫)项目&#xff0c;该开源框架于2008年 开始发布一款 Amoeba for Mysql软件。这个软件致力于MySQL的分布式数据库前端代理层&#xff0c;它主要在应用层访问MySQL的 时候充当SQL路由功能&#xff0c;专注于分布式数据库代理层&#xff08;Database …

findbugs html报告,利用findBugs插件来扫描代码,并用ant生成报告

最近项目要用findbugs插件来生成报告&#xff0c;总结了一下用法和如何生成报告 1&#xff0c; 把下载的压缩包解压后&#xff0c;把 copy到eclipse的plugin目录中去&#xff1b; 2&#xff0c; 重新启动eclipse 3&#xff0c; 打开eclipse->window->Preferences&#xf…

AS之Findbugs

一 前言 Findbugs是由 National Science Foundation支持的一个用静态分析的方式来寻找Java代码中Bug的项目&#xff0c;它是一个静态分析工具&#xff0c;它检查类或者jar文件&#xff0c;将字节码和一组缺陷模式进行对比以发现可能的问题。有了静态分析工具&#xff0c;就可以…

AndroidStudio中FindBugs的简单使用教程

对于代码质量的检查&#xff0c;一直是一个比较棘手的问题。虽然我们部门有关于java代码的各种规范&#xff0c;领导也多次强调对代码的评审。 但是在实际执行过程中&#xff0c;由于开发人员的水平参差不齐&#xff0c;在开发项目时还有各种其他因素&#xff0c;比如时间紧任…

maven项目集成findbugs详解

文章目录 0、概述一、接入方式二、如何使用方式一、在控制台中执行打包命令方式二、使用IntelliJ IDEA的maven工具&#xff08;其他IDE用户忽略&#xff09; 三、bug详情查看四、忽略指定的包、类、类中的方法步骤一、在pom.xml中 增加配置。步骤二、增加配置文件&#xff0c;用…

Findbugs maven 插件使用

Findbugs maven 插件使用 FindBugs™手册 http://findbugs.sourceforge.net/manual/index.html 0、概述 FindBugs是一个静态分析工具&#xff0c;它将**字节码&#xff08;因此需要先编译&#xff09;**与一组缺陷模式进行对比以发现可能的问题。有了静态分析工具&#xff0c;…

检查代码质量的插件Findbugs使用说明

一、简介 Findbugs是一个静态分析工具&#xff0c;它检查类或者jar文件&#xff0c;将字节码与一组缺陷模式进行对比以发现可能的问题。利用这个工具可以在不实际运行程序的情况下对软件进行分析。可以帮助改进代码质量。Findbugs提供了方便操作的可视化界面&#xff0c;同时也…

Findbugs的使用

转载请注明出处&#xff1a;http://blog.csdn.net/feibendexiaoma/article/details/72821781前言 Findbugs很多人都并不陌生&#xff0c;Eclipse中有插件可以帮助查找代码中隐藏的bug&#xff0c;IDEA中也有这款插件。这个插件可以帮助我们查找隐藏的bug,比较重要的功能就是查找…

android studio findbugs 过滤,Android Studio中使用FindBugs

1.什么是FindBugs 一句话简单理解就是&#xff1a;是一个工具&#xff0c;可以用它自动帮你找出代码中潜在的BUG。当然事实并不一定总是如此&#xff0c;也有很多它找不出来的地方。下面将直接介绍如何在Android Studio中的简单使用。有兴趣的童鞋可以自己去了解了解&#xff0…

FindBugs插件

官网 FindBugs官网&#xff1a;http://findbugs.sourceforge.net/ 插件安装 点击settings---->plugins---->Browse repositories 搜索框输入FindBugs-IDEA并点击右侧Install按钮 安装完毕后重启idea&#xff0c;发现左下角多了一个FindBugs图标 插件使用 在被检查文…

eclipse常用插件之FindBugs

1、简介 FindBugs 是由马里兰大学提供的一款开源 Java静态代码分析工具。FindBugs通过检查类文件或 JAR文件&#xff0c;将字节码与一组缺陷模式进行对比从而发现代码缺陷&#xff0c;完成静态代码分析。FindBugs既提供可视化 UI 界面&#xff0c;同时也可以作为 Eclipse插件使…

php findbugs,findBugs插件

现在使用Java进行开发的软件已经很多了&#xff0c;那么我们在使用Java开发的时候&#xff0c;是不是会遇到各种各样的错误了&#xff0c;有的错误隐藏着&#xff0c;有的错误你发现了&#xff0c;可以修改&#xff0c;那没有发现的错误就令人担忧了&#xff01;小编这款插件就…

软件测试实验 FindBugs

1.配置 FindBugs 打开 Eclipse&#xff0c;通过【Window -> Preferences】下【Java -> FindBugs】查看 FindBugs的 配置情况。问题: 这里可以配置 FindBugs的哪些特性&#xff1f; 选择导入的项目&#xff0c;通过【Window -> Preferences】下【Java -> FindBugs…

Findbug使用指南

Findbug使用指南 findbugs是一个开源的eclipse 代码检查工具&#xff1b;它可以简单高效全面地帮助我们发现程序代码中存在的bug&#xff0c;bad smell&#xff0c;以及潜在隐患。针对各种问题&#xff0c;它并且提供了简单的修改意见供我们重构时进行参考&#xff1b; 通过使…

findbugs用法教程

代码分析工具FindBugs详细配置使用教程 一&#xff0c;关于FindBugs (1) FindBugs 是由马里兰大学提供的一款开源 Java 静态代码分析工具&#xff0c;它检查类或者 JAR 文件&#xff0c;将字节码与一组缺陷模式进行对比以发现可能的问题(先对编译后的class进行扫描&#xff0c;…

自动找Bug/插件-代码静态检查findbugs-idea安装以及使用

目录 简介 IDEA安装FindBugs Findbugs配置 配置排除一些类 扫描级别 IDEA中使用FindBugs: 一些常见错误 补充 简介 Findbugs是一个静态分析工具&#xff0c;它检查类或者JAR 文件&#xff0c;将字节码与一组缺陷模式进行对比以发现可能的问题。Findbugs自带检测器&…

Elasticsearch安装IK分词器、配置自定义分词词库

一、分词简介1、单字分词&#xff1a;2、二分法分词&#xff1a;3、词库分词&#xff1a; 二、配置IK中文分词器三、配置自定义分词拓展词库 一、分词简介 在Elasticsearch中&#xff0c;假设搜索条件是“华为手机平板电脑”&#xff0c;要求是只要满足了其中任意一个词语组合…

Elasticsearch 英文分词 中文分词

对于倒排索引来说&#xff0c;很重要的一件事情就是需要对文本进行分词&#xff0c;经过分词可以获取情感、词性、质性、词频等等的数据。 Elasticsearch 分词工作原理 在 Elasticsearch 中进行行分词的需要经过分析器的3个模块&#xff0c;字符过滤器将文本进行替换或者删除&…