??????? Memcache本身并不實(shí)現(xiàn)集群功能。假設(shè)你想使用Memcahce集群需要使用第三方軟件或編程來實(shí)現(xiàn)自己的設(shè)計(jì)，這里將被用來memagent實(shí)現(xiàn)代理，memagent也被稱為magent。我們注意到，，這二者當(dāng)成兩種工具。至于memcache、magent的安裝請參考文章 ? 在Linux上安裝Memcached服務(wù)和?magent編譯安裝及常見錯誤??????

總體架構(gòu)

??????? 直接上圖：

從圖中能夠看到有兩個(gè)magent節(jié)點(diǎn)，兩個(gè)memcached節(jié)點(diǎn)，每一個(gè)magent節(jié)點(diǎn)又分別代理兩個(gè)memcached節(jié)點(diǎn)，應(yīng)用系統(tǒng)端使用magent pool來調(diào)用memcache進(jìn)行存儲。

硬件結(jié)構(gòu)為兩臺linuxserver。每臺server上分別安裝magent和memcached服務(wù)，并設(shè)為開機(jī)啟動。

這樣做的優(yōu)點(diǎn)是不論什么一臺server宕機(jī)后都不影響magent pool獲取memcache信息，即實(shí)現(xiàn)了memcached的高可用（HA），假設(shè)兩臺機(jī)器都宕機(jī)了。僅僅能說明你RP太差了。

當(dāng)然。也能夠用三臺、四臺或者很多其它server來提高HA。

測試HA

??????? 測試背景，本地局域網(wǎng)內(nèi)兩臺server172.18.117.71（memcacheport11211，magentport11210），172.18.117.113（memcacheport11211，magentport11210），和兩臺server在同一局域網(wǎng)內(nèi)的測試機(jī)器，下邊是測試代碼：

import com.danga.MemCached.MemCachedClient; import com.danga.MemCached.SockIOPool;public class MainTest {public static void main(String[] arg){SockIOPool pool = SockIOPool.getInstance();//magent連接池pool.setServers(new String[] { "172.18.117.71:11210","172.18.117.113:11210" });pool.setSocketTO(3000);pool.setNagle(false);pool.setSocketConnectTO(0);pool.initialize();MemCachedClient memCachedClient = new MemCachedClient();memCachedClient.set("becd0000", "測試樣例");//System.out.println(memCachedClient.get("becd0000"));//System.out.println(memCachedClient.flushAll());}}
步驟1：將key為“becd0000”，value為“測試樣例”通過magent的pool放到memcache中

步驟2：改動magent連接池為單個(gè)memcache連接，代碼例如以下

import com.danga.MemCached.MemCachedClient; import com.danga.MemCached.SockIOPool;public class MainTest {public static void main(String[] arg){SockIOPool pool = SockIOPool.getInstance();//magent連接池pool.setServers(new String[] { "172.18.117.71:11211"});pool.setSocketTO(3000);pool.setNagle(false);pool.setSocketConnectTO(0);pool.initialize();MemCachedClient memCachedClient = new MemCachedClient();//memCachedClient.set("becd0000", "測試樣例");System.out.println(memCachedClient.get("becd0000"));//System.out.println(memCachedClient.flushAll());}}
能夠看到單獨(dú)訪問memcache是能夠取到剛才所存儲的值的。

步驟3：改動

pool.setServers(new String[] { "172.18.117.71:11211"});為

pool.setServers(new String[] { "172.18.117.113:11211"});再次運(yùn)行能夠看到和步驟2一樣的結(jié)果，都能夠取到值，說明通過magent代理存的值會分別放到兩個(gè)memcache中

步驟4：停止172.18.117.113上的memcached服務(wù)

停止memcached服務(wù)命令：kill "cat /tmp/memcached.pid"

步驟5：再次通過magent代理取值，代碼例如以下：

import com.danga.MemCached.MemCachedClient; import com.danga.MemCached.SockIOPool;public class MainTest {public static void main(String[] arg){SockIOPool pool = SockIOPool.getInstance();//magent連接池pool.setServers(new String[] { "172.18.117.71:11210","172.18.117.113:11210" });pool.setSocketTO(3000);pool.setNagle(false);pool.setSocketConnectTO(0);pool.initialize();MemCachedClient memCachedClient = new MemCachedClient();//memCachedClient.set("becd0000", "測試樣例");System.out.println(memCachedClient.get("becd0000"));//System.out.println(memCachedClient.flushAll());}}
可以看到依舊可以取到值。

步驟6：啟動剛才停掉的memcached服務(wù)，重新啟動后memcache中全部信息將清空

步驟7：再次通過magent代理池去取key為“becd0000”的值。代碼例如以下：

import com.danga.MemCached.MemCachedClient; import com.danga.MemCached.SockIOPool;public class MainTest {public static void main(String[] arg){SockIOPool pool = SockIOPool.getInstance();//magent連接池pool.setServers(new String[] { "172.18.117.71:11210","172.18.117.113:11210" });pool.setSocketTO(3000);pool.setNagle(false);pool.setSocketConnectTO(0);pool.initialize();MemCachedClient memCachedClient = new MemCachedClient();//memCachedClient.set("becd0000", "測試樣例");System.out.println(memCachedClient.get("becd0000"));//System.out.println(memCachedClient.flushAll());}}
能夠看到這里取到的值為null。

結(jié)果分析

??????? 通過以上測試能夠得出結(jié)論

1、通過magent的連接池放的值會分別存在magent代理的全部memcached上去

2、假設(shè)有一個(gè)memcached宕機(jī)通過magent代理方式還能取到值

3、假設(shè)memcached修復(fù)重新啟動后通過magent代理方式取到的值就會為Null，這是由于memcache重新啟動后里邊的值隨著memcache服務(wù)的停止就消失了（由于在內(nèi)存中）。可是magent是通過key進(jìn)行哈希計(jì)算分配到某臺機(jī)器上的。memcache重新啟動后會還從這臺機(jī)器上取值，全部取到的值就沒空。

??????? 解決的方法

1、在每次memcache宕機(jī)修復(fù)后能夠?qū)懸粋€(gè)程序把集群中的其它memcache的全部信息全給復(fù)制到當(dāng)前宕機(jī)修復(fù)后的memcache中。

2、自己寫代理。當(dāng)從一個(gè)memcached服務(wù)上取到的值為null時(shí)再去其它memcached上取值

注意事項(xiàng)

??????? magent的調(diào)用方式同memcached一樣。client能夠不用改代碼就可以實(shí)現(xiàn)切換到magent模式下

版權(quán)全部分，轉(zhuǎn)載請注明、資源。

版權(quán)聲明：本文博客原創(chuàng)文章，博客，未經(jīng)同意，不得轉(zhuǎn)載。

轉(zhuǎn)載于:https://www.cnblogs.com/hrhguanli/p/4680866.html

總結(jié)

以上是生活随笔為你收集整理的Memcached 群集高可用性（HA）架构的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。