Mule ESB连接到RabbitMQ

Question

我是Mule ESB 3.6（Anypoint Studio Community Edition 5.2）的新手。我正在研究mule和rabbitmq之间的沟通。 rabbitmq支持AMQP协议，mule具有AMQP连接器，但可以与3.1版本配合使用。现在的问题是如何连接，如果不是从骡子的AMQP？

我已经尝试旧版本的AMQP连接器与新的Mule版本，但它不作为名称空间错误即将到来。请帮忙。 Maven我不确定它是如何工作的，因为提供的用户指南非常少。 JMS将在这种情况下工作，那么如何？

Answer 1

我很幸运地找到了AMQP连接器的奥秘。好吧，我看不到任何在骡文档中提到的安装相同的地方。嗯，我正在使用 Anypoint工作室 - 用于工装骡子ESB 版本：5.1.0

如果你坚持要找到如何安装AMQP连接器那么他就是简单的方法 去帮助=>安装新软件=>选择所有可用站点=>选择社区类别=>在社区下，您会发现AMQP传输连接器=> 选择它，选择是，然后接受许可证。 这将在您的Studio上安装AMQP传输连接器。您可以在设计应用程序流程时轻松使用。

为了帮助更多的关于AMQP连接器使用的配置以下参考

<?xml version="1.0" encoding="UTF-8"?> <mule xmlns:amqp="http://www.mulesoft.org/schema/mule/amqp" xmlns:http="http://www.mulesoft.org/schema/mule/http" xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation" 
xmlns:spring="http://www.springframework.org/schema/beans" version="EE-3.6.1" 
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-current.xsd http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd http://www.mulesoft.org/schema/mule/amqp http://www.mulesoft.org/schema/mule/amqp/current/mule-amqp.xsd"> <http:listener-config name="HTTP_Listener_Configuration" host="0.0.0.0" port="8082" doc:name="HTTP Listener Configuration"/> <amqp:connector name="AMQP_0_9_Connector" validateConnections="true" virtualHost="abctest" doc:name="AMQP-0-9 Connector" username="guest" password="guest" /> <flow name="mulerabbitmqFlow"> <http:listener config-ref="HTTP_Listener_Configuration" path="/myvishaltest/*" allowedMethods="GET" doc:name="HTTP"/> <set-payload value="Test is Vishal" doc:name="Set Payload"/> <amqp:outbound-endpoint responseTimeout="10000" exchange-pattern="request-response" doc:name="AMQP-0-9" connector-ref="AMQP_0_9_Connector" exchangeName="vishalbhandare" exchangeType="direct" exchangeDurable="true" queueName="task_queue" queueDurable="true" queueExclusive="true" routingKey="vishal1" /> </flow> </mule> 

Answer 2

对于所有的连接器，例子和模板把头伸出来：

https://www.mulesoft.com/exchange

或者更简单，打开从Exchange Anypoint工作室

https://docs.mulesoft.com/mule-fundamentals/v/3.7/anypoint-exchange

AMQP可以在这里找到：

https://www.mulesoft.com/exchange/#!/amqp-integration-connector

通过在工作室的更新站点也有可能，但交换给你概述，完整的图书馆和说明。