2022-05-04 00:28:39.286 WARN 23280 --- [essageThread_20] a.r.s.s.DefaultRocketMQListenerContainer : consume message failed. messageExt:MessageExt [queueId=0, storeSize=429, queueOffset=211, sysFlag=0, bornTimestamp=1651594740002, bornHost=/192.168.117.1:57495, storeTimestamp=1651595147217, storeHost=/192.168.117.1:10911, msgId=C0A8750100002A9F0000000000083CBD, commitLogOffset=539837, bodyCRC=1244179410, reconsumeTimes=4, preparedTransactionOffset=0, toString()=Message{topic='ly-seckill-topic', flag=0, properties={CONSUME_START_TIME=1651595316354, MIN_OFFSET=0, REAL_TOPIC=%RETRY%SECKILL_BEGIN_CONSUMER, ORIGIN_MESSAGE_ID=C0A8750100002A9F0000000000072BE7, RETRY_TOPIC=ly-seckill-topic, MAX_OFFSET=231, id=ed342c57-750e-4e11-bcf2-5afdfce4435a, UNIQ_KEY=C0A8010448C418B4AAC20F847922000F, WAIT=false, contentType=text/plain, DELAY=6, TAGS=seckill-begin, timestamp=1651594740002, REAL_QID=0}, body=[50, 48, 50, 50, 45, 48, 53, 45, 48, 52], transactionId='null'}]
feign.FeignException: status 400 reading SeckillClient#findSecKillPolicyListByDate(String)
at feign.FeignException.errorStatus(FeignException.java:78) ~[feign-core-10.1.0.jar:na]
at feign.codec.ErrorDecoder$Default.decode(ErrorDecoder.java:93) ~[feign-core-10.1.0.jar:na]
at feign.SynchronousMethodHandler.executeAndDecode(SynchronousMethodHandler.java:149) ~[feign-core-10.1.0.jar:na]
at feign.SynchronousMethodHandler.invoke(SynchronousMethodHandler.java:78) ~[feign-core-10.1.0.jar:na]
at feign.ReflectiveFeign$FeignInvocationHandler.invoke(ReflectiveFeign.java:103) ~[feign-core-10.1.0.jar:na]
at com.sun.proxy.$Proxy87.findSecKillPolicyListByDate(Unknown Source) ~[na:na]
at com.leyou.page.service.PageService.createSecKillListAndDetailHtml(PageService.java:122) ~[classes/:na]
at com.leyou.page.listener.GenerateSecKillPageListener.onMessage(GenerateSecKillPageListener.java:35) ~[classes/:na]
at com.leyou.page.listener.GenerateSecKillPageListener.onMessage(GenerateSecKillPageListener.java:18) ~[classes/:na]
at org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer$DefaultMessageListenerConcurrently.consumeMessage(DefaultRocketMQListenerContainer.java:308) ~[rocketmq-spring-boot-2.0.2.jar:2.0.2]
at org.apache.rocketmq.client.impl.consumer.ConsumeMessageConcurrentlyService$ConsumeRequest.run(ConsumeMessageConcurrentlyService.java:417) [rocketmq-client-4.4.0.jar:4.4.0]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_172]
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) [na:1.8.0_172]
at java.util.concurrent.FutureTask.run(FutureTask.java) [na:1.8.0_172]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [na:1.8.0_172]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [na:1.8.0_172]
at java.lang.Thread.run(Thread.java:748) [na:1.8.0_172]
上一次启动没有问题,刚才重启后就变成这样了?这是什么原因?
status 400?
你的客户端和服务端对应的接口参数不一致吧