消息队列(MQ)概括
2016-12-09 15:46
120 查看
RPC和消息队列
同步的RPC:常用的接口调用(restful(jessry、SpringMVC))
异步的RPC:使用MQ实现(JMS,RabbitMQ,Kafka)
RPC与MQ
个人理解RPC和MQ:RPC调用需要返回数据,MQ消息通知(也可以实现返回数据(RPC))。
RabbitMQ(AMQP)介绍
相对于JMS来说多了跨平台和Exchange(路由选择)
在C端,如果开启监听,事件可以监听队列,如果队列中有消息,通知Handler进行处理(需要设置监听)。
RabbitMQ实现了消息确认机制,如果没有收到C端的确认,可以重传机制确保(也可以不用,消息只发送不确认收到),exchange收到确认信息自动删除消息。
如果想使用RabbitMQ实现RPC功能,则可以设置回调队列,返回的数据通过回调队列进行返回。
RabbitMQ和Kafka
RabbitMQ实现了AMQP,Kafka更适合处理日志(更多不同看其他资料)
同步的RPC:常用的接口调用(restful(jessry、SpringMVC))
异步的RPC:使用MQ实现(JMS,RabbitMQ,Kafka)
RPC与MQ
个人理解RPC和MQ:RPC调用需要返回数据,MQ消息通知(也可以实现返回数据(RPC))。
RabbitMQ(AMQP)介绍
相对于JMS来说多了跨平台和Exchange(路由选择)
在C端,如果开启监听,事件可以监听队列,如果队列中有消息,通知Handler进行处理(需要设置监听)。
RabbitMQ实现了消息确认机制,如果没有收到C端的确认,可以重传机制确保(也可以不用,消息只发送不确认收到),exchange收到确认信息自动删除消息。
如果想使用RabbitMQ实现RPC功能,则可以设置回调队列,返回的数据通过回调队列进行返回。
RabbitMQ和Kafka
RabbitMQ实现了AMQP,Kafka更适合处理日志(更多不同看其他资料)
相关文章推荐
- MQ消息队列使用场景
- Activemq+spring的第一个程序(入门程序--内嵌Broker--消息队列)
- MQ中将消息发送至远程队列的配置
- 分布式消息队列RocketMQ之Netty -- 1+N+M1+M2模型
- 各类消息队列MQ比较
- RabbitMQ消息队列+spring监听mq服务器,接收消费mq消息
- 分布式消息队列RocketMQ源码分析之1 -- Topic路由数据结构解析 -- topicRoute与topicPublishInfo与queueId
- Posix消息队列 异步通知 mq_notify函数
- RabbitMQ+HAProxy构建高可用消息队列
- MQ-消息队列
- 分布式消息队列RocketMQ&Kafka -- 消息的“顺序消费”-- 一个看似简单的复杂问题
- 【消息队列MQ】各类MQ比较
- 【消息队列MQ】各类MQ比较
- 消息队列选型[首选Kafka](备选:RabbitMQ/NSQ/RocketMQ/disque/Kafka)
- 消息队列MQ基础
- 消息队列mq的原理及实现方法
- 应用服务器性能优化 之 消息队列(MQ:Message Queue)
- RabbitMQ .NET消息队列使用入门(一)【简单示例】
- 利用DelayQueue实现延时消息队列(简易版MQ)
- MQ消息队列