从.Net到Java学习第四篇——spring boot+redis
從.Net到Java學(xué)習(xí)系列目錄
“學(xué)習(xí)java已經(jīng)十天,有時(shí)也懷念當(dāng)初.net的經(jīng)典,讓這語(yǔ)言將你我相連,懷念你......”接上一篇,本篇使用到的框架redis、FastJSON。
環(huán)境準(zhǔn)備
安裝redis,下圖是我本機(jī)的redis綠色版,你可以網(wǎng)上自行下載安裝,如果不知道如何怎么操作,可以移步到我的另一篇文章:ASP.NET Redis 開(kāi)發(fā)
以管理員身份打開(kāi)CMD窗口:
C:\Users\zouqj>e:E:\>cd E:\Redis-x64-3.2.100E:\Redis-x64-3.2.100>redis-server --service-install redis.windows.conf --loglevel verbose --service-name redis --port 6379運(yùn)行之后,記得啟動(dòng)redis服務(wù),我這里redis沒(méi)有設(shè)置密碼。
啟動(dòng)服務(wù)命令:net start redis
關(guān)于FastJSON框架的使用呢可以參考文章:高性能JSON框架之FastJson的簡(jiǎn)單使用
修改pom.xml,添加redis的依賴(lài)
<!--redis--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-redis</artifactId><version>1.3.8.RELEASE</version></dependency><!--JSON--><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.1.23</version></dependency>修改項(xiàng)目配置文件,添加如下配置節(jié)點(diǎn)
redis:database: 0host: 127.0.0.1port: 6379pool:max-active: 100max-idle: 10max-wait: 100000timeout: 0最終配置如下:
redis配置項(xiàng)說(shuō)明:
# REDIS (RedisProperties) # Redis數(shù)據(jù)庫(kù)索引(默認(rèn)為0) spring.redis.database=0 # Redis服務(wù)器地址 spring.redis.host=127.0.0.1 # Redis服務(wù)器連接端口 spring.redis.port=6379 # Redis服務(wù)器連接密碼(默認(rèn)為空) spring.redis.password= # 連接池最大連接數(shù)(使用負(fù)值表示沒(méi)有限制) spring.redis.pool.max-active=8 # 連接池最大阻塞等待時(shí)間(使用負(fù)值表示沒(méi)有限制) spring.redis.pool.max-wait=-1 # 連接池中的最大空閑連接 spring.redis.pool.max-idle=8 # 連接池中的最小空閑連接 spring.redis.pool.min-idle=0 # 連接超時(shí)時(shí)間(毫秒) spring.redis.timeout=0新建一個(gè)redis的配置類(lèi)RedisConfig,因?yàn)槭桥渲妙?lèi),所以要在類(lèi)上面添加注解@Configuration
@EnableAutoConfiguration注解我們看下它的源碼,發(fā)現(xiàn)它是一個(gè)組合注解
@EnableAutoConfiguration注解大致處理流程就是:
1、先去掃描已經(jīng)被@Component所注釋的類(lèi),當(dāng)然會(huì)先判斷有沒(méi)有@Condition相關(guān)的注解。
2、然后遞歸的取掃描該類(lèi)中的@ImportResource,@PropertySource,@ComponentScan,@Bean,@Import。一直處理完。
參考:@EnableAutoConfiguration 配置解釋
@Configuration @EnableAutoConfiguration public class RedisConfig {@Bean@ConfigurationProperties(prefix = "spring.redis.pool")public JedisPoolConfig getRedisConfig() {JedisPoolConfig config = new JedisPoolConfig();return config;}@Bean@ConfigurationProperties(prefix = "spring.redis")public JedisConnectionFactory getConnectionFactory() {JedisConnectionFactory factory = new JedisConnectionFactory();factory.setUsePool(true);JedisPoolConfig config = getRedisConfig();factory.setPoolConfig(config);return factory;}@Beanpublic RedisTemplate<?, ?> getRedisTemplate() {JedisConnectionFactory factory = getConnectionFactory();RedisTemplate<?, ?> template = new StringRedisTemplate(factory);return template;} }添加一個(gè)redis的接口服務(wù)RedisService
package com.yujie.service;public interface RedisService {/*** set存數(shù)據(jù) * @param key * @param value * @return*/boolean set(String key, String value);/*** get獲取數(shù)據(jù) * @param key * @return*/String get(String key);/*** 設(shè)置有效天數(shù) * @param key * @param expire * @return*/boolean expire(String key, long expire);/*** 移除數(shù)據(jù) * @param key * @return*/boolean remove(String key);}添加redis實(shí)現(xiàn)類(lèi)RedisServiceImpl,注意下面代碼中標(biāo)紅了的代碼,這里設(shè)置redis的key和value以字符串的方式進(jìn)行存儲(chǔ),如果不配置的話(huà),默認(rèn)是以16進(jìn)制的形式進(jìn)行存儲(chǔ),到時(shí)候我們讀取的時(shí)候,就會(huì)看著很亂。
@Service("redisService") public class RedisServiceImpl implements RedisService {@Resourceprivate RedisTemplate<String, ?> redisTemplate;@Overridepublic boolean set(final String key, final String value) {boolean result = redisTemplate.execute(new RedisCallback<Boolean>() {@Overridepublic Boolean doInRedis(RedisConnection connection) throws DataAccessException { RedisSerializer<String> serializer = redisTemplate.getStringSerializer();connection.set(serializer.serialize(key), serializer.serialize(value));return true;}});return result;}@Overridepublic String get(final String key) {String result = redisTemplate.execute(new RedisCallback<String>() {@Overridepublic String doInRedis(RedisConnection connection) throws DataAccessException {RedisSerializer<String> serializer = redisTemplate.getStringSerializer();byte[] value = connection.get(serializer.serialize(key));return serializer.deserialize(value);}});return result;}@Overridepublic boolean expire(final String key, long expire) {return redisTemplate.expire(key, expire, TimeUnit.SECONDS);}@Overridepublic boolean remove(final String key) {boolean result = redisTemplate.execute(new RedisCallback<Boolean>() {@Overridepublic Boolean doInRedis(RedisConnection connection) throws DataAccessException {RedisSerializer<String> serializer = redisTemplate.getStringSerializer();connection.del(key.getBytes());return true;}});return result;} }由于項(xiàng)目中引入了spring-boot-starter-test的依賴(lài),也就是集成了spring boot的單元測(cè)試框架。給redis實(shí)現(xiàn)類(lèi),添加單元測(cè)試,將光標(biāo)移動(dòng)到RedisService接口位置處,然后按Alt+Enter,如下圖所示:
全選所有方法
在model包中,添加一個(gè)實(shí)體類(lèi)Person
public class Person {private String name;private String sex;public Person() {}public Person(String name, String sex) {this.name = name;this.sex = sex;}public String getName() {return name;}public void setName(String name) {this.name = name;}public String getSex() {return sex;}public void setSex(String sex) {this.sex = sex;} }接下來(lái),我們?cè)傩薷囊幌聠卧獪y(cè)試
@RunWith(SpringRunner.class) @SpringBootTest public class RedisServiceImplTest {private JSONObject json = new JSONObject();@Autowiredprivate RedisService redisService;@Testpublic void contextLoads() throws Exception {}/*** 插入字符串*/@Testpublic void setString() {redisService.set("redis_string_test", "springboot redis test");}/*** 獲取字符串*/@Testpublic void getString() {String result = redisService.get("redis_string_test");System.out.println(result);}/*** 插入對(duì)象*/@Testpublic void setObject() {Person person = new Person("person", "male");redisService.set("redis_obj_test", json.toJSONString(person));}/*** 獲取對(duì)象*/@Testpublic void getObject() {String result = redisService.get("redis_obj_test");Person person = json.parseObject(result, Person.class);System.out.println(json.toJSONString(person));}/*** 插入對(duì)象List*/@Testpublic void setList() {Person person1 = new Person("person1", "male");Person person2 = new Person("person2", "female");Person person3 = new Person("person3", "male");List<Person> list = new ArrayList<>();list.add(person1);list.add(person2);list.add(person3);redisService.set("redis_list_test", json.toJSONString(list));}/*** 獲取list*/@Testpublic void getList() {String result = redisService.get("redis_list_test");List<String> list = json.parseArray(result, String.class);System.out.println(list);}@Testpublic void remove() {redisService.remove("redis_test");}} View Code?我們發(fā)現(xiàn),在單元測(cè)試類(lèi)上面自動(dòng)添加了2個(gè)注解,@SpringBootTest和@RunWith(SpringRunner.class)
@SpringBootTest注解是SpringBoot自1.4.0版本開(kāi)始引入的一個(gè)用于測(cè)試的注解。
@RunWith就是一個(gè)運(yùn)行器
@RunWith(SpringRunner.class)就是指用SpringRunner來(lái)運(yùn)行
運(yùn)行單元測(cè)試:
查看redis中的結(jié)果,這里用到一個(gè)可視化的redis管理工具:RedisDesktopManager
轉(zhuǎn)載于:https://www.cnblogs.com/jiekzou/p/9205117.html
總結(jié)
以上是生活随笔為你收集整理的从.Net到Java学习第四篇——spring boot+redis的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇: S7-200作MODBUS RTU主站和
- 下一篇: cesium 修改 鼠标 样式