自定义 RabbitMessageListner 抛出包装异常

Question

我有来自自定义库的自定义 MessageListener

import org.springframework.amqp.core.*
public class Subscriber {

    private SimpleMessageListenerContainer simpleMessageListenerContainer;
    private ConnectionFactory rabbitConnectionFactory;

 public final class ScruberMessageListner implements MessageListener {

    @Override
    public void onMessage(Message message) {
        // TODO Auto-generated method stub

    }

    }

}

当我创建订阅者时，自定义库将负责启动容器和管理侦听器以及更多附加功能。

@Configuration
public class BrokerSubscriberConfiguration {
    @Bean
    public Subscriber treatmentEventSubscriber(EventConsumer treatmentEventConsumer) {

        return Subscriber.createInitialisedSubscriber(treatmentEventConsumer, configurations, 
          null, true);
    }

}


@SpringBootApplication
@ComponentScan(basePackages = "com.fin.bc")
public class Application {

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

应用程序加载调出消息侦听器，但在收到消息时抛出异常。

日志消息：

    SimpleConnection@2a76b80a [delegate=amqp://admin@10.15.190.17:5672/hydra.services, localPort= 50786], acknowledgeMode=AUTO local queue size=0
2020-05-08 15:22:16,251 DEBUG org.springframework.amqp.rabbit.listener.BlockingQueueConsumer [SimpleAsyncTaskExecutor-1] Received message: (Body:'[B@4037c15c(byte[4])' MessageProperties [headers={}, contentLength=0, receivedDeliveryMode=NON_PERSISTENT, redelivered=false, receivedExchange=, receivedRoutingKey=Hydra.clone.q2, deliveryTag=1, consumerTag=amq.ctag-50OU2ydRYIghmrPKncVtUw, consumerQueue=Hydra.clone.q2])
2020-05-08 15:22:16,369 WARN org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler [SimpleAsyncTaskExecutor-1] Execution of Rabbit message listener failed.
org.springframework.amqp.rabbit.listener.exception.ListenerExecutionFailedException: Listener threw exception
    at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.wrapToListenerExecutionFailedExceptionIfNeeded(AbstractMessageListenerContainer.java:1651)
    at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:1603)
    at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.actualInvokeListener(AbstractMessageListenerContainer.java:1489)
    at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:1466)
    at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:1461)
    at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.executeListener(AbstractMessageListenerContainer.java:1410)
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.doReceiveAndExecute(SimpleMessageListenerContainer.java:870)
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.receiveAndExecute(SimpleMessageListenerContainer.java:854)
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.access00(SimpleMessageListenerContainer.java:78)
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.mainLoop(SimpleMessageListenerContainer.java:1137)
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1043)
    at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.IllegalArgumentException: Detected a Non-hex character at 1 or 2 position
    at org.springframework.security.crypto.codec.Hex.decode(Hex.java:62)
    at org.springframework.security.crypto.encrypt.HexEncodingTextEncryptor.decrypt(HexEncodingTextEncryptor.java:40)
    at com.discover.cpp.mba.util.Encryptor.decrypt(Encryptor.java:32)
    at com.discover.cpp.mba.Subscriber$SubscriberMessageListener.onMessage(Subscriber.java:521)
    at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:1600)
    ... 10 common frames omitted
2020-05-08 15:22:16,372 DEBUG org.springframework.amqp.rabbit.listener.ContainerUtils [SimpleAsyncTaskExecutor-1] Rejecting messages (requeue=true)

Rabbit Listener 在处理消息时是否使用解码技术？

Answer 1

这与Spring AMQP 框架无关。是您的代码（间接）抛出了异常。

    at org.springframework.security.crypto.encrypt.HexEncodingTextEncryptor.decrypt(HexEncodingTextEncryptor.java:40)
    at com.discover.cpp.mba.util.Encryptor.decrypt(Encryptor.java:32)
    at com.discover.cpp.mba.Subscriber$SubscriberMessageListener.onMessage(Subscriber.java:521)
    at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:1600)

您似乎正在从您的侦听器中调用一些 spring 安全代码。

入站邮件似乎没有预期的格式。

我猜 Hex.decode 需要一个字符 [a-f,0-9] 并且数据包含其他内容。

自定义 RabbitMessageListner 抛出包装异常

Custom RabbitMessageListner Throws Wrapped Exception

spring-amqp

spring-rabbit