这里的selectOneMessageQueue的其实内部调用MQFaultStrategy内部对象的selectOneMessageQueue： 我个人看来，这个估算功能倒不是特别重要，所以mq默认是不使用这个逻辑，不过这个不妨碍我们研究下。下面是MQFaultStrategy的selectOne ...
分类：
其他好文 时间：
2019-10-01 20:15:31
阅读次数：
85
说在前面 本次开始进行rocketmq源码解析，比较喜欢rocketmq的架构设计，rocketmq内嵌了namesrv注册中心保存了元数据，进行负载均衡、容错的一些处理，4.3以上支持消息事务，有管理控制台、命令行工具，底层namesrv与broker、client与server交互netty实现 ...
分类：
其他好文 时间：
2019-10-01 13:32:33
阅读次数：
92
oracle12c RAC源端与Dataguard目标端实时同步，因业务需求需要在源端增加PDB 1. 源端添加PDB CREATE PLUGGABLE DATABASE kdlxpdb admin user kdlx identified by * FILE_NAME_CONVERT =('+DA ...
分类：
数据库 时间：
2019-09-30 23:43:55
阅读次数：
161
一、broker参数 broker.id：kafka集群的唯一标识。 log.dirs：kafka存储消息日志的目录，多个用逗号隔开，需要保证指定的目录有充足的磁盘空间。 zookeeper.connect：必须配置，指定kafka集群注册的zookeeper集群的地址。格式是：[主机名]:端口，多 ...
分类：
其他好文 时间：
2019-09-29 12:54:03
阅读次数：
366
前言 1. SpringBoot整合配置详解 publisher confirms,实现一个监听器用于监听Broker端给我们返回的确认请求： publisher returns,保证消息对Broker端是可达的，如果出现路由键不可达的情况，则使用监听器对不可达的消息进行后续的处理，保证消息的路由成 ...
分类：
编程语言 时间：
2019-09-28 14:37:28
阅读次数：
83
SparkStreaming+Kafka ?kafka是什么，有哪些特点 ?SparkStreaming+Kafka有什么好处 –解耦 –缓冲 消息列队的特点 生产者消费者模式 ?可靠性保证 –自己不丢数据 –消费者不丢数据：“至少一次，严格一次” broker n. 经纪人，掮客 vt. 以中间人... ...
分类：
其他好文 时间：
2019-09-28 00:47:33
阅读次数：
116
celery 1.概念 基本概念：Broker, Backend 什么是broker? broker是一个消息传输的中间件，可以理解为一个队列。每当应用程序调用celery的异步任务的时候，会向broker传递消息，而后celery的worker将会取到消息，进行对应的程序执行。 Broker的中文 ...
分类：
其他好文 时间：
2019-09-28 00:36:54
阅读次数：
105
50070：HDFSwebUI的端口号 8485:journalnode默认的端口号 9000：非高可用访问数rpc端口 8020：高可用访问数据rpc 8088：yarn的webUI的端口号 8080：master的webUI，Tomcat的端口号 7077：spark基于standalone的提 ...
分类：
其他好文 时间：
2019-09-27 19:34:16
阅读次数：
365
首先必须了解Mosquitto是什么，是支持MQTT的消息中间件。可以理解是MQTT的消息服务。 在Windows上安装Mosquitto Broker 注：从MQTT版本3.1.1开始采用的术语服务器而不是代理。 有两种可能性： 快速安装 标准安装 下载Windows安装包 http://mosq ...
Topic：可以理解为一个队列，生产者和消费者面向的都是一个 topic。 Partition：主要为了做负载，实现扩展性，一个非常大的 topic 可以分布到多个 broker（即服务器）上，一个 topic 可以分为多个 partition，每个 partition 是一个有序的队列。 一、to ...
分类：
系统相关 时间：
2019-09-13 17:16:17
阅读次数：
90
