spring集成mqtt型转换器问题

Question

尝试从web运行示例spring集成mqtt项目。我已经在根上下文中导入了mqtt上下文。战争部署后，我正在运行RunMqtt.java文件。但是得到以下问题。如果在独立模式下运行，相同的文件不会出现任何问题。

堆栈跟踪创建bean的实例"startCaseAdapter"16:50:54.147调试[main][org.springframework.beans.BeanUtils]根据"编辑器"后缀约定，找不到org.springfframework.integration.mqtt.core.MqttPahoClientFactoryEditor]类型的属性编辑器16:50:54.148 TRACE[main][org.springframework.beans.TypeConverterDelegate]字段[topic]不是枚举值java.lang.NoSuchFieldException：主题位于java.lang.Class.getField(Class.java：1579)位于org.springframework.beans.TypeConverterDelegate.tempptToConvertStringToEnum(TypeConverterDelegate.java:336)位于org.springframework.beans.TypeConverterDelegate.covertIfNenecessary(TypeConverterDelegate.java:257)位于org.springframework.beans.TypeConverterDelegate.covertIfNenecessary(TypeConverterDelegate.java:107)网址：org.springframework.beans.TypeConverterSupport.doConvert(TypeConverterSupport.java:64)网址：org.springframework.beans.TypeConverterSupport.covertIfNenecessary(TypeConverterSupport.java:47)位于org.springframework.beans.factory.support.ConstrutorResolver.createArgumentArray(ConstructorResolver.java:706)网址：org.springframework.beans.factory.support.ConstrutorResolver.autowireConstructor(ConstructorResolver.java:185)网址：org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.autowireConstructor(AbstractAutowireCapableBeanFactory.java:1133)网址：org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1036)网址：org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:505)网址：org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:476)位于org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:302)位于org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:229)网址：org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory:java:298)网址：org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:193)位于org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:725)位于org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:757)在org.springframework.context.support.ClassPathXmlApplicationContext.refresh(AbstractApplicationContext.java:480)上。(ClassPathXmlApplicationContext.java:139)位于org.springframework.context.support.ClassPathXmlApplicationContext。(ClassPathXmlApplicationContext.java:83)网址：com.iux.ieg.test.mqtt.RunMqtt.test(RunMqtt.java:24)网址：com.iux.ieg.test.mqtt.RunMqtt.main(RunMqtt.java:46)16:50:54.150 TRACE[main][org.springframework.beans.factory.support.DefaultListableBeanFactory]忽略bean"startCaseAdapter"的构造函数[public org.springfframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapterorg.springframework.beans.factory.UnsatisfiedDependencyException：创建名为"startCaseAdapter"的bean时出错：通过类型为[org.springfframework.integration.mqtt.core.MqttPahoClientFactory]的索引为2的构造函数参数表达的不满足依赖关系：无法将类型为[java.lang.String]的构造函数参数值转换为所需类型[org.springframework.integration.mqt.core.MqttPahoClientFactory]：无法将类型"java.lang.String"的值转换为所需类型"org.springfframework.integation.mqt.core.MqttPahoClientFactory"；嵌套异常为java.lang.IllegalStateException：无法将[java.lang.String]类型的值转换为所需类型[org.springframework.integration.mqtt.core.MqttPahoClientFactory]：找不到匹配的编辑器或转换策略16:50:54.150 TRACE[main][org.springframework.beans.TypeConverterDelegate]使用属性编辑器将字符串转换为[class[Ljava.lang.String；][org.springframework.beans.propertyeditors.StringArrayPropertyEditor@821075]16:50:54.150 TRACE[main][org.springframework.beans.TypeConverterDelegate]字段[clientId]不是枚举值java.lang.NoSuchFieldException：客户端ID位于java.lang.Class.getField(Class.java：1579)位于org.springframework.beans.TypeConverterDelegate.tempptToConvertStringToEnum(TypeConverterDelegate.java:336)位于org.springframework.beans.TypeConverterDelegate.covertIfNenecessary(TypeConverterDelegate.java:257)位于org.springframework.beans.TypeConverterDelegate.covertIfNenecessary(TypeConverterDelegate.java:107)网址：org.springframework.beans.TypeConverterSupport.doConvert(TypeConverterSupport.java:64)网址：org.springframework.beans.TypeConverterSupport.covertIfNenecessary(TypeConverterSupport.java:47)位于org.springframework.beans.factory.support.ConstrutorResolver.createArgumentArray(ConstructorResolver.java:706)网址：org.springframework.beans.factory.support.ConstrutorResolver.autowireConstructor(ConstructorResolver.java:185)网址：org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.autowireConstructor(AbstractAutowireCapableBeanFactory.java:1133)网址：org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1036)网址：org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:505)网址：org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:476)位于org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:302)位于org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:229)网址：org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory:java:298)网址：org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:193)位于org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:725)位于org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:757)网址：org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:480)位于org.springframework.context.support.ClassPathXmlApplicationContext。(ClassPathXmlApplicationContext.java:139)位于org.springframework.context.support.ClassPathXmlApplicationContext。(ClassPathXmlApplicationContext.java:83)网址：com.iux.ieg.test.mqtt.RunMqtt.test(RunMqtt.java:24)网址：com.iux.ieg.test.mqtt.RunMqtt.main(RunMqtt.java:46)配置Web应用程序配置.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd">
<!-- This file will be the root context file for web app. All other context 
will be imported here -->
<!-- Security context . Now the spring security with basic authentication 
implemented. OAuth2 will be implemented -->
<import resource="security-config.xml" />
<!-- rest service call context -->
<import
resource="classpath:META-INF/spring/integration/rest/applicationContext-http-int.xml" />
<!-- Sftp context -->
<import
resource="classpath:META-INF/spring/integration/sftp/SftpInboundReceive-context.xml" />
<import
resource="classpath:META-INF/spring/integration/sftp/SftpOutboundTransfer-poll.xml" />
<!-- mqtt context -->
<import resource="classpath:META-INF/spring/integration/mqtt/mqtt-context.xml" />
<!-- Mail Context -->
<import
resource="classpath:META-INF/spring/integration/mail/mail-imap-idle-config.xml" />
<import
resource="classpath:META-INF/spring/integration/mail/mail-pop3-config.xml" />

<!--Component scan base package -->
<context:component-scan base-package="com.iux.ieg" />
<!-- All the property configuration moved to parent context file to solve 
the propert not found exception -->
<!-- <context:property-placeholder order="1" location="classpath:/sftpuser.properties, 
classpath:/sftpfile.properties,classpath:/resthttp.properties" ignore-unresolvable="true"/> -->
<context:property-placeholder order="0"
location="classpath:/sftpfile.properties" ignore-unresolvable="true" />
<context:property-placeholder order="1"
location="classpath:/sftpuser.properties" ignore-unresolvable="true" />
<context:property-placeholder order="2"
location="classpath:/resthttp.properties" ignore-unresolvable="true" />
<context:property-placeholder order="3"
location="classpath:/mqtt.properties" ignore-unresolvable="true" />
<context:property-placeholder order="4"
location="classpath:/mail.properties" />
</beans>

mqtt context.xml

http://www.springframework.org/schema/integrationhttp://www.springframework.org/schema/integration/spring-integration-4.1.xsdhttp://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans-4.1.xsdhttp://www.springframework.org/schema/integration/mqtthttp://www.springframework.org/schema/integration/mqtt/spring-integration-mqtt-4.1.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context-4.1.xsd">

<context:property-placeholder 
location="classpath:/mqtt.properties" ignore-unresolvable="true" />

<!-- intercept and log every message -->
<int:logging-channel-adapter id="logger"
level="ERROR" />
<int:wire-tap channel="logger" />
<!-- Mark the auto-startup="true" for starting MqttPahoMessageDrivenChannelAdapter from configuration  -->
<int-mqtt:message-driven-channel-adapter
id="startCaseAdapter" client-id="clientId" url="${mqtt.brokerurl}"
topics="topic" channel="startCase" auto-startup="true" />
<int:channel id="startCase" />

<int:service-activator id="startCaseService"
input-channel="startCase" ref="mqttCaseService" method="startCase" />
<bean id="mqttCaseService" class="com.iux.ieg.mqtt.MqttCaseService" />

MqttCaseService.java

import org.apache.log4j.Logger;

public class MqttCaseService {
private static Logger logger = Logger.getLogger(MqttCaseService.class);
public void startCase(String message){
logger.debug(message);
}
}

RunMqtt.java

public class RunMqtt {
private static Logger logger = Logger.getLogger(RunMqtt.class);
//@Test
public void test() throws MqttException{
ConfigurableApplicationContext context =
new ClassPathXmlApplicationContext("/META-INF/spring/integration/mqtt/mqtt-context.xml");
logger.debug(context);
//MqttPahoMessageDrivenChannelAdapter startCaseAdapter = (MqttPahoMessageDrivenChannelAdapter)context.getBean("startCaseAdapter");
//Uncomment to stop the adapter manually from program
//startCaseAdapter.start();
//DefaultMqttPahoClientFactory mqttClient = (DefaultMqttPahoClientFactory)ac.getBean("clientFactory");
DefaultMqttPahoClientFactory mqttClient = new DefaultMqttPahoClientFactory();
MqttClient mclient = mqttClient.getClientInstance("tcp://*messagebrokerurl*:1883", "JavaSample");
String data = "This is what I am sending in 2nd attempt";
MqttMessage mm = new MqttMessage(data.getBytes());
mm.setQos(1);
mclient.connect();
mclient.publish("topic",mm);
mclient.disconnect();
//Uncomment to stop the adapter manually from program
//startCaseAdapter.stop();
}

public static void main(String[] args)  {
try {
new RunMqtt().test();
} catch (MqttException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}

Answer 1

示例弹簧集成mqtt项目

哪个样本？

请显示您的配置。

编辑：

看起来Spring在确定要使用哪个构造函数时遇到了问题。

尝试添加

<bean id="clientFactory" class="org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory" />

并将CCD_ 1添加到消息驱动适配器。