spring webFlux修改以下代码public MonoVoid handleSocketChannel socketChannel throws IOException return Monodefer - try Message sendMsg = new MessageDemoTop

public Mono handle(SocketChannel socketChannel) throws IOException { return Mono.fromRunnable(() -> { try { Message sendMsg = new Message("DemoTopic", "DemoTag", socketChannel); DefaultMQProducer defaultMQProducer = SpringUtils.getBean("producer"); // 默认3秒超时 SendResult sendResult = defaultMQProducer.send(sendMsg); } catch (Exception e) { log.info("get responseJsonBody fail."); } }); }