`
QING____
  • 浏览: 2250659 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

Spring-data-redis: 事务与pipeline

 
阅读更多

    本文主要展示如何使用spring-data-redis编写事务和pipeline:

 

1.配置文件:

<beans xmlns="http://www.springframework.org/schema/beans" 
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd" default-autowire="byName">
	<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
		<property name="maxActive" value="32"></property>
		<property name="maxIdle" value="6"></property>
		<property name="maxWait" value="15000"></property>
		<property name="minEvictableIdleTimeMillis" value="300000"></property>
		<property name="numTestsPerEvictionRun" value="3"></property>
		<property name="timeBetweenEvictionRunsMillis" value="60000"></property>
		<property name="whenExhaustedAction" value="1"></property>
	</bean>
	<bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory" destroy-method="destroy">
		<property name="poolConfig" ref="jedisPoolConfig"></property>
		<property name="hostName" value="127.0.0.1"></property>
		<property name="port" value="6379"></property>
		<property name="password" value="0123456"></property>
		<property name="timeout" value="15000"></property>
		<property name="usePool" value="true"></property>
	</bean>
	<bean id="jedisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
		<property name="connectionFactory" ref="jedisConnectionFactory"></property>
		<property name="keySerializer">
			<bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>
		</property>
	</bean>
</beans>

2. 程序实例:

package com.sample.redis.sdr;
public class RedisClientTest {

	//private JsonRedisSeriaziler seriaziler;
	
	private RedisTemplate redisTemplate;

	public void setRedisTemplate(RedisTemplate redisTemplate) {
		this.redisTemplate = redisTemplate;
	}
	
	public void valueOperationSample(){
		ValueOperations<String, User> valueOper = redisTemplate.opsForValue();
		User suser = new User(1,"zhangsan",12);
		valueOper.set("user:" + suser.getId(),suser);
		System.out.println(valueOper.get("user:" + suser.getId()).getName());
	}
	
	public void listOperationSample(){
		User suser = new User(1,"zhangsan",12);
		ListOperations<String, User> listOper = redisTemplate.opsForList();
		listOper.leftPush("user:list", suser);//lpush,head
		listOper.rightPush("user:list", suser);//rpush,tail
	}
	
	public void boundValueOperationSample(){
		User suser = new User(1,"zhangsan",12);
		BoundValueOperations<String, User> bvo = redisTemplate.boundValueOps("user:" + suser.getId());
		bvo.set(suser);
		bvo.expire(60, TimeUnit.MINUTES);
	}
	
	/**
	 * 非连接池环境下,事务操作;对于sdr而言,每次操作(例如,get,set)都有会从pool中获取connection;
	 * 因此在连接池环境下,使用事务需要注意。
	 */
	public void txUnusedPoolSample(){
		User suser = new User(1,"zhangsan",12);
		redisTemplate.watch("user:" + suser.getId());
		redisTemplate.multi();
		ValueOperations<String, User> tvo = redisTemplate.opsForValue();
		tvo.set("user:" + suser.getId(), suser);
		redisTemplate.exec();
	}
	
	/**
	 * 在连接池环境中,需要借助sessionCallback来绑定connection
	 */
	public void txUsedPoolSample(){
		SessionCallback<User> sessionCallback = new SessionCallback<User>() {
			@Override
			public User execute(RedisOperations operations) throws DataAccessException {
				operations.multi();
				User user = new User(2,"lisi",32);
				String key = "user:" + user.getId();
				BoundValueOperations<String, User> oper = operations.boundValueOps(key);
				oper.set(user);
				oper.expire(60, TimeUnit.MINUTES);
				operations.exec();
				return user;
			}
		};
		redisTemplate.execute(sessionCallback);
	}
	
	/**
	 * pipeline : 1,正确使用方式
	 */
	public void pipelineSample(){
		final byte[] rawKey = redisTemplate.getKeySerializer().serialize("user_total");
		//pipeline
		RedisCallback<List<Object>> pipelineCallback = new RedisCallback<List<Object>>() {
			@Override
			public List<Object> doInRedis(RedisConnection connection) throws DataAccessException {
				connection.openPipeline();
				connection.incr(rawKey);
				connection.incr(rawKey);
				return connection.closePipeline();
			}
			
		};
		
		List<Object> results = (List<Object>)redisTemplate.execute(pipelineCallback);
		for(Object item : results){
			System.out.println(item.toString());
		}
	}
	//pipeline:备用方式
	public void pipelineSampleX(){
		byte[] rawKey = redisTemplate.getKeySerializer().serialize("user_total");
		RedisConnectionFactory factory = redisTemplate.getConnectionFactory();
		RedisConnection redisConnection = RedisConnectionUtils.getConnection(factory);
		List<Object> results;
		try{
			redisConnection.openPipeline();
			redisConnection.incr(rawKey);
			results = redisConnection.closePipeline();
		}finally{
			RedisConnectionUtils.releaseConnection(redisConnection, factory);
		}
		if(results == null){
			return;
		}
		for(Object item : results){
			System.out.println(item.toString());
		}

	}
/**
	 * list/set排序,注意排序是根据value值的“字符”特性排序,如果value是java-object字节流,将不会有效
	 */
	public void sort(){
		ListOperations<String, String> listOper = redisTemplate.opsForList();
		String listKey = "user:list";
		listOper.leftPush(listKey, "zhangsan");
		listOper.leftPush(listKey, "lisi");
		listOper.leftPush(listKey, "wanger");
		SortQueryBuilder<String> builder = SortQueryBuilder.sort(listKey);
		builder.alphabetical(true);//对字符串使用“字典顺序”
		builder.order(Order.DESC);//倒序
		builder.limit(0, 2);
		//builder.limit(new Range(0, 2));
		List<String> results = redisTemplate.sort(builder.build());
		for(String item : results){
			System.out.println(item);
		}
	}
}

 

2
1
分享到:
评论
1 楼 javatozhang 2015-03-14  
浏览中有所收获、谢谢!

相关推荐

    Spring mvc整合redis实例(redis连接池)

    在Maven项目中,可以在pom.xml文件中添加`spring-data-redis`和`jedis`库,这两个库分别提供了Spring对Redis的支持和Jedis,一个Java客户端连接Redis。 ```xml &lt;groupId&gt;org.springframework.data &lt;artifactId&gt;...

    tomcat-redis依赖jar包

    - Spring Data Redis:如果使用Spring框架,可以借助Spring Data Redis模块简化Redis的集成,提供更高级别的抽象和操作。 总结来说,"tomcat-redis依赖jar包"涉及到的是将Tomcat应用服务器与Redis缓存系统整合的...

    redis-as-database-advanced:Redis作为NoSQL数据库的高级用法

    使用Spring Data Redis,可以方便地在Spring Boot应用中集成Redis。配置`RedisTemplate`和`StringRedisTemplate`,利用`.opsForValue()`、`opsForHash()`等方法操作数据。 五、Redis客户端优化 1. 连接池:使用...

    Spring整合Redis代码

    总结来说,整合Spring和Redis能够有效地提升应用性能,通过Spring Data Redis提供的API,我们可以方便地进行键值操作、事务处理、消息订阅等。在实际应用中,根据需求可以进一步优化配置,比如使用Redis的Pipeline或...

    redis集群java客户端,支持批量提交

    java客户端不是很好支持redis cluster,spring-date-redis和jedis批量提交还不支持,单个提交都是可以的。...使用的spring版本是4.3.2以下版本可能不是很好支持,jedis版本是2.8.2, spring-data-redis版本是1.7.2。

    jedis-2.1.0

    **Jedis与Spring Data Redis的比较:** 虽然Spring Data Redis提供了更高级别的抽象和自动化,但Jedis因其轻量级和高性能而受到许多开发者的青睐。Jedis更适合对性能有极致追求和需要精细控制的场景。而Spring Data...

    springboot-examples - 副本.zip

    在SpringBoot项目中,可以通过添加`spring-boot-starter-data-redis`依赖来实现。在`pom.xml`或`build.gradle`文件中添加对应的依赖项,确保项目可以调用Redis的相关功能。 ```xml &lt;groupId&gt;org.springframework....

    movie-db-java-on-azure:在Azure上使用Java构建的示例电影数据库应用程序

    在Azure上使用Java的电影数据库应用 该示例应用程序的目的是说明云中的现代Java应用程序。 该项目的结果将是创建一个类似于IMDB的电影数据库。 要求 为了创建和部署此示例应用程序,您需要具备以下条件: ...

    个人关于Java相关知识整理

    文件可能涵盖了Spring Boot、Spring Cloud、Spring Data等子项目及其应用场景。 通过深入学习这些文档,开发者不仅可以掌握Java语言本身,还能了解并应用到一系列关键的分布式技术和数据库管理技术,从而提升在企业...

    网络管道:网络流量数据管道,用于实时预测和构建深度神经网络的数据集

    在数据处理阶段,Spring框架(通常与Java环境一起使用)可以提供服务层的抽象,以处理数据清洗、转换和聚合。Vue.js和React等前端框架可用于构建用户界面,展示实时流量图表和分析结果。ZAP(Zed Attack Proxy)是...

Global site tag (gtag.js) - Google Analytics