Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
rocketmq客户端日志配置
rocketmq客户端会打印一些日志如消费进度 心跳等 默认的是滚动10个日志文件 每个100MB 又一次看到这个日志目录有几十GB 手动删除 但是悲剧的是rocketmq没有释放这个日志目录 导致不能真正的释放磁盘空间 于是研究了下怎么配
RocketMQ
RocketMQ rocketmq_client.log日志文件配置
1 默认路径 项目添加RocketMQ以后启动项目时会在user home下创建一个rocketmq client log日志文件 文件全路径是 user home logs rocketmqlogs rocketmq client log
MQ
RocketMQ
sendfile“零拷贝”、mmap内存映射、DMA
原创连接 https blog csdn net z69183787 article details 104760890 utm source app groupmessage KAFKA推送消息用到了sendfile 落盘技术用到了mma
RocketMQ
rocketmq消息重试和死信队列
1 消息重试 若Consumer消费某条消息失败 则RocketMQ会在重试间隔时间后 将消息重新投递给Consumer消费 若达到最大重试次数后消息还没有成功被消费 则消息将被投递至死信队列 消息重试只针对集群消费模式生效 广播消费模式不
MQ
RocketMQ
Powered by 金山文档
RocketMQ安装与启动
分享知识 传递快乐 官网 https rocketmq apache org 1 准备环境 系统 Centos7 jdk 1 8 2 环境部署 解压 rocketmq 并进入 rocketmq 下的 bin 目录 调整启动内存 vim bi
RocketMQ
RocketMQ
消息队列
RocketMQ学习笔记 - 顺序消息
文章目录 1 定义 2 代码示例 2 1 消息实体 2 2 生产者 2 3 消费者 2 3 测试结果 1 定义 顺序消息 FIFO 消息 是 MQ 提供的一种严格按照顺序进行发布和消费的消息类型 顺序消息由两个部分组成 顺序发布和顺序消费
RocketMQ
消息队列
ActiveMQ
中间件
rabbitmq
RocketMQ发送接收项目实战+对cos或者oss服务上的pdf文件和图片加水印
使用mq的原因 因为项目中文件上传比较多 需要使用mq分担当前系统线程压力 所以单独使用一个服务来处理文件上传 加快文件上传速度的同时也缓解了当前服务的处理压力 核心服务1 一个项目 发送mq GeneralFileEvent 需要发送给m
Java
springCloud
MyBatisPlus
javarocketmq
RocketMQ
消息中间件 RocketMQ 源码解析:Message 发送&接收
摘要 原创出处 http www iocoder cn RocketMQ message send and receive 芋道源码 欢迎转载 保留摘要 谢谢 本文主要基于 RocketMQ 4 0 x 正式版 1 概述 2 Produce
RocketMQ
RocketMQ 源码解析
源码
Java
JavaEE
RocektMQ社区"每周直播分享第6期"如约而至
分享题目 RocketMQ路由机制与联通性交互设计原理 直播方式 钉钉群直播方式 群号 21791227 分享时间 2019 01 10 20 00 21 30 本周四 内容简介 源码分析RocketMQ Topic路由机制与NameSer
RocketMQ技术
RocketMQ
【RocketMQ】顺序消息实现原理
全局有序 在RocketMQ中 如果使消息全局有序 可以为Topic设置一个消息队列 使用一个生产者单线程发送数据 消费者端也使用单线程进行消费 从而保证消息的全局有序 但是这种方式效率低 一般不使用 局部有序 假设一个Topic分配了两个
RocketMQ
javarocketmq
Java
实际生产环境Apache RocketMQ消息体过大的解决方案
前言 官方定义消息体默认大小为 4MB 普通顺序消息类型 事务 定时 延时类消息默认大小为64KB 如果超过限制则会抛出异常 但实际工作中 需要使用到MQ进行异步解耦 传输的业务消息偶尔会遇到超过4MB 尤其在业务复杂的系统中 那么我们应该
精选博文
JAVA核心技术
java笔记分享
javarocketmq
RocketMQ
RocketMQ:粗略认识RocketMQ以及在Window部署单机模式
一 粗略认识RocketMQ RocketMQ主要解决当访问服务数量超过系统性能瓶颈的问题 大概的解决思路就是先把信息收集起来 然后按照自己的速度一步步处理 而系统的访问者在把信息发送给RocketMQ之后 可以不用等返回结果 就可以先去忙
RocketMQ
基于RocketMQ分布式事务 - 完整示例
前言 之前我们说到 分布式事务是一个复杂的技术问题 没有通用的解决方案 也缺乏简单高效的手段 不过 如果我们的系统不追求强一致性 那么最常用的还是最终一致性方案 今天 我们就基于 RocketMQ来实现消息最终一致性方案的分布式事务 本文代
笔记
面试
RocketMQ
RocketMQ Bug修复记录
文章目录 1 Bug详情及解决 1 1 Bug 来龙去脉 1 2 验证这真的是一个BUG 1 2 1 BrokerFixedThreadPoolExecutor 1 2 2 FutureTaskExt 1 2 3 RegisterBroke
笔记
Java
多线程
并发编程
RocketMQ
4 SpringBoot整合RocketMQ实现消息发送和接收
我们使用主流的SpringBoot框架整合RocketMQ来讲解 使用方便快捷 最终项目结构如下 具体步骤如下 第一步 我们新建一个父项目rocketmq test pom类型 主要是依赖管理 包括版本的管理 以及管理module子项目 p
RocketMQ
Java
消息队列
RocketMQ-实际开发中遇到的几个问题
消息幂等性 什么是幂等性 一个操作任意执行多次与执行一次的结果相同 这个操作就是幂等 生产者发送消息之后 为了确保消费者消费成功 我们通常会采用手动签收方式确认消费 MQ就是使用了消息超时 重传 确认机制来保证消息必达 场景 1 订单服务
RocketMQ
消息队列
RocketMQ中文文档(译)
前言 近日需要研究一下RocketMQ 为了方便日后查找 因此对官方英文文档进行翻译记载 也希望能帮助到要学习的朋友 阅读后发现 文档还是比较粗略的 大概也只能了解些概念和简单实用 快速入门部分比较简单 因此暂时没翻译只翻译其中重要的几个部
消息发送
消息队列
RocketMQ
RocketMQ第四节(部署模式、监控面板等)
1 mq的部署模式 部署方式 RocketMQ 参考官网 单机模式 抗风险能力差 单机挂机没服务 单机硬盘损坏 丢失数据 多机 多master没有Slave副本 多个master采用RAID10磁盘 不会丢失数据 但是某一个master关闭
RocketMQ
javarocketmq
Java
«
1
2
3
4
5
6
7
8
»