我想要将Spring Boot和Camel进行整合,尽情使用Camel组件
通过与camel的协作,可以随心所欲地使用大量的camel组件。
駝峰组件列表
http://camel.apache.org/components.html
在Spring Boot应用中运行Camel。
可以很容易地在Spring Boot应用程序中使用Camel进行操作,只需要在Spring Boot应用程序的pom.xml文件中添加Camel的依赖即可。
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-spring-boot-starter</artifactId>
<version>2.17.3</version>
</dependency>
不需要碰他。整个代码在最底部显示。启动部分也没有改变。不需要camel的描述。
package helloboot;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class AppMain {
public static void main(String[] args) {
SpringApplication.run(AppMain.class, args);
}
}
添加路由
只需要在@Component中编写继承RouteBuilder的代码。这样就能启动camel的路由。
package helloboot.route;
import org.apache.camel.builder.RouteBuilder;
import org.springframework.stereotype.Component;
@Component
public class HelloRoute extends RouteBuilder {
@Override
public void configure() throws Exception {
from("direct://hello")
.setBody(constant("hello"));
}
}
由于可以从根目录调用各种骆驼组件,因此要使用的组件请在此处列出。
呼叫駱駝的根节点
我想从REST控制器中调用启动的路由。
package helloboot.controller;
import org.apache.camel.CamelContext;
import org.apache.camel.Exchange;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.impl.DefaultExchange;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class HelloRestController {
@Autowired
private CamelContext camelContext;
@RequestMapping("/")
public String hello() {
// camelで流通するデータの作成
Exchange exchange = new DefaultExchange(camelContext);
// routeにデータを送信
ProducerTemplate producerTemplate = camelContext.createProducerTemplate();
producerTemplate.send("direct://hello", exchange);
// camelのrouteが例外で終了したかどうかの確認
if (exchange.getException() != null) {
return "NG";
}
return exchange.getIn().getBody(String.class);
}
}
开启
mvn spring-boot:run
pom.xml 可以更好地管理项目的依赖和构建设置。
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>suburi</groupId>
<artifactId>HelloSpringBoot</artifactId>
<version>1</version>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
</properties>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.4.0.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-spring-boot-starter</artifactId>
<version>2.17.3</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>