我正在尝试执行rpush操作,但遇到以下错误:
redis.clients.jedis.exceptions.JedisConnectionException: Unexpected end of stream.
at redis.clients.util.RedisInputStream.ensureFill(RedisInputStream.java:199) ~[jedis-2.9.0.jar:na]
at redis.clients.util.RedisInputStream.readByte(RedisInputStream.java:40) ~[jedis-2.9.
我正在学习jedis,我不能准确地找出这段代码的问题所在。任何人都可以帮助在语句tx.exec()中发生me.The异常吗?
public class JedisFactory {
public static void main (String [] args){
JedisPool pool = new JedisPool(new JedisPoolConfig(), "127.0.0.1", 6379);
Jedis jedis = pool.getResource();
Pipeline pipeline = jedis.pipelin
在访问Jedis时,我有时会遇到以下异常。
例外1:
java.lang.ClassCastException: java.lang.Long cannot be cast to [B
at redis.clients.jedis.Connection.getBinaryBulkReply(Connection.java:204)
at redis.clients.jedis.Connection.getBulkReply(Connection.java:193)
at redis.clients.jedis.Jedis.get(Jedis.java:89)
例
我为Jedis创建了一个代理类,然后它可以将资源返回到池中,并自动标记已损坏的资源。
public class JedisProxy implements InvocationHandler {
private final JedisPool jedisPool;
public JedisProxy(JedisPool pool) {
this.jedisPool = pool;
}
public Object invoke(Object proxy, Method m, Object[] args) throws Throwable {
我在我的web应用中使用jdish.publish,在我的桌面应用中使用jedis.subscribe。因此两者都是独立的应用程序。
我有一个pubsub类
public class RedisNewPostListener extends JedisPubSub {
private final Jedis jedis;
private final AppInstances appInstances;
public RedisNewPostListener(AppInstances instances, Jedis jedis) {
this.jed
我不知道我的问题是否有意义。但这是我所做的。Java应用程序的第一次试用:-我创建了示例Java项目。-添加了jedis jar文件。-建立连接,如:
Jedis jedis = new Jedis("my IP address");
jedis.connect();
String value = jedis.get("foo"); //I have set the value for "foo" in redis
System.out.println(value); //successfully prints foo i
我已经设置了一个独立的Redis服务器(V7.0.4)。我已经使用requirepass配置为它配置了密码。我使用Jedis (v4.2.0)作为客户端。
下面是创建与Redis连接的JedisPool的代码-
public JedisConnectionPool(final JedisPoolConfig poolConfig, final String host, int port, int timeout, final String password) {
this.pool = new JedisPool(poolConfig, host, port, timeout, pas
下面哪个代码片段更好?更好地处理资源。
try (Jedis jedis = jedisPool.getResource()) {
String value = jedis.get("key");
// Validation calls using `value` but not using `jedis`
// Another DB call using `value` but not using `jedis`
}
或
String value;
try (Jedis jedis = jedisPool.getResource()) {
v
我得到以下错误
WARN r.c.j.JedisFactory: Error while close
redis.clients.jedis.exceptions.JedisException: Could not return the broken resource to the pool
请告诉我怎么修理。因为我经常会犯这个错误。我认为还需要在“尝试”和“捕捉”中加上一些东西。还是别的什么事有问题?我很乐意帮忙。
代码看起来是这样的。
import redis.clients.jedis.Jedis;
import java.util.ArrayList;
import java.util
我有一个组件,主要任务是返回一个Jedis实例,它看起来如下所示:
@Component
public class JedisConfig {
private Jedis jedis;
public JedisConfig() {
jedis = new Jedis("localhost", 6379);
}
public Jedis getJedis() {return jedis;}
}
然后,我使用Jedis实例在我的拦截器的preHandler中做一些事情:
public class AuthInterceptor
现在,我在我的应用程序中出现了这样一个问题:
Caused by: redis.clients.jedis.exceptions.JedisDataException: NOGROUP No such key 'pydolphin:stream:article' or consumer group 'pydolphin:stream:group:article' in XREADGROUP with GROUP option
at redis.clients.jedis.Protocol.processError(Protocol.java:135) ~
当我作为一个redis.But测试运行时,我编写了一个用于实践JUnit的程序,有一些问题:
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'jedisClientPool' defined in class path resource [spring/applicationContext-redis.xml]: Error setting property values; nested exception is org.springframework
因此,我有一个代码,它使用Jedis客户端从Redis获取值。但在同一时间,Redis处于最大的连接状态,这些异常被抛出:
org.springframework.data.redis.RedisConnectionFailureException
Cannot get Jedis connection; nested exception is redis.clients.jedis.exceptions.JedisConnectionException: Could not get a resource from the pool
at org.springframework.dat
我正在尝试探索redis键空间通知及其在springboot中的实现,以便在ttl用例中使用redis键空间通知。当我使用10k-100 k键这样的更小的音量时,我试着测试它可以工作的比例,它的工作正常,没有任何问题。但是,当我将在特定时间到期的密钥增加到500 K时,我将得到以下错误。
org.springframework.data.redis.RedisConnectionFailureException: Unexpected end of stream.; nested exception is redis.clients.jedis.exceptions.JedisConnecti
下面是我尝试进行单元测试的方法:
public void setToCache(final String cacheKey, final String value) {
if (StringUtils.isEmpty(cacheKey)) {
throw new NamedSystemException(
ENamedSystemExceptionCode.ILLEGAL_ARGUMENT_EXCEPTION,
"Cache Key is null or empty.");
} e