0

我正在使用 WSO2Esb 和 WSO2DSS 在数据库中插入读数 我的插入工作正常，而我正在从移动端获取请求读取我需要以 200 和唯一值响应，有时在插入后连接失败意味着插入结束但客户端没有得到响应在那种情况下，移动端客户端再次发送请求，所以我的代理再次将此请求发送到数据库。因此，我的数据库为每 2 或 3 个读数存储重复值，这对客户端完全不公平，因为我找到了一个小解决方案使用幂等服务我们可以找到解决方案

<!-- The example shows WSO2 ESB acting as an Idempotent Receiver -->
<definitions xmlns="http://ws.apache.org/ns/synapse">
    <proxy name="IdempotencyReceivingProxy">
        <target>
            <inSequence>
                <log level="full"/>
                <!-- Store all messages in an Jmsmemory message store -->
                <store messageStore="MyStore"/>
            </inSequence>
            <outSequence>
                <send/>
            </outSequence>
        </target>           
    </proxy>
    <!-- Further mediation of messages are done in this sequence -->
    <sequence name="next_seq">
        <send>
            <endpoint>
                <address uri="http://localhost:9000/services/SimpleStockQuoteService"/>
            </endpoint>
        </send>
    </sequence>
    <messageStore name="MyStore"/>
    <!-- Resequencing Processor takes the next sequence number and hand over to "next_seq" and preserve Idempotency -->
    <messageProcessor
            class="org.apache.synapse.message.processors.resequence.ResequencingProcessor"
            name="ResequencingProcessor" messageStore="MyStore"> 
        <parameter name="interval">2000</parameter>
        <!-- Takes the sequence number using Xpath -->
        <parameter name="seqNumXpath" xmlns:m0="http://services.samples" expression="substring-after(//m0:placeOrder/m0:order/m0:symbol,'-')"/>
        <parameter name="nextEsbSequence">next_seq</parameter>
        <parameter name="deleteDuplicateMessages">true</parameter> 
    </messageProcessor>
</definitions>

为此，我点击了此链接http://docs.wso2.org/wiki/display/IntegrationPatterns/Idempotent+Receiver 它是否适合我的要求

4

2 回答 2

0

我认为这不符合您的要求。重排序处理器所做的是，根据seqNumXpath属性中的数字对消息进行排序。所以消息应该包含一个数字，并且您应该使用 xpath 表达式获取这个数字。当deleteDuplicateMessages参数设置为true时，它将删除与从seqNumXpath参数中获得的具有相同序列号的重复消息。

在您的情况下，您可以使用存储和转发方案来防止客户端必须发送多个请求。在您的代理服务中将属性设置FORCE_SC_ACCEPTED为 true 以始终向客户端返回 202 响应。然后消息将存储在 msg 存储中，并将使用消息处理器转发。

http://docs.wso2.org/wiki/display/ESB470/Store+and+Forward+Using+JMS+Message+Stores http://wso2.com/library/articles/2011/10/implementing-store-forward -消息模式-wso2esb-part-1

于 2013-08-13T09:48:09.870 回答
0

Apache Camel 有一个幂等消费者http://camel.apache.org/idempotent-consumer.html，它使用一个 IdempotentRepository 来查看它之前是否见过；如果有，则使用该消息；如果不是，则处理消息并将 ID 添加到存储库。查看http://camel.apache.org/sql-component.html特别是“使用基于 JDBC 的幂等存储库”部分。这正是我们所需要的。因为在我们的例子中，重复消息甚至可以在几天后到达（离线客户端，例如移动设备），但每条消息都有一个 UUID 字段，可用于检测重复消息。

wso2esb 中是否有类似的实现？如果是，任何指向文档的指针？如果没有，我们在使用 wso2esb 时获得这种行为的替代方法是什么？

于 2013-08-20T12:47:33.720 回答