JAVA 中 Redis與ehcache對比與使用
第一:兩者之間的介紹
Redis:屬於獨立的執行程式,需要單獨安裝後,使用JAVA中的Jedis來操縱。因為它是獨立,所以如果你寫個單元測試程式,放一些資料在Redis中,然後又寫一個程式去拿資料,那麼是可以拿到這個資料的。,
ehcache:與Redis明顯不同,它與java程式是綁在一起的,java程式活著,它就活著。譬如,寫一個獨立程式放資料,再寫一個獨立程式拿資料,那麼是拿不到資料的。只能在獨立程式中才能拿到資料。
第二:使用及各種配置:
兩者都可以叢集:
1.Redis可以做主從來叢集,例如,在A電腦上裝個Redis,作為主庫;在其他電腦上裝Redis,作為從庫;這樣主庫擁有讀和寫的功能,而從庫只擁有讀的功能。每次主庫的資料都會同步到從庫中。
1.預設方式啟動
-
Linux下使用Redis
-
安裝:從官網上下載tar.gz格式的包,然後使用tar zxvf redis-2.8.24.tar.gz命令解壓,然後進入Redis資料夾目錄下的src目錄,使用make編譯一下
-
1.開啟:進入/usr/local/redis-3.2.1/src
-
然後./redis-server
2.如果我們想修改埠,設定密碼:那麼得修改配置檔案的redis.conf
port 6379 //埠修改
requirepass redis123 //設定密碼 redis123為密碼
配置主從:主庫的配置檔案不用修改,從庫的配置檔案需要修改,因為從庫需要繫結主庫,以便可以獲取主庫的資料
slaveof 192.168.1.100 6379 //主庫的IP地址和埠號
masterauth redis123 //主庫設定的密碼
3.要讓配置檔案的屬性生效,那麼啟動的redis的時候,要將配置檔案加上去
進入/usr/local/redis-3.2.1/src
然後 ./redis-server redis.conf
那麼將成功的啟動redis,如果沒有加入配置的話,按照普通方式啟動的話,埠仍然還是6379.
4.客戶端連線遠端的Redis
第一步:在遠端端處設定密碼:config set requirepass 123 //123為密碼
第二步:可以在客戶端登入 redis-cli.exe -h 114.215.125.42 -p 6379
第三步:認證:auth 123 //123為密碼
本地端設定密碼後,要使用密碼登入;如果Redis重啟的話,密碼需要重新設定
5.主從配置後,為保證主庫寫的能力,一般不在主庫做持久化,而是在從庫做持久化:
主庫配置:
將save註釋,不使用rdb
# save 900 1
# save 300 10
# save 60 10000
appendonly no 不使用aof
從庫配置:
save 900 1
save 300 10
save 60 10000
appendonly yes
這樣做的優缺點:
優點:保證了主庫寫的能力。
缺點:主庫掛掉後,重啟主庫,然後進行第一次寫的動作後,主庫會先生成rdb檔案,然後傳輸給從庫,從而覆蓋掉從庫原先的rdb檔案,造成資料丟失。但是第二次寫的時候,主庫會以快照方式直接傳資料給從庫,不會重新生成rdb檔案。
解決方案:先複製從庫中的資料到主庫後,再啟動主庫。
使用:
引入jedis包
-
<dependency>
-
<groupId>redis.clients</groupId>
-
<artifactId>jedis</artifactId>
-
<version>2.7.3</version>
-
</dependency>
簡單的寫個類玩玩吧
-
public class RedisMain {
-
public static void main(String [] str)
-
{
-
Jedis jedis = new Jedis("114.215.125.42",6379);
-
jedis.auth("123"); //密碼認證
-
System.out.println("Connection to server sucessfully");
-
//檢視服務是否執行
-
jedis.set("user","namess");
-
// System.out.println("Server is running: "+jedis.ping());
-
System.out.println(jedis.get("user").toString());
-
jedis.set("user","name");
-
System.out.println(jedis.get("user"));
-
}
-
}
Redis完畢
下面說說Ehcache:
Ehcache的使用:
1.首先引入包
-
<dependency>
-
<groupId>net.sf.ehcache</groupId>
-
<artifactId>ehcache-core</artifactId>
-
<version>2.6.6</version>
-
</dependency>
-
<dependency>
-
<groupId>org.slf4j</groupId>
-
<artifactId>slf4j-log4j12</artifactId>
-
<version>1.6.6</version>
-
</dependency>
2.建立一個ehcache.xml檔案,裡面配置cache的資訊,這個配置是包含了叢集的配置:與192.168.93.129:40001的機器叢集了:Ip為192.168.93.129機子的配置要將rmiUrls對應的資料改為這個配置檔案的機子的IP地址,和對應的快取名字
-
<ehcache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-
xsi:noNamespaceSchemaLocation="ehcache.xsd">
-
<cacheManagerPeerProviderFactory
-
class="net.sf.ehcache.distribution.RMICacheManagerPeerProviderFactory"
-
properties="peerDiscovery=manual,rmiUrls=//192.168.93.129:40001/demoCache"/> <!--另一臺機子的ip快取資訊-->
-
<cacheManagerPeerListenerFactory class="net.sf.ehcache.distribution.RMICacheManagerPeerListenerFactory"
-
properties="hostName=localhost,port=40001,socketTimeoutMillis=2000" /> <!--hostName代表本機子的ip-->
-
<diskStore path="java.io.tmpdir"/>
-
<defaultCache
-
maxElementsInMemory="10000"
-
maxElementsOnDisk="0"
-
eternal="true"
-
overflowToDisk="true"
-
diskPersistent="false"
-
timeToIdleSeconds="0"
-
timeToLiveSeconds="0"
-
diskSpoolBufferSizeMB="50"
-
diskExpiryThreadIntervalSeconds="120"
-
memoryStoreEvictionPolicy="LFU"
-
>
-
<cacheEventListenerFactory
-
class="net.sf.ehcache.distribution.RMICacheReplicatorFactory"/>
-
</defaultCache>
-
<cache name="demoCache"
-
maxElementsInMemory="100"
-
maxElementsOnDisk="0"
-
eternal="false"
-
overflowToDisk="false"
-
diskPersistent="false"
-
timeToIdleSeconds="119"
-
timeToLiveSeconds="119"
-
diskSpoolBufferSizeMB="50"
-
diskExpiryThreadIntervalSeconds="120"
-
memoryStoreEvictionPolicy="FIFO"
-
>
-
<cacheEventListenerFactory class="net.sf.ehcache.distribution.RMICacheReplicatorFactory"/> <!--監聽這個cache-->
-
</cache>
-
</ehcache>
配置完後寫程式碼:
放資料:
-
@RequestMapping("/testehcache.do")
-
public void testehcache(HttpServletResponse response) throws IOException
-
{
-
URL url = getClass().getResource("ehcache.xml");
-
CacheManager singletonmanager = CacheManager.create(url);
-
Cache cache = singletonmanager.getCache("demoCache");
-
//使用快取
-
Element element = new Element("key1", "value1");
-
cache.put(element);
-
cache.put(new Element("key2", "value2"));
-
response.getWriter().println("我存放了資料");
-
}
拿資料:
-
@RequestMapping("/getcache.do")
-
public void getcache(HttpServletResponse response) throws IOException
-
{
-
CacheManager singletonmanager = CacheManager.create();
-
Cache cache = singletonmanager.getCache("demoCache");
-
String one=cache.get("key1").getObjectValue().toString();
-
String two=cache.get("key2").getObjectValue().toString();
-
response.getWriter().println(one+two);
-
}
配置集群后,A機器放資料,在B機器上能拿到資料,B機器放資料,A機器也可以拿到資料