redis apis

CPyeah · CPyeah · commit 11d7baf93091 · 2022-05-13T17:43:37.000+08:00
diff --git a/README.md b/README.md
@@ -16,12 +16,22 @@ docker-compose up
 - jpa
 - docker-compose
 
+# java-redis
+
+Java操作redis（单机）
+
+- jdk11
+- springboot
+- redis
+- redission
+- docker compose
+
 ---
 
 TODO List:
 
 - Redis
-- ElasticSearch†
+- ElasticSearch
 - MongoDB
 - Zookeeper
 - Kafka
diff --git a/java-redis/README.md b/java-redis/README.md
@@ -1,6 +1,9 @@
 # Redis
 
 
+[doc](https://github.com/redisson/redisson/wiki/Table-of-Content)
+
+
 Redis 是一种内存存储，具有一些持久性功能。您的所有数据集都应该适合内存。因此，单个实例受到服务器最大内存的限制。现在，可以将数据分片到多个Redis实例，在多个服务器上运行。如果有预算，完全有可能在一组 Redis 上存储 100GB - 1TB 的数据。请注意分片不是自动的：它必须由客户端或应用程序实现。对数据执行的操作施加一些限制（例如，无法在服务器端计算由不同 Redis 实例托管的两个集合的交集）。
 
 单个Redis实例不是分布式系统。它是一个远程集中存储。现在通过使用多个 Redis 实例，可以构建一个分布式系统。因为它是一种自己动手的方法，所以您可以决定将其设为 CP 或 AP 系统。
diff --git a/java-redis/src/main/java/org/cp/javaredis/model/Person.java b/java-redis/src/main/java/org/cp/javaredis/model/Person.java
@@ -0,0 +1,24 @@
+package org.cp.javaredis.model;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import lombok.Data;
+
+@Data
+public class Person implements Serializable {
+
+	private String name;
+
+	private Integer ages;
+
+	private LocalDateTime createTime;
+
+	public static Person tom() {
+		Person person = new Person();
+		person.setName("Tom");
+		person.setAges(4);
+		person.setCreateTime(LocalDateTime.now());
+		return person;
+	}
+
+}
diff --git a/java-redis/src/test/java/org/cp/javaredis/BasicApi.java b/java-redis/src/test/java/org/cp/javaredis/BasicApi.java
@@ -0,0 +1,53 @@
+package org.cp.javaredis;
+
+import java.util.concurrent.TimeUnit;
+import org.cp.javaredis.model.Person;
+import org.junit.jupiter.api.Test;
+import org.redisson.api.RBucket;
+import org.redisson.api.RList;
+import org.redisson.api.RedissonClient;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+
+@SpringBootTest
+public class BasicApi {
+
+	@Autowired
+	private RedissonClient redissonClient;
+
+	//String
+	@Test
+	public void testString() {
+		RBucket<String> hello = redissonClient.getBucket("hello");
+		System.out.println(hello.get());
+		hello.set("world ! ", 5, TimeUnit.MINUTES);
+		System.out.println(hello.get());
+	}
+
+	// Object
+	@Test
+	public void testObject() {
+		RBucket<Person> hello = redissonClient.getBucket("Tom");
+		System.out.println(hello.get());
+		hello.set(Person.tom(), 5, TimeUnit.MINUTES);
+		System.out.println(hello.get());
+	}
+
+	// List
+	@Test
+	public void testList() {
+		RList<Person> list = redissonClient.getList("list");
+		list.add(Person.tom());
+		list.add(Person.tom());
+		System.out.println(list.size());
+		list.forEach(System.out::println);
+	}
+
+	// Map
+
+	// Set
+
+	// ZSet
+
+
+}
diff --git a/java-redis/src/test/java/org/cp/javaredis/JavaRedisApplicationTests.java b/java-redis/src/test/java/org/cp/javaredis/JavaRedisApplicationTests.java
@@ -1,13 +1,22 @@
 package org.cp.javaredis;
 
 import org.junit.jupiter.api.Test;
+import org.redisson.api.RedissonClient;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 
 @SpringBootTest
 class JavaRedisApplicationTests {
 
+	@Autowired
+	private RedissonClient redissonClient;
+
 	@Test
 	void contextLoads() {
+		redissonClient.getBucket("hello").set("world");
+		String test = (String) redissonClient.getBucket("hello").get();
+		System.out.println(test);
+
 	}
 
 }
