Heim  >  Artikel  >  Datenbank  >  MySQL-Lese- und Schreibtrennungspraxis – Codebeispiele für den Aufbau eines leistungsstarken Webs

MySQL-Lese- und Schreibtrennungspraxis – Codebeispiele für den Aufbau eines leistungsstarken Webs

黄舟
黄舟Original
2017-03-11 14:28:241111Durchsuche

Eine vollständige MySQL-Umgebung zur Lese-/Schreibtrennung umfasst die folgenden Teile:

  • Anwendungsclient

  • Datenbank-Proxy

  • Datenbankcluster

In diesem tatsächlichen Kampf stellt der Anwendungsclient eine Verbindung zum Back-End-Datenbank-Proxy basierend auf c3p0 her. Der Datenbank-Proxy ist für die Verwaltung der Routing-Strategie verantwortlich, damit Clients mithilfe des Open-Source-Frameworks Amoeba tatsächlich auf die Datenbank zugreifen können. Der Datenbankcluster verwendet die Master-Slave-Replikationslösung von MySQL. Das Strukturdiagramm der gesamten Umgebung lautet wie folgt:

Praktische Schritte und detaillierte Erklärungen

1. Erstellen Sie die Master-Slave-Umgebung von MySQL

1) Installieren Sie MySQL (5.0.45) auf Host1 (10.20.147.110) bzw. Host2 (10.20.147.111). Die spezifische Installationsmethode finden Sie im offiziellen Dokument

2) Master konfigurieren

Bearbeiten Sie zuerst /etc/my.cnf und fügen Sie die folgende Konfiguration hinzu:

log-bin=mysql-bin #slave会基于此log-bin来做replication
server-id=1 #master的标示
binlog-do-db = amoeba_study #用于master-slave的具体数据库

Fügen Sie dann einen Benutzer speziell für die Replikation hinzu:

mysql> GRANT REPLICATION SLAVE ON *.* TO repl@10.20.147.111 IDENTIFIED BY '111111';

MySQL neu starten, damit die Konfiguration wirksam wird:

/etc/init.d/mysqld restart

Überprüfen Sie abschließend den Master-Status:

3) Slave konfigurieren

Bearbeiten Sie zuerst /etc/my.cnf und fügen Sie die folgende Konfiguration hinzu:

server-id=2 #slave label

Nachdem die Konfiguration wirksam wird, konfigurieren Sie die Verbindung mit dem Master:

mysql> CHANGE MASTER TO
    -> MASTER_HOST='10.20.147.110',
   
 -> MASTER_USER='repl',
    -> MASTER_PASSWORD='111111',
   
 -> MASTER_LOG_FILE='mysql-bin.000003',
    -> 
MASTER_LOG_POS=161261;

wobei MASTER_HOST die Master-Maschinen-IP ist, MASTER_USER und MASTER_PASSWORD die Benutzer sind, die wir gerade auf dem Master hinzugefügt haben, MASTER_LOG_FILE und MASTER_LOG_POS entsprechen den Informationen im Master-Status

Starten Sie schließlich den Slave :

mysql> start slave;

4) Master überprüfen – Der Slave-Build wird wirksam

Durch Überprüfung des Protokolls der Slave-Maschine (/var/log/mysqld.log):

100703 10:51:42 [Note] Slave I/O thread: connected to master 'repl@10.20.147.110:3306',  
replication started in log 'mysql-bin.000003' at position 161261

Wenn Sie die oben genannten Informationen sehen, beweist dies, dass der Build erfolgreich war. Wenn vorhanden, kann die Ursache des Problems auch über dieses Protokoll gefunden werden

2 . Erstellen Sie einen Datenbank-Proxy

In diesem tatsächlichen Kampf verwendet der Datenbank-Proxy Amoeba , die zugehörigen Informationen finden Sie in den offiziellen Dokumenten, die hier nicht näher erläutert werden

1) Amoeba installieren

Amoeba (1.2.0-GA) herunterladen und lokal entpacken (D: /openSource/amoeba -mysql-1.2.0-GA), d. end mysql server (D:/openSource/amoeba- mysql-1.2.0-GA/conf/amoeba.xml):

Das Obige ist die Verbindungskonfiguration, die dem Client vom Proxy bereitgestellt wird

Das Obige ist die Konfigurationsinformation für den Proxy und den Back-End-MySQL-Datenbankserver. Informationen zur spezifischen Konfiguration finden Sie in den Kommentaren.

Konfigurieren Sie abschließend die Richtlinie zur Lese-/Schreibtrennung:
<dbServerList>  
    <dbServer name="server1">           
        <!-- PoolableObjectFactory实现类 -->  
        <factoryConfig class="com.meidusa.amoeba.mysql
        <a href="http://lib.csdn.net/base/dotnet" class=&#39;replace_word&#39; title=".NET知识库" target=&#39;_blank&#39; style=&#39;color:#df3434; font-weight:bold;&#39;>.NET</a>
        .MysqlServerConnectionFactory">  
            <property name="manager">defaultManager</property>  
              
            <!-- 真实mysql数据库端口 -->  
            <property name="port">3306</property>  
              
            <!-- 真实mysql数据库IP -->  
            <property name="ipAddress">10.20.147.110</property>  
            <property name="schema">amoeba_study</property>  
              
            <!-- 用于登陆mysql的用户名 -->  
            <property name="user">root</property>  
              
            <!-- 用于登陆mysql的密码 -->  
            <property name="password"></property>  
              
        </factoryConfig>  
          
        <!-- ObjectPool实现类 -->  
        <poolConfig class="com.meidusa.amoeba
        <a href="http://lib.csdn.net/base/dotnet" class=&#39;replace_word&#39; title=".NET知识库" target=&#39;_blank&#39; style=&#39;color:#df3434; font-weight:bold;&#39;>.Net</a>
        .poolable.PoolableObjectPool">  
            <property name="maxActive">200</property>  
            <property name="maxIdle">200</property>  
            <property name="minIdle">10</property>  
            <property name="minEvictableIdleTimeMillis">600000</property>  
            <property name="timeBetweenEvictionRunsMillis">600000</property>  
            <property name="testOnBorrow">true</property>  
            <property name="testWhileIdle">true</property>  
        </poolConfig>  
    </dbServer>  
    <dbServer name="server2">  
          
        <!-- PoolableObjectFactory实现类 -->  
        <factoryConfig class="com.meidusa.amoeba.mysql.net.MysqlServerConnectionFactory">  
            <property name="manager">defaultManager</property>  
              
            <!-- 真实mysql数据库端口 -->  
            <property name="port">3306</property>  
              
            <!-- 真实mysql数据库IP -->  
            <property name="ipAddress">10.20.147.111</property>  
            <property name="schema">amoeba_study</property>  
              
            <!-- 用于登陆mysql的用户名 -->  
            <property name="user">root</property>  
              
            <!-- 用于登陆mysql的密码 -->  
            <property name="password"></property>  
              
        </factoryConfig>  
          
        <!-- ObjectPool实现类 -->  
        <poolConfig class="com.meidusa.amoeba.net.poolable.PoolableObjectPool">  
            <property name="maxActive">200</property>  
            <property name="maxIdle">200</property>  
            <property name="minIdle">10</property>  
            <property name="minEvictableIdleTimeMillis">600000</property>  
            <property name="timeBetweenEvictionRunsMillis">600000</property>  
            <property name="testOnBorrow">true</property>  
            <property name="testWhileIdle">true</property>  
        </poolConfig>  
    </dbServer>         
</dbServerList>

Aus der obigen Konfiguration )

3) Starten Sie Amoeba

und führen Sie D:/openSource/amoeba aus -mysql-1.2.0-GA/amoeba.bat in der Befehlszeile:

3. Client-Aufrufe und Tests

log4j:WARN log4j config load completed from file:D:/openSource/amoeba-mysql-1.2.0-GA/conf/log4j.xml
log4j:WARN ip access config load completed from file:D:/openSource/amoeba-mysql-1.2.0-GA/conf/access_list.conf
2010-07-03 09:55:33,821 INFO  net.ServerableConnectionManager - Server listening on 0.0.0.0/0.0.0.0:8066.

1) Schreiben ein Client-Aufrufprogramm
Die spezifischen Programmdetails werden nicht detailliert beschrieben, es handelt sich lediglich um das häufigste Datenbankbetriebsprogramm von JDBC, das auf dem MySQL-Treiber basiert

2) Datenbankverbindung konfigurieren

Dieser Client basiert auf c3p0. Die spezifische Datenquellenkonfiguration ist wie folgt:

Es ist erwähnenswert, dass der Client nur eine Verbindung zum Proxy herstellen muss und nichts mit der eigentlichen Datenbank zu tun hat , sodass die jdbcUrl-, Benutzer- und Passwortkonfigurationen alle den von Amoeba bereitgestellten Konfigurationsinformationen entsprechen

3) Aufrufen und Testen
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"  
    destroy-method="close">  
    <property name="driverClass" value="com.mysql.jdbc.Driver" />  
    <property name="jdbcUrl" value="jdbc:mysql://localhost:8066/amoeba_study" />  
    <property name="user" value="root" />  
    <property name="password" value="root" />  
    <property name="minPoolSize" value="1" />  
    <property name="maxPoolSize" value="1" />  
    <property name="maxIdleTime" value="1800" />  
    <property name="acquireIncrement" value="1" />  
    <property name="maxStatements" value="0" />  
    <property name="initialPoolSize" value="1" />  
    <property name="idleConnectionTestPeriod" value="1800" />  
    <property name="acquireRetryAttempts" value="6" />  
    <property name="acquireRetryDelay" value="1000" />  
    <property name="breakAfterAcquireFailure" value="false" />  
    <property name="testConnectionOnCheckout" value="true" />  
    <property name="testConnectionOnCheckin" value="false" />  
</bean>

Fügen Sie zuerst ein Datenelement ein:

Durch Überprüfung des Protokolls /var/lib/mysql/mysql_log.log auf dem Master-Computer:

insert into zone_by_id(id,name) values(20003,&#39;name_20003&#39;)
Es ist bekannt, dass der Schreibvorgang auf dem Master-Computer stattgefunden hat

Durch Überprüfung Das Protokoll /var/lib/mysql/mysql_log.log auf dem Slave-Computer:
100703 11:58:42       1 Query       set names latin1
                      1 Query       SET NAMES latin1
                      1 Query       SET character_set_results = NULL
                      1 Query       SHOW VARIABLES
                      1 Query       SHOW COLLATION
                      1 Query       SET autocommit=1
                      1 Query       SET sql_mode='STRICT_TRANS_TABLES'
                      1 Query       SHOW VARIABLES LIKE 'tx_isolation'
                      1 Query       SHOW FULL TABLES FROM `amoeba_study` LIKE 'PROBABLYNOT'
                      1 Prepare     [1] insert into zone_by_id(id,name) values(?,?)
                      1 Prepare     [2] insert into zone_by_id(id,name) values(?,?)           
                      1 Execute     [2] insert into zone_by_id(id,name) values(20003,&#39;name_20003&#39;)

Es ist bekannt, dass der Slave diese Anweisung synchron ausgeführt hat

100703 11:58:42       2 Query       insert into zone_by_id(id,name) values(20003,&#39;name_20003&#39;)
und dann die Daten überprüfen : Wählen Sie t.name aus zone_by_id t aus, wobei t.id = 20003


Lesen Sie, indem Sie das Protokoll /var/lib/mysql/mysql_log.log auf dem Slave-Computer überprüfen:

Das Der Vorgang ist auf der Slave-Maschine aufgetreten

und bei der Überprüfung des Protokolls /var/lib/mysql/mysql_log.log auf der Slave-Maschine wurde festgestellt, dass diese Anweisung nicht auf der Master-Maschine ausgeführt wurde
100703 12:02:00      33 Query       set names latin1
                     33 Prepare     [1] select t.name from zone_by_id t where t.id = ?
                     33 Prepare     [2] select t.name from zone_by_id t where t.id = ?    
                     33 Execute     [2] select t.name from zone_by_id t where t.id = 20003

Durch die obige Überprüfung ist bekannt, dass die einfache Master-Slave-Konstruktion und der tatsächliche Kampf wirksam werden können

Das obige ist der detaillierte Inhalt vonMySQL-Lese- und Schreibtrennungspraxis – Codebeispiele für den Aufbau eines leistungsstarken Webs. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Stellungnahme:
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn