-1

我正在开发 Spring Boot + Axon Framework 开发演示在这里解释：https ://www.youtube.com/watch?v=Jp-rW-XOYzA&list=PLgGXSWYM2FpOa_FTla-x5Wd10dpmgrRC4&index=54 。在这个例子中，我只使用最新的依赖项，其他的东西我保持原样。

当我简单地运行代码时，我得到以下错误，并且这里已经有问题了。请指导我。

错误：-

java.lang.Error: Unresolved compilation problem: 
    Exception Exception is not compatible with throws clause in SpringAMQPMessageSource.onMessage(Message, Channel)

    at com.example.DemoComplaintsStatsApplication$1.onMessage(DemoComplaintsStatsApplication.java:54) ~[classes/:na]
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_151]
    at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) ~[na:1.8.0_151]
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) ~[na:1.8.0_151]
    at java.lang.reflect.Method.invoke(Unknown Source) ~[na:1.8.0_151]
    at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:181) ~[spring-messaging-5.0.10.RELEASE.jar:5.0.10.RELEASE]
    at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:114) ~[spring-messaging-5.0.10.RELEASE.jar:5.0.10.RELEASE]
    at org.springframework.amqp.rabbit.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:51) ~[spring-rabbit-2.0.8.RELEASE.jar:2.0.8.RELEASE]
    at org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:188) ~[spring-rabbit-2.0.8.RELEASE.jar:2.0.8.RELEASE]
    at org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.onMessage(MessagingMessageListenerAdapter.java:126) ~[spring-rabbit-2.0.8.RELEASE.jar:2.0.8.RELEASE]
    at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:1414) ~[spring-rabbit-2.0.8.RELEASE.jar:2.0.8.RELEASE]
    at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.actualInvokeListener(AbstractMessageListenerContainer.java:1337) ~[spring-rabbit-2.0.8.RELEASE.jar:2.0.8.RELEASE]
    at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:1324) ~[spring-rabbit-2.0.8.RELEASE.jar:2.0.8.RELEASE]
    at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.executeListener(AbstractMessageListenerContainer.java:1303) ~[spring-rabbit-2.0.8.RELEASE.jar:2.0.8.RELEASE]
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.doReceiveAndExecute(SimpleMessageListenerContainer.java:817) ~[spring-rabbit-2.0.8.RELEASE.jar:2.0.8.RELEASE]
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.receiveAndExecute(SimpleMessageListenerContainer.java:801) ~[spring-rabbit-2.0.8.RELEASE.jar:2.0.8.RELEASE]
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.access$700(SimpleMessageListenerContainer.java:77) ~[spring-rabbit-2.0.8.RELEASE.jar:2.0.8.RELEASE]
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1042) ~[spring-rabbit-2.0.8.RELEASE.jar:2.0.8.RELEASE]
    at java.lang.Thread.run(Unknown Source) [na:1.8.0_151]

DemoComplaintsStatsApplication.java

@SpringBootApplication
public class DemoComplaintsStatsApplication {

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


    @ProcessingGroup("amqpEvents")
    @RestController
    public static class ComplaintStatisticsAPI {

        private ConcurrentMap<String, AtomicLong> staticstics = new ConcurrentHashMap<>();

        @EventHandler
        public void on(ComplaintFileEvent event) {
            staticstics.computeIfAbsent(event.getCompany(), k -> new AtomicLong()).incrementAndGet();
        }

        @GetMapping
        public Map<String, AtomicLong> getStatistics(){
            return staticstics;
        }
    }

    @Bean
    public SpringAMQPMessageSource complaintEvents(Serializer serializer) {
        return new SpringAMQPMessageSource(new DefaultAMQPMessageConverter(serializer)) {

            @RabbitListener(queues = "ComplaintEvents")
            @Override
            public void onMessage(Message message, Channel channel) throws Exception {
                super.onMessage(message, channel);
            }
        };
    }
}

在此处输入图像描述

4

1 回答 1

1

以前的SpringAMQPMessageSource#onMessage(Message, Channel)功能是SpringAMQPMessageSource#onMessage(Message, Channel) throws Exception。然而，从 3.4 开始，情况不再如此。

我看到你也在 Axon Framework 上发布了另一个 StackOverflow，你升级到 3.4 版了吗，对吗？我想指出 3.4不是框架的最新版本，因为那是 4.0。4.0 还包括对Axon Server的非常简单的介绍，这是一个可免费使用的替代品，用于在应用程序之间存储事件和发布消息（如命令、事件和查询）。很快，它完全不需要“Spring AMQP”包，并且应该大大简化你的代码。

尽管如此，为了解决您的问题，删除throws Exception您的覆盖onMessage(Message, Channel)函数应该可以解决问题。

于 2018-11-05T08:33:55.087 回答