使用Apache Camel表达REST服务的方法介绍_F11 - 专业站长和开发者的学习网站

分享到

使用Apache Camel表达REST服务的方法介绍

linux 来源：互联网作者：酷站发布时间：2022-06-10 20:51:16 人浏览

摘要

使用Apache Camel的REST服务 Apache Camel可以作为一个独立的或嵌入的库在任何地方运行，它可以帮助整合。继续阅读，了解如何使用它来暴露REST服务。如何使用Apache Camel来表达REST服务 Cam

使用Apache Camel的REST服务

Apache Camel可以作为一个独立的或嵌入的库在任何地方运行，它可以帮助整合。继续阅读，了解如何使用它来暴露REST服务。

如何使用Apache Camel来表达REST服务

Camel REST允许使用Restlet、Servlet和许多这样的HTTP感知组件来实现REST服务的创建。

大家都知道，Camel的主要功能是路由引擎。路由可以使用基于Java的DSL或基于XML来开发。在这篇文章中，我将按照JavaDSL来开发一个REST服务。

定义端点

为了定义端点，我们需要使用Apache Camel DSL与 Java DSL（尽管你可以使用XML）。

下面是Java DSL。

Java

rest("/api/products")

.get().route().to("...")

.post().route().to("...")

.delete().route().to("...");

它与Camel路由类似，但使用rest() 。我们需要提到用于暴露端点的组件服务。Camel支持以下组件来实现Bootstrap REST服务。

Servlet
Spark REST
Netty HTTP
Jetty

如果你打算将Camel与Spring Boot框架集成以暴露服务，最好使用servlet 组件，因为Spring Boot支持嵌入式Tomcat，Camel可以使用它。

让我们把REST配置成。

Java

// Define the implementing component - and accept the default host and port

restConfiguration()

.component("servlet");

如何覆盖端口

你可以用你选择的任何其他端口号来覆盖默认的8080端口，方法是将.port() 设置为restConfiguration() API，或者，如果你将Apache Camel与Spring Boot集成，你可以使用application.properties 中的server.port=8082 。

覆盖上下文路径

默认情况下，Camel将导入请求映射到/camel/* 。你可以通过使用application.properties 作为camel.component.servlet.mapping.context-path=/services/api/*，将其覆盖到你选择的任何特定路径。

配置绑定模式，将请求集合到POJO对象。如果设置为 "off "以外的任何内容，生产者将尝试把传入信息的主体从inType转换为JSON或XML，而把响应从JSON或XML转换为outType。有五个枚举，其值可以是以下之一：自动、关闭、JSON、XML或json_xml。为了实现这一点，你需要将绑定模式设置为restConfiguration() ，因为bindingMode(RestBindingMode.auto); 。

请看下面的REST API的配置样本。

@Component

public class HttpRouteBuilder extends BaseRouteBuilder {

@Override

public void configure() throws Exception {

super.configure();

// it tells Camel how to configure the REST service

restConfiguration()

// Use the 'servlet' component.

// This tells Camel to create and use a Servlet to 'host' the RESTful API.

// Since we're using Spring Boot, the default servlet container is Tomcat.

.component("servlet")

// Allow Camel to try to marshal/unmarshal between Java objects and JSON

.bindingMode(RestBindingMode.auto);

rest().get("/kyc/{uid}").route().process("httpRequestProcessor").to("log:?level=INFO&showBody=true").endRest();

rest().post("/kyc").type(RequestObject.class).route().to("bean-validator:myvalidatorname")

.process("httpRequestProcessor").to("log:?level=INFO&showBody=true");

}

您可以使用Apache Camel bean验证器组件验证传入的请求，这需要在您的Maven POM中添加camel-bean-validator 依赖关系。

<groupId>org.apache.camel</groupId>

<artifactId>camel-bean-validator</artifactId>

</dependency>

在请求对象中定义验证规则

为了实现输入请求验证，你需要为POJO/请求类中的字段添加验证注解。这些注释可在包javax.validation.constraints 。JSR-303 API中最常见的是。

@NotNull - 检查该字段是否是null
@AssertTrue/@AssertFalse - 检查该字段是否为真或假
@Pattern(regex=, flags=) - 检查该字段是否与给定的，与给定的regex flags

在org.hibernate.validator.constraints ，有一些Hibernate特有的注释，比如。

@Email - 检查该字段是否包含一个有效的电子邮件地址
@CreditCardNumber - 这个可能很明显
@NotEmpty - 检查注解的字段是否为空或空。

如何处理异常

你可以处理不同类型的异常，并使用Apache Camel异常条款（onException ）向客户端发送自定义的错误信息，无论是在路由级别还是在全球级别。你也可以重写REST API调用的HTTP响应代码和消息。

public class BaseRouteBuilder extends RouteBuilder {

@Override

public void configure() throws Exception {

onException(BeanValidationException.class).handled(true).process(new Processor() {

@Override

public void process(Exchange exchange) throws Exception {

Throwable cause = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, Throwable.class);

exchange.getMessage().setHeader(Exchange.HTTP_RESPONSE_CODE, 400);

exchange.getMessage().setHeader(Exchange.CONTENT_TYPE, MediaType.APPLICATION_JSON);

exchange.getMessage().setBody("{error:" + cause.getMessage() + "}");

}

});

onException(InvalidRequestException.class).handled(true).process(new Processor() {

@Override

public void process(Exchange exchange) throws Exception {

Throwable cause = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, Throwable.class);

exchange.getMessage().setHeader(Exchange.HTTP_RESPONSE_CODE, 400);

exchange.getMessage().setHeader(Exchange.CONTENT_TYPE, MediaType.APPLICATION_JSON);

exchange.getMessage().setBody("{error:" + cause.getMessage() + "}");

}

});

onException(Exception.class).handled(true).process(new Processor() {

@Override

public void process(Exchange exchange) throws Exception {

Throwable cause = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, Throwable.class);

exchange.getMessage().setHeader(Exchange.HTTP_RESPONSE_CODE, 500);

exchange.getMessage().setHeader(Exchange.CONTENT_TYPE, MediaType.APPLICATION_JSON);

exchange.getMessage().setBody("{error:" + cause.getMessage() + "}");

}

});

}

注意：在这里我创建了一个基类来处理各种异常，在我的主REST API构建器类(HttpRouteBuilder)中，它扩展了BaseRouteBuilder。

最后是POM。

100

101

102

103

104

105

106

107

108

109

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-dependencies</artifactId>

<version>${spring-boot.version}</version>

<scope>import</scope>

</dependency>

<groupId>org.apache.camel.springboot</groupId>

<artifactId>camel-spring-boot-dependencies</artifactId>

<version>${camel.version}</version>

<scope>import</scope>

</dependency>

<groupId>org.projectlombok</groupId>

<artifactId>lombok</artifactId>

<scope>provided</scope>

</dependency>

</dependencies>

</dependencyManagement>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-actuator</artifactId>

<groupId>com.fasterxml.jackson.datatype</groupId>

<artifactId>jackson-datatype-jsr310</artifactId>

</exclusion>

<groupId>com.fasterxml.jackson.core</groupId>

<artifactId>jackson-annotations</artifactId>

</exclusion>

</exclusions>

</dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-web</artifactId>

<groupId>com.fasterxml.jackson.datatype</groupId>

<artifactId>jackson-datatype-jsr310</artifactId>

</exclusion>

</exclusions>

</dependency>

<groupId>org.apache.camel.springboot</groupId>

<artifactId>camel-spring-boot-starter</artifactId>

</dependency>

<groupId>org.projectlombok</groupId>

<artifactId>lombok</artifactId>

</dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-test</artifactId>

</dependency>

<groupId>org.apache.camel.springboot</groupId>

<artifactId>camel-jackson-starter</artifactId>

<groupId>com.fasterxml.jackson.core</groupId>

<artifactId>jackson-annotations</artifactId>

</exclusion>

</exclusions>

</dependency>

<groupId>org.apache.camel.springboot</groupId>

<artifactId>camel-servlet-starter</artifactId>

</dependency>

<groupId>org.apache.camel</groupId>

<artifactId>camel-test-spring</artifactId>

</dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-test</artifactId>

<groupId>com.vaadin.external.google</groupId>

<artifactId>android-json</artifactId>

</exclusion>

</exclusions>

</dependency>

<groupId>org.apache.camel</groupId>

<artifactId>camel-swagger-java</artifactId>

</dependency>

<groupId>org.apache.camel</groupId>

<artifactId>camel-bean-validator</artifactId>

</dependency>

</dependencies>

总结

现在你知道了如何用Camel暴露REST API，你可能想知道什么时候/为什么要用Apache Camel来构建REST服务。简单的答案是，如果你已经在使用Apache Camel来整合不同协议和应用程序之间的数据，那么REST是你需要支持的另一个数据源，而不是用Spring Boot或任何其他框架来构建REST服务。你可以利用Camel REST组件来暴露REST API，并使用已知的Camel DSL来消费/生产消息，这有助于你规范技术桩。你还可以扩展Camel REST，使其包括Swagger，以便使用camel-swagger 组件提供API规范。

您可能感兴趣的文章 :

原文链接 : https://juejin.cn/post/7107138393548521508

Tag : Apache(15)

jar包在linux服务器已经运行好但是访问不到地址的

今天用命令已经将jar包运行好了但是在本地访问的时候，访问不到,云服务的的安全组策略也开放了相对应的端口。解决方案：修改防火墙
Linux apache实现https的配置方法

http协议：应用层协议，传输层使用TCP协议，默认使用80端口。http协议主要是用来是实现万维网站点资源的访问。 ssl（安全套接层）协议：
Apache网页的优化、安全与防盗链图文介绍

1. Apache 网页的压缩在企业中，部署Apache后只采用默认的配置参数，会引发网站很多问题，换言之默认配置是针对以前较低的服务器配置的，
安装CentOs 5.5后无法显中文（中文乱码）

症状：在使用CentOS 系统时，安装的时候可能你会遇到英文的CentOS系统，在这中情况下安装CentOS系统时是默认安装（即英文）。安装完毕后，
Apache Doris的Bitmap索引和BloomFilter索引使用及注意事

1. Bitmap索引的使用 1.1 Bitmap索引介绍 bitmap index是一种位图索引，是一种快速数据结构，能够加快查询速度 1.2 Bitmap索引使用的注意事项使用
源码安装apache脚本部署过程详解

源码安装apache脚本部署 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53
Apache SkyWalking 监控 MySQL Server实战解析

正文 Apache SkyWalking 在本月初发布了 SkyWalking Backend、UI 的9.2.0 版本以及SkyWalkingJavaAgent 8.12.0 版本，其中就有笔者贡献的hutool-http client 5.x 插件
Apache安装配置避坑指南介绍

1.下载解压 httpd-2.4.54-o111p-x64-vs17 2.将解压后的文件夹放置C盘，打开conf文件夹里的httpd.conf，修改Apache安装存放的目录地址 3.修改一些参数，
服务器被入侵的处理过程分享给大家

下文中的，给文件和目录加锁，是指给文件和目录增加了一些属性，只读等。chattr +ia 一、服务器入侵现象近期有一个朋友的服务器(自己做
linux服务器校对时间方法命令介绍

Linux中有个ntp包可以自动校准时间，并且非常好用。 Debian系统安装NTP校时包： 1 apt-get install ntpdate CentOS系统安装NTP校时包： 1 yum install ntp 校