我正在使用带有Spring数据及其存储库的couchbase,它的工作非常好 . 现在问题是我必须查询一些不由Spring管理的旧文档 .

我明白我应该创建一个 CouchbaseEnvironment 并根据文档重用它 . https://developer.couchbase.com/documentation/server/3.x/developer/java-2.1/env-config.html

所以我试图做的是@Autowire由Spring创建的couchbase环境bean,它运行良好我可以打开并查询我需要的桶 . 但是一旦关闭应用程序,就会出现一些错误,表明池管理器拒绝了额外的任务:

Caused by: rx.exceptions.OnErrorNotImplementedException: java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask@43d89a1d rejected from java.util.concurrent.ScheduledThreadPoolExecutor@2118de9d[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0]
    at rx.Observable$27.onError(Observable.java:7997) ~[rxjava-1.0.17.jar:1.0.17]
    at rx.observers.SafeSubscriber._onError(SafeSubscriber.java:159) ~[rxjava-1.0.17.jar:1.0.17]
    at rx.observers.SafeSubscriber.onError(SafeSubscriber.java:120) ~[rxjava-1.0.17.jar:1.0.17]
    at rx.subjects.SubjectSubscriptionManager$SubjectObserver.onError(SubjectSubscriptionManager.java:227) ~[rxjava-1.0.17.jar:1.0.17]
    at rx.subjects.AsyncSubject.onError(AsyncSubject.java:115) ~[rxjava-1.0.17.jar:1.0.17]
    at com.couchbase.client.core.endpoint.AbstractGenericHandler.decode(AbstractGenericHandler.java:245) ~[core-io-1.2.9.jar:na]
    at com.couchbase.client.deps.io.netty.handler.codec.MessageToMessageCodec$2.decode(MessageToMessageCodec.java:81) ~[core-io-1.2.9.jar:na]
    at com.couchbase.client.deps.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:89) ~[core-io-1.2.9.jar:na]
    ... 21 common frames omitted 
    Caused by: com.couchbase.client.core.CouchbaseException: java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask@43d89a1d rejected from java.util.concurrent.ScheduledThreadPoolExecutor@2118de9d[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0]
    ... 24 common frames omitted
Caused by: java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask@43d89a1d rejected from java.util.concurrent.ScheduledThreadPoolExecutor@2118de9d[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0]
    at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2047) ~[na:1.8.0_102]
    at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:823) ~[na:1.8.0_102]
    at java.util.concurrent.ScheduledThreadPoolExecutor.delayedExecute(ScheduledThreadPoolExecutor.java:326) ~[na:1.8.0_102]
    at java.util.concurrent.ScheduledThreadPoolExecutor.schedule(ScheduledThreadPoolExecutor.java:533) ~[na:1.8.0_102]
    at java.util.concurrent.ScheduledThreadPoolExecutor.submit(ScheduledThreadPoolExecutor.java:632) ~[na:1.8.0_102]
    at rx.internal.schedulers.NewThreadWorker.scheduleActual(NewThreadWorker.java:239) ~[rxjava-1.0.17.jar:1.0.17]
    at com.couchbase.client.core.env.CoreScheduler.scheduleDirect(CoreScheduler.java:151) ~[core-io-1.2.9.jar:na]
    at com.couchbase.client.core.endpoint.AbstractGenericHandler.scheduleDirect(AbstractGenericHandler.java:369) ~[core-io-1.2.9.jar:na]
    at com.couchbase.client.core.endpoint.AbstractGenericHandler.publishResponse(AbstractGenericHandler.java:332) ~[core-io-1.2.9.jar:na]
    at com.couchbase.client.core.endpoint.AbstractGenericHandler.decode(AbstractGenericHandler.java:237) ~[core-io-1.2.9.jar:na]
    ... 23 common frames omitted

即使在重新启动应用程序后,此错误仍会出现 . 当我不重用couchbase环境时,不会发生此错误 .

我的问题是,如果我需要打开一个存储桶,我应该在这个新配置中创建一个集群,还是应该重用这个?

谢谢 .