服务提供端:

@RestController
public class RabbitmqProducerController {
    
    @Autowired
    private RabbitTemplate rabbitTemplate;
    
    @PostMapping("/send")
    public String sendMessage(@RequestBody String message) {
        rabbitTemplate.convertAndSend("exchange-name", "routing-key", message);
        return "Message sent to RabbitMQ successfully!";
    }
}

服务消费端:

@Service
public class RabbitmqConsumerService {

    @RabbitListener(queues = "queue-name")
    public void consumeMessage(String message) {
        System.out.println("Received message from RabbitMQ: " + message);
    }
}

注:以上代码只是示例,具体实现需要根据实际情况进行调整。

用Java代码把rabbitmq整合到springcloud中 写出服务的提供端和消费端

原文地址: https://www.cveoy.top/t/topic/bVYm 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录