RocketMQ整理 概念 broker MQ服务节点 topic 主题 message queue 消息队列，类似于kafka中的partition producer 生产者，先去连接name server，查询到对应的broker信息，再去连接broker consumer 消费者，先去连接na ...
分类：
其他好文 时间：
2019-07-23 11:39:13
阅读次数：
85
rocketmq的主要部分是由4种集群构成的：namesrv集群、broker集群、producer集群和consumer集群。 namesrv集群：也就是注册中心，rocketmq在注册中心这块没有使用第三方的中间件，而是自己写的代码来实现的，代码行数才1000行，producer、broker和 ...
分类：
其他好文 时间：
2019-07-22 15:20:47
阅读次数：
81
每个kafka副本对象都持有2个重要的属性：日志末端位移LEO，高水印HW Kafka对leader副本和follower副本的LEO更新机制是不同的，后面我们会详细讨论。 Kafka对leader副本和follower副本的hw值更新机制也是不同的。 消费者无法消费分区leader副本上那些位移大 ...
分类：
其他好文 时间：
2019-07-20 21:32:11
阅读次数：
477
1.什么是Clelery Celery是一个简单、灵活且可靠的，处理大量消息的分布式系统 专注于实时处理的异步任务队列 同时也支持任务调度 Celery架构 Celery的架构由三部分组成，消息中间件（message broker），任务执行单元（worker）和任务执行结果存储（task resu ...
分类：
其他好文 时间：
2019-07-20 00:00:08
阅读次数：
137
使用docker 安装kafka时报错 查看报错日志 查看内存使用情况 创建swapfile 将swapfile设置为swap空间 启用交换空间，这个操作有点类似于mount操作 至此增加交换空间的操作结束了，可以使用free命令查看swap空间大小是否发生变化 kafka 安装成功~ 参考博客：h ...
分类：
其他好文 时间：
2019-07-15 15:58:14
阅读次数：
392
一、什么是Exchange 首先我们要了解到，RabbitMQ 是 AMQP（高级消息队列协议）的标准实现： 从 AMQP 协议可以看出，Queue、Exchange 和 Binding 构成了 AMQP 协议的核心 Producer：消息生产者，即投递消息的程序。 Broker：消息队列服务器实体 ...
分类：
其他好文 时间：
2019-07-14 21:23:31
阅读次数：
405
Celery 1.什么是Clelery Celery是一个简单、灵活且可靠的，处理大量消息的分布式系统 专注于实时处理的异步任务队列 同时也支持任务调度 Celery架构 Celery的架构由三部分组成，消息中间件（message broker），任务执行单元（worker）和任务执行结果存储（ta ...
分类：
其他好文 时间：
2019-07-14 11:13:11
阅读次数：
73
Celery 1.什么是Clelery Celery是一个简单、灵活且可靠的，处理大量消息的分布式系统 专注于实时处理的异步任务队列 同时也支持任务调度 Celery架构 Celery的架构由三部分组成： ● 消息中间件（message broker） ● 任务执行单元（worker） ● 任务执行 ...
分类：
其他好文 时间：
2019-07-12 17:03:43
阅读次数：
139
1、RocketMQ结构 通过topic确定将消息发送到不同broker；broker中有多个messagequeue，消息放松到broker后经过轮询算法、hash算法等将消息发送到不同的messagequeue上 messagequeue本身不存放消息，真正的消息存放在commitlog中，me ...
分类：
其他好文 时间：
2019-07-11 15:47:20
阅读次数：
172
队列消息持久化之JDBC 1、 配置activemq.xml文件，修改持久化方式为jdbc 2、在broker外配置数据库连接bean 3、启动服务，可以看到数据库中多了3张表，表明配置成功 4、运行Producer，模拟生产者发送消息 控制台输出： Activemq管理控制台： 数据库表中: 5、 ...
分类：
其他好文 时间：
2019-07-11 12:20:40
阅读次数：
70
