JedisPool pool = new JedisPool(new JedisPoolConfig(), "localhost");
可以以靜態(tài)的方式處理以上代碼,它是線程安全的.
創(chuàng)新互聯(lián)是專業(yè)的撫寧網(wǎng)站建設公司,撫寧接單;提供網(wǎng)站建設、做網(wǎng)站,網(wǎng)頁設計,網(wǎng)站設計,建網(wǎng)站,PHP網(wǎng)站建設等專業(yè)做網(wǎng)站服務;采用PHP框架,可快速的進行撫寧網(wǎng)站開發(fā)網(wǎng)頁制作和功能擴展;專業(yè)做搜索引擎喜愛的網(wǎng)站,專業(yè)的做網(wǎng)站團隊,希望更多企業(yè)前來合作!static {
pool= new JedisPool(new Config(), "host", 6379);
}
JedisPoolConfig包含了許多有用的redis指定的連接池的默認參數(shù)。比如,如果一個連接300秒內(nèi)沒有任何的返回Jedis將關閉這個連接.
可以這樣使用:
Jedis jedis = pool.getResource();
try {
//隨便做一些對于redis的操作 jedis.set("foo", "bar");
String foobar= jedis.get("foo");
jedis.zadd("sose", 0, "car"); jedis.zadd("sose", 0, "bike");
Set<String> sose = jedis.zrange("sose", 0, -1);
}finally {
//這里很重要,一旦拿到的jedis實例使用完畢,必須要返還給池中 pool.returnResource(jedis);
}
//程序關閉時,需要調(diào)用關閉方法 pool.destroy();
啟用同步復制
Redis主要為了主/從分布而構建。這意味著"write"請求必須要指向"master", "master"會同步復制改變的內(nèi)容到"slave". "read"請求可以(不是必須的)被指向"slave",緩解"master"的讀寫壓力.
可以按以下的步驟使用"master". 為了啟用同步復制,有兩個方式去告訴"slave"將"slaveOf"到一個給定的"master": 1.在redis server的config文件(redis.conf)指明 2.在拿到的jedis實例中調(diào)用"slaveOf"方法并指定IP和端口
jedis.slaveOf("192.168.1.35", 6379);
注意:"slave"也是一個redis server,也可以接收"write"請求并不會報錯,但是改變不會被同步復制,所以如果弄反了jedis的實例則一些操作會被覆蓋.
禁用同步復制/master失敗后,提升slave
如果"master"down掉,可以提升"slave"成為新的"master".首先試著禁用同步復制離線的"master",如果有幾個"slave",啟用同步復制其余的"slave"到新的"master".
slave1jedis.slaveofNoOne();
slave2jedis.slaveOf("192.168.1.36", 6379);
因為自己在使用Hadoop做join的時候,小表也很大,導致內(nèi)存爆滿,所以打算用Redis來看看。把數(shù)據(jù)加入Redis的代碼如下:
import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.IOException;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
public class RedisInutAccount {
private static String parseRaw(String str) {
if (str==null) {
return "";
}
str= str.trim();
if (str.startsWith(""")) {
str= str.substring(1);
}
if (str.endsWith(""")) {
str= str.substring(0, str.length() - 1);
}
return str;
}
public static void main(String[] args) throws IOException {
JedisPool pool= new JedisPool("192.168.2.101", 6379);
Jedis jedis= pool.getResource();
jedis.flushAll();
File file= new File("sample_account.del");
FileReader is= new FileReader(file);
BufferedReader br= new BufferedReader(is);
String tmp= null;
while ((tmp = br.readLine()) != null) {
System.out.println(tmp);
jedis.set(parseRaw(tmp),"1");
}
br.close();
pool.returnResource(jedis);
pool.destroy();
}
}
分享標題:Java連接Redis(key-value存儲系統(tǒng))-創(chuàng)新互聯(lián)
當前路徑:http://aaarwkj.com/article24/ccoije.html
成都網(wǎng)站建設公司_創(chuàng)新互聯(lián),為您提供商城網(wǎng)站、網(wǎng)站維護、關鍵詞優(yōu)化、營銷型網(wǎng)站建設、網(wǎng)站建設、品牌網(wǎng)站設計
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)
猜你還喜歡下面的內(nèi)容