詳解java之redis篇(spring-data-redis整合)

1，spring-data-redis整合

項目使用的pom.xml：

 <Project XMLNS =“ http://maven.apache.org/pom/4.0.0” xmlns：xsi =“ http：//www.org/2001/xmlschema-chema-ingschema-ingschema-ingstance” http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.x.redis</groupId> <artifactId>Spring_redis</artifactId> <version>1.0-SNAPSHOT</version> <packaging>jar</packaging> <name>Spring_redis</name> <URL> http://maven.apache.org </url> <properties> <project.build.sourceencoding> utf-8 </project.build.sourceencencoding> </properties> </properties> <dependencies> <dependencies> <dependence> <dependency> <gropsiD> <gropsId> <gropsId> <gropsId> org.springframefringframefringframefringframe.dataa </groupsId> <ArtifactId> spring-data-redis </artifactid> <版本> 1.0.2.release </distrace> </dependency> <dependency> <groudency> <groupId> org.springframework </groupid> <ARTIFACTID> spring-core </artifactid> spring-core </artifactid> </artifactid> <artifactId>jedis</artifactId> <version>2.1.0</version> </dependency> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>4.8.2</version> <scope>test</scope> </dependency> <dependency> <groupId>org.slf4j</groupId> <Artifactid> slf4j-api </artifactid> <版本> 1.6.1 </version> </dependency> <！ - 將現有的jakarta commons記錄的調用轉換成lsf4j的調用。-> <glateency> <groupentigy> <groupId> org.slf4j </dependenty> <！ -  hack：hack：確保common-loging的jar包不被引入 slf4j的實現：logback，用來取代log4j。更快、更強！ --> <dependency> <groupId>ch.qos.logback</groupId> <artifactId>logback-classic</artifactId> <version>0.9.24</version> <scope>runtime</scope> </dependency> </dependencies></project>

除了log部分部分

項目文件目錄結構：

ApplicationContext.xml：

1，上下文：屬性 - 持有人標籤用來導入屬性文件。從而替換$ {redis.maxidle}這樣的變量。

2，上下文：組件掃描是為了在com.x.redis.dao報下的類能夠實用春季

3，事實上我們只需要把jedispoolconfig配數來就好了，spring的封裝了。所以直接看

<？ xml版本=“ 1.0”編碼=“ utf-8”？ > <beans xmlns =“ http://www.springframework.org/schema/beans/beans” xmlns：xsi =“ XMLNS：p =“ http://www.springframework.org/schema/p” xmlns：context =“ http：//www.springframework.org/schema/schema/context/context/context” XMLNS：tx =“ http://www.springframework.org/schema/tx” xmlns：aop =“ http：//wwwwwwwwwwwwwwwwwwwwwwwwerwork.org/schema/schema/aop/aop” http://www.springframework.org/schema/schema/spring-beans.xsd http://www.springframeworkframework/context.org/schema/schema/context http :///wwwwwwwwwwwwwwwwwwwwwwwwwwwwww.framework.orgramework.orglext-lotter topperta位置=“ class path：redis.properties” /> <上下文：component-scan base-package =“ com.x.redis.dao”> < /context：component-scan> <bean id =“ pool conconfig”> <property name =“ maxidle” valit name =“ maxwait” value =“ $ {redis.maxwait}” /> <屬性名稱=“ testOnBorrow” value =“ $ {redis.testonBorrow}” /> < /> < /> < /> < /bean> <bean id =“ connectionfactory” p：host-name = host-name =“ $ {redis.host}” P：pool-config-ref =“ poolconfig”/> <bean ID =“ redistemplate”> <property name =“ connectionFactory” ref =“ connectionFactory”/> </> </> </> </bean> <bean ID =“ userdao”/> </beans> </beans>

redis.properties：

 # Redis settings#redis.host=192.168.20.101#redis.port=6380#redis.pass=foobaredredis.host=127.0.0.1redis.port=6379redis.pass= redis.maxIdle=300redis.maxActive=600redis.maxWait=1000redis.testOnBorrow=true

USERDAOIMPL：

1，春天對dao層的封裝很多用了類似於下面代碼的模板方式。

2，重新標誌就是春季對redis的一個封裝而已。

公共類UserDaoimpl實現了UserDao {@Autowired Protected redistemplate <serializable，serializable> redistemplate; public void saveuser（最終用戶）{redistemplate.execute（new rediscallback <obsect>（）{@Override public obspoct doinredis（redisconnection connection）拋出dataAccessexception {connection.set.set.set.set（redistemplate.getStringStringSerialializer（） redistemplate.getStringserializer（）。serialize（user.getName（））; } @Override公共用戶getuser（final long ID）{return redistemplate.execute（new rediscallback <user>（）{@override public doinredis（redisconnection連接）拋出dataAccessexception {byte [byte [byte [byte = redistemplate = redistemplate.getStringSerialializiziziziziziziziziziziziziziziziziziaLIze.serialize.serialist iferist if inder.if） byte = connection.get（鍵）; redistemplate。 }}}

其他：

用戶：

公共類用戶{私人長ID;私有字符串名稱； public long getid（）{返回id; } public void setID（長ID）{this.id = id; } public String getName（）{返回名稱; } public void setName（string name）{this.name = name; }}}

測試代碼：

 public static void main（string [] args）{applicationContext ac = new classpathxmlapplicationContext（“ classPath：/applicationContext.xml”）; USERDAO USERDAO =（USERDAO）ac.getBean（“ userdao”）;用戶用戶1 = new User（）; user1.setid（1）; user1.setName（“ obama”）; userdao.saveuser（user1）; user user2 = userdao.getuser（1）; system.out.println（user2.getName（））; }

2，spring-data-redis

個人覺得這樣整合靈活度更大，能夠更加明了的完成任務。 ，能夠更加明了的完成任務。

pom.xml：

 <Project XMLNS =“ http://maven.apache.org/pom/4.0.0” xmlns：xsi =“ http：//www.org/2001/xmlschema-chema-ingschema-ingschema-ingstance” http://maven.apache.org/xsd/maven-4.0.0.0.xsd“> <modelversion> 4.0.0 </modelversion> <groupId> com.d.work </groupId> <ARTIFACTID> <ARTIFACTID> redis_tem_temed> redis_tem_temete </artifactid> <NAME> redis_templete </name> <url> http://maven.apache.org </url> <properties> <project.build.sourceencoding> utf-8 </project.build.sourceecceenc.sourceencecencOccOccOnding> <version>3.8.1</version> <scope>test</scope> </dependency> <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>2.1.0</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-core</artifactId> <version>3.1.2.RELEASE</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-beans</artifactId> <version>3.1.2.RELEASE</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context</artifactId> <版本> 3.1.2.release </version> </deverency> <dependency> <groupId> org.slf4j </groupid> <ArtifactId> slf4j-api </artifactid> </artifactid> <版本> 1.6.1 </verion> </distrion> </dependenty> <！ <groupId> org.slf4j </groupId> <trifactid> jcl-over-slf4j </artifactid> <版本> <版本> 1.6.1 </version> </deverency> <！<！ -  hack：hack：確保commons-logging：確保commons-loging的<tratifactid> common-logging </artifactid> <版本> 1.1.1 </version> <scope>提供</scope> </deverency> <！ -  slf4j的實現：logback：logback，log4j> log4j> <dependention> <grouped> <groupID> <groupId> <groupId> ch.qos.qos.logback.logback> groupId> log afifactid> log acclastiD> <imbackIdy> 0.00.20.2.2 <scope> Runtime </scope> </depentency> </depentencies> </project>

目錄結構：

data-source.xml

1，上下文：物業持有人和上下文：組件 - 掃描前面解釋過啦。

2，配置了一個sharddjedispool，在

一個是分片形式，可以連接有主備的redis服務端，一個是單個的。詳細後續學習，一個是單個的。詳細後續學習

3，spring-data-redis的封裝，所以自己要自己封裝一個

<？ xml版本=“ 1.0”編碼=“ utf-8”？ > <beans xmlns =“ http://www.springframework.org/schema/beans/beans” xmlns：xsi =“ XMLNS：p =“ http://www.springframework.org/schema/p” xmlns：context =“ http：//www.springframework.org/schema/schema/context/context/context” XMLNS：tx =“ http://www.springframework.org/schema/tx” xmlns：aop =“ http：//wwwwwwwwwwwwwwwwwwwwwwwwerwork.org/schema/schema/aop/aop” http://www.springframework.org/schema/schema/spring-beans.xsd http://www.springframeworkframework/context.org/schema/schema/context http :///wwwwwwwwwwwwwwwwwwwwwwwwwwwwww.framework.orgramework.orglext-lotter topperta位置=“ class path：redis.properties” /> <上下文：component-scan base-package =“ com.d.work.main”> < /context：component-scan> <context：component-scan基本base-package =“ com.d.work.dork.dork.dork.redis”> < /cancent：component-scan> component-scan> name =“ maxidle” value =“ 8”/> <屬性名稱=“ maxwait” value =“ 1000”/> <屬性名稱=“ testOnBorrow” value =“ true”/> <property name =“ testOnreturn” value =“ true”/> <！ -  <property name =“ testwhileidle =” testwhileidle =“ testwhileidle” value =“ <constructor-arg index =“ 0” ref =” value =“ $ {redis.timeout}”/> <constructor-arg name =“ stroge” value =“ 1”/> </bean> </list> </constructor-arg> </bean> </bean> </beans>

REDISDATASOURCE：定義三個方法

public界面redisdatasource {公共摘要shardedjedis getredisclient（）;公共void returnResource（sharddjedis sharddjedis）；公共void returnResource（shardedjedis sharddjedis，boolean broken）;};}

Redisdatasource：

1，shardjedispool，這三個方法的作用：：

• getRedisClient（）：取得redis的客戶端，可以執行命令了。 ，可以執行命令了。
• returnResource（sharddjedis sharddjedis）：將資源返還給游泳池
• returnResource（sharddjedis sharddjedis，布爾式破碎）：出現異常後，將資源返還給池（其實不需要第二個方法）

 @repository（“ redisdatasource”）公共類RedisDataSourceImpl instlind redisdatasource {私有靜態最終logger log = loggerfactory.getLogger（redisdatasourceimpl.class）; @Autowired的私人sharddjedispool sharddjedispool; public shardedjedis getredisclient（）{try {shardedjedis shardjedis = shardedjedispool.getResource（）;返回shardjedis; } catch（異常e）{log.error（“ getredisclent error”，e）; }返回null; } public void returnResource（sharddjedis shardedjedis）{shardedjedispool.returnresource（shardedjedis）; } public void returnResource（shardedjedis shardedjedis，boolean broken）{if（broken）{shardedjedispool.returnbrokenterrokenresource（shardedjedis）; } else {shardedjedispool.returnresource（shardedjedis）; }}}}

第二層的封裝：RedisClientTemplate，例子實現了放值和取值。最後代碼提供了全部命令的實現。

代碼就是映射性質的又一次調用吉迪斯的方法而已，用了個，用了個，決定返還資源的方式。 ，決定返還資源的方式。 ，決定返還資源的方式。

這一層的目的主要也是讓再上層的調用不需要關心池中鏈接的取得和返還問題了。

 @repository（“ redisClientTemplate”）public類redisClientTemplate {private static final logger log = loggerfactory.getLogger（redisClientTemplate.class）; @Autowired私人redisdatasource redisdatasource; public void disconnect（）{shardedjedis shardedjedis = redisdatasource.getRedisClient（）; sharddjedis.disconnect（）; } / ** * * * * * @param鍵 * @param value * @return * / public string set（字符串鍵，字符串value）{字符串result = null; sharddjedis shardedjedis = redisdatasource.getRedisclient（）; if（shardedjedis == null）{返回結果; } boolean broken = false;嘗試{結果= shardedjedis.set（key，value）; } catch（異常E）{log.error（e.getMessage（），e）;破碎= true; }最後{redisdatasource.returnresource（shardedjedis，broken）; }返回結果; } / ** * * * * * @param鍵 * @return * / public String get（String鍵）{字符串result = null; sharddjedis shardedjedis = redisdatasource.getRedisclient（）; if（shardedjedis == null）{返回結果; } boolean broken = false;嘗試{結果= shardedjedis.get（key）; } catch（異常E）{log.error（e.getMessage（），e）;破碎= true; }最後{redisdatasource.returnresource（shardedjedis，broken）; }返回結果; }}}

測試代碼：

 public static void main（string [] args）{applicationContext ac = new classpathxmlapplicationContext（“ classPath：/data-source.xml”）; redisClientTemplate redisClient =（redisClientTemplate）ac.getBean（“ redisClientTemplate”）; redisclient.set（“ A”，“ ABC”）; system.out.println（redisclient.get（“ a”））; }

附上redisclientTemplate全部實現：

redisClientTemplate代碼太多，附上下載地址：http：//xiazai.vevb.com/201701/yuanma/redisclientTemplate_jb51.rar

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持武林網。 ，也希望大家多多支持武林網。