我正在尝试在spring-boot集群应用程序中使用共享缓存。看起来一切都正常,但当我试图从应用程序的第二个示例检索缓存值时,却无法从缓存值中获取。
似乎每个应用程序都在使用自己的缓存,而不是共享它。
我按照这里的指导方针设置了一个简单的环境https://hazelcast.com/blog/spring-boot/
我的代码:
Controller.java
@Controller
@RequestMapping("/public/testcache")
public class TestCacheController {
@Autowired
BookService bookService;
@GetMapping("/get/{isbn}")
@ResponseBody
public String getBookNameByIsbn(@PathVariable("isbn") String isbn) {
return bookService.getBookNameByIsbn(isbn);
}
@GetMapping("/clear/cache")
@ResponseBody
public String clearCache() {
bookService.deleteCache();
return "done";
}
}
BookService.java
@Service
public class BookService {
@Cacheable("books")
public String getBookNameByIsbn(String isbn) {
return findBookInSlowSource(isbn);
}
private String findBookInSlowSource(String isbn) {
// some long processing
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
return "Sample Book "+isbn;
}
@CacheEvict(value = {"books"}, allEntries = true)
public void deleteCache() {}
}
# hazelcast.yaml
hazelcast:
network:
join:
multicast:
enabled: true
当我启动应用程序时,我总是得到正确的输出:
Members {size:2, ver:2} [
Member [192.168.178.107]:5702 - d53f2c3f-d66f-4ba3-bf8d-88d4935bde4e
Member [192.168.178.107]:5701 - 69860793-c420-48d3-990c-d0c30a3a92d6 this
]
我试过:
在不同的端口上运行两个spring启动应用程序
在不同的端口上运行两个tomcat
用java配置替换yaml配置
Java Based Configuration
@Configuration
@EnableCaching
public class CacheConfigurator {
@Bean
public Config config() {
Config config=new Config();
config.getNetworkConfig().getJoin().getMulticastConfig().setEnabled(true);
return config;
}
}
每次我得到相同的结果,每个应用程序似乎都在自己缓存。
其他信息:
我试着使用管理中心https://hazelcast.com/product-features/management-center/ 我可以连接到集群成员,但在“map”下看不到任何值
我想知道hazelcast的示例是否已启动,但spring boot没有使用它,而是使用自己的简单缓存
我的application.properties为空
spring boot版本2.4.4
1条答案
按热度按时间eni9jsuy1#
可能每个spring引导应用程序实际上创建了两个单独的hazelcast示例,而不是使用集群示例进行缓存。
请尽量遵循以下指南:
hazelcast指南:hazelcast使用spring boot入门
hazelcast指南:使用spring boot和hazelcast缓存