Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
RocketMQ源码(26)—DefaultMQPushConsumer事务消息源码【一万字】
事务消息是RocketMQ的一大特性 其被用来实现分布式事务 关于RocketMQ的事务消息的相关原理的介绍见这篇博客 RocketMQ的分布式事务机制 事务消息 关于事务消息的基本案例看这里 消息事务样例 本文主要介绍RocketMQ的事
RocketMQ 源码
javarocketmq
RocketMQ
Java
事务消息
解决Eclipse没有serve及无tomcat9.0
网上一般提供的 Kepler repository http download eclipse org releases kepler 版本老 在Eclipse help install new 直接输入版本时间 出现如下 我的版本是201
Java
eclipse
IDE
javarocketmq
服务器
基于Jmeter实现Rocketmq消息发送
在互联网企业技术架构中 MQ占据了越来越重要的地位 系统解耦 异步通信 削峰填谷 数据顺序保证等场景中 到处都能看到MQ的身影 而测试工程师在工作中 也经常需要和mq打交道 比如构造测试数据 触发某些业务场景 以及针对mq的性能测试等 目前
IT
软件测试
程序员
javarocketmq
RocketMQ
RocketMq顺序发送消息
错乱消息出现的原因 1 在RocketMq为啥消息不是按照顺序来的呢 首先您需要了解 队列是一个先进先出的一个数据的结构 生产者 您可以将topic理解为里面有一个一个的队列 你将一个消息发送到topic的时候 当前的消息不一定是往当前的这
javarocketmq
RocketMQ-源码解读与调试
源码环境搭建 源码拉取 RocketMQ的官方Git仓库地址 GitHub apache rocketmq Mirror of Apache RocketMQ 可以用git把项目clone下来或者直接下载代码包 也可以到RocketMQ的官
RocketMQ
javarocketmq
Java
RocketMQ的消息优先级
有些场景 需要应用程序处理几种类型的消息 不同消息的优先级不同 RocketMQ是个先入先出的队列 不支持消息级别或者Topic级别的优先级 业务中简单的优先级需求 可以通过间接的方式解决 下面列举三种优先级相关需求的具体处理方法 第一种
Java
MQ
javarocketmq
RocketMQ
关于rocketmq 中日志文件路径的配置
前些天发现了一个巨牛的人工智能学习网站 通俗易懂 风趣幽默 忍不住分享一下给大家 点击跳转到网站 rocketmq 中的数据和日志文件默认都是存储在user home路径下面的 往往我们都需要修改这些路径到指定文件夹以便管理 服务端日志 网
消息队列
javarocketmq
RocketMQ
Java
rocketmq 日志路径
rocketMq启动broker报错找不到或无法加载主类 Files\Java\jdk1.8.0_171\lib\dt.jar;C:\Program]
假如弹出提示框提示 错误 找不到或无法加载主类 xxxxxx 1 打开runbroker cmd 将 CLASSPATH 加上英文双引号 切勿别加中文双引号 2 打开runserver cmd 同理 将 CLASSPATH 加上英文双引号
Java
javarocketmq
RocketMQ
分析rocketmq-client产生大量rocketmq_client.log日志文件的原因处理方案
源码 public static final String CLIENT LOG USESLF4J rocketmq client logUseSlf4j public static final String CLIENT LOG ROOT
javarocketmq
RocketMQ
Java
rocketMq消息队列原生api使用以及rocketMq整合springboot
rocketMq消息队列 文章目录 rocketMq消息队列 一 RocketMQ原生API使用 1 测试环境搭建 2 RocketMQ的编程模型 3 RocketMQ的消息样例 3 1 基本样例 3 2 顺序消息 3 3 广播消息 3 4
消息队列
javarocketmq
RocketMQ
spring boot
java消息队列
Rocketmq 消息过滤简述
Rocketmq消息过滤是指在消息消费时 消费者Consumer可以对某一主题下的消息按照某种过滤规则进行过滤 只消费自己感兴趣的消息 Rocketmq同时支持在Broker端和Consumer端做消息过滤 Broker端过滤 Broker
rocketmq学习
RocketMQ
javarocketmq
IndexFile实现原理
摘要 rocketmq作为转发数据的中间件 其特点就是快字当头 那么如何做到快 rocketmq从各个角度都进行了优化 今天我们来看下它的索引文件 观察其组织文件的格式 使用的方式 一 组织文件的格式 Indexfile是mq索引文件的主要
rocketmq系列
javarocketmq
centos安装rocketmq
centos安装rocketmq 1 下载rocketmq二进制包 2 解压二进制包 3 修改broker conf 4 修改runbroker sh和runserver sh的JVM参数 5 启动NameServer和Broker 6 安
centOS
javarocketmq
RocketMQ
RocketMQ-如何保证顺序消息
1 简介 实际开发中会有以下场景 需要保证一组消息的生产顺序与消费顺序相同 例如 监听数据库表单条数据的的多次修改 需要保证监听者最终得到的消息顺序和数据库表对单条数据的修改顺序一样 网购平台创建订单的过程一般都是异步实现 订单创建和支付流
Java
javarocketmq
RocketMQ
RocketMQ部署之动态设置JVM启动参数
这里是weihubeats 觉得文章不错可以关注公众号小奏技术 文章首发 拒绝营销号 拒绝标题党 背景 线上的RocketMQ集群有运行一段时间了 比如测试环境和线上环境的RocketMQ集群部署的机器内存大小肯定不一样 所以可能要写多个部
RocketMQ
JVM
javarocketmq
RocketMQ
RocketMQ源码(十三)—消费者DefaultMQPushConsumer启动主要流程源码
此前我们学习了Broker和Producer的启动源码 以及Producer发送消息源码和Broker接收存储消息的源码 现在 我们来学习Consumer的启动以及消费消息的源码 Consumer的启动源码和Producer的启动源码还是有
javarocketmq
RocketMQ
Java
面试题篇-09-RocketMQ相关面试题
文章目录 1 RocketMQ如何保证消息有序消费 2 RocketMQ和Kafka 快的飞起 底层存储有什么不同 2 1 什么是 零拷贝 2 1 1 传统IO数据读写 2 1 2 mmap优化 3次切换 3次拷贝 2 1 3 SendFi
javarocketmq
RocketMQ
Java
windows安装rocketmq
windows安装rocketmq 问题背景 操作步骤 Lyric 请再给我 一个理由 问题背景 最近有使用rocketmq 为测试方便 在本地安装rocketmq 注意事项 默认已安装java1 8 启动mq必须是1 8版本 我之前使用1
rocketmq开发常遇问题
Windows
javarocketmq
RocketMQ
Docker 部署 RocketMQ
文章目录 安装nameserver 拉取镜像 运行容器 出现问题卸载 安装broker 创建配置文件 运行容器 出现问题卸载 安装控制台 拉取镜像 运行容器 出现问题卸载 安装nameserver 拉取镜像 docker pull rock
RocketMQ
Docker
javarocketmq
Centos7下基于jdk11 安装RocketMQ
1 简介 RocketMQ是阿里巴巴中间件团队自研的一款高性能 高吞吐量 低延迟 高可用 高可靠 具备金融级稳定性 的分布式消息中间件 开源后并于2016年捐赠给Apache社区孵化 目前已经成为了 Apache顶级项目 当前在国内被广泛的
RocketMQ
javarocketmq
RocketMQ
Linux
1
2
»