SpringBoot整合RabbitMQ

• 首先你需要安装RabbitMQ，安装教程可百度查下资料即可，不做赘述，敬请谅解
  
• 启动RabbitMQ
  
• RabbitMQ可以算是一个异步消息队列，在实际的开发项目中，一般是以工具模块的方式创建，像一些SpringBoot工程所需要的基本依赖都是会有的
  
• 说明：关键在于谁是消息的生产者、消息的消费者；另外还需要注意生产消费之间消息类型的传递
  
• 创建一个maven工程，导入RabbitMQ相关的依赖
  

1. <dependencies>
2.     <dependency>
3.         <groupId>org.springframework.boot</groupId>
4.         <artifactId>spring-boot-starter-actuator</artifactId>
5.     </dependency>
6.     <dependency>
7.         <groupId>org.springframework.cloud</groupId>
8.         <artifactId>spring-cloud-starter-bus-amqp</artifactId>
9.     </dependency>
10.     <dependency>
11.         <groupId>com.alibaba</groupId>
12.         <artifactId>fastjson</artifactId>
13.     </dependency>
14. </dependencies>

复制代码

• 编写一个简单的配置类，配置消息转换器
  

1. import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
2. import org.springframework.amqp.support.converter.MessageConverter;
3. import org.springframework.context.annotation.Bean;
4. import org.springframework.context.annotation.Configuration;
5. @Configuration
6. public class RabbitConfig {
7.     /**
8.      * 配置消息转换器，默认是字符串转换器
9.      * @return MessageConverter
10.      */
11.     @Bean
12.     public MessageConverter messageConverter() {
13.         return new Jackson2JsonMessageConverter();
14.     }
15. }

复制代码

• 编写一个常量类
  

1. public class RabbitConstant {
2.     /** 短信发送 */
3.     public static final String EXCHANGE_DIRECT_MSM = "exchange.direct.msm";
4.     public static final String ROUTING_MSM = "msm";
5.     public static final String QUEUE_MSM = "queue.msm";
6. }

复制代码

• 在编写一个简单的生产消息的封装类
  

1. import org.springframework.amqp.rabbit.core.RabbitTemplate;
2. import org.springframework.beans.factory.annotation.Autowired;
3. import org.springframework.stereotype.Service;
5. @Service
6. public class RabbitService {
7.     @Autowired
8.     private RabbitTemplate rabbitTemplate;
10.     /**
11.      * 生产消息到RabbitMQ中
12.      * @param exchange 交换机
13.      * @param routingKey 路由Key
14.      * @param message 任意类型的消息
15.      * @return boolean
16.      */
17.     public boolean sendMessage(String exchange, String routingKey, Object message) {
18.         rabbitTemplate.convertAndSend(exchange, routingKey, message);
19.         return true;
20.     }
21. }

复制代码

• 虽说一个简单的整合就这么几步，主要还是实操示例，这里以下单成功，通过手机发送消息通知为示例
  
• 还需要在创建一个工程（接触过微服务项目，很容易了解不同模块有需要放在不同的服务下，便于管理）
  
• 既然涉及手机短信发消息，可参考SpringBoot整合阿里云短信服务
  
• 在手机短信服务中导入消息队列模块，所以在原有的基础上添加配置文件
  

1. #rabbitmq地址
2. spring.rabbitmq.host=your_ip
3. spring.rabbitmq.port=5672
4. spring.rabbitmq.username=your_username
5. spring.rabbitmq.password=your_password

复制代码

• 封装手机发送消息，和手机发送验证码业务代码相似。
  

1. @Service
2. public class MsmServiceImpl implements MsmService {
3.     @Override
4.     public boolean orderConfirm(Map<String, Object> param) {
5.         if (StringUtils.isEmpty(param.get("phone"))) return false;
6.         // 整合阿里云短信服务，设置相关参数
7.         DefaultProfile profile = DefaultProfile.
8.                 getProfile(ConstantPropertiesUtils.REGION_ID,
9.                         ConstantPropertiesUtils.ACCESS_KEY,
10.                         ConstantPropertiesUtils.ACCESS_SECRET);
11.         IAcsClient client = new DefaultAcsClient(profile);
12.         
13.         SendSmsRequest request = new SendSmsRequest();
14.         request.setPhoneNumbers(param.get("phone"));//接收短信的手机号码
15.         request.setSignName(ConstantPropertiesUtils.SIGN_NAME);//短信签名名称
16.         request.setTemplateCode(ConstantPropertiesUtils.TEMPLATE_CODE);//短信模板CODE
17.         
18.         // 使用json格式   {"msg":"下单成功"}
19.         request.setTemplateParam(JSONObject.toJSONString(param));//短信模板变量对应的实际值
20.         
21.         try {
22.             SendSmsResponse response = client.getAcsResponse(request);
23.             // 发送短信，尽量打印出来是否发送成功
24.             new Gson().toJson(response);
25.         } catch (ClientException e) {
26.             e.printStackTrace();
27.             return false;
28.         }
29.         return true;
30.     }
31. }

复制代码

• 在当前短信服务模块中创建一个RabbitMQ消息监听（可以理解为消息的消费者）
  

1. import com.rabbitmq.client.Channel;
2. import com.xsha.msg.service.MsgService;
3. import com.xsha.rabbit.constant.RabbitConstant;
4. import org.springframework.amqp.core.Message;
5. import org.springframework.amqp.rabbit.annotation.Exchange;
6. import org.springframework.amqp.rabbit.annotation.Queue;
7. import org.springframework.amqp.rabbit.annotation.QueueBinding;
8. import org.springframework.amqp.rabbit.annotation.RabbitListener;
9. import org.springframework.beans.factory.annotation.Autowired;
10. import org.springframework.stereotype.Component;
12. @Component
13. public class MsgReceive {
14.     @Autowired
15.     private MsgService msgService;
17.     /** 消息监听：监听到RabbitMQ中有消息就消费，并通过手机发送短信通知 */
18.     @RabbitListener(bindings = @QueueBinding(
19.             value = @Queue(value = RabbitConstant.QUEUE_MSM, durable = "true"),
20.             exchange = @Exchange(value = RabbitConstant.EXCHANGE_DIRECT_MSM),
21.             key = {RabbitConstant.ROUTING_MSM}
22.     ))
23.     public void orderConfirm(Map<String, Object> param, Message message, Channel channel) {
24.         msgService.orderConfirm(param);
25.     }
26. }

复制代码

• 由于涉及订单，所以订单是一个独立的服务模块，即导入消息队列模块，在原有的基础上添加配置文件
  

1. #rabbitmq地址
2. spring.rabbitmq.host=your_ip
3. spring.rabbitmq.port=5672
4. spring.rabbitmq.username=your_username
5. spring.rabbitmq.password=your_password

复制代码

• 在实际开发中，用户下单并不会立即通知用户下单成功，而是通过异步的方式稍后告知用户下单成功。简单示例，不可钻牛角尖
  
• 生成订单业务（不考虑库存），就是消息的生产者
  

1. @Service
2. public class OrderServiceImpl implements OrderService {
3.     @Autowired
4.     private RabbitService rabbitService;
5.     @Override
6.     public void saveOrder(String userId, String id) {
7.         
8.         UserInfo userInfo = userInfoService.selectById(userId);
9.         String phone = userInfo.getPhone();
10.         // 短信信息封装（根据业务需求，封装重要信息）
11.         Map<String,Object> param = new HashMap<String,Object>(){{
12.             put("title", "消息标题");
13.             put("phone", phone);
14.             put("message", "下单成功");
15.             put("name", userInfo.getName());
16.             put("currentTime", new DateTime().toString("yyyy-MM-dd HH:mm"));
17.         }};
18.         // 生产消息
19.         rabbitService.sendMessage(RabbitConstant.EXCHANGE_DIRECT_MSM, RabbitConstant.ROUTING_MSM, param);
20.     }
21. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！