rediscala {
akka {
actor {
provider = "akka.actor.DefaultAskTimeoutActorRefProvider"
}
}
redis {
host = "localhost"
port = 6379
timeout = 5000
password = "password"
}
}
import redis.RedisClient;
import redis.RedisConnection;
import redis.RedisConnectionListener;
public class RedisConfigExample {
public static void main(String[] args) {
RedisClient redisClient = new RedisClient("localhost", 6379);
redisClient.addConnectionListener(new RedisConnectionListener() {
@Override
public void onConnected(RedisConnection connection) {
System.out.println("Connected to Redis");
}
@Override
public void onDisconnected(RedisConnection connection) {
System.out.println("Disconnected from Redis");
}
});
RedisConnection connection = redisClient.connect();
// ...
connection.close();
}
}
import redis.RedisClient;
import redis.RedisConnection;
public class KeyOperationsExample {
public static void main(String[] args) {
RedisClient redisClient = new RedisClient("localhost", 6379);
RedisConnection connection = redisClient.connect();
connection.set("key", "value");
String value = connection.get("key");
connection.close();
}
}
import redis.RedisClient;
import redis.RedisConnection;
public class ListOperationsExample {
public static void main(String[] args) {
RedisClient redisClient = new RedisClient("localhost", 6379);
RedisConnection connection = redisClient.connect();
connection.lpush("list", "element1", "element2");
List<String> elements = connection.lrange("list", 0, -1);
connection.close();
}
}
import redis.RedisClient;
import redis.RedisConnection;
import redis.RedisPubSubListener;
public class PubSubOperationsExample {
public static void main(String[] args) {
RedisClient redisClient = new RedisClient("localhost", 6379);
RedisConnection connection = redisClient.connect();
connection.addListener(new RedisPubSubListener() {
@Override
public void onMessage(String channel, String message) {
System.out.println("Received message: " + message + " from channel: " + channel);
}
@Override
public void onSubscribe(String channel, int subscribedChannels) {
System.out.println("Subscribed to channel: " + channel);
}
@Override
public void onUnsubscribe(String channel, int subscribedChannels) {
System.out.println("Unsubscribed from channel: " + channel);
}
});
connection.psubscribe("channel");
connection.publish("channel", "Hello, Redis!");
connection.close();
}
}
