SpringBoot + ActiveMQ-如何设置可信包? [英] SpringBoot + ActiveMQ - How to set trusted packages?
问题描述
我要创建两个springboot服务器&客户端应用程序使用JMS进行通信,并且在activemq的 5.12.1
版本中一切正常,但是当我更新到 5.12.3时,一切正常
版本,出现以下错误:
I'm creating two springboot server & client applications communicating using JMS, and everything is working fine with the release 5.12.1
for activemq, but as soon as I update to the 5.12.3
version, I'm getting the following error :
org.springframework.jms.support.converter.MessageConversionException: Could not convert JMS message; nested exception is javax.jms.JMSException: Failed to build body from content. Serializable class not available to broker. Reason: java.lang.ClassNotFoundException: Forbidden class MyClass! This class is not trusted to be serialized as ObjectMessage payload. Please take a look at http://activemq.apache.org/objectmessage.html for more information on how to configure trusted classes.
我继续所提供的URL ,我发现我的问题与 5.12.2 $中实现的新安全性有关。 c $ c>版本的ActiveMQ,我知道可以通过定义受信任的程序包来修复它,但我不知道在SpringBoot项目中的哪里放置这样的配置。
I went on the URL that is provided and I figured out that my issue is related to the new security implemented in the 5.12.2
release of ActiveMQ, and I understand that I could fix it by defining the trusted packages, but I have no idea on where to put such a configuration in my SpringBoot project.
我对客户端和服务器中的JMS队列的唯一参考是在application.properties中设置它的URI,并使用 @EnableJms在我的主类上启用JMS
,这是我在单独代理上的配置:
The only reference I'm making to the JMS queue in my client and my server is setting up it's URI in application.properties and enabling JMS on my "main" class with @EnableJms
, and here's my configuration on the separate broker :
@Configuration
@ConfigurationProperties(prefix = "activemq")
public class BrokerConfiguration {
/**
* Defaults to TCP 10000
*/
private String connectorURI = "tcp://0.0.0.0:10000";
private String kahaDBDataDir = "../../data/activemq";
public String getConnectorURI() {
return connectorURI;
}
public void setConnectorURI(String connectorURI) {
this.connectorURI = connectorURI;
}
public String getKahaDBDataDir() {
return kahaDBDataDir;
}
public void setKahaDBDataDir(String kahaDBDataDir) {
this.kahaDBDataDir = kahaDBDataDir;
}
@Bean(initMethod = "start", destroyMethod = "stop")
public BrokerService broker() throws Exception {
KahaDBPersistenceAdapter persistenceAdapter = new KahaDBPersistenceAdapter();
persistenceAdapter.setDirectory(new File(kahaDBDataDir));
final BrokerService broker = new BrokerService();
broker.addConnector(getConnectorURI());
broker.setPersistent(true);
broker.setPersistenceAdapter(persistenceAdapter);
broker.setShutdownHooks(Collections.<Runnable> singletonList(new SpringContextHook()));
broker.setUseJmx(false);
final ManagementContext managementContext = new ManagementContext();
managementContext.setCreateConnector(true);
broker.setManagementContext(managementContext);
return broker;
}
}
所以我想知道我在哪里
谢谢:)
推荐答案
添加以下bean:
@Bean
public ActiveMQConnectionFactory activeMQConnectionFactory() {
ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("your broker URL");
factory.setTrustedPackages(Arrays.asList("com.my.package"));
return factory;
}
下一个版本已添加了通过配置属性执行此操作的功能:
https://github.com/spring-projects/spring- boot / issues / 5631
The ability to do this via a configuration property has been added for the next release: https://github.com/spring-projects/spring-boot/issues/5631
这篇关于SpringBoot + ActiveMQ-如何设置可信包?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!