普通模式整合
一、在pom.xml中引入redis的依赖
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-redis</artifactId>
<version>1.8.0.RELEASE</version>
</dependency>
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.9.0</version>
</dependency>
二、新建redis.xml文件
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns="http://www.springframework.org/schema/beans"
xmlns:p="http://www.springframework.org/schema/p"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.0.xsd"> <!-- Redis连接池配置 -->
<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
<property name="maxWaitMillis" value="${redis.maxWait}"/>
<property name="maxIdle" value="${redis.maxIdle}" />
<property name="minIdle" value="${redis.minIdle}" />
<property name="maxTotal" value="${redis.maxTotal}" />
<property name="testOnBorrow" value="true" />
</bean> <bean id="jedisShardInfo" class="redis.clients.jedis.JedisShardInfo">
<constructor-arg index="0" value="${redis.host}" />
<constructor-arg index="1" value="${redis.port}" type="int" />
<!--如果redis没有设置密码，就不需要这个-->
<property name="password" value="${redis.password}" />
</bean> <!-- Redis连接 -->
<bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"
p:shardInfo-ref="jedisShardInfo"
p:poolConfig-ref="jedisPoolConfig" /> <!-- 缓存序列化方式 -->
<!-- 如果不配置Serializer，那么存储的时候只能使用String，如果用对象类型存储，那么会提示错误 can't cast to String！！！-->
<bean id="keySerializer" class="org.springframework.data.redis.serializer.StringRedisSerializer" />
<bean id="valueSerializer" class="org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer" />
<bean id="hashKeySerializer" class="org.springframework.data.redis.serializer.StringRedisSerializer"/>
<bean id="hashValueSerializer" class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"/> <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate"
p:connectionFactory-ref="jedisConnectionFactory"
p:keySerializer-ref="keySerializer"
p:valueSerializer-ref="valueSerializer"
p:enableTransactionSupport="false"
p:hashKeySerializer-ref="hashKeySerializer"
p:hashValueSerializer-ref="hashValueSerializer"/>
</beans>
三、在spring的配置文件中引入redis.xml
<import resource="classpath*:spring/redis.xml" />
四、编写dao层
public abstract class RedisGeneratorDao<K extends Serializable, V extends Serializable> {
@Autowired
protected RedisTemplate<K, V> redisTemplate;
public void setRedisTemplate(RedisTemplate<K, V> redisTemplate) {
this.redisTemplate = redisTemplate;
}
/**
* 获取 RedisSerializer
*/
protected RedisSerializer<String> getRedisSerializer() {
return redisTemplate.getStringSerializer();
}
}
public interface MemberDao {
public boolean add(final Member member);
public boolean add(final List<Member> list);
public void delete(String key);
public void delete(List<String> keys);
public boolean update(final Member member);
public Member get(final String keyId);
public void deleteStr(String key);
}
import org.burning.sport.redis.model.Member;
import org.springframework.dao.DataAccessException;
import org.springframework.data.redis.connection.RedisConnection;
import org.springframework.data.redis.core.RedisCallback;
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.stereotype.Repository;
import org.springframework.util.Assert; import java.util.ArrayList;
import java.util.List; @Repository("memberDao")
public class MemberDaoImpl extends RedisGeneratorDao<String, Member> implements MemberDao { /**
* 添加对象
* @param member
* @return
*/
@Override
public boolean add(final Member member) {
Boolean result = redisTemplate.execute(new RedisCallback<Boolean>() { @Override
public Boolean doInRedis(RedisConnection redisConnection) throws DataAccessException {
RedisSerializer<String> serializer = getRedisSerializer();
byte[] key = serializer.serialize(member.getId());
byte[] name = serializer.serialize(member.getNickname());
return redisConnection.setNX(key, name);
}
});
return result;
} /**
* 添加集合
* @param list
* @return
*/
@Override
public boolean add(final List<Member> list) {
Assert.notEmpty(list);
Boolean result = redisTemplate.execute(new RedisCallback<Boolean>() {
@Override
public Boolean doInRedis(RedisConnection redisConnection) throws DataAccessException {
RedisSerializer<String> serializer = getRedisSerializer();
for(Member member : list) {
byte[] key = serializer.serialize(member.getId());
byte[] name = serializer.serialize(member.getNickname());
return redisConnection.setNX(key, name);
} return true;
}
}, false, true);
return false;
} /**
* 删除对象 ,依赖key
* @param key
*/
@Override
public void delete(String key) {
List<String> list = new ArrayList<String>();
list.add(key);
delete(list);
} /**
* 删除字符串
* @param key
*/
@Override
public void deleteStr(String key) {
redisTemplate.delete(key);
} /**
* 删除集合 ,依赖key集合
* @param keys
*/
@Override
public void delete(List<String> keys) {
redisTemplate.delete(keys);
} /**
* 修改对象
* @param member
* @return
*/
@Override
public boolean update(final Member member) {
String key = member.getId();
if(get(key) == null) {
throw new NullPointerException("数据行不存在, key = " + key);
} Boolean result = redisTemplate.execute(new RedisCallback<Boolean>() {
@Override
public Boolean doInRedis(RedisConnection redisConnection) throws DataAccessException {
RedisSerializer<String> serializer = getRedisSerializer();
byte[] key = serializer.serialize(member.getId());
byte[] value = serializer.serialize(member.getNickname());
redisConnection.setNX(key, value);
return true;
}
});
return result;
} /**
* 根据key获取对象
* @param keyId
* @return
*/
@Override
public Member get(final String keyId) {
Member result = redisTemplate.execute(new RedisCallback<Member>() {
@Override
public Member doInRedis(RedisConnection redisConnection) throws DataAccessException {
RedisSerializer<String> serializer = getRedisSerializer();
byte[] key = serializer.serialize(keyId);
byte[] value = redisConnection.get(key);
if(value == null) {
return null;
} String nickName = serializer.deserialize(value);
return new Member(keyId, nickName);
}
}); return result;
}
}
五、编写service层
public interface MemberService {
/**
* 添加对象
*/
public boolean add(final Member member);
/**
* 添加集合
*/
public boolean add(final List<Member> list);
/**
* 删除对象 ,依赖key
*/
public void delete(String key);
/**
* 删除字符串，依赖key
* @param key
*/
public void deleteStr(String key);
/**
* 删除集合 ,依赖key集合
*/
public void delete(List<String> keys);
/**
* 修改对象
*/
public boolean update(final Member member);
/**
* 根据key获取对象
*/
public Member get(final String keyId);
}
@Service("memberService")
public class MemberServicefImpl implements MemberService {
@Autowired
private MemberDao memberDao;
@Override
public boolean add(Member member) {
return memberDao.add(member);
}
@Override
public boolean add(List<Member> list) {
return memberDao.add(list);
}
@Override
public void delete(String key) {
memberDao.delete(key);
}
@Override
public void deleteStr(String key) {
memberDao.deleteStr(key);
}
@Override
public void delete(List<String> keys) {
memberDao.delete(keys);
}
@Override
public boolean update(Member member) {
return memberDao.update(member);
}
@Override
public Member get(String keyId) {
return memberDao.get(keyId);
}
}
六、写测试类进行测试
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = {"classpath*:applicationContext.xml"})
public class RedisTest { @Autowired
private MemberService memberService; @Test
public void redisAddMember() {
Member member = new Member();
member.setId("1");
member.setNickname("ls"); memberService.add(member);
} @Test
public void redisDeleteStr() {
memberService.deleteStr("1");
} }
哨兵模式(sentinel)
就一个配置文件独特一点 redis-sentinel.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns="http://www.springframework.org/schema/beans"
xmlns:p="http://www.springframework.org/schema/p"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.0.xsd"> <!--redis 哨兵模式(sentinel) 配置-->
<bean id="redisSentinelConfiguration" class="org.springframework.data.redis.connection.RedisSentinelConfiguration">
<property name="master">
<bean class="org.springframework.data.redis.connection.RedisNode">
<property name="name" value="mymaster" />
</bean>
</property>
<property name="sentinels">
<set>
<bean class="org.springframework.data.redis.connection.RedisNode">
<constructor-arg index="0" value="10.6.1**.**6" /><!--ip-->
<constructor-arg index="1" value="9980" /><!--port-->
</bean>
<bean class="org.springframework.data.redis.connection.RedisNode">
<constructor-arg index="0" value="10.6.1**.**4" /><!--ip-->
<constructor-arg index="1" value="9980" /><!--port-->
</bean>
</set>
</property>
</bean> <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
<constructor-arg ref="redisSentinelConfiguration"/>
</bean> <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
<property name="connectionFactory" value="jedisConnectionFactory" />
</bean>
</beans>