消息队列主要在于异步和服务解耦,一般在大型IT应用广泛。怎么给刚入门的同学讲解什么是MQ呢?比喻成工厂和消费中中间的百货商场,这样就很形象了。
比如我在开发实践中,A服务调用了发送邮件和espace消息的服务B,使用异步线程,基于HTTP请求。这个功能符合消息队列的使用场景。但是由于使用该场景小,使用消息队列有学习成本,故没有使用,从侧面说明了消息队列使用的广泛性。
如果两个服务能通信(消息),那么也可以实现RPC,比如发邮件,espace这个过程,只不过做成一般的rpc需要一些封装。那么现在来学习一下高性能的,流行的RabbitMQ。其使用Erlang语言编写,并发性能好,使用AMQP协议,支持跨语言。但是安装RabbitMQ需要安装Erlang,并邦本要兼容。
ActiveMQ比较轻量级,文档支持也好。
在消息中间件中,消费者怎么消费消息是重点,通常做法是定义消息监听器。activemq提供了3种消息监听器,MessageListener, SessionAwareMessageListener, MessageListenerAdapter. 后面两种消息监听器都是需要收到消息后需要确认或者回复时使用的(双向消息)。
程序员的高级之处不是什么都会,而是对自己不会的进行抽象,然后完成自己的工作。比如对于RabbitMQ,按照字面理解,就将其看成Message Queue,也就是用来容纳对象的集合。很多功能都拆分给一个专一的模块,然后使用tcp/ip通信,使用端口号,最熟悉的就是mysql等数据库产品。回归正题,spring中怎么配置RabbitMQ的参数呢?看源码:
@ConfigurationProperties(prefix = "spring.rabbitmq") public class RabbitProperties { /** * RabbitMQ host. */ private String host = "localhost"; /** * RabbitMQ port. */ private int port = 5672; /** * Login user to authenticate to the broker. */ private String username = "guest";
这和数据库的配置美什么大的区别,以spring.rabbitmq开头,将配置信息封装成一个对象,然后就可以使用这个对象了,那么问题来了@ConfigurationProperties这个注解是什么呢?它的作用已经很明显了,就是从properties文件提取以spring.rabbitmq开头的字符串。
@Configuration @ConditionalOnClass({ RabbitTemplate.class, Channel.class }) @EnableConfigurationProperties(RabbitProperties.class) @Import(RabbitAnnotationDrivenConfiguration.class) public class RabbitAutoConfiguration { // 这是RabbitAutoConfiguration的注解,基本思路就是如果有Rabbitmq,spring会去加载这个bean,
而RabbitAutoConfiguration告诉spring具体怎么加载
参考博文:https://sixdegree.github.io/2019/01/05/Rabbitmq.html
acivemq博文:https://www.cnblogs.com/liuyuan1227/p/10771460.html