Task测试发送和接收出错

Question

test测试时接收无法获取信息，只能收到这样的一串信息

不知道是不是发送时就没发送成功，因为后续用controller调用发送函数的时候FastRequest会卡住，test测试时发送显示通过但是也会有如下的报错
代码换成纯贴进来的也不行

Answer 1

神思者 2023-08-01 09:35:33

你的项目没连上nacos吗？报错信息里面怎么写的跟nacos有关？

• 提问者 慕先生9552895 #1

  nacos应该是连上了，这个报错是测试方法和rabbitMQ关闭连接的冲突，上面那张receive收到的是nacos的心跳报文。测试时就是同步发送的sendNewOrderMessage函数测试时会一直运行，然后卡死在那里，我调试了一下，是在走完了函数之后回到
  try (
                  Connection connection = factory.newConnection();
                  Channel channel = connection.createChannel()
          )
  在close的时候会显示应用程序正在运行然后卡住。然后我试着用了一下调用同步发送方法的异步发送，函数倒是不会卡住，但是recieve还是打印不出来发送出去的消息内容。这应该怎么办呀？

• 神思者 回复 提问者 慕先生9552895 #2

  你导入我的子系统项目试一下，先排查一下是不是消息队列的问题。如果我的代码也这样，就要看消息队列到底出了什么问题。如果我的代码没有问题，就得花时间排查代码了

• 提问者 慕先生9552895 回复 神思者 #3

  我把你的子系统导入了，也是一样的效果，消息队列要怎么排查呀，我是按你的视频操作过来的

点开查看后面2条评论