本文主要是介绍2 秒杀系统模拟基础实现,使用Redis实现,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
这一篇,我们来使用redis进行数据存储。
新建一个redis的service实现类
package com.tianyalei.service;import com.tianyalei.model.GoodInfo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;/*** Created by wuwf on 17/7/5.*/
@Service("redis")
public class GoodInfoRedisService implements GoodInfoService {@Autowiredprivate StringRedisTemplate redisTemplate;@Overridepublic void add(GoodInfo goodInfo) {redisTemplate.opsForValue().set(goodInfo.getCode(), goodInfo.getAmount() + "");}@Overridepublic void delete(GoodInfo goodInfo) {redisTemplate.delete(goodInfo.getCode());}@Overridepublic int update(String code, int count) {if (redisTemplate.opsForValue().increment(code, -count) < 0) {return -1;}return 1;}
}
我们使用RedisTemplate的increment来保证操作的原子性。
注意一下update方法,如果剩余数量小于0,则返回失败。
由于使用了RedisTemplate,需要先配置一下。
package com.tianyalei;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;@SpringBootApplication
public class CommonApplication {@Beanpublic RedisTemplate getRedisTemplate(JedisConnectionFactory jedisConnectionFactory) {RedisTemplate redisTemplate = new StringRedisTemplate();redisTemplate.setConnectionFactory(jedisConnectionFactory);return redisTemplate;}public static void main(String[] args) {SpringApplication.run(CommonApplication.class, args);}
}
测试:
将MyTest中的Service接口填充为redis
@Resource(name = "redis")private GoodInfoService service;
其他的不用变,直接运行即可。
可以看到redis同样完成了抢购资格的分配。
这篇关于2 秒杀系统模拟基础实现,使用Redis实现的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!