积分充值
 首页
前端开发
AngularDartElectronFlutterHTML/CSSJavaScriptReactSvelteTypeScriptVue.js构建工具
后端开发
.NetC#C++C语言DenoffmpegGoIdrisJavaJuliaKotlinLeanMakefilenimNode.jsPascalPHPPythonRISC-VRubyRustSwiftUML其它语言区块链开发测试微服务敏捷开发架构设计汇编语言
数据库
Apache DorisApache HBaseCassandraClickHouseFirebirdGreenplumMongoDBMySQLPieCloudDBPostgreSQLRedisSQLSQLiteTiDBVitess数据库中间件数据库工具数据库设计
系统运维
AndroidDevOpshttpdJenkinsLinuxPrometheusTraefikZabbix存储网络与安全
云计算&大数据
Apache APISIXApache FlinkApache KarafApache KyuubiApache OzonedaprDockerHadoopHarborIstioKubernetesOpenShiftPandasrancherRocketMQServerlessService MeshVirtualBoxVMWare云原生CNCF机器学习边缘计算
综合其他
BlenderGIMPKiCadKritaWeblate产品与服务人工智能亿图数据可视化版本控制笔试面试
文库资料
前端
AngularAnt DesignBabelBootstrapChart.jsCSS3EchartsElectronHighchartsHTML/CSSHTML5JavaScriptJerryScriptJestReactSassTypeScriptVue前端工具小程序
后端
.NETApacheC/C++C#CMakeCrystalDartDenoDjangoDubboErlangFastifyFlaskGinGoGoFrameGuzzleIrisJavaJuliaLispLLVMLuaMatplotlibMicronautnimNode.jsPerlPHPPythonQtRPCRubyRustR语言ScalaShellVlangwasmYewZephirZig算法
移动端
AndroidAPP工具FlutterFramework7HarmonyHippyIoniciOSkotlinNativeObject-CPWAReactSwiftuni-appWeex
数据库
ApacheArangoDBCassandraClickHouseCouchDBCrateDBDB2DocumentDBDorisDragonflyDBEdgeDBetcdFirebirdGaussDBGraphGreenPlumHStreamDBHugeGraphimmudbIndexedDBInfluxDBIoTDBKey-ValueKitDBLevelDBM3DBMatrixOneMilvusMongoDBMySQLNavicatNebulaNewSQLNoSQLOceanBaseOpenTSDBOracleOrientDBPostgreSQLPrestoDBQuestDBRedisRocksDBSequoiaDBServerSkytableSQLSQLiteTiDBTiKVTimescaleDBYugabyteDB关系型数据库数据库数据库ORM数据库中间件数据库工具时序数据库
云计算&大数据
ActiveMQAerakiAgentAlluxioAntreaApacheApache APISIXAPISIXBFEBitBookKeeperChaosChoerodonCiliumCloudStackConsulDaprDataEaseDC/OSDockerDrillDruidElasticJobElasticSearchEnvoyErdaFlinkFluentGrafanaHadoopHarborHelmHudiInLongKafkaKnativeKongKubeCubeKubeEdgeKubeflowKubeOperatorKubernetesKubeSphereKubeVelaKumaKylinLibcloudLinkerdLonghornMeiliSearchMeshNacosNATSOKDOpenOpenEBSOpenKruiseOpenPitrixOpenSearchOpenStackOpenTracingOzonePaddlePaddlePolicyPulsarPyTorchRainbondRancherRediSearchScikit-learnServerlessShardingSphereShenYuSparkStormSupersetXuperChainZadig云原生CNCF人工智能区块链数据挖掘机器学习深度学习算法工程边缘计算
UI&美工&设计
BlenderKritaSketchUI设计
网络&系统&运维
AnsibleApacheAWKCeleryCephCI/CDCurveDevOpsGoCDHAProxyIstioJenkinsJumpServerLinuxMacNginxOpenRestyPrometheusServertraefikTrafficUnixWindowsZabbixZipkin安全防护系统内核网络运维监控
综合其它
文章资讯
 上传文档  发布文章  登录账户
IT文库
  • 综合
  • 文档
  • 文章

无数据

分类

全部云计算&大数据(7)RocketMQ(7)

语言

全部中文(简体)(4)中文(简体)(2)英语(1)

格式

全部PDF文档 PDF(7)
 
本次搜索耗时 0.020 秒,为您找到相关结果约 7 个.
  • 全部
  • 云计算&大数据
  • RocketMQ
  • 全部
  • 中文(简体)
  • 中文(简体)
  • 英语
  • 全部
  • PDF文档 PDF
  • 默认排序
  • 最新排序
  • 页数排序
  • 大小排序
  • 全部时间
  • 最近一天
  • 最近一周
  • 最近一个月
  • 最近三个月
  • 最近半年
  • 最近一年
  • pdf文档 消息中间件RocketMQ原理解析 - 斩秋

    1. 获取 namesrv 的地址列表(是乱序的) 2. 遍历向每个 namesrv 注册 topic 的配置信息 topicconfig Topic 在 broker 文件上的存储 json 格式 "TopicTest":{ "perm":6, "readQueueNums":8, "topicFilterType":"SINGLE_TAG" 信息, namesrv 只存内存,但是 broker 有任务定时推送 1. 接收数据向 RouteInfoManager 注册。 Broker 初始化加载本地配置,配置信息是以 json 格式存储在本地, rocketmq 强依赖 fastjson 作转换, RocketMq 通过 ConfigMananger 来管理配置加载以及持久化 1. 加载 topic 配置${user 值, 值为 proccessOffset%mapedFileSize 2) 正常恢复 commitLog 文件 步骤跟流程恢复 Consume Queue 判断消息有效, 根据消息的存储格式读取消息到 DispatchRequest 对象, 获取 消息大小值 msgSize 大于 0 正常数据 等于-1 文件读取错误 恢复结束 等于 0 读到文件末尾
    0 码力 | 57 页 | 2.39 MB | 1 年前
    3
  • pdf文档 Apache RocketMQ 从入门到实战

    broker 信息,主要是通过向 NameServer 发送 GET_BR OKER_CLUSTER_INFO 请求,NameServer 返回集群包含的所有 broker 信息,包 含从节点的信息,返回的格式如下: "clusterInfo": { "brokerAddrTable": { "broker-a": { "cluster": "DefaultCluster", "brokerName": 需要放在${ROCKETMQ_HOME}/store/co nfig 目录下。下面对其配置项一一介绍。 globalWhiteRemoteAddresses 全局白名单,其类型为数组,即支持多个配置。其支持的配置格式如下:  空 表示不设置白名单,该条规则默认返回 false。 本文来自『中间件兴趣圈』公众号,仅作技术交流,未授权任何商业行为。 143 > 1.15 RocketMQ ACL 使用指南 RocketMQ 消息轨迹,主要跟踪消息发送、消息消费的轨迹,即详细记录消息各个处 理环节的日志,从设计上至少需要解决如下三个核心问题:  消费轨迹数据格式  记录消息轨迹(消息日志)  消息轨迹数据存储在哪? 一、消息轨迹数据格式 RocketMQ4.5 版本消息轨迹主要记录如下信息:  traceType 跟踪类型,可选值:Pub(消息发送)、SubBefore(消息拉取到客户端,执行业务定义
    0 码力 | 165 页 | 12.53 MB | 1 年前
    3
  • pdf文档 RocketMQ v3.2.4 开发指南

    组成 MsgId 总共 16 字节,包含消息存储主机地址,消息 Commit Log offset。从 MsgId 中解析出 Broker 的地址和 Commit Log 的偏秱地址,然后挄照存储格式所在位置消息 buffer 解析成一个完整的消息。 7.3.2 挄照 Message Key 查询消息 Commit Log Offset Timestamp Next Index Offset 大端 4 个字节整数,等亍 2、3、4 长度总和 2. 大端 4 个字节整数,等亍 3 的长度 3. 使用 json 序列化数据 4. 应用自定丿二迕制序列化数据 Header 格式 { "code": 0, 项目开源主页:https://github.com/alibaba/RocketMQ 30 "language": "JAVA", "version":
    0 码力 | 52 页 | 1.61 MB | 1 年前
    3
  • pdf文档 基于Apache APISIX 与RocketMQ 构建云原生一体化架构

    逻辑队列:秒级无损弹性扩缩,无数据复制,流量精准调度 消息与流融合索引支持 核心问题 • 消息体小且存储结构面向单 条消息,导致提升吞吐困难 • 在进行状态存储时,无 KV 语义支撑 挑战 • Commitlog 格式存储, 统一复制算法 • 不借助外部依赖,提供 状态存储能力 • 单一数据文件,支持面向流的索引及面向 批的索引 • 批量发,批量存,批量读,吞吐提升十倍 • 统一消息,KV 语义,统一
    0 码力 | 22 页 | 2.26 MB | 1 年前
    3
  • pdf文档 rocketmq 服务部署

    namesrv/namesrv.log & Linux 环境下遇到的问题: ● 启动的时候设置内存太大,只是用来测试的话,我们可以改下启动脚本的内存配置, runserver.sh ● 还有一个就是脚本格式问题,会导致脚本执行不了,解决办法: https://blog.lacknb.cn/articles/ 019/10/10/1577974148936.html#toc_h2_18 nameserver启动完毕后,可以执行
    0 码力 | 11 页 | 284.35 KB | 1 年前
    3
  • pdf文档 Apache RocketMQ on Amazon Web Services

    等没有达到上限。如果某一项您已经达到上限,请向后台提交⼯单选择申 请提高限制。 3. 如果在该区域内您还没有密钥对,请在 Amazon EC2 控制台的导航窗格中,依 次选择密钥对、创建密钥对,选择默认的.pem 格式,键⼊名称,然后选择创建 并妥善保管好此秘钥。请妥善保管此密钥,若丢失,将无法访问实例。 Page 6 of 18 4. 请通过右上⻆区域选择按钮选择您的目标区域。
    0 码力 | 18 页 | 1.55 MB | 1 年前
    3
  • pdf文档 快速部署高可用的Apache RocketMQ 集群 - Amazon S3

    等没有达到上限。如果某⼀项您已经达到上限,请向后台提交 ⼯单选择申请提⾼限制。 3. 如果在该区域内您还没有密钥对,请在 Amazon EC2 控制台的导航窗格中, 依次选择密钥对、创建密钥对,选择默认的.pem 格式,键⼊名称,然后选择 创建并妥善保管好此秘钥。请妥善保管此密钥,若丢失,将⽆法访问实例。 Page 6 of 21 4. 请通过右上⻆区域选择按钮选择您的⽬标区域。
    0 码力 | 21 页 | 2.57 MB | 1 年前
    3
共 7 条
  • 1
前往
页
相关搜索词
消息中间中间件消息中间件RocketMQ原理解析Apache入门实战开发指南基于APISIX构建原生一体一体化架构rocketmq服务部署onAmazonWebServices快速可用集群S3
IT文库
关于我们 文库协议 联系我们 意见反馈 免责声明
本站文档数据由用户上传或本站整理自互联网,不以营利为目的,供所有人免费下载和学习使用。如侵犯您的权益,请联系我们进行删除。
IT文库 ©1024 - 2025 | 站点地图
Powered By MOREDOC AI v3.3.0-beta.70
  • 关注我们的公众号【刻舟求荐】,给您不一样的精彩
    关注我们的公众号【刻舟求荐】,给您不一样的精彩