MySQL-Ein Master und mehrere Slaves lesen und schreiben getrennte Konfigurationsmethode basierend auf Amöbe

MySql wird als Datenbank im kürzlich entwickelten System verwendet. Da es sich bei den Daten um Geld handelt, müssen wir vorsichtig sein. Gleichzeitig stellen Nutzer auch Anforderungen an die maximale Anzahl von Besuchen. Um zu verhindern, dass MySQL zu einem Leistungsengpass wird und um eine gute Fehlertoleranz zu gewährleisten, werden Master-Slave-Hot-Backup und Lese-/Schreib-Trennung implementiert. Ich werde hier eine kurze Notiz zum späteren Nachschlagen aufbewahren!

1. Master und Slave konfigurieren

Bedingungen: Zwei PCs, IPs sind 192.168.168.253 bzw. 192.168.168.251. Die MySQL-Version auf beiden PCs ist 5.0. Mysql auf 253 ist Master und Mysql auf 251 ist Slave.

1. Konfiguration des Hauptdatenbankservers

Geben Sie das Installationsverzeichnis des Hauptdatenbankservers ein, öffnen Sie my.ini und fügen Sie am Ende der Datei die folgende Konfiguration hinzu:

#数据库ID号， 为1时表示为Master,其中master_id必须为1到232–1之间的一个正整数值; 
server-id = 1
#启用二进制日志；
log-bin=mysql-bin
#需要同步的二进制数据库名；
binlog-do-db=minishop
#不同步的二进制数据库名,如果不设置可以将其注释掉;
binlog-ignore-db=information_schema
binlog-ignore-db=mysql
binlog-ignore-db=personalsite
binlog-ignore-db=test
#设定生成的log文件名；
log-bin="D:/Database/materlog"
#把更新的记录写到二进制文件中；
log-slave-updates

Speichern Sie die Datei. Starten Sie den MySQL-Dienst neu.

Geben Sie das Installationsverzeichnis des Slave-Datenbankservers ein, öffnen Sie my.ini und fügen Sie am Ende der Datei die folgende Konfiguration hinzu:

#如果需要增加Slave库则，此id往后顺延；
server-id = 2  
log-bin=mysql-bin
#主库host
master-host = 192.168.168.253
#在主数据库服务器中建立的用于该从服务器备份使用的用户
master-user = forslave
master-password = ******
master-port = 3306
#如果发现主服务器断线，重新连接的时间差；
master-connect-retry=60
#不需要备份的数据库； 
replicate-ignore-db=mysql
#需要备份的数据库
replicate-do-db=minishop
log-slave-update

Speichern Sie die Datei. Starten Sie den MySQL-Dienst neu.

Geben Sie den primären Datenbankserver ein, erstellen Sie den Benutzernamen und das Passwort, die für die obige Sicherung verwendet werden, und autorisieren Sie Replikationsslave, Super und Neuladen.

mysql>grant replication slave,super,reload on minishop.* to forslave@192.168.168.251 identified by '******';

Geben Sie den Slave-Datenbankserver ein und starten Sie Slave.

mysql>slave start;
mysql>show slave status\G;

Test: Geben Sie den Hauptdatenbankserver ein, fügen Sie ein Datenelement in eine Tabelle in Minishop ein und prüfen Sie dann, ob der Slave-Datenbankserver die gerade eingefügten Daten enthält. vollständig!

Bemerkungen: 1) Führen Sie den konfigurierten Master-Datenbankserver vor dem Slave-Datenbankserver aus. Auf diese Weise stimmen Datei und Position der Master-Datenbank mit den Einstellungen „Master_Log_File“ und „Read_Master_Log_Pos“ überein der Slave-Datenbank. Andernfalls kann es zu Inkonsistenzen kommen. Dies kann auch über Befehle angepasst werden.

2) Wenn Sie feststellen, dass die Master-Slave-Replikation fehlschlägt, können Sie zuerst den Slave-Datenbankserver herunterfahren und dann die Dateien „relay-log.info“, „hosname-relay-bin*“, „master.info“ und „relay-log.info“ löschen Andere Dateien im Datenverzeichnis des Slave-Datenbankservers, starten Sie den Slave-Server neu.

2. Konfiguration der Lese- und Schreibtrennung

Ich wollte Mysql Proxy verwenden, um eine Lese- und Schreibtrennung zu erreichen, aber das verwendete Lua-Skript bereitete mir wirklich Kopfschmerzen Verwenden Sie das von Chinese Pieces of Amoeba entwickelte Open-Source-Datenbank-Proxy-Center. Mit Amoeba können Sie mit einer einfachen XML-Konfiguration problemlos eine Lese-/Schreibtrennung erreichen.

Amoeba sitzt zwischen der Anwendung und dem Datenbankserver und fungiert als Zwischen-Proxy-Schicht. Es unterstützt Lastausgleich, Hochverfügbarkeit, Abfragefilterung und Lese-/Schreibtrennung, kann verwandte Abfragen an die Zieldatenbank weiterleiten und kann mehrere Datenbanken gleichzeitig anfordern, Ergebnisse zusammenzuführen. Die Funktion ist sehr mächtig.

Der Standardport von Amoeba ist 8066, der das MySQL-Protokoll implementiert. Die Anwendung muss lediglich eine Datenbankverbindung ändern, um Amoeba als Proxy für den Datenbankzugriff zu verwenden. Beispiel: Wenn in einer Java-Anwendung Ihre ursprüngliche JDBC-Verbindungszeichenfolge jdbc:mysql://192.168.168.42:3306/minishop lautet und Sie Amoeba als Datenbankzugriffs-Proxy verwenden möchten, müssen Sie nur das oben Genannte ändern Verbindungszeichenfolge Ändern Sie sie wie folgt (wenn die IP des Computers, auf dem sich Amoeba befindet, 192.168.168.88 ist): jdbc:mysql://192.168.168.88:8066/minishop. Amoeba leistet hervorragende Arbeit mit Transparenz.

Die Hauptsache ist, Amoeda zu konfigurieren, aber die Konfiguration ist auch recht einfach. Grundsätzlich müssen nur zwei Dateien konfiguriert werden: confdbServers.xml und confamoeba.xml. Die Bedeutung der einzelnen Elemente in der Konfiguration finden Sie im chinesischen Leitfaden von amoeda. Ich werde hier nicht zu viel erklären. Notieren Sie einfach die Konfiguration.

dbServers.xml-Hauptkonfiguration

<amoeba:dbServers xmlns:amoeba="http://amoeba.meidusa.com/">

		<!-- 
			Each dbServer needs to be configured into a Pool,
			If you need to configure multiple dbServer with load balancing that can be simplified by the following configuration:
			 add attribute with name virtual = "true" in dbServer, but the configuration does not allow the element with name factoryConfig
			 such as &#39;multiPool&#39; dbServer   
		-->
		
	<dbServer name="abstractServer" abstractive="true">
		<factoryConfig class="com.meidusa.amoeba.mysql.net.MysqlServerConnectionFactory">
			<property name="manager">${defaultManager}</property>
			<property name="sendBufferSize">64</property>
			<property name="receiveBufferSize">128</property>
				
			<!-- mysql port -->
			<property name="port">3306</property>
			
			<!-- mysql schema -->
			<property name="schema">minishop</property>
			
			<!-- mysql user -->
			<property name="user">chenjie</property>
			
			<!--  mysql password -->
			<property name="password">chenjie</property>

		</factoryConfig>

		<poolConfig class="com.meidusa.amoeba.net.poolable.PoolableObjectPool">
			<property name="maxActive">500</property>
			<property name="maxIdle">500</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="master"  parent="abstractServer">
		<factoryConfig>
			<!-- mysql ip -->
			<property name="ipAddress">192.168.168.253</property>
		</factoryConfig>
	</dbServer>

	<dbServer name="slave1"  parent="abstractServer">
		<factoryConfig>
			<!-- mysql ip -->
			<property name="ipAddress">192.168.168.119</property>
		</factoryConfig>
	</dbServer>

	<dbServer name="slave2"  parent="abstractServer">
		<factoryConfig>
			<!-- mysql ip -->
			<property name="ipAddress">192.168.168.251</property>

		</factoryConfig>
	</dbServer>
	
	<dbServer name="multiPool" virtual="true">
		<poolConfig class="com.meidusa.amoeba.server.MultipleServerPool">
			<!-- Load balancing strategy: 1=ROUNDROBIN , 2=WEIGHTBASED , 3=HA-->
			<property name="loadbalance">1</property>
			
			<!-- Separated by commas,such as: server1,server2,server1 -->
			<property name="poolNames">slave1,slave2</property>
		</poolConfig>
	</dbServer>
		
</amoeba:dbServers>

amoeba.xml-Konfiguration:

<amoeba:configuration xmlns:amoeba="http://amoeba.meidusa.com/">

	<proxy>
	
		<!-- service class must implements com.meidusa.amoeba.service.Service -->
		<service name="Amoeba for Mysql" class="com.meidusa.amoeba.net.ServerableConnectionManager">
			<!-- port -->
			<property name="port">8066</property>
			
			<!-- bind ipAddress -->

			<property name="ipAddress">192.168.168.253</property>

			
			<property name="manager">${clientConnectioneManager}</property>
			
			<property name="connectionFactory">
				<bean class="com.meidusa.amoeba.mysql.net.MysqlClientConnectionFactory">
					<property name="sendBufferSize">128</property>
					<property name="receiveBufferSize">64</property>
				</bean>
			</property>
			
			<property name="authenticator">
				<bean class="com.meidusa.amoeba.mysql.server.MysqlClientAuthenticator">
					
					<property name="user">chenjie</property>
					
					<property name="password">chenjie</property>
					
					<property name="filter">
						<bean class="com.meidusa.amoeba.server.IPAccessController">
							<property name="ipFile">${amoeba.home}/conf/access_list.conf</property>
						</bean>
					</property>
				</bean>
			</property>
			
		</service>
		
		<!-- server class must implements com.meidusa.amoeba.service.Service -->
		<service name="Amoeba Monitor Server" class="com.meidusa.amoeba.monitor.MonitorServer">
			<!-- port -->
			<!--  default value: random number
			<property name="port">9066</property>
			-->
			<!-- bind ipAddress -->
			<property name="ipAddress">127.0.0.1</property>
			<property name="daemon">true</property>
			<property name="manager">${clientConnectioneManager}</property>
			<property name="connectionFactory">
				<bean class="com.meidusa.amoeba.monitor.net.MonitorClientConnectionFactory"></bean>
			</property>
			
		</service>
		
		<runtime class="com.meidusa.amoeba.mysql.context.MysqlRuntimeContext">
			<!-- proxy server net IO Read thread size -->
			<property name="readThreadPoolSize">20</property>
			
			<!-- proxy server client process thread size -->
			<property name="clientSideThreadPoolSize">30</property>
			
			<!-- mysql server data packet process thread size -->
			<property name="serverSideThreadPoolSize">30</property>
			
			<!-- per connection cache prepared statement size  -->
			<property name="statementCacheSize">500</property>
			
			<!-- query timeout( default: 60 second , TimeUnit:second) -->
			<property name="queryTimeout">60</property>
		</runtime>
		
	</proxy>
	
	<!-- 
		Each ConnectionManager will start as thread
		manager responsible for the Connection IO read , Death Detection
	-->
	<connectionManagerList>
		<connectionManager name="clientConnectioneManager" class="com.meidusa.amoeba.net.MultiConnectionManagerWrapper">
			<property name="subManagerClassName">com.meidusa.amoeba.net.ConnectionManager</property>
			<!-- 
			  default value is avaliable Processors 
			<property name="processors">5</property>
			 -->
		</connectionManager>
		<connectionManager name="defaultManager" class="com.meidusa.amoeba.net.MultiConnectionManagerWrapper">
			<property name="subManagerClassName">com.meidusa.amoeba.net.AuthingableConnectionManager</property>
			
			<!-- 
			  default value is avaliable Processors 
			<property name="processors">5</property>
			 -->
		</connectionManager>
	</connectionManagerList>
	
		<!-- default using file loader -->
	<dbServerLoader class="com.meidusa.amoeba.context.DBServerConfigFileLoader">
		<property name="configFile">${amoeba.home}/conf/dbServers.xml</property>
	</dbServerLoader>
	
	<queryRouter class="com.meidusa.amoeba.mysql.parser.MysqlQueryRouter">
		<property name="ruleLoader">
			<bean class="com.meidusa.amoeba.route.TableRuleFileLoader">
				<property name="ruleFile">${amoeba.home}/conf/rule.xml</property>
				<property name="functionFile">${amoeba.home}/conf/ruleFunctionMap.xml</property>
			</bean>
		</property>
		<property name="sqlFunctionFile">${amoeba.home}/conf/functionMap.xml</property>
		<property name="LRUMapSize">1500</property>

		<property name="defaultPool">master</property>
		

		<property name="writePool">master</property>
		<property name="readPool">multiPool</property>

		<property name="needParse">true</property>
	</queryRouter>
</amoeba:configuration>

Zu diesem Zeitpunkt Mysql Master-Slave Hot Standby und lesen und schreiben Die Trennungskonfiguration ist abgeschlossen. Der konkrete Einsatz im Produktionsumfeld muss jedoch noch getestet und untersucht werden. Später wurde beim Testen eines Masters und mehrerer Slaves ein MySQL-Slave-Datenbankserver hinzugefügt. Aus diesem Grund gibt es in der obigen Amoeba-Konfiguration eine zusätzliche IP von 119.

Das obige ist der detaillierte Inhalt vonMySQL-Ein Master und mehrere Slaves lesen und schreiben getrennte Konfigurationsmethode basierend auf Amöbe. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!