草庐IT

ROCKETMQ_HOME

全部标签

【打怪升级】【rocketMq】rocket的持久化

rocket持久化保证的思想有两点:1是刷盘保证大部分数据不丢失;2是持久化文件的处理,零拷贝技术和内存页,NIO模型保证处理能力文件持久化目录  ├──abort:rocketbroker启动检查的文件,正常启动会写入一个abort,正常退出会删除abort,通过它来判断上一次是否异常退出  ├──checkpoint:随着broker启动,加载的历史检查点  ├──lock:全局资源的文件锁  ├──commitlog:broker存储的核心,我们都是到rocket是broker集中存储,落地存盘就存在commitlog里  │├──00000000000000000000(示例)rock

RocketMQ 介绍及基本概念

1介绍RocketMQ作为一款纯java、分布式、队列模型的开源消息中间件,支持事务消息、顺序消息、批量消息、定时消息、消息回溯等。1.1RocketMQ特点支持发布/订阅(Pub/Sub)和点对点(P2P)消息模型在一个队列中可靠的先进先出(FIFO)和严格的顺序传递(RocketMQ可以保证严格的消息顺序,而ActiveMQ无法保证)支持拉(pull)和推(push)两种消息模式pull其实就是消费者主动从MQ中去拉消息,而push则像rabbitMQ一样,是MQ给消费者推送消息。但是RocketMQ的push其实是基于pull来实现的。它会先由一个业务代码从MQ中pull消息,然后再由业

RocketMQ 介绍及基本概念

1介绍RocketMQ作为一款纯java、分布式、队列模型的开源消息中间件,支持事务消息、顺序消息、批量消息、定时消息、消息回溯等。1.1RocketMQ特点支持发布/订阅(Pub/Sub)和点对点(P2P)消息模型在一个队列中可靠的先进先出(FIFO)和严格的顺序传递(RocketMQ可以保证严格的消息顺序,而ActiveMQ无法保证)支持拉(pull)和推(push)两种消息模式pull其实就是消费者主动从MQ中去拉消息,而push则像rabbitMQ一样,是MQ给消费者推送消息。但是RocketMQ的push其实是基于pull来实现的。它会先由一个业务代码从MQ中pull消息,然后再由业

[已解决]Mac安装mvn:The JAVA_HOME environment variable is not defined correctly

Mac安装maven遇到的问题及解决问题一:TheJAVA_HOMEenvironmentvariableisnotdefinedcorrectly场景分析解决结果问题二:无法打开“libjansi.jnilib”,因为无法验证开发者解决方案问题一:TheJAVA_HOMEenvironmentvariableisnotdefinedcorrectly场景在mac电脑安装maven后,通过vim~/.bash_profile配置maven环境变量,exportM2_HOME=/Users/sujiaying/Documents/maven/apache-maven-3.6.3exportPAT

[已解决]Mac安装mvn:The JAVA_HOME environment variable is not defined correctly

Mac安装maven遇到的问题及解决问题一:TheJAVA_HOMEenvironmentvariableisnotdefinedcorrectly场景分析解决结果问题二:无法打开“libjansi.jnilib”,因为无法验证开发者解决方案问题一:TheJAVA_HOMEenvironmentvariableisnotdefinedcorrectly场景在mac电脑安装maven后,通过vim~/.bash_profile配置maven环境变量,exportM2_HOME=/Users/sujiaying/Documents/maven/apache-maven-3.6.3exportPAT

【智能家居】Home Assistant入门安装并内网穿透实现远程安全控制

文章目录前言1.安装HomeAssistant2.配置HomeAssistant3.安装cpolar内网穿透3.1windows系统3.2Linux系统3.3macOS系统4.映射HomeAssistant端口5.公网访问HomeAssistant6.固定公网地址6.1保留一个固定二级子域名6.2配置固定二级子域名前言HomeAssistant(以下简称HA)是个开源的智能家居平台,也叫家庭助手,就像一个软件,比如我们的QQ软件,微信软件。HomeAssistant把家中的智能家居设备整合到HA中,它能够接入的设备非常的多比如大名鼎鼎的小米、博联、易微联、飞利浦、特斯拉…,也可以接入软件,让后

【智能家居】Home Assistant入门安装并内网穿透实现远程安全控制

文章目录前言1.安装HomeAssistant2.配置HomeAssistant3.安装cpolar内网穿透3.1windows系统3.2Linux系统3.3macOS系统4.映射HomeAssistant端口5.公网访问HomeAssistant6.固定公网地址6.1保留一个固定二级子域名6.2配置固定二级子域名前言HomeAssistant(以下简称HA)是个开源的智能家居平台,也叫家庭助手,就像一个软件,比如我们的QQ软件,微信软件。HomeAssistant把家中的智能家居设备整合到HA中,它能够接入的设备非常的多比如大名鼎鼎的小米、博联、易微联、飞利浦、特斯拉…,也可以接入软件,让后

关于rocketmq 中日志文件路径的配置

前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家。点击跳转到网站。rocketmq中的数据和日志文件默认都是存储在user.home路径下面的,往往我们都需要修改这些路径到指定文件夹以便管理。服务端日志网上搜索rocketmq日志存储路径的修改,一堆都是写着要把源码拉下来,用rocketmq_home全局替换user.home,然后再配置rocketmq_home变量。既然都是变量的替换,指定user.home的位置不就行了吗?rocketmq是java编写的,也就是可以指定启动参数,按照上面那个思路我们只要在rocketmq启动的时候指定启动参数就行了。在co

关于rocketmq 中日志文件路径的配置

前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家。点击跳转到网站。rocketmq中的数据和日志文件默认都是存储在user.home路径下面的,往往我们都需要修改这些路径到指定文件夹以便管理。服务端日志网上搜索rocketmq日志存储路径的修改,一堆都是写着要把源码拉下来,用rocketmq_home全局替换user.home,然后再配置rocketmq_home变量。既然都是变量的替换,指定user.home的位置不就行了吗?rocketmq是java编写的,也就是可以指定启动参数,按照上面那个思路我们只要在rocketmq启动的时候指定启动参数就行了。在co

springboot 用rocketmq实现批量消息,亲测可用

本地测试,一定要启动rocketmq,否则报错。启动方式请百度。1.创建Springboot项目,添加rockermq依赖  org.apache.rocketmq  rocketmq-spring-boot-starter  2.2.12.配置rocketmq#端口server: port:8083#配置rocketmqrocketmq: name-server:127.0.0.1:9876 #生产者 producer:  #生产者组名,规定在一个应用里面必须唯一  group:group1  #消息发送的超时时间默认3000ms  send-message-timeout:3000  #消