ホームページ >Java >＆＃＆チュートリアル >Java と SpringBoot が Redis を使用する方法
Java と SpringBoot が Redis を使用する方法
- 王林転載
- 2023-05-12 20:31:04896ブラウズ
1. Java が redis に接続します
redis はどのような言語をサポートし、操作できますか (redis 公式 Web サイトを確認してください)
# 1.1 Jedis の使用
(1) jedis 依存関係の追加
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
<!--只能在测试类中使用-->
<scope>test</scope>
</dependency>
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>3.6.0</version>
</dependency>(2) コード テスト
public class TestJedis {
@Test
public void test01(){
//连接redis--必须保证你的redis服务运行远程连接
//该对象把每个redis命令封装成对应的方法
//注意端口号
//xshell中的redis要运行起来，注意防火墙释放端口号，注意配置文件的修改
Jedis jedis=new Jedis("192.168.1.16",6379);
//对于字符串操作的命令
String set = jedis.set("k1", "v1");
System.out.println(set);
String set1 = jedis.set("k2", "v2");
System.out.println(set1);
String set2 = jedis.set("k3", "v3");
System.out.println(set2);
//对于hash的操作
jedis.hset("k4","name","小花");
Long hset = jedis.hset("k4", "age", "18");
System.out.println(hset);
Map<String ,String> map=new HashMap<>();
map.put("name","小明");
map.put("age","20");
Long k = jedis.hset("k5", map);
System.out.println(k);
jedis.close();
}
} 1.2 接続プールを使用する redis への接続
@Test
public void test02(){
//创建连接池的配置类
JedisPoolConfig jedisPoolConfig=new JedisPoolConfig();
jedisPoolConfig.setMaxIdle(20);
jedisPoolConfig.setMinIdle(5);
jedisPoolConfig.setMaxWait(Duration.ofMillis(3000));
JedisPool jedisPool=new JedisPool(jedisPoolConfig,"192.168.1.16",6379);
long start = System.currentTimeMillis();
for (int i = 0; i < 1000; i++) {
//从jedis连接池获取资源
Jedis jedis=jedisPool.getResource();
String ping = jedis.ping();
jedis.close();//是否关闭池子
}
long end=System.currentTimeMillis();
//是为了比较使用池子还是不使用快，结论是使用池子快
System.out.println("总耗时："+(end-start));
}1.3 Java による Redis クラスター モードへの接続
クラスターに接続するときは、クラスターに値が格納されていないことを確認してください。値が保存されている場合は、以前に生成したファイルを削除する必要があります (必ずきれいに削除してください)
もう 1 つは、対応するポート 6001、6002、6003、を解放することです。 6004、6005、6006。以前にリリースされたポートが実際には 10000 だったためです。このアイデアを使用して正常に作成する前に、上記の 2 つの点に注意してください。
@Test
public void test03(){
Set<HostAndPort> nodes=new HashSet<>();
nodes.add(new HostAndPort("192.168.227.175",6001));
nodes.add(new HostAndPort("192.168.227.175",6002));
nodes.add(new HostAndPort("192.168.227.175",6003));
nodes.add(new HostAndPort("192.168.227.175",6004));
nodes.add(new HostAndPort("192.168.227.175",6005));
nodes.add(new HostAndPort("192.168.227.175",6006));
JedisCluster jedisCluster=new JedisCluster(nodes);
jedisCluster.set("k6", "小老虎和小兔子");
jedisCluster.close();
}
2. SpringBoot は redis を統合します
springboot の redis の操作は、2 つの StringRedisTemplate クラスと RedisTemplate クラスをカプセル化します。StringRedisTemplate は RedisTemplate のサブクラスであり、StringRedisTemplate は文字列のみです型は保存できますが、オブジェクト型は保存できません。 StringRedisTemplate を使用してオブジェクトを保存する場合は、オブジェクトを json 文字列に変換する必要があります。
springboot が redis を統合すると、StringRedisTemplate と RedisTemplate という 2 つのテンプレート ツール クラスが提供されます。
#2.1 StringRedisTemplate#(1) 関連する依存関係を導入する <dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>#(2) このクラスの StringRedisTemplate オブジェクトを挿入する
@Autowired private StringRedisTemplate redisTemplate;(3) StringRedisTemplate を使用します
このクラスは、各データ型の操作に対応する内部クラスを個別にシールします。
シリアル化、デシリアル化メソッドがString型に変更されているため、文字化けは発生しません。 
@Autowired
private StringRedisTemplate stringRedisTemplate;
@Test
public void test01(){
//对hash类型的操作
HashOperations<String, Object, Object> forHash = stringRedisTemplate.opsForHash();
forHash.put("k1","name","张三");
forHash.put("k1","age","15");
Map<String,String> map=new HashMap<>();
map.put("name","李四");
map.put("age","25");
forHash.putAll("k36",map);
Object o = forHash.get("k1", "name");
System.out.println(o);
Set<Object> k1 = forHash.keys("k1");
System.out.println(k1);
List<Object> k11 = forHash.values("k1");
System.out.println(k11);
//获取k1对于的所有的field和value
Map<Object, Object> k12 = forHash.entries("k1");
System.out.println(k12);
}
@Test
void contextLoads() {
//删除指定的key
// stringRedisTemplate.delete("k");
//查看所有的key
//stringRedisTemplate.keys("k");
//是否存在指定的key
//stringRedisTemplate.hasKey("k");
//对字符串数据类型的操作ValueOperations
ValueOperations<String, String> forValue = stringRedisTemplate.opsForValue();
//存储字符串类型--key value long uint setex()
forValue.set("k1","张三",30, TimeUnit.SECONDS);
//等价于setnx 存入成功返回true ,失败返回false
Boolean absent = forValue.setIfAbsent("k11", "李四", 30, TimeUnit.SECONDS);
System.out.println(absent);
//append拼接
Integer append = forValue.append("k11", "真好看");
String k11 = forValue.get("k11");
System.out.println(k11);
}2.2 RedisTemplateシリアル化および逆シリアル化メソッドがデフォルトの JDK であるため、ここで文字化けが発生します。 @SpringBootTest
class SbredisApplicationTests02 {
//当你存储的value类型为对象类型使用redisTemplate
//存储的value类型为字符串。StringRedisTemplate 验证码
@Autowired
private RedisTemplate redisTemplate;
@Test
public void test01(){
//必须认为指定序列化方式
redisTemplate.setKeySerializer(new StringRedisSerializer());
redisTemplate.setValueSerializer(new Jackson2JsonRedisSerializer<Object>(Object.class));
//对String类型操作类
ValueOperations forValue = redisTemplate.opsForValue();
//redis中key和value都变成了乱码
//key和value都没有指定序列化方式，默认采用jdk的序列化方式
forValue.set("k1","张三");
//value默认采用jdk，类必须实现序列化接口
forValue.set("k44",new User(1,"haha",12));
}
}
上記のRedisTemplateではキー値とフィールドのシリアル化方法を毎回指定する必要がありますが、RedisTemplateに対してシリアル化を指定済みの設定クラスを作成することは可能でしょうか？後で使用する場合は指定する必要はありません。 rree
以上がJava と SpringBoot が Redis を使用する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。