<dependencies> <dependency> <groupId>com.github.etaty</groupId> <artifactId>scredis_2.13</artifactId> <version>2.2.0</version> </dependency> </dependencies> import scredis.Client; public class RedisClientExample { public static void main(String[] args) { Client scredisClient = new Client("localhost", 6379); } } scredisClient.set("key", "value"); String value = scredisClient.get("key"); import scredis.Subscriber; import scredis.messages.PMessage; public class MessageListenerExample implements PMessage => Unit { public void onMessage(PMessage<String, String> message) { System.out.println("Received message: " + message); } } Subscriber subscriber = new Subscriber(new MessageListenerExample(), Seq("channel"));


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