<dependencies> <dependency> <groupId>com.github.etaty</groupId> <artifactId>scredis</artifactId> <version>2.10.0</version> </dependency> </dependencies> properties redis.host=127.0.0.1 redis.port=6379 redis.password= redis.database=0 import scredis.Redis; import scredis.exceptions.RedisConnectionException; public class RedisConnector { private static final Redis client = connect(); private static Redis connect() { try { Redis redis = Redis.apply(); redis.connect(); return redis; } catch (RedisConnectionException e) { System.out.println("Failed to connect to Redis database."); return null; } } public static Redis getClient() { return client; } } import scredis.Response; import scredis.exceptions.RedisCommandException; import scredis.protocol.Decoder; import scredis.protocol.decoder.StringDecoder; public class RedisOperations { private Redis client = RedisConnector.getClient(); private Decoder<String> decoder = new StringDecoder(); public void set(String key, String value) { try { Response.Status status = client.set(key, value); System.out.println("SET command status: " + status.waitFor()); } catch (RedisCommandException e) { System.out.println("Failed to execute SET command."); } } public String get(String key) { try { Response.jValue response = client.get(key); return decoder.decode(response.get()); } catch (RedisCommandException e) { System.out.println("Failed to execute GET command."); return null; } } } public class ScredisExample { public static void main(String[] args) { RedisOperations redisOps = new RedisOperations(); Redis client = RedisConnector.getClient(); redisOps.set("name", "John Doe"); String name = redisOps.get("name"); System.out.println("Value retrieved from Redis: " + name); } } SET command status: OK Value retrieved from Redis: John Doe


上一篇:
下一篇:
切换中文