apache camel_REST与Apache Camel

apache camel

有许多方法可以在Camel中公开HTTP终结点:jetty,tomcat,servlet,cxfrs和restlet。 其中的两个组件– cxfrs和restlet也仅需几行代码即可支持REST语义。 这个简单的示例演示了如何使用camel-restlet和camel-jdbc进行CRUD操作。 四个HTTP动词执行不同的操作,并映射到以下单个URI模板:

  • POST –创建一个新用户: / user
  • GET –请求URI指定的用户的当前状态: / user / {userId}
  • PUT –使用新信息更新给定URI上的用户/ user / {userId}
  • 删除–删除由给定URI标识的用户: / user / {userId}



还有一个/ users URI,它返回所有用户,无论使用哪种HTTP方法。 用Camel创建这样的应用程序很简单。 添加所有必要的依赖项(restlet,spring,jdbc…)之后,配置web.xml来加载Camel上下文:

<context-param><param-name>contextConfigLocation</param-name><param-value>classpath:camel-config.xml</param-value></context-param><listener><listener-class>org.springframework.web.context.ContextLoaderListener</listener-class></listener>

并映射Restlet servlet

<servlet><servlet-name>RestletServlet</servlet-name><servlet-class>org.restlet.ext.spring.SpringServerServlet</servlet-class><init-param><param-name>org.restlet.component</param-name><param-value>RestletComponent</param-value></init-param>
</servlet>
<servlet-mapping><servlet-name>RestletServlet</servlet-name><url-pattern>/rs/*</url-pattern>
</servlet-mapping>

在Spring上下文中,还有更多的Restlet和一个内存中的数据源设置代码:

<bean id="RestletComponent" class="org.restlet.Component"/><bean id="RestletComponentService" class="org.apache.camel.component.restlet.RestletComponent"><constructor-arg index="0"><ref bean="RestletComponent"/></constructor-arg></bean><jdbc:embedded-database id="dataSource" type="HSQL"><jdbc:script location="classpath:sql/init.sql"/></jdbc:embedded-database>

完成所有设置后,下一步是创建将处理HTTP请求并执行适当的CRUD操作的骆驼路由。 第一个是createUser路由,该路由仅使用POST请求中的参数执行SQL插入命令,并在响应正文中返回新创建的用户:

<route id="createUser"><from uri="restlet:/user?restletMethod=POST"/><setBody><simple>insert into user(firstName, lastName) values('${header.firstName}','${header.lastName}');  </simple></setBody><to uri="jdbc:dataSource"/><setBody><simple>select * from user ORDER BY id desc LIMIT 1</simple></setBody><to uri="jdbc:dataSource"/>
</route>

“ manipulateUser”路由处理GET,PUT和DELETE HTTP方法,但是根据使用的方法,它执行不同SQL命令:

<route id="manipulateUser"><from uri="restlet:/user/{userId}?restletMethods=GET,PUT,DELETE"/><choice><when><simple>${header.CamelHttpMethod} == 'GET'</simple><setBody><simple>select * from user where id = ${header.userId}</simple></setBody></when><when><simple>${header.CamelHttpMethod} == 'PUT'</simple><setBody><simple>update user set firstName='${header.firstName}', lastName='${header.lastName}' where id = ${header.userId}</simple></setBody></when><when><simple>${header.CamelHttpMethod} == 'DELETE'</simple><setBody><simple>delete from user where id = ${header.userId}</simple></setBody></when><otherwise><stop/></otherwise></choice><to uri="jdbc:dataSource"/>
</route>

列出所有用户的最后一条路线是不言而喻的:

<route id="listUsers"><from uri="restlet:/users"/><setBody><constant>select * from user</constant></setBody><to uri="jdbc:dataSource"/>
</route>

如果您想查看应用程序的运行情况,请从github获取源代码,并通过键入以下命令使用嵌入式maven-jetty插件运行它如果安装了curl,您甚至可以尝试一些快速查询:

要创建用户,请使用firstName和lastName参数发出http POST请求

curl -d 'firstName=test&lastName=user' http://localhost:8080/rs/user/

要更新现有用户,请使用firstName和lastName参数发出http PUT请求

curl -X PUT -d 'firstName=updated&lastName=user' http://localhost:8080/rs/user/2

要检索现有用户,请发出带有userId作为URL一部分的http GET请求

curl -X GET http://localhost:8080/rs/user/2

要删除现有用户,请发出http DELETE请求,并将userId作为URL的一部分

curl -X DELETE http://localhost:8080/rs/user/2

要检索所有现有用户,请向用户url发出http GET请求

curl -X GET http://localhost:8080/rs/users

参考:来自OFBIZian博客的JCG合作伙伴 Bilgin Ibryam的REST with Apache Camel 。

翻译自: https://www.javacodegeeks.com/2013/03/rest-with-apache-camel.html

apache camel

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/349030.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

删除 多个表_合并汇总多个工作簿多个工作表,删除修改新增更新内容只需刷新...

要求&#xff1a;1、把多个工作簿的多个工作表内容合并汇总2、后续在任一工作表内删除修改新增内容&#xff0c;无需再重新做表3、后续在任一工作簿中新增一个或多个工作表&#xff0c;无需再重新做表4、后续在文件夹中添加一个或多个Excel工作簿文件&#xff0c;无需再重新做表…

OAuth2,JWT,Open-ID Connect和其他令人困惑的事物

免责声明 如果觉得我必须从一个重要的免责声明开始这篇文章&#xff1a; 不要太相信我要说的话。 我之所以这样说&#xff0c;是因为我们正在讨论安全性。 而且&#xff0c; 当您谈论安全性时&#xff0c;除了100&#xff05;正确的陈述外&#xff0c;还有冒任何其他风险的风险…

go语言查询某个值是否在数组中_go语言中的数组

package main;import ("fmt")func main() {//声明一个数组var a [3]int;a [3]int{1, 2, 3};//声明并赋值var b [3]int [3]int{1, 2, 3};//声明并赋值(省略类型)var c [3]int{1, 2, 3};//声明并赋值简写d : [3]int{1, 2, 3};//GO中将数组长度作为数组类型的一部分/…

ssm集成笔记_SSM整合笔记

SSM一般是分开学的&#xff0c;Spring&#xff0c;SpringMVC&#xff0c;Mybatis。学完之后整合也是需要学习一段时间。下面是一次整合的实践...SSM的整合顺序一般先整合Spring和Mybatis。再整合SpringMVC。Spring整合Mybatis首先把文件放到lib的文件夹下。然后在src目录下新建…

人工智能在建筑运营_打造智能建筑商

人工智能在建筑运营构建API时&#xff0c;您应始终考虑谁将使用它。 当API简单易用时&#xff0c;用户就会感到满意。 当用户满意时&#xff0c;每个人也都会满意。 但是出色的可用性并非总是容易实现的。 有一些模式对此有所帮助&#xff0c;在这篇文章中&#xff0c;我将重点…

mysql删除用户账号和密码_mysql添加、删除用户和授权用户

MySql中添加用户,新建数据库,用户授权,删除用户,修改密码(注意每行后边都跟个;表示一个命令语句结束):1.新建用户1.1 登录MYSQL&#xff1a;>mysql -u root -p>密码1.2 创建用户&#xff1a;mysql> insert into mysql.user(Host,User,Password) values("localhos…

从GWT开发人员的角度概述Scala.js

该博客严重偏向于GWT&#xff08;和基于GWT的框架&#xff09;&#xff0c;但是我们牢记未来GWT可能会被其他技术所取代&#xff0c;因此我们始终愿意探索其他平台/框架。 正如他们所说&#xff0c;多元化可以降低风险。 每种编程语言&#xff0c;甚至最奇怪的编程语言&#xf…

alinq mysql_ALinq让Mysql变得如此简单_MySQL

当大家已经习惯了使用.net 去操作SQL Server&#xff0c;有多少人曾经尝试过使用.net 去操作Mysql数据库&#xff01;在.net 的光环下&#xff0c;Mysql是显得如此微不足道&#xff01;但是Mysql的开源又是如此具有诱惑。1. ADO.NET 方式连接Mysql数据库经过在网上查找资料&…

debian php mysql 安装_在 Debian 下安装 Apache,MySQL,PHP

我是转载过来的&#xff0c;原地址 http://blog.csdn.net/youngdze/article/details/20455557 ,我安装成功!首先&#xff0c;对你的源进行更新&#xff1a;$ sudo apt-get update第一步--安装 ApacheApache 是一个开源软件&#xff0c;它目前运行在全球超过 50% 的服务器上&…

java ee cdi_Java EE CDI bean范围

java ee cdiJava EE平台的上下文和依赖注入&#xff08;CDI&#xff09;是一项功能&#xff0c;有助于将Java EE平台的Web层和事务层绑定在一起。 CDI是一组服务&#xff0c;可以一起使用&#xff0c;使开发人员可以轻松地在Web应用程序中使用企业bean和JavaServer Faces技术。…

airflow mysql_Airflow 使用及原理分析

Airflow 入门及使用什么是 Airflow&#xff1f;Airflow 是一个使用 Python 语言编写的 Data Pipeline 调度和监控工作流的平台。Airflow 是通过 DAG(Directed acyclic graph 有向无环图)来管理任务流程的任务调度工具&#xff0c;不需要知道业务数据的具体内容&#xff0c;设置…

mysql关于死锁的优化_mysql死锁探究及优化

什么是锁&#xff1f;锁是计算机为了平衡协调多个进程或线程并发访问资源的机制。计算机除了cpu&#xff0c;ram&#xff0c;I/O&#xff0c;数据也是一种共享资源。锁冲突是影响数据库并发性能的一个重要因素。例如行锁&#xff0c;表锁等&#xff0c;读锁&#xff0c;写锁等&…

jdk8 calendar_JDK 8的Calendar.Builder

jdk8 calendar勇敢的Java新世界的定义特征之一是Java空间中构建器模式的日益普及。 Groovy是JVM上最流行的替代语言&#xff08;对于Java&#xff09;&#xff0c;以在核心库以及Groovy支持的库和框架中大量使用Builder而闻名。 Josh Bloch将该模式带到了Java开发人员社区的最前…

mt5 mysql数据库_Django -- 使用MySql数据库

Django默认使用的sqlite3&#xff0c;这在实际的生产环境中是不推荐的&#xff1b;1. 创建数据库Linux VM_0_15_centos 3.10.0-693.el7.x86_64 #1 SMP Tue Aug 22 21:09:27 UTC 2017 x86_64 x86_64 x86_64 GNU/Linux1.1. 使用utf8mb4编码mysql的utf-8编码最多只支持3个字节&…

gradle 安装_如何安装Gradle

gradle 安装Gradle是一个依赖管理/构建工具&#xff0c;结合了Maven和Ant的优点&#xff0c;使其成为功能强大且可自定义的工具。 它还使用了光滑的Groovy DSL而不是Maven和Ant的XML方法&#xff0c;并且当我开始一个新项目时&#xff0c;它是我个人的选择工具。 安装方法如下。…

wps怎么旋转页面_用WPS文字编辑一份试卷,详细教程来了,老师们赶快收藏吧

​ 试卷是每一个教师接触最多的资料了&#xff0c;很多教师在检测前找一些现成的试卷复印给学生练习&#xff0c;但是&#xff0c;有很多题不适合学生&#xff0c;因此&#xff0c;我们需要自己编辑一份试卷了&#xff0c;编辑试卷也并不是很难的&#xff0c;今天&#xff0c;就…

maven 部署nexus_Maven部署到Nexus

maven 部署nexus1.概述 在上一篇文章中 &#xff0c;我讨论了Maven项目如何在本地安装尚未部署在Maven Central&#xff08;或任何其他大型且公共托管的存储库&#xff09;上的第三方jar。 该解决方案仅适用于小型项目&#xff0c;在这些项目中安装&#xff0c;运行和维护完整的…

mongodb mysql json数据_使用MongoDB与MySQL有很多JSON字段?

所以&#xff0c;直接回答问题…Shall we chose mongodb if half of data is schemaless, and is being stored as JSON if using MySQL?无数存储空间肯定是MongoDB的一个引人注目的理由&#xff0c;但正如您所指出的&#xff0c;将JSON存储在RDBMS中也是相当容易的。 MongoDB…

Java命令行界面(第15部分):Jargo

Jargo在其GitHub主页上定义为“一种减轻程序参数/选项处理的工具”。 当已经存在许多其他命令行处理库时&#xff0c;该页面为另一个命令行处理库提供了基本原理 &#xff0c;该列表的顶部是“因为类型安全性&#xff0c;不变性和可读性很重要”。 Jargo的选项“定义”阶段使用…

mysql 过滤相同数据库_MySQL数据库查询中的重复记录过滤

今天帮别人修改程序&#xff0c;需要分组去最大值。也就是所谓&#xff0c;某一字段有重复字&#xff0c;过滤掉有重复的数据。弄了半天&#xff0c;最后总结一下。首先搞点模拟数据出来create table t2 (id int primary key,gid char,col1 int,col2 int) enginemyisam;insert …