Spring Boot和RabbitMQ实现发送短信任务投递和消费的简单示例

秒速五厘米 2023-09-26 22:09 98阅读 0赞

Spring Boot和RabbitMQ实现发送短信任务投递和消费的简单示例：

首先，需要在Spring Boot项目中添加RabbitMQ的依赖：

xml

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>

接着，定义一个发送短信的任务类：

java

public class SmsTask {
        
        private String phoneNumber;
        private String content;
    
        // 构造函数和getter/setter方法
    
        @Override
        public String toString() {
        
            return "SmsTask{" +
                    "phoneNumber='" + phoneNumber + '\'' +
                    ", content='" + content + '\'' +
                    '}';
        }
    }

然后，定义一个发送短信任务的生产者：

java

@Component
    public class SmsTaskProducer {
        
        private static final String EXCHANGE_NAME = "sms_exchange";
        private static final String ROUTING_KEY = "sms_task";
    
        @Autowired
        private RabbitTemplate rabbitTemplate;
    
        public void sendSmsTask(SmsTask smsTask) {
        
            rabbitTemplate.convertAndSend(EXCHANGE_NAME, ROUTING_KEY, smsTask);
            System.out.println("Sent SMS task: " + smsTask);
        }
    }

在发送短信任务的生产者中，使用RabbitTemplate将短信任务对象转换为消息并发送到名为"sms\_exchange"的交换机上，使用"sms\_task"作为路由键。然后在控制台输出发送的短信任务对象。

接下来，定义一个消费者来处理发送短信任务：

java

@Component
    public class SmsTaskConsumer {
        
        private static final String EXCHANGE_NAME = "sms_exchange";
        private static final String QUEUE_NAME = "sms_queue";
        private static final String ROUTING_KEY = "sms_task";
    
        @Autowired
        private SmsService smsService;
    
        @RabbitListener(bindings = @QueueBinding(
                value = @Queue(value = QUEUE_NAME, durable = "true"),
                exchange = @Exchange(value = EXCHANGE_NAME, durable = "true"),
                key = ROUTING_KEY)
        )
        public void handleSmsTask(SmsTask smsTask) {
        
            System.out.println("Received SMS task: " + smsTask);
            smsService.sendSms(smsTask.getPhoneNumber(), smsTask.getContent());
        }
    }

在消费者中，使用@RabbitListener注解来监听名为"sms\_queue"的队列，同时绑定到名为"sms\_exchange"的交换机上，使用"sms\_task"作为路由键。然后，在接收到短信任务时，将任务发送给SmsService来发送短信。

最后，可以在Controller中调用SmsTaskProducer来发送短信任务：

java

@RestController
    public class SmsController {
        
        @Autowired
        private SmsTaskProducer smsTaskProducer;
    
        @PostMapping("/sendSmsTask")
        public void sendSmsTask(@RequestParam String phoneNumber, @RequestParam String content) {
        
            SmsTask smsTask = new SmsTask(phoneNumber, content);
            smsTaskProducer.sendSmsTask(smsTask);
        }
    }

这样，当通过/sendSmsTask接口发送短信任务时，生产者将任务发送到RabbitMQ，消费者将从队列中获取任务并发送