100个用户的Spring集成Http amqp rabbitmq并发问题

Question

Im在rabbit mq中使用spring Http集成和amqp，无法对并发用户进行负载测试。。。jmeter和rabbitmq消息计数中显示的消息计数不匹配。。对于30个用户来说效果很好

<int-http:inbound-gateway id="logIngesterGatewayBulk"
        supported-methods="POST" request-channel="logIngesterRestEndpointBulk"
        path="/rest/log/bulk" error-channel="errorChannel" reply-timeout="10" 
        request-payload-type="java.lang.String">
    </int-http:inbound-gateway>

<int:filter input-channel="logIngesterRestEndpointBulk"
        throw-exception-on-rejection="true" method="validate" ref="payloadValidation"
        output-channel="filterChannelbulk">
    </int:filter>

     <int:chain input-channel="filterChannelbulk" output-channel="messageOutputChannel" id="chaining" >
        <int:splitter id="splitter" ref="payloadSplitter" method="splitPayLoad" >

        </int:splitter>
        <int:transformer id="logMessageTransformerbulk" ref="logMessageHeaderTransformer"
            method="transform">
        </int:transformer>
    </int:chain>
    <int:service-activator input-channel="errorChannel"
        ref="responseHandler" method="handleFailedPayLoad">
    </int:service-activator>


<int-amqp:outbound-channel-adapter  
        id="amqpAdapter" channel="messageOutputChannel" amqp-template="amqpTemplate" 
        exchange-name="dhp_exchange" routing-key-expression="headers['routingKey']">

Answer 1

你需要找出为什么存在不匹配。恐怕是调试101。

首先要弄清楚哪些消息丢失了，以及为什么会丢失-调试日志记录会有所帮助，但跟踪日志以跟踪每条消息可能会很繁琐，但信息肯定在那里。确保在日志配置中包含线程名称；调试多线程应用程序时，它是必需的。

您需要确保您的代码是线程安全的-payloadValoration、payloadSplitter、logMessageHeaderTransexbean等-没有共享状态（字段）或同步是正确的。