阿帕奇跨域_阿帕奇骆驼遇见Redis

阿帕奇跨域

键值商店的兰博基尼

Camel是最好的面包集成框架，在本文中，我将向您展示如何通过利用另一个出色的项目Redis使它更加强大。

Camel 2.11即将发布，具有许多新功能，错误修复和组件。这些新组件中的几个是我创作的， redis-component是我最喜欢的组件。 Redis – ligth键/值存储区是一款出色的意大利软件，专为提高速度而设计（与Lamborghini相同– Lamborghini是一款两人座的意大利汽车，专为速度）。 Redis用C语言编写，并且具有接近金属性质的内存，其表现非常出色（Lamborgini的座右铭是“ Closer to the Road”）。由于键可以包含字符串，哈希，列表和排序集，因此Redis通常被称为数据结构服务器。快速轻巧的数据结构服务器对于软件工程师来说就像是一辆超级跑车，它只是飞行而已。如果您想了解有关Redis和兰博基尼独特性能特征的更多信息，那么您会发现自己。

Redis入门很容易：下载，制作和启动Redis服务器。完成这些步骤之后，您就可以从Camel应用程序中使用它了。该组件在内部使用Spring Data ，而后者又使用Jedis驱动程序，但有可能切换到其他Redis驱动程序。以下是一些适合使用camel-redis组件的用例：

幂等存储库

幂等一词在数学中用于描述一个函数，如果将其应用到其自身上会产生相同的结果。在“消息传递”中，无论是一次还是多次接收，此概念都将转换为具有相同效果的消息。在Camel中，此模式是使用IdempotentConsumer类实现的，该类使用Expression计算给定消息交换的唯一消息ID字符串。然后可以在IdempotentRepository中查找此ID，以查看是否以前已看到它；如果消息已被消耗；如果不是，则处理消息并将ID添加到存储库。 RedisIdempotentRepository使用集合结构来存储和检查现有ID。

<bean id="idempotentRepository" class="org.apache.camel.component.redis.processor.idempotent.RedisIdempotentRepository">
<constructor-arg value="test-repo"/>
</bean><route>
<from uri="direct:start"/>
<idempotentConsumer messageIdRepositoryRef="idempotentRepository">
<simple>${in.body.id}</simple>
<to uri="mock:result"/>
</idempotentConsumer>
</route>

快取

Redis的主要用途之一是作为LRU缓存。它可以将内存中的数据存储为Memcached，也可以进行调整以将持久的刷新数据存储到日志文件中，如果节点重新启动则可以重播。

volatile-lru删除具有过期集的密钥中的一个，以尝试删除最近未使用的密钥。
volatile-ttl删除具有过期集的密钥，并尝试删除剩余生存时间短的密钥。
volatile-random从具有到期集的密钥中删除一个随机密钥。
allkeys-lru与volatile-lru类似，但是将删除每种密钥，包括普通密钥或具有过期集的密钥。
allkeys-random和volatile-random一样，但是会删除各种键，包括普通键和具有过期集的键。

在为Redis服务器配置正确的策略并使其运行后，您需要执行的操作是SET和GET：

<?xml version="1.0" encoding="UTF-8"?>
<route>
<from uri="direct:start"/>
<setHeader headerName="CamelRedis.Command">
<constant>SET</constant>
</setHeader>
<setHeader headerName="CamelRedis.Key">
<constant>keyOne</constant>
</setHeader>
<setHeader headerName="CamelRedis.Value">
<constant>valueOne</constant>
</setHeader>
<to uri="redis://localhost:6379"/>
</route>

与Redis的Interap发布/订阅

骆驼具有在路线之间进行交互的各种组件：

direct ：在同一骆驼上下文中提供直接，同步的调用。
seda ：异步行为，再次在同一骆驼上下文中在BlockingQueue上交换消息。
vm ：类似于seda的异步行为，但只要它们在同一个JVM中，它还支持跨CamelContext的通信。复杂的应用程序通常包括在单独的计算机上运行的多个独立的Camel实例。对于这种情况，Camel提供了jms，activemq以及AWS SNS与SQS的组合，用于实例之间的消息传递。 Redis为发布/订阅消息范式提供了一个更简单的解决方案。订阅者通过指定频道名称或使用模式匹配从多个频道接收消息来订阅一个或多个频道。然后，发布者将消息发布到频道，然后Redis确保它到达所有匹配的订阅者。

<?xml version="1.0" encoding="UTF-8"?>
<camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">
<route startupOrder="1">
<from uri="redis://localhost:6379?command=SUBSCRIBE&channels=testChannel"/>
<to uri="mock:result"/>
</route><route startupOrder="2">
<from uri="direct:start"/>
<setHeader headerName="CamelRedis.Command">
<constant>PUBLISH</constant>
</setHeader>
<setHeader headerName="CamelRedis.CHANNEL">
<constant>testChannel</constant>
</setHeader>
<setHeader headerName="CamelRedis.MESSAGE">
<constant>Test Message</constant>
</setHeader>
<to uri="redis://localhost:6379"/>
</route>
</camelContext>