本指南將引導(dǎo)您使用Leopard Cache操作緩存。

你可以從頭開始并完成每一個步驟,或者您可以繞過你已經(jīng)熟悉的基本設(shè)置步驟。無論哪種方式,你最終都可以得到可工作的代碼。

在dao模塊的pom.xml加入

    <dependencies>        [...]        <dependency>            <groupId>io.leopard</groupId>            <artifactId>leopard-data</artifactId>            <version>0.0.1-SNAPSHOT</version>        </dependency>        [...]    </dependencies>    <repositories>        <repository>            <id>leopard-snapshots</id>            <name>Leopard Snapshots</name>            <url>http://leopard.io/nexus/content/repositories/snapshots/</url>        </repository>    </repositories>

src/main/resources/applicationContext-dao.xml

<?xml version="1.0" encoding="UTF-8"?><beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:leopard="http://www.leopard.io/schema/leopard"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.leopard.io/schema/leopard http://www.leopard.io/schema/leopard.xsd"><leopard:component-scan base-package="io.leopard.guides" /><leopard:jdbc id="jdbc" host="112.126.75.27" database="example" user="example" passWord="leopard" /><leopard:redis id="redis" server="112.126.75.27:6311" /></beans>

此處為了展現(xiàn)更多接口直接實現(xiàn)了IDelete接口

創(chuàng)建src/main/java/io/leopard/guides/dao/UserDao.java

package io.leopard.guides.dao;import io.leopard.data4j.cache.api.uid.IDelete;import io.leopard.guides.model.User;import java.util.Date;public interface UserDao extends IDelete<User, Long> {@Overridepublic boolean add(User user);@OverrideUser get(Long uid);@Overrideboolean delete(Long uid, long opuid, Date lmodify);}

創(chuàng)建src/main/java/io/leopard/guides/dao/mysql/UserDaoMysqlImpl.java

package io.leopard.guides.dao.mysql;import io.leopard.data4j.jdbc.Jdbc;import io.leopard.data4j.jdbc.builder.InsertBuilder;import io.leopard.guides.dao.UserDao;import io.leopard.guides.model.User;import java.util.Date;import javax.annotation.Resource;import org.springframework.stereotype.Repository;@Repositorypublic class UserDaoMysqlImpl implements UserDao {@Resourceprivate Jdbc jdbc;@Overridepublic boolean add(User user) {InsertBuilder builder = new InsertBuilder("user");builder.setLong("uid", user.getUid());builder.setString("nickname", user.getNickname());builder.setDate("posttime", user.getPosttime());return this.jdbc.insertForBoolean(builder);}@Overridepublic User get(Long uid) {String sql = "select * from user where uid=?;";return jdbc.query(sql, User.class, uid);}@Overridepublic boolean delete(Long uid, long opuid, Date lmodify) {String sql = "delete from user where uid=?;";return jdbc.updateForBoolean(sql, uid);}}

創(chuàng)建src/main/java/io/leopard/guides/dao/redis/UserDaoRedisImpl.java

package io.leopard.guides.dao.redis;import io.leopard.burrow.lang.Json;import io.leopard.burrow.util.NumberUtil;import io.leopard.data4j.redis.Redis;import io.leopard.guides.dao.UserDao;import io.leopard.guides.model.User;import java.util.Date;import javax.annotation.Resource;import org.springframework.stereotype.Repository;@Repositorypublic class UserDaoRedisImpl implements UserDao {@Resourceprivate Redis redis;@Overridepublic boolean add(User user) {String key = this.getKey(user.getUid());redis.set(key, Json.toJson(user));return true;}@Overridepublic User get(Long uid) {String key = this.getKey(uid);String json = redis.get(key);return Json.toObject(json, User.class);}@Overridepublic boolean delete(Long uid, long opuid, Date lmodify) {String key = this.getKey(uid);Long result = redis.del(key);return NumberUtil.toBool(result);}protected String getKey(long uid) {return "user:" + uid;}}

創(chuàng)建src/main/java/io/leopard/guides/dao/cache/UserDaoCacheImpl.java

package io.leopard.guides.dao.cache;import io.leopard.data4j.cache.CacheLoader;import io.leopard.guides.dao.UserDao;import io.leopard.guides.model.User;import java.util.Date;import javax.annotation.Resource;import org.springframework.stereotype.Repository;@Repositorypublic class UserDaoCacheImpl implements UserDao {@Resourceprivate UserDao userDaoMysqlImpl;@Resourceprivate UserDao userDaoRedisImpl;@Overridepublic boolean add(User user) {return userDaoMysqlImpl.add(user);}@Overridepublic User get(Long uid) {// 先到userDaoRedisImpl.get方法查，有數(shù)據(jù)直接返回// 如果redis實現(xiàn)沒有數(shù)據(jù)，就到userDaoMysqlImpl.get方法查詢數(shù)據(jù)。如果有數(shù)據(jù)將數(shù)據(jù)傳給userDaoRedisImpl.add方法保存并返回。如果mysql實現(xiàn)也沒有數(shù)據(jù)則返回null.return CacheLoader.get(userDaoRedisImpl, userDaoMysqlImpl, uid);}@Overridepublic boolean delete(Long uid, long opuid, Date lmodify) {userDaoRedisImpl.delete(uid, opuid, lmodify);return this.userDaoMysqlImpl.delete(uid, opuid, lmodify);}}

創(chuàng)建src/main/java/io/leopard/guides/service/UserService.java

package io.leopard.guides.service;import io.leopard.guides.dao.UserDao;import io.leopard.guides.model.User;import java.util.Date;import javax.annotation.Resource;import org.springframework.stereotype.Service;@Servicepublic class UserService {@Resource// 當(dāng)有xxxDaoCacheImpl存在時，Leopard自動為它增加了@Primary注解// 這里會自動注入userDaoCacheImpl.private UserDao userDao;public boolean add(User user) {return this.userDao.add(user);}public User get(long uid) {return this.userDao.get(uid);}public boolean delete(long uid) {return this.userDao.delete(uid, 0, new Date());}}

創(chuàng)建src/test/java/io/leopard/guides/service/UserServiceTest.java

package io.leopard.guides.service;import io.leopard.guides.model.User;import io.leopard.test.IntegrationTests;import java.util.Date;import org.junit.Assert;import org.junit.Test;import org.springframework.beans.factory.annotation.Autowired;public class UserServiceTest extends IntegrationTests {@Autowiredprivate UserService userService;@Testpublic void get() {this.userService.delete(1);// 先刪除記錄{User user = new User();user.setUid(1);user.setNickname("Leopard");user.setPosttime(new Date());userService.add(user);}{User user = userService.get(1);Assert.assertNotNull(user);Assert.assertEquals("Leopard", user.getNickname());}}}

恭喜你！您已經(jīng)可以配置使用Leopard Cache，雖然功能比較簡單，你可以在這個基礎(chǔ)上擴(kuò)展出你的業(yè)務(wù)系統(tǒng)，祝您好運。