springboot camel mqtt activemq

电玩女神 2022-03-15 01:58 216阅读 0赞

**前面写类一篇kafka的，这里就不说了**

springboot版本 2.0.4.RELEASE

## maven ##

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
    
            <dependency>
                <groupId>org.apache.camel</groupId>
                <artifactId>camel-mqtt</artifactId>
                <version>2.23.1</version>
            </dependency>
    
            <dependency>
                <groupId>org.apache.camel</groupId>
                <artifactId>camel-spring-boot</artifactId>
                <version>2.16.0</version>
            </dependency>
    
            <dependency>
                <groupId>org.apache.camel</groupId>
                <artifactId>camel-core</artifactId>
                <version>2.23.1</version>
            </dependency>
    
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-activemq</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.apache.activemq</groupId>
                <artifactId>activemq-camel</artifactId>
                <version>5.15.4</version>
            </dependency>
    
            <dependency>
                <groupId>org.apache.activemq</groupId>
                <artifactId>activemq-pool</artifactId>
            </dependency>

## 配置文件 ##

**application.properties**

spring.activemq.pool.enabled=true
    spring.activemq.broker-url=tcp://127.0.0.1:61616

**data.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"
           xsi:schemaLocation=
                   "http://www.springframework.org/schema/beans
                   http://www.springframework.org/schema/beans/spring-beans.xsd
                   http://camel.apache.org/schema/spring
                   http://camel.apache.org/schema/spring/camel-spring.xsd">
    
    
        <camelContext id="testCamelContext" xmlns="http://camel.apache.org/schema/spring">
    
            <route autoStartup="true">
    
                <from uri="mqtt:adv?host=tcp://123.58.3.48:1883&userName=hnyfadmin&password=hnyfadmin&subscribeTopicNames=sa/#"/>
    
                <to uri="activemq:topic:camel?username=smx&password=smx"/>
            </route>
    
        </camelContext>
    
    </beans>

加载data.xml配置文件方式如上一篇