RabbitMQ初体验之彤医通项目应用场景

https://www.jianshu.com/p/e9736212adc7
访问localhost:15671。账号密码均为guest

预约挂号后减少号源。
商品处理订单后减少库存。
短信发送。

异步处理
流量削峰
日志处理
应用解耦

1. 引入maven依赖

	

        
            org.springframework.boot
            spring-boot-starter-actuator
        
        
            org.springframework.cloud
            spring-cloud-starter-bus-amqp
        
        
            com.alibaba
            fastjson
        
    

2. 创建service编写发送sendMessage方法

package com.lwt.common.rabbit.service;

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class RabbitService {
    @Autowired
    private RabbitTemplate rabbitTemplate;

    
    public boolean sendMessage(String exchange,String routingKey,Object message){
        rabbitTemplate.convertAndSend(exchange,routingKey,message);
        return true;
    }
}

3. 创建@Configuration配置类，创建默认的json字符串转换器

package com.lwt.common.rabbit.config;

import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class MQConfig {
    @Bean
    public MessageConverter messageConverter(){
        return new Jackson2JsonMessageConverter(); // 默认json字符串转换器
    }
}