用Java代码把rabbitmq整合到springcloud中 写出服务的提供端和消费端
服务提供端:
@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);
}
}
注:以上代码只是示例,具体实现需要根据实际情况进行调整。
原文地址: https://www.cveoy.top/t/topic/bVYm 著作权归作者所有。请勿转载和采集!