Spring bus与RabbitMQ

1、本地安装RabbitMQ

a、安装erlang(RabbitMQ运行环境)

b、安装RabbitMQ

c、cmd 进入RabbitMQ的sbin，键入rabbitmq-plugins enable rabbitmq_management

d、浏览器键入http://localhost:15672  用户名：guest 密码：guest（默认）

2、项目添加 spring-cloud-bus 依赖

a、创建者

@Controller
@RequestMapping(path="/bussend")
public class BusController {

    @Autowired
    private AmqpTemplate amqpTemplate;
    
    @GetMapping(path="/sendmessage")
    public @ResponseBody String sendMessageToMq(@RequestParam String message){
        System.out.println("start send");
        amqpTemplate.convertAndSend("helloserol", message);
        return message + " send";
    }

}

b、接受者，此处用监听器

@Component
@EnableScheduling
public class BusMqReciever {
    
    /**
     * 首先创建 queue 名称helloserol，或者初始化程序的时候添加
     * @param orderXML
     */
    @RabbitHandler
    @RabbitListener(queues = "helloserol", containerFactory = "rabbitListenerContainerFactory")
    public void process(@Payload String orderXML) {
        System.out.println("receive message ============" + orderXML);
    }
}

c、首先创建 queue 名称helloserol，或者初始化程序的时候添加

d、启动服务，访问 http://localhost:8080/bussend/sendmessage?message=serolMessage222

e、查看控制台