之前项目里使用过rabbitmq,但是没有系统的总结过,今天就专门总结一下rabbitmq的好处和意义,并且附上一个小例子。展示一下rabbitMq的简单应用
MQ(Message Queue)消息队列。队列是一种基础的数据结构。具有先进先出的特性,用队列来实现消息的传递。生产者生产消息,将消息放入队列。消费者从队列取出消息(服务端推送,或者订阅),进行消费。
MQ有三大优点:
这里我们就实现简单的在springCloud项目中使用rabbitMq的例子。
org.springframework.boot spring-boot-starter-amqp
添加rabbitMq配置
编写消息生产者
编写消息消费者
测试
提供一个test接口用来测试
@Autowiredprivate SpringMqProduceTest springMqProduceTest;@GetMapping("testMq/{message}")public String testMq(@PathVariable("message") String message){springMqProduceTest.testSimpleQueue("testMq",message);return "已发送:"+message;}
执行效果:
调用接口
控制台输出
通过总结rabbitMQ的使用,体会MQ消息队列的作用,通过这个队列可以让我们代码耦合度更小。理解MQ的好处才能在以后的工作中更好的使用这门技术。