一、MQ服务器设置
1、访问MQ控制台
2、创建用户
创建用户 srbuser，配置管理员权限
3、创建虚拟机
创建虚拟机 /srbhost，在Set permission中为新建的用户分配访问虚拟机 /srbhost 和 / 的权限
二、创建rabbit-mq模块
1、创建模块
srb下创建rabbit-mq模块
2、引入依赖
<dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> </dependency> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> </dependency> </dependencies>
3、创建MQConfig
@Configuration public class MQConfig { @Bean public MessageConverter messageConverter(){ //json字符串转换器 return new Jackson2JsonMessageConverter(); } }
4、创建MQConst
public class MQConst { public static final String EXCHANGE_TOPIC_SMS = "exchange.topic.sms";//交换机 public static final String ROUTING_SMS_ITEM = "routing.sms.item";//路由 public static final String QUEUE_SMS_ITEM = "queue.sms.item";//消息队列 }
5、创建MQService
@Service @Slf4j public class MQService { @Resource private AmqpTemplate amqpTemplate; /** * 发送消息 * @param exchange 交换机 * @param routingKey 路由 * @param message 消息 */ public boolean sendMessage(String exchange, String routingKey, Object message) { log.info("发送消息..........."); amqpTemplate.convertAndSend(exchange, routingKey, message); return true; } }
