2

JUnit テスト シナリオで @Cacheable アノテーションを取得する際に問題が発生しました。キャッシングを完全に無視しているようです。テスト以外のシナリオでは機能しますが、テストでは、キャッシュに触れているという証拠さえありません。新しいキー、ハッシュ、リストはなく、例外もありません。

現在、私がテストしようとしている方法は私のDAOにあり、基本的に低速の接続をシミュレートします(キャッシュが方程式に組み込まれると低速になることはありません):

@Component
public class DAO {
    @Cacheable(value="slowRetrieval", keyGenerator="simpleKeyGenerator", cacheManager="cacheManager")
    public boolean slowRetrievalTestIdExists(long testIdValue, long pauseLength) {
        boolean response = valueExists("id", "test", testIdValue);

        log.info("Pausing for " + pauseLength + "ms as a part of slow DB transaction simulation");
        slowMeDown(pauseLength);

        return response;
    }

    private void slowMeDown(long pause) {
        try {
            Thread.sleep(pause);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

これらは、私のテスト クラスの関連部分です。それらはまだコメントされていませんが、TL;DRは slowRetrievalTestIdExists メソッドを何度も実行し、同じパラメーターを使用して再実行します (キャッシュを使用してメソッドの本体を無視する必要があるため)。私はすでにこれらのメソッドをテストクラスに移動しようとしましたが、結果は変わりません:

@RunWith(SpringJUnit4ClassRunner.class)
@SpringApplicationConfiguration(classes={ResultsServiceApplication.class, CacheConfig.class })
@DatabaseSetup("TestData.xml")
@Slf4j
public class DAOTest {
    @Autowired
    private DAO dao;

    @Test
    public void cacheTest() {
        log.info("Testing caching. Deliberately slow database simulations ahead! Be patient please :)");
        int maxTests = 5;
        long pause = 5000l,     //5 seconds
                estimate, executionTime = 0;
        List<Map<String, Object>> testIds = getTestData(new String[] {"id"}, "test");
        assertNotNull("No test IDs could be retrieved to test caching", testIds);

        if(testIds.size() < maxTests) maxTests = testIds.size();

        estimate = (long)maxTests * pause;

        log.info("Slow database simulation shouldn't take much more than " + (estimate / 1000) + " seconds to complete");

        for(int i = 0; i < maxTests; i++) {
            Long testId = (Long)testIds.get(i).get("id");

            log.info("Running simulated slow database transaction " + (i + 1) + " of " + maxTests);
            boolean result = dao.slowRetrievalTestIdExists(testId, pause);
        }

        log.info("Slow database simulations complete (hopefully). Now re-running tests but caching should speed it up");

        for(int i = 0; i < maxTests; i++) {
            Long testId = (Long)testIds.get(i).get("id");

            long start = System.currentTimeMillis();

            log.info("Re-running simulated slow database transaction " + (i + 1) + " of " + maxTests);
            boolean result = dao.slowRetrievalTestIdExists(testId, pause);

            long end = System.currentTimeMillis();

            executionTime += (end - start);
        }

        executionTime /= (long)maxTests;

        assertTrue("The second (supposedly cached) run took longer than the initial simulated slow run", 
                Utilities.isGreaterThan(estimate, executionTime));
    }
}

キャッシュ構成クラスは次のとおりです (XML ベースの構成を使用していないため)。

@Configuration
@EnableCaching
public class CacheConfig { 
    @Bean
    public JedisConnectionFactory redisConnectionFactory() {
        JedisConnectionFactory redisConnectionFactory = new JedisConnectionFactory();

        // Defaults
        redisConnectionFactory.setHostName("127.0.0.1");
        redisConnectionFactory.setPort(6379);
        return redisConnectionFactory;
    }

    @Bean
    public RedisTemplate<String, String> redisTemplate(RedisConnectionFactory cf) {
        RedisTemplate<String, String> redisTemplate = new RedisTemplate<String, String>();
        redisTemplate.setConnectionFactory(cf);

        return redisTemplate;
    }

    @Primary
    @Bean
    public CacheManager cacheManager(RedisTemplate<String, String> redisTemplate) {
        RedisCacheManager cacheManager = new RedisCacheManager(redisTemplate);

        cacheManager.setDefaultExpiration(300l);    //300 seconds = 5 minutes

        return cacheManager;
    }

    @Bean(name="cacheManagerLongExpiry")
    public CacheManager cacheManagerLongExpiry(RedisTemplate<String, String> redisTemplate) {
        RedisCacheManager cacheManager = new RedisCacheManager(redisTemplate);

        cacheManager.setDefaultExpiration(604800l); //604,800 seconds = 1 week

        return cacheManager;
    }

    @Bean(name="cacheManagerShortExpiry")
    public CacheManager cacheManagerShortExpiry(RedisTemplate<String, String> redisTemplate) {
        RedisCacheManager cacheManager = new RedisCacheManager(redisTemplate);

        cacheManager.setDefaultExpiration(43200l);  //43,200 seconds = 12 hours

        return cacheManager;
    }

    @Bean(name="simpleKeyGenerator")
      public KeyGenerator keyGenerator() {
          return new KeyGenerator() {

              @Override
              public Object generate(Object o, Method method, Object... objects)                     {
                // This will generate a unique key of the class name, the method name,
                // and all method parameters appended.
                StringBuilder sb = new StringBuilder();
                sb.append(o.getClass().getName());
                sb.append(method.getName());

                for (Object obj : objects) {
                    sb.append(obj.toString());
                }

                return sb.toString();
            }
        };
    }
}

私は何時間もこれに携わってきましたが、Googleにもほとんど何もないので、これに関する助けに本当に感謝しています.

4

2 に答える 2

2

だから私は私の問題に対する答えを見つけました。setUp()問題は、メソッドが@AutowiredDAOを上書きしたコードの一部を見落としていたことです。ソートされた今、それは魅力のように機能します。

于 2015-11-05T11:49:51.310 に答える