当前位置: 首页 > news >正文

Mac M芯片安装RocketMQ服务

阿里开源的基于MVC架构,JAVA语言开发的,异步的消息序列;消息流转模型;

MQ:MessageQueue消息队列,消息是在不同进程之间传递的数据,可以是一台机器也可以分布在不同机器。队列是具有FIFO特性的结构,用来缓存数据的。

MQ的主要作用:

异步;解耦;削峰

安装

官方下载版本 :下载 | RocketMQ

下载Binary后解压到本地,如下图:

环境配置

一:配置内存大小

基于自己电脑的配置设置rocketmq的大小

1.bin目录下runserver.sh文件,根据自己jdk的版本,如果为8及以下的调整绿色箭头else之前的;9及以后的放入else之后

调整-Xms4g -Xmx4g  (以自己的实际为准,太小了容易OOM)

2.bin目录下runbroker.sh文件,调整 -Xms8g -Xmx8g (以自己的实际为准,太小了容易OOM)

注意:可能会因为jdk版本的问题导致GC失败,加上XX:+UnlockExperimentalVMOptions -XX:+UseG1GC即可如下:

JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -XX:+UnlockExperimentalVMOptions -XX:+UseG1GC"

二:启动:
【1】启动NamesrvStartup

1.建一个logs文件夹

2.然后执行 nohup ./mqnamesrv > ../logs/namesrv.log 2>&1 &

3.检查namesrv.log文件发现结尾处有 The Name Server boot success. serializeType=JSON, address 0.0.0.0:9876就成功了;

【2】启动mqbroker

1.给配置环境变量

vim ~/.bash_profile 加入 export NAMESRV_ADDR=localhost:9876 ;

保存完成然后执行 source ~/.bash_profile让配置生效

2.执行  nohup ./mqbroker >  ../logs/mqbroker.log 2>&1 &

3.检查mqbroker.log 结尾出现The broker[MacBook-Air.local, IP:10911] boot success. serializeType=JSON and name server is localhost:9876就算成功

整体运行成功就是这样: 

测试:

1.bin路径下执行 ./tools.sh  org.apache.rocketmq.example.quickstart.Producer

2.看到消息发送成功

3.接受消息,同样bin下执行 :./tools.sh org.apache.rocketmq.example.quickstart.Consumer

这样就成功了恭喜你安装完整!

http://www.dtcms.com/a/275349.html

相关文章:

  • 【Docker基础】Dockerfile指令速览:基础常用指令详解
  • 【STM32实践篇】:最小系统组成
  • 实战指南:用pmap+gdb排查Linux进程内存问题
  • 9.4 自定义SMC服务开发
  • springboot使用@Validated不起作用
  • 加法器学习
  • AI图像修复工具CodeFormer实测:马赛克去除与画质增强效果评测
  • Java使用Langchai4j接入AI大模型的简单使用(四)--整合Springboot
  • Window/linux获得程序运行目录C++
  • C++ Map 和 Set 详解:从原理到实战应用
  • 基于 Python 的数据分析技术综述
  • 2025 全球酒店用品厂家竞争力排行榜发布:扬州卓韵领衔,布草工厂实力重塑行业格局
  • 未来软件开发的新方向:从工程到智能的深度演进
  • 利用scale实现图片放大案例
  • 商业机密保卫战:如何让离职员工带不走的客户资源?
  • TCP的socket编程
  • 【unity实战】在Unity实现低耦合可复用的交互系统
  • 科技驯服烈日狂沙:中东沙漠农场的光储革命
  • SQL server之版本的初认知
  • 江协科技STM32入门教程——通信接口
  • 希尔排序和选择排序及计数排序的简单介绍
  • 数据湖和数据库对比
  • 笔记-分布式计算基础
  • 可穿戴智能硬件在国家安全领域的应用
  • day4--上传图片、视频
  • WebGL简易教程——结语
  • JVM--虚拟线程
  • 【springcloud】快速搭建一套分布式服务springcloudalibaba(四)
  • leetcode:HJ18 识别有效的IP地址和掩码并进行分类统计[华为机考][字符串]
  • 华为IPD(集成产品开发)流程是其研发管理的核心体系