Kafka适合离线和在线的消息消费,其消息保存在磁盘上。 Kafka以Topic为单位进行消息的归纳,Producers向Topic发送(Push)消息,Consumers会消费(Pull)预订了Topic的消息。 基本概念 消息队列中的基本概念尤为重要,当对基本概念有了深入的理解之后,消息队列的原 ...
分类:
其他好文 时间:
2020-05-05 20:05:38
阅读次数:
70
RabbitMQ 即一个消息队列,主要是用来实现应用程序的异步和解耦,同时也能起到消息缓冲,消息分发的作用。 消息中间件在互联网公司的使用中越来越多,刚才还看到新闻阿里将RocketMQ捐献给了apache,当然了今天的主角还是讲RabbitMQ。消息中间件最主要的作用是解耦,中间件最标准的用法是生 ...
分类:
编程语言 时间:
2020-05-05 18:09:04
阅读次数:
65
RabbitMQ,消息队列的一个中间件,这里不打算展开介绍了。此文意在记录工作中使用RabbitMQ时的过程及一些心得,大神可忽略。如有表述有误,各路大神可在留言区进行指正,不胜感谢。 ...
分类:
其他好文 时间:
2020-05-05 10:39:54
阅读次数:
62
redis提供了list类型,此类型底层是通过双向链表来实现:
> lpush、rpop 非阻塞式
> blpop、brpop 阻塞式
先来对比一下上面阻塞与非阻塞会有什么问题;
> 1.阻塞式:如果队列里面没有消息,会阻塞连接,长时间占用redis连接,需要考虑redis配置的超时以及redis会对空闲连接进行释放以减少资源浪费,需要对异常进行捕获重试;
> 2.非阻塞式:如果是1s主动去redis中拉取一次消息,也不太适合;
分类:
其他好文 时间:
2020-05-04 22:59:34
阅读次数:
72
redis和memcached比较? redis中数据库默认是多少个db 及作用? python操作redis的模块? 如果redis中的某个列表中的数据量非常大,如果实现循环显示每一个值? redis如何实现主从复制?以及数据同步机制? redis中的sentinel的作用? 如何实现redis集 ...
分类:
其他好文 时间:
2020-05-04 00:36:05
阅读次数:
61
一、消息中间件的介绍 介绍 ? 消息队列 是指利用 高效可靠 的 消息传递机制 进行与平台无关的 数据交流,并基于 数据通信 来进行分布式系统的集成。 特点(作用) 应用解耦 异步通信 流量削峰 (海量)日志处理 消息通讯 …... 应用场景 根据消息队列的特点,可以衍生出很多场景,或者说很多场景都 ...
分类:
其他好文 时间:
2020-05-03 13:08:26
阅读次数:
66
喜欢关注个人公众号:java乐园消息队列中间件是分布式系统中重要的组件,主要解决应用耦合,异步消息,流量削锋等问题。实现高性能,高可用,可伸缩和最终一致性架构;是大型分布式系统不可缺少的中间件。目前使用较多的消息队列有ActiveMQ、RabbitMQ、Kafka、RocketMQ、MetaMQ等。springboot提供了对JMS系统的支持;springboot很方便就可以集成这些消息中间件。对
分类:
编程语言 时间:
2020-05-02 09:27:36
阅读次数:
55
一、消息为什么丢失 RabbitMQ默认情况下的交换机和队列以及消息是非持久化的,也就是说在服务器重启或者宕机恢复后,之前创建的交换机和队列都将不复存在,之前未消费的消息也就消失不见了。原因在于每个队列和交换机的durable属性。该属性默认情况是false,它决定了RabbitMQ是否需要在崩溃或 ...
分类:
其他好文 时间:
2020-05-01 16:41:29
阅读次数:
396
邮箱与消息队列: 邮箱:开销小,效率高(每次4字节,32位任意值或指向缓冲区的指针),相当于MQTT中的代理。一(发)对多(收)关系; 分阻塞(邮箱不存在或超时参数不为0)和非阻塞(中断与线程间发送消息的有效手段) 发送满等待与接收空等待。 创建邮箱:分配内存大小=邮件数*4 /* 邮箱控制块 */ ...
分类:
编程语言 时间:
2020-05-01 16:37:42
阅读次数:
87
rabbitMQ是一个在AMQP协议标准基础上完整的,可服用的企业消息系统。它遵循Mozilla Public License开源协议,采用 Erlang 实现的工业级的消息队列(MQ)服务器,Rabbit MQ 是建立在Erlang OTP平台上。 1、安装Erlang 下载地址:https:// ...