作者热门文章
- r - 以节省内存的方式增长 data.frame
- ruby-on-rails - ruby/ruby on rails 内存泄漏检测
- android - 无法解析导入android.support.v7.app
- UNIX 域套接字与共享内存(映射文件)
我正在尝试导入 RedisStreamCommands
。我可以导入它,但我可以导入 RedisCommands。我认为它需要依赖。我不知道那是什么,请帮帮我。
RedisCommands<String, String> syncCommands = connection.sync();
RedisStreamCommands<String, String> streamCommands = connection.sync();
syncCommands.set("key_1", "Hello, Redis!");
Map<String, String> body = Collections.singletonMap("key", "value");
String messageId = streamCommands.xadd("my-stream", body);
我试过这样:在 RedisStreamCommands 上显示错误。
import java.util.Collections;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import io.lettuce.core.RedisClient;
import io.lettuce.core.RedisURI;
import io.lettuce.core.api.StatefulRedisConnection;
import io.lettuce.core.api.sync.*;
import io.lettuce.core.api.sync.RedisCommands;
import io.lettuce.core.cluster.RedisClusterClient;
import io.lettuce.core.cluster.api.StatefulRedisClusterConnection;
import io.lettuce.core.cluster.api.sync.RedisAdvancedClusterCommands;
public class LettuceDemo {
public static void main(String[] args) {
RedisClient redisClient = RedisClient.create("redis://15m4madm4bd6ypfqtc353wfq4q292brk@expeditious-ironwood-6027.redisgreen.net:11042/0");
StatefulRedisConnection<String, String> connection = redisClient.connect();
RedisCommands<String, String> syncCommands = connection.sync();
RedisStreamCommands<String, String> streamCommands = connection.sync();
syncCommands.set("key_1", "Hello, Redis!");
Map<String, String> body = Collections.singletonMap("key", "value");
String messageId = streamCommands.xadd("my-stream", body);
connection.close();
redisClient.shutdown();
}
}
最佳答案
界面io.lettuce.core.api.sync.RedisStreamCommands
在 Redis 5.1 版中引入;很可能您使用的是不包含它的早期版本。
因此,基本上,您应该检查您的类路径和 Redis 的版本,并在必要时将其调整为 5.1+ 版本。您可以从这里获取:https://lettuce.io/docs或查看文档以获取更多详细信息。
希望对您有所帮助。
关于java - 为什么在我的项目中找不到 "RedisStreamCommands"接口(interface)?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/53870164/
我正在尝试导入 RedisStreamCommands。我可以导入它,但我可以导入 RedisCommands。我认为它需要依赖。我不知道那是什么,请帮帮我。 RedisCommands syncCo
我是一名优秀的程序员,十分优秀!