问题标签 [wso2mi]

使用 WSO2 在新的 1.0.0 Micro Integrator 上配置的极其简单的代理服务。我使用 Integration Studio 和它的内置集成器来运行和测试功能。然而，由于某种原因，我似乎无法调用我的代理服务。

我可以清楚地看到我的更改在启动时得到了反映，并且出现了以下行：

已从文件部署名为“myprox”的代理服务

此外，它提到端点已配置：

信息 {org.apache.synapse.transport.passthru.core.PassThroughListeningIOReactorManager} - 传递 EI_INTERNAL_HTTP_INBOUND_ENDPOINT 侦听器于 0.0.0.0:9201 开始

自定义代理服务现在缩小到只有一个 LOG 和 RESPOND 中介。无论我使用什么 URL，都会不断弹出相同的错误：

WARN {org.wso2.carbon.inbound.endpoint.internal.http.api.InternalAPIDispatcher} - 未找到发送消息的内部 API

到目前为止，我已经尝试了我能想象到的每一种组合，每一种组合都提供上述信息。我尝试的最新方法是：

http://localhost:9201/services/myprox

我尝试使用和不使用“/services/”子目录。我尝试使用提供的 9164 端口使用和不使用 HTTPS。我还尝试了 8290 和 8253 端口的变体，但无济于事。

当我使用 EI 6.5.0 运行这个 CAR 文件时。我可以在上面提到的 url 上得到结果。

这里发生了什么？

我尝试将 wso2 EI 6.5.0 和 6.6.0 以及 MI 1.0 和 1.1.0 产品安装为 Windows 服务。在检查runConsole.bat自身时抛出大量异常。

如果有人遇到同样的情况，就意味着帮助我摆脱这些例外。

6.6.0 异常

我正在尝试使用Integration-studio 7.0.0实现服务链

例如

服务 1(GET) - getCityById/{cityId}

响应=> {"cityName":"Mumbai"}

服务 2(POST) - getStateByCityName

（它在正文中接受上面的 cityName）

响应=> {"stateName":"马哈拉施特拉邦"}

服务 3(GET) - getCountryByStateName/{stateName}

响应=> {"countryName":"India"}

服务 1 以 {"cityName":"Mumbai"} 形式返回我的响应。

我在有效负载中设置了该响应并调用 service 2。但是服务 2 没有被调用。请让我知道，我应该如何进一步

提前感谢您的帮助！

下面是代码

在 Windows 10 中使用 Integration Studio。

当我尝试使用带有 Validate Mediator 的序列从 REST API 主体验证我的有效负载时，我收到一个错误。错误：

然后我尝试从中验证：

JSON模式：

当我在属性中获取架构时，我看到了架构的字符串。

我最近安装了 wso2 Micro Integrator，但找不到下载 Micro Integrator Dashboard 的链接我在哪里可以找到它？Tks

我在问这两个版本之间的区别，因为我在 7.0 中看不到集成器

我正在尝试在 docker 上运行 WSO2 Micro 集成器。当不使用任何形式的连接器时，这似乎可行。但是我现在需要 amazon sqs 连接器。

使用 Intergration studio 7.0.0 时，我已成功从商店导入连接器并在我的序列之一中使用。它出现在工作室的设计模式中。我像这样使用 SQS 版本：

当我在微积分器上运行包时，我不断收到同样的错误：

[2020-04-02 10:39:36,257] 错误 {org.apache.synapse.deployers.SequenceDeployer} - 来自文件的序列部署：/home/ludo/development/wso2_studio_700/IntegrationStudio/runtime/microesb/tmp/carbonapps/ -1234/1585816776255TestCompositeApplication_1.0.0.car/seq_msg_to_sqs_1.0.0/seq_msg_to_sqs-1.0.0.xml：失败。org.apache.synapse.SynapseException：配置元素引用的未知中介：{ http://ws.apache.org/ns/synapse }amazonsqs

在相同的堆栈跟踪中跟随：

引起：org.apache.synapse.SynapseException：配置元素引用的未知中介：{ http://ws.apache.org/ns/synapse }amazonsqs

根据我能找到的文件，这就是我需要做的。我究竟做错了什么？

仅供参考：当我直接在工作室的微集成器上运行时，以及使用我之前制作的 docker 版本时，我得到了这个结果。

假设我们有一个与多个服务通信的微集成器。

我们希望能够集群其中一个服务，例如，如果我们向一个服务发送两个请求，我们希望每个请求都由服务的不同节点处理，这可能吗？

服务是第三方 REST API，我们想向两个不同的 URL 发送请求。

Integration studio 元素中有 Load-BalanceEndPoint 元素，但不清楚它是如何工作的，或者即使它允许我们解决上述问题。

谁能帮助我们解决这个问题/解释我们应该如何使用提到的端点？

我正在研究 WSO2 MI 和 RabbitMQ 的集成，目标是创建一个具有以下步骤的系统： 1. MI 接收来自客户端的请求并将消息发送到 RabbitMQ 2. RabbitMQ 将消息放入队列并由订阅者客户端进行处理。3. 来自处理服务的响应的消息放入响应 RabbitMQ 队列。4. MI 从该响应队列接收消息并将回复发送给客户端。

wso2官方手册中有以下文档： https ://ei.docs.wso2.com/en/latest/micro-integrator/setup/brokers/configure-with-rabbitMQ/ https://ei.docs.wso2.com /en/latest/micro-integrator/use-cases/examples/jms_examples/rabbitmq-examples/

我认为这就是我所需要的，但目前尚不清楚这些应该如何执行。

假设我在 MI 中配置了到 RabbitMQ 的连接。

我究竟如何使用synapse configurations文档中提到的这些来根据客户端请求向rabbit发送消息或根据来自rabbit的消息回复客户端？

我运行一个非常简单的微集成服务，它只有一个代理服务和一个序列。在这个序列中，传入的 XML 消息被传输到亚马逊 SQS 服务。如果我在集成工作室中内置的实例上运行它，我没有问题。但是，当我将文件打包成 CAR 并将其提供给 docker 实例时，它会启动并立即被请求轰炸吗？也就是说下面的日志接管了，容器不能再手动停止了：

[2020-04-15 12:45:44,585] INFO {org.apache.synapse.transport.passthru.SourceHandler} - 调用 informWriterError ^[[?62;c^[[?62;c[2020-04 -15 12:45:46,589] 错误 {org.apache.synapse.transport.passthru.SourceHandler} - 发生 HttpException org.apache.http.ProtocolException：无效请求行：ÇÃ^ú§ß¡ðO©%åË*29xÙVÀ$ org.apache.http.impl.nio.codecs.AbstractMessageParser.parse(AbstractMessageParser.java:208) 上 org.apache.synapse.transport.http.conn.LoggingNHttpServerConnection$LoggingNHttpMessageParser.parse(LoggingNHttpServerConnection. java:407) 在 org.apache.http.impl.nio.DefaultNHttpServerConnection 的 org.apache.synapse.transport.http.conn.LoggingNHttpServerConnection$LoggingNHttpMessageParser.parse(LoggingNHttpServerConnection.java:381)。org.apache.synapse.transport.http.conn.LoggingNHttpServerConnection.consumeInput(LoggingNHttpServerConnection.java:114) 上的 consumeInput(DefaultNHttpServerConnection.java:265) org.apache.synapse.transport.passthru.ServerIODispatch.onInputReady(ServerIODispatch.java: 82）在 org.apache.synapse.transport.passthru.ServerIODispatch.onInputReady(ServerIODispatch.java:39) 在 org.apache.http.impl.nio.reactor.AbstractIODispatch.inputReady(AbstractIODispatch.java:113) 在 org.apache .http.impl.nio.reactor.BaseIOReactor.readable(BaseIOReactor.java:159) 在 org.apache.http.impl.nio.reactor.AbstractIOReactor.processEvent(AbstractIOReactor.java:338) 在 org.apache.http.impl .nio.reactor.AbstractIOReactor.processEvents(AbstractIOReactor.java:316) 在 org.apache.http.impl.nio.reactor.AbstractIOReactor。在 org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:105) 处执行(AbstractIOReactor.java:277) 在 org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run( AbstractMultiworkerIOReactor.java:586) at java.lang.Thread.run(Thread.java:748) 原因：org.apache.http.ParseException：无效请求行：ÇÃ^þvHÅFmÉ (@ë¸'º¯æ¦VÇÃ^þvHÅFmÉ (@ë¸'º¯æ¦VÇÃ^þvHÅFmÉ (@ë¸'º¯æ¦V

我确保没有可能的外部连接，并且我还发现了描述此问题的某人的旧线程，但他们的解决方案（更改密钥库中的某些内容）不起作用。

另外，我确保在容器中也包含 SQS 证书。

我没有设置连接到容器的连接，因此这也不在等式中。

我在这里想念什么？