- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我正在为我们的一个应用程序开发消息接口(interface)。该应用程序是一种服务,旨在接受“作业”,进行一些处理并返回结果(实际上是以文件的形式)。
这个想法是使用 RabbitMQ 作为消息传递基础设施和 Spring AMQP 来处理协议(protocol)特定的细节。
我不想将我的代码与 Spring AMQP 紧密耦合,所以我想使用 Spring Integration 来隐藏消息传递 API。所以基本上我想要这个:
消息发送到 RabbitMQ ====> Spring AMQP ====> Spring Integration ====> MyService ====> 一路回复 RabbitMQ
我正在尝试制定将其连接在一起所需的 XML 配置,但我遇到了多层次抽象和不同术语的问题。事实证明,在 Spring AMQP/RabbitMQ 之上找到一个演示 Spring Integration 的工作示例非常困难,尽管这种设置对我来说感觉非常“最佳实践”。
1)所以..那里有一些聪明的灵魂可以快速看看这个,也许会把我推向正确的方向?我需要什么,不需要什么? :-)
2) 理想情况下,队列应该是多线程的,这意味着 taskExecutor 应该将多条消息传递给我的 jobService 以进行并行处理。需要什么配置?
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:util="http://www.springframework.org/schema/util"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:rabbit="http://www.springframework.org/schema/rabbit"
xmlns:int="http://www.springframework.org/schema/integration"
xmlns:int-amqp="http://www.springframework.org/schema/integration/amqp"
xmlns:int-stream="http://www.springframework.org/schema/integration/stream"
xsi:schemaLocation="
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd
http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.0.xsd
http://www.springframework.org/schema/rabbit http://www.springframework.org/schema/rabbit/spring-rabbit.xsd
http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration.xsd
http://www.springframework.org/schema/integration/amqp http://www.springframework.org/schema/integration/amqp/spring-integration-amqp.xsd
http://www.springframework.org/schema/integration/stream http://www.springframework.org/schema/integration/stream/spring-integration-stream.xsd
">
<context:component-scan base-package="com.myprogram.etc" />
<!-- Messaging infrastructure: RabbitMQ -->
<bean id="connectionFactory" class="org.springframework.amqp.rabbit.connection.CachingConnectionFactory">
<constructor-arg value="${ei.messaging.amqp.servername}" />
<property name="username" value="${ei.messaging.amqp.username}" />
<property name="password" value="${ei.messaging.amqp.password}" />
</bean>
<rabbit:connection-factory id="connectionFactory" />
<rabbit:admin connection-factory="connectionFactory"/>
<!-- From RabbitMQ -->
<int-amqp:inbound-gateway request-channel="fromAMQP" reply-channel="toAMQP" queue-names="our-product-name-queue" connection-factory="connectionFactory"/>
<!-- Spring Integration configuration -->
<int:channel id="fromAMQP">
<!-- Is this necessary?? -->
<int:queue/>
</int:channel>
<!-- JobService is a @Service with a @ServiceActivator annotation -->
<int:service-activator input-channel="fromAMQP" ref="jobService"/>
</beans>
最佳答案
我怀疑我和你一样对 spring-integration 和 spring-integration-amqp 很陌生,但我确实得到了部分基于一个示例项目的工作。
对于 rabbitmq 基础设施,我有以下内容:
<rabbit:connection-factory id="rabbitConnectionFactory"/>
<rabbit:template id="amqpTemplate" connection-factory="rabbitConnectionFactory"/>
<rabbit:admin connection-factory="rabbitConnectionFactory"/>
<!-- some attributes seemed to be ok with queue name, others required id
-- so I used both with the same value -->
<rabbit:queue id='test.queue' name='test.queue'/>
<rabbit:direct-exchange name:"my.exchange">
<rabbit:bindings>
<rabbit:binding queue="test.queue" key="test.binding"/>
</rabbit:bindings>
</rabbit:direct-exchange>
<!-- This is just an interface definition, no implementation required
-- spring will generate an implementation which puts a message on the channel -->
<int:gateway id="backgroundService",
service-interface="com.company.BackgroundService"
default-request-channel="toRabbit"
<int:channel id:"toRabbit"/>
<!-- used amqpTemplate to send messages on toRabbit channel to rabbitmq -->
<int-amqp:outbound-channel-adapter channel:"toRabbit"
amqp-template="amqpTemplate"
exchange-name="my.exchange"
routing-key="test.binding"/>
<int:service-activator input-channel="fromRabbit"
ref="testService"
method="serviceMethod"/>
// from rabbitmq to local channel
<int-amqp:inbound-channel-adapter channel="fromRabbit"
queue-names="test.queue"
connection-factory="rabbitConnectionFactory"/>
<int:channel id="fromRabbit"/>
package com.company
import org.springframework.integration.annotation.Gateway
public interface BackgroundService {
//@Gateway(requestChannel="someOtherMessageChannel")
public String sayHello(String toWho)
}
package com.company;
class TestService {
public void serviceMethod(String param) {
log.info("serviceMethod received: " + param");
//return "hello, " + param;
}
}
关于rabbitmq - 使用 Spring 与 RabbitMQ 集成,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/10351948/
Windows 集成 (NTLM) 身份验证和 Windows 集成 (Kerberos) 之间有什么区别? 如何在IIS6中实现这些 w.r.t. MSDN 最佳答案 Kerberos 和 NTLM
Keycloak是一个用 Java 编写的开源身份验证和身份管理解决方案。它提供了一个nodejs适配器,使用它我能够成功地与express集成。这是有效的路由文件: 'use strict'
这是我关于 Bamboo 的第二个问题 ( My First One )。阅读建议信息后我的理解是,我需要一个构建工具,例如 nAnt 或 MSbuild 来编写一个获取源代码并构建它的脚本(我正在开
可用于将第三方应用程序与 jira 4.3 集成的身份验证方案有哪些?显然,从客户那里获取用户名和密码听起来很荒谬。另外,我知道 oauth 身份验证仅适用于版本 5。请告诉我。谢谢。 附注。我不是在
我有一个使用 DDS 的旧版 C++ 应用程序用于异步通信/消息传递。我需要将此应用程序集成到使用 JMS 进行消息传递的 JavaEE 环境中。除了构建独立的 JMS/DDS 桥接模块之外,我还有其
我正在尝试使用 Whatsapp 发送测试消息,但收到此错误消息: "error":{"code":27,"description":"Recipient not available on chann
我想将 photologue 与我的 Django 应用程序集成,并使用它在车辆库存中显示照片......有点像 Boost Motor Group Inc. 提供的内容。我已经集成了该应用程序,所以
我目前正在尝试弄清楚如何与 fujitsu scansnap 扫描仪集成,但没有从 fujitsu 找到有关 fujitsu scansnap 管理器如何调用您的应用程序并将文件发送到您的应用程序的详
在我的项目中,我使用了 9 个(九个)int-ip:udp-inbound-channel-adapter 和一个 jms:inbound-channel-adapter。 Jms 适配器从服务器接收
在我们当前的原型(prototype)中,大多数标准 HTML 控件都被小程序取代,最重要的是表单提交由小程序触发。 有没有一种方法可以像 一样在服务器端调用关联的操作 ? 本文Applet and
是否可以使用 twilio 号码从 whatsapp 发送/接收短信?有人用whatsapp试过twilio吗?我问过客服,如果可能的话,他说,不确定,但很多人都问过这个问题。 最佳答案 万一其他人来
我们办公室中几乎不存在版本控制,这显然导致了很多麻烦。我们想使用SVN和Notepad++进行设置...任何人都对如何实现此目标有任何想法?我已经开始研究并浏览了这个网站: http://www.sw
曾经有提供这种集成的 spring-modules 项目;但是,该项目现已弃用。现在有没有人继续支持这种集成?谢谢。 最佳答案 工作正在进行中。 http://blog.athico.com/sear
我的理解是,根据 http://wiki.dbpedia.org/Datasets,DBpedia 从 YAGO 获取类层次结构,而不是实体。 .但是,类似 http://dbpedia.org/cl
任何人都可以帮助我如何将 OpenCMS 与 Java Spring Web 应用程序集成。已经用谷歌搜索并浏览了很多网站但没有用。所以,请帮助我。 最佳答案 我认为将 SpringMVC 与 Ope
我正在尝试使用新的 migs getaway (MPGS) 我遵循了下一个 url 中的代码 https://ap-gateway.mastercard.com/api/documentation/i
关闭。这个问题不满足Stack Overflow guidelines .它目前不接受答案。 想改善这个问题吗?更新问题,使其成为 on-topic对于堆栈溢出。 4年前关闭。 Improve thi
我有一个 cmake 项目。我想轻松完成以下操作 搜索光标下任何变量、函数等的声明、定义和引用,这些可能在外部头文件中声明,其路径是在CMakeLists.txt中使用INCLUDE_DIRECTOR
有人能给我指点一下 Objective-C(或 c/c++)库的方向,或者教通过 FTP 上传或下载的教程(Objective-C)吗?最好能展示如何将文件下载到临时目录,然后稍后上传?我不介意针对
集成()给出了非常错误的答案: integrate(function (x) dnorm(x, -5, 0.07), -Inf, Inf, subdivisions = 10000L) # 2.127
我是一名优秀的程序员,十分优秀!