我正在编写一个使用cassandra-unit的商店单元测试。
public class StoreTest {
public void before() throws Exception {
EmbeddedCassandraServerHelper.startEmbeddedCassandra();
DataLoader dataLoader = new DataLoader("mydata", "127.0.0.1:9171");
dataLoader.load(new ClassPathJsonDataSet("cassandra.json"));
}
@After
public void after() throws Exception {
EmbeddedCassandraServerHelper.cleanEmbeddedCassandra();
}
@Test
public void testSomething() {
// test code
}
}
测试运行良好，能够连接到内存中的cassandra实例，并返回合理的结果。但是，当我关闭cassandra时，在日志中得到以下异常。
17:05:48.666 [StorageServiceShutdownHook] INFO o.a.cassandra.thrift.ThriftServer - Stop listening to thrift clients
17:05:48.667 [StorageServiceShutdownHook] INFO org.apache.cassandra.gms.Gossiper - Announcing shutdown
17:05:48.782 [GossipTasks:1] DEBUG o.a.c.c.DebuggableThreadPoolExecutor - Task cancelled
java.util.concurrent.CancellationException: null
at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:250) ~[na:1.7.0_21]
at java.util.concurrent.FutureTask.get(FutureTask.java:111) ~[na:1.7.0_21]
at org.apache.cassandra.concurrent.DebuggableThreadPoolExecutor.extractThrowable(DebuggableThreadPoolExecutor.java:230) [cassandra-all-1.2.0.jar:1.2.0]
at org.apache.cassandra.concurrent.DebuggableThreadPoolExecutor.logExceptionsAfterExecute(DebuggableThreadPoolExecutor.java:194) [cassandra-all-1.2.0.jar:1.2.0]
at org.apache.cassandra.concurrent.DebuggableScheduledThreadPoolExecutor.afterExecute(DebuggableScheduledThreadPoolExecutor.java:46) [cassandra-all-1.2.0.jar:1.2.0]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1153) [na:1.7.0_21]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) [na:1.7.0_21]
at java.lang.Thread.run(Thread.java:722) [na:1.7.0_21]
17:05:49.667 [StorageServiceShutdownHook] INFO o.a.cassandra.net.MessagingService - Waiting for messaging service to quiesce
17:05:49.668 [ACCEPT-/27.0.0.1] INFO o.a.cassandra.net.MessagingService - MessagingService shutting down server thread.
这是从哪里来的，我该如何防止它发生？
最佳答案
看起来stop方法有问题。我的猜测是，系统的仍在关闭部分的工作线程在完成之前就被中断了。 latest EmbeddedCassandraServerHelper代码不推荐使用stopEmbeddedCassandra方法，并带有注释，指出该方法不能完全起作用。
我们使用自己的代码将cassandra嵌入到单元测试中。我们不像EmbeddedCassandraServerHelper类那样使用Activate（）方法，而是使用CassandraDaemon的init（）和start（）方法。然后，stop（）方法似乎起作用了。 Cassandra不能完美嵌入，因为它希望在jsvc下执行。
如果除了烦人的日志消息外没有其他问题，我将配置日志记录以禁止该类。否则，请尝试使用init（）/ start（）方法替换EmbeddedCassandraServerHelper中的active（）方法调用。