<dependencies>
<dependency>
<groupId>com.livestream</groupId>
<artifactId>scredis_2.11</artifactId>
<version>1.9.0</version>
</dependency>
</dependencies>
import scredis.Redis;
public class RedisConnection {
public static void main(String[] args) {
Redis redis = Redis.newRichClient("localhost", 6379);
}
}
import scredis.Redis;
public class RedisOperations {
public static void main(String[] args) {
Redis redis = Redis.newRichClient("localhost", 6379);
redis.set("key", "value");
String value = redis.get("key");
System.out.println("Value: " + value);
}
}
import scredis.Redis;
import scredis.Publisher;
import scredis.Subscriber;
public class RedisPubSub {
public static void main(String[] args) {
Redis redis = Redis.newRichClient("localhost", 6379);
Publisher publisher = redis.publisher();
publisher.publish("channel", "message");
Subscriber subscriber = redis.subscriber();
subscriber.subscribe("channel", (c, m) -> {
System.out.println("Received message: " + m);
});
}
}
import scredis.Redis;
public class RedisConfig {
public static void main(String[] args) {
Redis redis = Redis.Configured(new Redis.Config()
.setHost("localhost")
.setPort(6379)
.setTimeout(Duration.ofSeconds(5))
.setMaxWriteAttempts(3)
.setMaxWriteBatchSizePolicy(128)
).newRichClient();
}
}
