简述 RabbitMQ是流行的开源消息队列系统，本身已经具备了较强的并发处理速度及运行稳定性，然而在大规模的实际应用中，往往还需要使用集群配置来保证系统中消息通信部分的高可用性，并发处理性能及异常恢复能力。这里将介绍一种实用的消息集群架构，以及一种能够快速、高效、可靠地部署并配置消息集群的方式，通过 ...
分类：
其他好文 时间：
2020-07-14 20:09:20
阅读次数：
80
为什么要进行持久化 为了避免MQ服务器意外宕机导致数据丢失，需要做到重启后没有被消费的数据依然在消息队列中。 ActiveMQ的持久化机制包含： 1. JDBC：持久化到数据库 2. AMQ：日志文件 3. KahaBD：AMQ基础上改进，默认选择 4. LevelDB：谷歌K/V数据库 注：Act ...
分类：
其他好文 时间：
2020-03-01 20:12:10
阅读次数：
122
导读 在上一篇文章《【分布式事务】基于RocketMQ搭建生产级消息集群？》中给大家介绍了基于RocketMQ如何搭建生产级消息集群。因为本系列文章最终的目的是介绍基于RocketMQ的事物消息来解决分布式系统中的数据一致性问题，所以先给大家率先介绍了RocketMQ消息集群的搭建。 原本是想着在这 ...
分类：
其他好文 时间：
2019-01-31 13:31:12
阅读次数：
178
可以借鉴：https://blog.csdn.net/junchenbb0430/article/details/77583955 zookeeper的组成部分： 1. Leader：起主导集群的作用，负责事物请求的调度和处理，保证集群中事物处理的顺序性； 2. Follower：处理客户端的非事物 ...
分类：
其他好文 时间：
2018-12-04 00:54:00
阅读次数：
156
Q: 如果集群多个客户端订阅会不会重复接收消息？ A: 集群环境用，有另外一个参数。 NodeManager类没有在框架里面： public interface INodeManager : IGrainWithStringKey { /// <summary> /// 初始化节点管理器 /// < ...
分类：
其他好文 时间：
2018-07-10 19:16:50
阅读次数：
209
rabbitmq的队列并不是分布在集群中，而且每个节点维护自己的 假设A B组成一个集群，rabbit域名或elb指向A，那么client会连接到A。但如果目标queue在B上，rabbit就会有一个内部的“转发机”的机制来维护，相当于代理一样。通过该机制，client仍能正常操作queue 但有一 ...
分类：
其他好文 时间：
2017-12-06 18:04:35
阅读次数：
440
时常看到高并发的问题，但高并发其实是最不需要考虑的东西。为何，他虚无缥缈，很少有网站真的需要这些东西，而且其中很多技术，其实你已经在用了。有这个意识就够了，不需要时刻盯着这个问题。只有很少的网站真的能达到高并发。 简单做一个归纳，从低成本、高性能和高扩张性的角度来说有如下处理方案： 1、HTML静态 ...
分类：
其他好文 时间：
2017-03-01 23:23:16
阅读次数：
302
转载：http://blog.csdn.net/ligt0610/article/details/47311771 由于目前每天需要从kafka中消费20亿条左右的消息，集群压力有点大，会导致job不同程度的异常退出。原来使用spark1.1.0版本中的createStream函数，但是在数据处理速 ...
kafka集群搭建与api客户端创建，以前的消息队列（activeMQ）对于大数据吞吐率不行，但kafka很好的解决了此类问题，并且以集群的方式进行扩展，可谓相当强大...
