집 >데이터 베이스 >MySQL 튜토리얼 >Mysql - 마스터-다중-슬레이브 및 읽기-쓰기 분리 구성의 코드 예제 소개
MySql은 최근 개발된 시스템에서 데이터베이스로 사용되는 데이터이기 때문에 주의가 필요합니다. 동시에 사용자는 최대 방문 횟수에 대한 요구 사항도 제시했습니다. MySQL이 성능 병목 현상을 방지하고 우수한 내결함성을 갖기 위해 마스터-슬레이브 핫 백업 및 읽기-쓰기 분리가 구현됩니다. 나중에 참고할 수 있도록 여기에 간략한 메모를 남겨 두겠습니다!
1. 마스터와 슬레이브 구성
조건: PC 2대, IP가 각각 192.168.168.253, 192.168.168.251. 두 PC의 Mysql 버전은 5.0입니다. 253의 Mysql은 Master이고 251의 Mysql은 Slave입니다.
1. 기본 데이터베이스 서버 구성
기본 데이터베이스 서버 설치 디렉터리에 들어가서 my.ini를 열고 파일 끝에 다음 구성을 추가합니다.
#数据库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
파일을 저장합니다. MySQL 서비스를 다시 시작합니다.
슬레이브 데이터베이스 서버의 설치 디렉터리에 들어가서 my.ini를 열고 파일 끝에 다음 구성을 추가합니다.
#如果需要增加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
파일을 저장합니다. MySQL 서비스를 다시 시작합니다.
메인 데이터베이스 서버에 들어가서 위 백업에 사용된 사용자 이름과 비밀번호를 생성하고 복제 슬레이브를 승인하고 슈퍼 및 다시 로드
mysql>grant replication slave,super,reload on minishop.* to forslave@192.168.168.251 identified by '******';
슬레이브 데이터베이스 서버에 들어가서 슬레이브를 시작합니다.
mysql>slave start; mysql>show slave status\G;
테스트: 메인 데이터베이스 서버에 접속하여 미니샵의 테이블에 데이터를 삽입한 후, 방금 삽입한 데이터가 슬레이브 데이터베이스 서버에 들어 있는지 확인합니다. 완벽한!
주의 사항: 1) 슬레이브 데이터베이스 서버보다 먼저 구성된 마스터 데이터베이스 서버를 실행합니다. 이런 방식으로 슬레이브 데이터베이스 서버를 실행할 때 마스터 데이터베이스의 파일 및 위치는 Master_Log_File 및 Read_Master_Log_Pos 설정과 일치합니다. 슬레이브 데이터베이스의 그렇지 않으면 불일치가 발생할 수 있습니다. 이는 명령을 통해서도 조정할 수 있습니다.
2) 마스터-슬레이브 복제가 실패하면 먼저 슬레이브 데이터베이스 서버를 종료한 후 Relay-log.info, hosname-relay-bin*, master.info 및 슬레이브 데이터베이스 서버의 데이터 디렉터리에 있는 다른 파일을 삭제하려면 슬레이브 서버를 다시 시작하세요.
2. 읽기 및 쓰기 분리 구성
읽기 및 쓰기 분리를 구현하기 위해 Mysql Proxy를 사용하고 싶었지만, 사용된 lua 스크립트가 정말 골치아팠습니다. Chinese Pieces of Amoeba에서 개발한 오픈 소스 데이터베이스 프록시 중간을 사용합니다. Amoeba를 사용하면 간단한 XML 구성으로 읽기-쓰기 분리를 쉽게 달성할 수 있습니다.
Amoeba는 애플리케이션과 데이터베이스 서버 사이에 위치하여 중간 프록시 계층 역할을 합니다. 로드 밸런싱, 고가용성, 쿼리 필터링, 읽기-쓰기 분리를 지원하고 관련 쿼리를 대상 데이터베이스로 라우팅할 수 있으며 여러 데이터베이스에 결과 병합을 동시에 요청할 수 있습니다. 기능은 매우 강력합니다.
Amoeba의 기본 포트는 Mysql 프로토콜을 구현하는 8066입니다. 애플리케이션은 Amoeba를 사용하여 데이터베이스 액세스를 프록시하도록 데이터베이스 연결을 수정하기만 하면 됩니다. 예: Java 애플리케이션에서 원래 jdbc 연결 문자열이 jdbc:mysql://192.168.168.42:3306/minishop인 경우 Amoeba를 데이터베이스 액세스 프록시로 사용하려면 위의 사항만 변경하면 됩니다. 연결 문자열 다음과 같이 변경합니다(Amoeba가 위치한 머신의 IP가 192.168.168.88인 경우): jdbc:mysql://192.168.168.88:8066/minishop. 아메바는 투명성을 잘 활용합니다.
Amoeda를 구성하는 것이 가장 중요하지만 구성도 꽤 간단합니다. 기본적으로 confdbServers.xml과 confamoeba.xml의 두 파일만 구성하면 됩니다. 구성의 각 항목의 의미는 amoeda 중국어 가이드를 참조하세요. 여기서는 자세히 설명하지 않겠습니다. 구성을 기록하면 됩니다.
dbServers.xml 기본 구성
<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 'multiPool' 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 구성:
<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>
이 시점에서 Mysql 마스터-슬레이브 상시 대기 및 읽기-쓰기 분리 구성이 완료되었습니다. 그러나 프로덕션 환경의 특정 애플리케이션은 아직 테스트 및 조사되지 않았습니다. 나중에 하나의 마스터와 여러 개의 슬레이브를 테스트할 때 Mysql 슬레이브 데이터베이스 서버가 추가되었습니다. 이것이 위의 아메바 구성에 추가 IP 119가 있는 이유입니다.
위 내용은 Mysql - 마스터-다중-슬레이브 및 읽기-쓰기 분리 구성의 코드 예제 소개의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!